Spring事务管理

配置环境，导入相应jar包：ioc/aop/jdbcTemplate/c3p0连接池的相应jar包

程序大致说明：创建数据库

表结构：

dao中两个方法，lessSalary(),moreSalary()用来模拟转账，

然后再service中调用dao中的两个方法完成转账操作

一.不使用事务：

 1  1 package org.dao;
 2  2 
 3  3 import org.springframework.jdbc.core.JdbcTemplate;
 4  4 
 5  5 
 6  6 public class Dao {
 7  7     private JdbcTemplate jdbcTemplate;
 8  8     
 9  9     public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
10 10         this.jdbcTemplate = jdbcTemplate;
11 11     }
12 12 
13 13     //小王转账给小马  金额2000
14 14     public void lessSalary() {
15 15         // TODO Auto-generated method stub
16 16         String sql="update acountmoney set salary=salary+? where name=?";
17 17         jdbcTemplate.update(sql,-2000,"小王");    
18 18     }
19 19 
20 20     public void moreSalary() {
21 21         // TODO Auto-generated method stub
22 22         String sql="update acountmoney set salary=salary+? where name=?";
23 23         jdbcTemplate.update(sql,2000,"小马");;
24 24     }
25 25 
26 26 }

 1 package org.service;
 2 
 3 import org.dao.Dao;
 4 
 5 public class Service {
 6     private Dao dao;
 7 
 8     public void setDao(Dao dao) {
 9         this.dao = dao;
10     }
11     public void changeSalary(){
12         System.out.println("开始转账。。。。。。。。");
13         this.dao.lessSalary();
14         this.dao.moreSalary();
15         System.out.println("转账成功。。。。。。。。。。。");
16     }
17 }

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="http://www.springframework.org/schema/beans"
 3     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 4     xmlns:context="http://www.springframework.org/schema/context"
 5     xmlns:aop="http://www.springframework.org/schema/aop"
 6     xmlns:tx="http://www.springframework.org/schema/tx"
 7     xsi:schemaLocation="http://www.springframework.org/schema/beans 
 8     http://www.springframework.org/schema/beans/spring-beans.xsd
 9     http://www.springframework.org/schema/context
10     http://www.springframework.org/schema/context/spring-context.xsd
11     http://www.springframework.org/schema/aop
12     http://www.springframework.org/schema/aop/spring-aop.xsd
13     http://www.springframework.org/schema/tx
14     http://www.springframework.org/schema/tx/spring-tx.xsd">
15     <!-- 配置c3p0连接池 -->
16     <bean id="c3p0" class="com.mchange.v2.c3p0.ComboPooledDataSource">
17         <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
18         <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/account"></property>
19         <property name="user" value="root"></property>
20         <property name="password" value="jay571018"></property>
21     </bean>
22     
23     <!-- 创建dao对象  注入jdbcTemplate-->
24     <bean id="dao" class="org.dao.Dao">
25         <property name="jdbcTemplate" ref="jdbcTemplate"></property>
26     </bean>
27     
28     <!-- 创建service对象  注入dao-->
29     <bean id="service" class="org.service.Service">
30         <property name="dao" ref="dao"></property>
31     </bean>
32     
33     <!-- 创建jdbcTemplate对象 注入数据库连接池-->
34     <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
35         <property name="dataSource" ref="c3p0"></property>
36     </bean>
37     
38 </beans>

 1 package org.test;
 2 
 3 import org.junit.Test;
 4 import org.service.Service;
 5 import org.springframework.context.ApplicationContext;
 6 import org.springframework.context.support.ClassPathXmlApplicationContext;
 7 
 8 public class TestSalary {
 9     @Test
10     public void testsalary(){
11         ApplicationContext ac=new ClassPathXmlApplicationContext("applicationContext.xml");
12         Service s=(Service)ac.getBean("service");
13         s.changeSalary();
14     }
15 }

程序运行结果：小王向小马转账2000，数据库中的数据得到了更新

以上代码没有使用事务，但是如果在转账过程中，即

1     public void changeSalary(){
2         System.out.println("开始转账。。。。。。。。");
3         this.dao.lessSalary();

　　　　　　　　A:此处发生错误

4         this.dao.moreSalary();
5         System.out.println("转账成功。。。。。。。。。。。");
6     }

函数中A处出现错误，就会造成数据的不一致性，即小王的salary减少，小马的salary没有得到增加

1     public void changeSalary(){
2         System.out.println("开始转账。。。。。。。。");
3         this.dao.lessSalary();
4         int t=10/0;//模拟发生异常
5         this.dao.moreSalary();
6         System.out.println("转账成功。。。。。。。。。。。");
7     }

二.使用Spring框架中的事务机制进行处理(其他地方代码不需要改变，只需要在配置文件中增加事务处理，这就是AOP的魅力)

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="http://www.springframework.org/schema/beans"
 3     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 4     xmlns:context="http://www.springframework.org/schema/context"
 5     xmlns:aop="http://www.springframework.org/schema/aop"
 6     xmlns:tx="http://www.springframework.org/schema/tx"
 7     xsi:schemaLocation="http://www.springframework.org/schema/beans 
 8     http://www.springframework.org/schema/beans/spring-beans.xsd
 9     http://www.springframework.org/schema/context
