spring整合jdbc
spring提供了很多模板整合dao技術
| orm持久化技術 | 模板類 |
|---|---|
| jdbc | org.springframework.jdbc.core.jdbctemplate |
| hibernate3.0 | org.springframework.orm.hiberate3.hibernatetemplate |
| ibatis(mybatis) | org.springframework.orm.sqlmapclienttemplate |
| jpa | org.springframework.orm.jpa.jpatemplate |
spring中提供了一個可以操作數據庫的對象.對象封裝了jdbc技術.
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
// jdbctemplate => jdbc模板對象// 與dbutils中的queryrunner非常相似.// 0 準備連接池combopooleddatasource datasource = new combopooleddatasource();datasource.setdriverclass("com.mysql.jdbc.driver");datasource.setjdbcurl("jdbc:mysql:///hibernate_32");datasource.setuser("root");datasource.setpassword("1234");// 1 創建jdbc模板對象jdbctemplate jt = new jdbctemplate();jt.setdatasource(datasource);// 2 書寫sql,并執行string sql = "insert into t_user values(null,'rose') ";jt.update(sql); |
步驟
1.導包
- 基礎包4 + 2
- spring-test
- spring-aop
- junit4類庫
- 新增c3p0連接池jdbc驅動包
- spring-jdbc包
- spring-tx事務包
2.準備數據庫
本地數據庫和表
3.書寫dao
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
|
// 使用jdbc模板實現增刪改查public class userdaoimpl extends jdbcdaosupport implements userdao { @override public void save(user u) { string sql = "insert into t_user values(null,?) "; super.getjdbctemplate().update(sql, u.getname()); } @override public void delete(integer id) { string sql = "delete from t_user where id = ? "; super.getjdbctemplate().update(sql,id); } @override public void update(user u) { string sql = "update t_user set name = ? where id=? "; super.getjdbctemplate().update(sql, u.getname(),u.getid()); } @override public user getbyid(integer id) { string sql = "select * from t_user where id = ? "; return super.getjdbctemplate().queryforobject(sql,new rowmapper<user>(){ @override public user maprow(resultset rs, int arg1) throws sqlexception { user u = new user(); u.setid(rs.getint("id")); u.setname(rs.getstring("name")); return u; }}, id); } @override public int gettotalcount() { string sql = "select count(*) from t_user "; integer count = super.getjdbctemplate().queryforobject(sql, integer.class); return count; } @override public list<user> getall() { string sql = "select * from t_user "; list<user> list = super.getjdbctemplate().query(sql, new rowmapper<user>(){ @override public user maprow(resultset rs, int arg1) throws sqlexception { user u = new user(); u.setid(rs.getint("id")); u.setname(rs.getstring("name")); return u; }}); return list; }} |
4.spring配置
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
<!-- 指定spring讀取db.properties配置 --><context:property-placeholder location="classpath:db.properties" /><!-- 1.將連接池放入spring容器 --><bean name="datasource" class="com.mchange.v2.c3p0.combopooleddatasource" > <property name="jdbcurl" value="${jdbc.jdbcurl}" ></property> <property name="driverclass" value="${jdbc.driverclass}" ></property> <property name="user" value="${jdbc.user}" ></property> <property name="password" value="${jdbc.password}" ></property></bean><!-- 2.將jdbctemplate放入spring容器 --><bean name="jdbctemplate" class="org.springframework.jdbc.core.jdbctemplate" > <property name="datasource" ref="datasource" ></property></bean><!-- 3.將userdao放入spring容器 --><bean name="userdao" class="cn.zhli13.jdbctemplate.userdaoimpl" > <property name="jt" ref="jdbctemplate" ></property></bean>// 若userdao類繼承了jdbcdaosupport,則無需將jdbctemplate注入到容器中，省略第二步，第三步改為 <!-- 3.將userdao放入spring容器 --><bean name="userdao" class="cn.zhli13.jdbctemplate.userdaoimpl" > <property name="datasource" ref="datasource" ></property></bean> |
spring中aop事務
事務
事務特性:acid
事務并發問題：臟讀、不可重復讀、幻讀
事務的隔離級別：1 讀未提交、2 讀已提交、4 可重復讀、8 串行化
spring封裝了事務管理代碼
事務操作：1、打開事務、2、提交事務、3、回滾事務
事務操作對象
因為在不同平臺,操作事務的代碼各不相同.spring提供了一個接口
platformtransactionmanager 接口
- datasourcetransactionmanager
- hibernatetransitionmanager
注意:在spring中玩事務管理.最為核心的對象就是transactionmanager對象
spring管理事務的屬性介紹
事務的隔離級別：1 讀未提交、2 讀已提交、4 可重復讀、8 串行化
是否只讀： true只讀 false可操作
事務的傳播行為：決定業務方法之間調用，事務應該如何處理
* 保證同一個事務中
propagation_required 支持當前事務，如果不存在 就新建一個(默認、推薦99.99%用這種)
propagation_supports 支持當前事務，如果不存在，就不使用事務
propagation_mandatory 支持當前事務，如果不存在，拋出異常* 保證沒有在同一個事務中
propagation_requires_new 如果有事務存在，掛起當前事務，創建一個新的事務
propagation_not_supported 以非事務方式運行，如果有事務存在，掛起當前事務
propagation_never 以非事務方式運行，如果有事務存在，拋出異常
propagation_nested 如果當前事務存在，則嵌套事務執行
spring管理事務方式
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
// 編碼式// 1.將核心事務管理器配置到spring容器<!-- 事務核心管理器,封裝了所有事務操作. 依賴于連接池 --><bean name="transactionmanager" class="org.springframework.jdbc.datasource.datasourcetransactionmanager" > <property name="datasource" ref="datasource" ></property></bean>// 2.配置transactiontemplate模板<!-- 事務模板對象 --><bean name="transactiontemplate" class="org.springframework.transaction.support.transactiontemplate" > <property name="transactionmanager" ref="transactionmanager" > </property></bean>// 3.將事務模板注入service<!-- 3.service--><bean name="accountservice" class="cn.itcast.service.accountserviceimpl" > <property name="ad" ref="accountdao" ></property> <property name="tt" ref="transactiontemplate" ></property></bean> |
xml配置(aop)
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
|
// 1.導包 // aop、aspect、aopliance、aspect.weaver // 2.導入新的約束(tx) // beans: 最基本、context:讀取properties配置、aop:配置aop、tx:配置事務通知 // 3.配置通知 <!-- 配置事務通知 --><tx:advice id="txadvice" transaction-manager="transactionmanager" > <tx:attributes> <!-- 以方法為單位,指定方法應用什么事務屬性 isolation:隔離級別 propagation:傳播行為 read-only:是否只讀 --> <tx:method name="save*" isolation="repeatable_read" propagation="required" read-only="false" /> <tx:method name="persist*" isolation="repeatable_read" propagation="required" read-only="false" /> <tx:method name="update*" isolation="repeatable_read" propagation="required" read-only="false" /> <tx:method name="modify*" isolation="repeatable_read" propagation="required" read-only="false" /> <tx:method name="delete*" isolation="repeatable_read" propagation="required" read-only="false" /> <tx:method name="remove*" isolation="repeatable_read" propagation="required" read-only="false" /> <tx:method name="get*" isolation="repeatable_read" propagation="required" read-only="true" /> <tx:method name="find*" isolation="repeatable_read" propagation="required" read-only="true" /> <tx:method name="transfer" isolation="repeatable_read" propagation="required" read-only="false" /> </tx:attributes></tx:advice>// 4.配置將通知織入目標<!-- 配置織入 --><aop:config > <!-- 配置切點表達式 --> <aop:pointcut expression="execution(* cn.zhli13.service.*serviceimpl.*(..))" id="txpc"/> <!-- 配置切面 : 通知+切點 advice-ref:通知的名稱 pointcut-ref:切點的名稱 --> <aop:advisor advice-ref="txadvice" pointcut-ref="txpc" /></aop:config> |
注解配置(aop)
|
1
2
3
4
5
6
7
8
9
10
11
|
// 1.導包（如xml配置一樣）// 2.導入約束（同上）// 3.開啟注解管理事務<!-- 開啟使用注解管理aop事務 --><tx:annotation-driven/>// 4.使用注解@transactional(isolation=isolation.repeatable_read,propagation=propagation.required,readonly=true)public class accountserviceimpl implements accountservice {@transactional(isolation=isolation.repeatable_read,propagation=propagation.required,readonly=false)public void transfer(final integer from,final integer to,final double money) { |
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。
原文鏈接：https://segmentfault.com/a/1190000015822794
