前言
本文配套示例代码下载地址(完整可运行,含sql文件,下载后请修改数据库配置):点击这里下载
将若干的数据库操作作为一个整体控制,一起成功或一起失败。
原子性:指事务是一个不可分割的工作单位,事务中的操作要么都发生,要么都不发生。
一致性:指事务前后数据的完整性必须保持一致。
隔离性:指多个用户并发访问数据库时,一个用户的事务不能被其他用户的事务所干扰,多个并发事务之间数据要相互隔离。
持久性:指一个事务一旦被提交,它对数据库中数据的改变就是永久性的,即时数据库发生故障也不应该对其有任何影响。
--Platform TransactionManager 事务管理器(提交、回滚事务)
Spring为不同的持久化框架提供了不同的Platform TransactionManager接口实现。如:
使用Spring JDBC或iBatis进行持久化数据时使用DataSourceTransactionManager
使用Hibernate3.0版本进行持久化数据时使用HibernateTransactionManager
--TransactionDefinition 事务定义信息(隔离、传播、超时、只读)
脏读:一个事务读取了另一个事务改写但还未提交的数据,如果这些数据被回滚,则读到的数据是无效的。
不可重复读:在同一事务中,多次读取同一数据返回的结果有所不同。
幻读:一个事务读取了几行记录后,另一个事务插入一些记录,幻读就发生了。再后来的查询中,第一个事务就会发现有些原来没有的记录。
事务隔离级别:(五种)
其中,MySQL默认采用REPEATABLE_READ隔离级别;Oracle默认采用READ_COMMITTED隔离级别
事务传播行为:(七种)
--TransactionStatus 事务具体运行状态
a.编程式事务管理(基于Java编程控制,很少使用)--见demo1包
利用TransactionTemplate将多个DAO操作封装起来
*b.声明式事务管理(基于Spring的AOP配置控制)
-基于TransactionProxyFactoryBean的方式.(很少使用)--见demo2包
需要为每个进行事务管理的类,配置一个TransactionProxyFactoryBean进行增强.
-基于XML配置(经常使用)--见demo3包
一旦配置好之后,类上不需要添加任何东西。
如果Action作为目标对象切入事务,需要在<aop:config>元素里添加proxy-target-class="true"属性。原因是通知Spring框架采用CGLIB技术生成具有事务管理功能的Action类。
-基于注解(配置简单,经常使用)--见demo4包
在applicationContext.xml中开启事务注解配置。(applicationContext.xml中只需定义Bean并追加以下元素)
<bean id="txManager" class="..."> <property name="sessionFactory"> </property><tx:annotation-driven transaction-manager="txManager"/>
在目标组件类中使用@Transactional,该标记可定义在类前或方法前。
--编程式
/** * @Description:转账案例的DAO层接口 * */ public interface AccountDao { /** * @param out * :转出账号 * @param money * :转账金额 */ public void outMoney(String out, Double money); /** * * @param in * :转入账号 * @param money * :转账金额 */ public void inMoney(String in, Double money); }
/** * @Description:转账案例的DAO层实现类 */ public class AccountDaoImpl extends JdbcDaoSupport implements AccountDao { /** * @param out * :转出账号 * @param money * :转账金额 */ @Override public void outMoney(String out, Double money) { String sql = "update account set money = money-? where name = ?"; this.getJdbcTemplate().update(sql, money, out); } /** * @param in * :转入账号 * @param money * :转账金额 */ @Override public void inMoney(String in, Double money) { String sql = "update account set money = money+? where name = ?"; this.getJdbcTemplate().update(sql, money, in); } }
/** * @Description:转账案例的业务接口 * */ public interface AccountService { /** * @param out :转出账号 * @param in :转入账号 * @param money :转账金额 */ public void transfer(String out,String in,Double money); }
/** * @Description:转账案例的业务层实现类 */ public class AccountServiceImpl implements AccountService { // 注入转账的DAO private AccountDao accountDao; // 注入事务管理的模板 private TransactionTemplate transactionTemplate; /** * @param out * :转出账号 * @param in * :转入账号 * @param money * :转账金额 */ @Override public void transfer(final String out, final String in, final Double money) { // 未经事务控制的业务处理操作,如果过程中出异常,则导致前面的操作能完成,后面的不能,即转账成功但未收到转账款 // accountDao.outMoney(out, money); // int i = 1/0; // accountDao.inMoney(in, money); transactionTemplate.execute(new TransactionCallbackWithoutResult() { @Override protected void doInTransactionWithoutResult( TransactionStatus transactionStatus) { accountDao.outMoney(out, money); // int i = 1 / 0;//事务控制,即出现异常,该段内代码都执行失效 accountDao.inMoney(in, money); } }); } public void setAccountDao(AccountDao accountDao) { this.accountDao = accountDao; } public void setTransactionTemplate(TransactionTemplate transactionTemplate) { this.transactionTemplate = transactionTemplate; } }
applicationContext1.xml
<!-- 引入外部的属性文件 --> <context:property-placeholder location="classpath:jdbc.properties"/> <!-- 配置c3p0连接池 --> <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"> <property name="driverClass" value="${jdbc.driverClass}" /> <property name="jdbcUrl" value="${jdbc.url}" /> <property name="user" value="${jdbc.username}" /> <property name="password" value="${jdbc.password}" /> </bean> <!-- 配置业务层类 --> <bean id="accountService" class="com.zs.spring.demo1.AccountServiceImpl"> <property name="accountDao" ref="accountDao" /> <!-- 注入事务管理的模板 --> <property name="transactionTemplate" ref="transactionTemplate" /> </bean> <!-- 配置DAO类(简化,会自动配置JdbcTemplate) --> <bean id="accountDao" class="com.zs.spring.demo1.AccountDaoImpl"> <property name="dataSource" ref="dataSource" /> </bean> <!-- 配置DAO类(未简化) --> <!-- <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"> <property name="dataSource" ref="dataSource" /> </bean> <bean id="accountDao" class="com.zs.spring.demo1.AccountDaoImpl"> <property name="jdbcTemplate" ref="jdbcTemplate" /> </bean> --> <!-- ==================================1.编程式的事务管理=============================================== --> <!-- 配置事务管理器 --> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource" /> </bean> <!-- 配置事务管理的模板:Spring为了简化事务管理的代码而提供的类 --> <bean id="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate"> <property name="transactionManager" ref="transactionManager"/> </bean>
测试:
@RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration("classpath:applicationContext1.xml") public class TransactionTest { @Resource(name = "accountService") private AccountService accountService; @Test public void demo1() { accountService.transfer("aaa", "bbb", 200d); } }
--基于TransactionProxyFactoryBean的方式
public class AccountServiceImpl implements AccountService { // 注入转账的DAO private AccountDao accountDao; /** * @param out * :转出账号 * @param in * :转入账号 * @param money * :转账金额 */ @Override public void transfer(String out, String in, Double money) { accountDao.outMoney(out, money); // int i = 1/0; accountDao.inMoney(in, money); } public void setAccountDao(AccountDao accountDao) { this.accountDao = accountDao; } }
applicationContext2.xml
<!-- 引入外部的属性文件 --> <context:property-placeholder location="classpath:jdbc.properties"/> <!-- 配置c3p0连接池 --> <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"> <property name="driverClass" value="${jdbc.driverClass}" /> <property name="jdbcUrl" value="${jdbc.url}" /> <property name="user" value="${jdbc.username}" /> <property name="password" value="${jdbc.password}" /> </bean> <!-- 配置业务层类 --> <bean id="accountService" class="com.zs.spring.demo2.AccountServiceImpl"> <property name="accountDao" ref="accountDao" /> </bean> <!-- 配置DAO类(简化,会自动配置JdbcTemplate) --> <bean id="accountDao" class="com.zs.spring.demo2.AccountDaoImpl"> <property name="dataSource" ref="dataSource" /> </bean> <!-- ==================================2.使用XML配置声明式的事务管理(原始方式)=============================================== --> <!-- 配置事务管理器 --> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource" /> </bean> <!-- 配置业务层的代理 --> <bean id="accountServiceProxy" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean"> <!-- 配置目标对象 --> <property name="target" ref="accountService" /> <!-- 注入事务管理器 --> <property name="transactionManager" ref="transactionManager"></property> <!-- 注入事务的属性 --> <property name="transactionAttributes"> <props> <!-- prop的格式: * PROPAGATION :事务的传播行为 * ISOTATION :事务的隔离级别 * readOnly :只读 * -EXCEPTION :发生哪些异常回滚事务 * +EXCEPTION :发生哪些异常不回滚事务 --> <prop key="transfer">PROPAGATION_REQUIRED</prop> <!-- <prop key="transfer">PROPAGATION_REQUIRED,readOnly</prop> --> <!-- <prop key="transfer">PROPAGATION_REQUIRED,+java.lang.ArithmeticException</prop> --> </props> </property> </bean>
测试:
@RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration("classpath:applicationContext2.xml") public class TransactionTest { /** * 一定要注入代理类:因为代理类进行增强的操作 */ // @Resource(name="accountService") @Resource(name = "accountServiceProxy") private AccountService accountService; @Test public void demo1() { accountService.transfer("aaa", "bbb", 200d); } }
--基于XML配置
public class AccountServiceImpl implements AccountService { // 注入转账的DAO private AccountDao accountDao; /** * @param out * :转出账号 * @param in * :转入账号 * @param money * :转账金额 */ @Override public void transfer(String out, String in, Double money) { accountDao.outMoney(out, money); // int i = 1/0; accountDao.inMoney(in, money); } public void setAccountDao(AccountDao accountDao) { this.accountDao = accountDao; } }
applicationContext3.xml
<!-- 引入外部的属性文件 --> <context:property-placeholder location="classpath:jdbc.properties"/> <!-- 配置c3p0连接池 --> <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"> <property name="driverClass" value="${jdbc.driverClass}" /> <property name="jdbcUrl" value="${jdbc.url}" /> <property name="user" value="${jdbc.username}" /> <property name="password" value="${jdbc.password}" /> </bean> <!-- 配置业务层类 --> <bean id="accountService" class="com.zs.spring.demo3.AccountServiceImpl"> <property name="accountDao" ref="accountDao" /> </bean> <!-- 配置DAO类(简化,会自动配置JdbcTemplate) --> <bean id="accountDao" class="com.zs.spring.demo3.AccountDaoImpl"> <property name="dataSource" ref="dataSource" /> </bean> <!-- ==================================3.使用XML配置声明式的事务管理,基于tx/aop=============================================== --> <!-- 配置事务管理器 --> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource" /> </bean> <!-- 配置事务的通知 --> <tx:advice id="txAdvice" transaction-manager="transactionManager"> <tx:attributes> <!-- propagation :事务传播行为 isolation :事务的隔离级别 read-only :只读 rollback-for:发生哪些异常回滚 no-rollback-for :发生哪些异常不回滚 timeout :过期信息 --> <tx:method name="transfer" propagation="REQUIRED"/> </tx:attributes> </tx:advice> <!-- 配置切面 --> <aop:config> <!-- 配置切入点 --> <aop:pointcut expression="execution(* com.zs.spring.demo3.AccountService+.*(..))" id="pointcut1"/> <!-- 配置切面 --> <aop:advisor advice-ref="txAdvice" pointcut-ref="pointcut1"/> </aop:config>
测试:
/** * @Description:Spring的声明式事务管理的方式二:基于AspectJ的XML方式的配置 */ @RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration("classpath:applicationContext3.xml") public class TransactionTest { /** * 一定要注入代理类:因为代理类进行增强的操作 */ @Resource(name = "accountService") private AccountService accountService; @Test public void demo1() { accountService.transfer("aaa", "bbb", 200d); } }
--基于注解
/** * @Transactional中的的属性 propagation :事务的传播行为 isolation :事务的隔离级别 readOnly :只读 * rollbackFor :发生哪些异常回滚 noRollbackFor :发生哪些异常不回滚 * rollbackForClassName 根据异常类名回滚 */ @Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.DEFAULT, readOnly = false) public class AccountServiceImpl implements AccountService { // 注入转账的DAO private AccountDao accountDao; /** * @param out * :转出账号 * @param in * :转入账号 * @param money * :转账金额 */ @Override public void transfer(String out, String in, Double money) { accountDao.outMoney(out, money); // int i = 1/0; accountDao.inMoney(in, money); } public void setAccountDao(AccountDao accountDao) { this.accountDao = accountDao; } }
applicationContext4.xml
<!-- 引入外部的属性文件 --> <context:property-placeholder location="classpath:jdbc.properties"/> <!-- 配置c3p0连接池 --> <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"> <property name="driverClass" value="${jdbc.driverClass}" /> <property name="jdbcUrl" value="${jdbc.url}" /> <property name="user" value="${jdbc.username}" /> <property name="password" value="${jdbc.password}" /> </bean> <!-- 配置业务层类 --> <bean id="accountService" class="com.zs.spring.demo4.AccountServiceImpl"> <property name="accountDao" ref="accountDao" /> </bean> <!-- 配置DAO类(简化,会自动配置JdbcTemplate) --> <bean id="accountDao" class="com.zs.spring.demo4.AccountDaoImpl"> <property name="dataSource" ref="dataSource" /> </bean> <!-- ==================================4.使用注解配置声明式事务============================================ --> <!-- 配置事务管理器 --> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource" /> </bean> <!-- 开启注解事务 --> <tx:annotation-driven transaction-manager="transactionManager"/>
测试:
@RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration("classpath:applicationContext4.xml") public class TransactionTest { /** * 一定要注入代理类:因为代理类进行增强的操作 */ @Resource(name = "accountService") private AccountService accountService; @Test public void demo1() { accountService.transfer("aaa", "bbb", 200d); } }
具体代码和数据库文件参考项目完整代码:
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对VeVb武林网的支持。
新闻热点
疑难解答
图片精选