10     http://www.springframework.org/schema/context/spring-context.xsd
11     http://www.springframework.org/schema/aop
12     http://www.springframework.org/schema/aop/spring-aop.xsd
13     http://www.springframework.org/schema/tx
14     http://www.springframework.org/schema/tx/spring-tx.xsd">
15     <!-- 配置c3p0连接池 -->
16     <bean id="c3p0" class="com.mchange.v2.c3p0.ComboPooledDataSource">
17         <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
18         <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/account"></property>
19         <property name="user" value="root"></property>
20         <property name="password" value="jay571018"></property>
21     </bean>
22     
23     <!-- 创建dao对象  注入jdbcTemplate-->
24     <bean id="dao" class="org.dao.Dao">
25         <property name="jdbcTemplate" ref="jdbcTemplate"></property>
26     </bean>
27     
28     <!-- 创建service对象  注入dao-->
29     <bean id="service" class="org.service.Service">
30         <property name="dao" ref="dao"></property>
31     </bean>
32     
33     <!-- 创建jdbcTemplate对象 注入数据库连接池-->
34     <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
35         <property name="dataSource" ref="c3p0"></property>
36     </bean>
37     
38     <!-- 配置事务管理器 -->
39     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
40         <!-- 注入数据源 ，即上面的c3p0对象 -->
41         <property name="dataSource" ref="c3p0"></property>
42     </bean>
43     
44     <!-- 配置事务增强 ,指定使用的事务管理器，即上面配置的transactionManager-->
45     <tx:advice id="txadvice" transaction-manager="transactionManager">
46         <!-- 设置需要进行事务操作的方法  的匹配规则  本程序中对changeSalary()方法进行事务处理（change*包括changeSalary）-->
47         <tx:attributes>    
48             <tx:method name="changeSalary"/>
49         </tx:attributes>
50     </tx:advice>
51     
52     <!-- 配置切面，把增强用到具体方法上面的过程 -->
53     <aop:config>
54         <!-- 配置切入点 -->
55         <aop:pointcut expression="execution(* org.service.Service.*(..))" id="p1"/>
56         <!--指定使用的增强以及应用的切入点-->
57         <aop:advisor advice-ref="txadvice" pointcut-ref="p1"/>
58     </aop:config>
59     
60 </beans>

这样即使在A处发生了异常，通过事务的回滚机制，数据仍然保持一致性

所以事务处理在数据库访问中的作用显而易见。

三.使用注解方式实现事务管理

只需在service类上面标识注解，配置文件中开启注解扫描：

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="http://www.springframework.org/schema/beans"
 3     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 4     xmlns:context="http://www.springframework.org/schema/context"
 5     xmlns:aop="http://www.springframework.org/schema/aop"
 6     xmlns:tx="http://www.springframework.org/schema/tx"
 7     xsi:schemaLocation="http://www.springframework.org/schema/beans 
 8     http://www.springframework.org/schema/beans/spring-beans.xsd
 9     http://www.springframework.org/schema/context
10     http://www.springframework.org/schema/context/spring-context.xsd
11     http://www.springframework.org/schema/aop
12     http://www.springframework.org/schema/aop/spring-aop.xsd
13     http://www.springframework.org/schema/tx
14     http://www.springframework.org/schema/tx/spring-tx.xsd">
15     <!-- 配置c3p0连接池 -->
16     <bean id="c3p0" class="com.mchange.v2.c3p0.ComboPooledDataSource">
17         <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
18         <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/account"></property>
19         <property name="user" value="root"></property>
20         <property name="password" value="jay571018"></property>
21     </bean>
22     
23     <!-- 创建dao对象  注入jdbcTemplate-->
24     <bean id="dao" class="org.dao.Dao">
25         <property name="jdbcTemplate" ref="jdbcTemplate"></property>
26     </bean>
27     
28     <!-- 创建service对象  注入dao-->
29     <bean id="service" class="org.service.Service">
30         <property name="dao" ref="dao"></property>
31     </bean>
32     
33     <!-- 创建jdbcTemplate对象 注入数据库连接池-->
34     <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
35         <property name="dataSource" ref="c3p0"></property>
36     </bean>
37     
38     <!-- 配置事务管理器 -->
39     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
40         <!-- 注入数据源 ，即上面的c3p0对象 -->
41         <property name="dataSource" ref="c3p0"></property>
42     </bean>
43     
44     <!-- 开启注解扫描  指定事务管理器-->
45     <tx:annotation-driven transaction-manager="transactionManager"></tx:annotation-driven>
46     
47     <!-- 在需要使用事务的类上边标注注解 -->
48     
49     
50 </beans>

 1 package org.service;
 2 
 3 import org.dao.Dao;
 4 import org.springframework.transaction.annotation.Transactional;
 5 @Transactional //对该注解标识的类中的所有方法都加上注解
 6 public class Service {
 7     private Dao dao;
 8 
 9     public void setDao(Dao dao) {
10         this.dao = dao;
11     }
12     public void changeSalary(){
13         System.out.println("开始转账。。。。。。。。");
14         this.dao.lessSalary();
15         //int t=10/0;//模拟发生异常
16         this.dao.moreSalary();
17         System.out.println("转账成功。。。。。。。。。。。");
18     }
19 }

其他程序不变，同样实现了事务管理功能。

------------------------------

欢迎大家转载，但请注明原创链接：http://www.cnblogs.com/Joke-Jay/p/6505949.html

查看更多随笔：http://www.cnblogs.com/Joke-Jay/