事务
属性
- read-only:是否是只读事务。默认false,不只读。
- isolation:指定事务的隔离级别。默认值是使用数据库的默认隔离级别。
- propagation:指定事务的传播行为。
- timeout:指定超时时间。默认值为:-1。永不超时。
- rollback-for:用于指定一个异常,当执行产生该异常时,事务回滚。产生其他异常,事务不回滚。没有默认值,任何异常都回滚。
- no-rollback-for:用于指定一个异常,当产生该异常时,事务不回滚,产生其他异常时,事务回滚。没有默认值,任何异常都回滚。
传播行为
传播行为 | 含义 |
---|---|
PROPAGATION_REQUIRED | 表示当前方法必须运行在事务中。如果当前事务存在,方法将会在该事务中运行。否则,会启动一个新的事务 |
PROPAGATION_SUPPORTS | 表示当前方法不需要事务上下文,但是如果存在当前事务的话,那么该方法会在这个事务中运行 |
PROPAGATION_PROPAGATION | 表示该方法必须在事务中运行,如果当前事务不存在,则会抛出一个异常 |
PROPAGATION_REQUIRED_NEW | 表示当前方法必须运行在它自己的事务中。一个新的事务将被启动。如果存在当前事务,在该方法执行期间,当前事务会被挂起。如果使用JTATransactionManager的话,则需要访问TransactionManager |
PROPAGATION_NOT_ SUPPORTED | 表示该方法不应该运行在事务中。如果存在当前事务,在该方法运行期间,当前事务将被挂起。如果使用JTATransactionManager的话,则需要访问TransactionManager |
PROPAGATION_NEVER | 表示当前方法不应该运行在事务上下文中。如果当前正有一个事务在运行,则会抛出异常 |
PROPAGATION_NESTED | 表示如果当前已经存在一个事务,那么该方法将会在嵌套事务中运行。嵌套的事务可以独立于当前事务进行单独地提交或回滚。如果当前事务不存在,那么其行为与PROPAGATION_ REQUIRED- -样. 注意各厂商对这种传播行为的支持是有所差异的。可以参考资源管理器的文档来确认它们是否支持嵌套事务 |
声明式事务
- 声明式事务都是基于编程事务
XML 配置
<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation="http://www.springframework.org/schema/beans https://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/aop https://www.springframework.org/schema/aop/spring-aop.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd"> <bean class="wang.ismy.spring.Dao"> <constructor-arg ref="template"/> </bean> <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource"> <property name="username" value="root"/> <property name="password" value="123"/> <property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/> <property name="url" value="jdbc:mysql:///mybatis"/> </bean> <bean id="template" class="org.springframework.jdbc.core.JdbcTemplate"> <constructor-arg name="dataSource" ref="dataSource"/> </bean> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"/> </bean> <!--配置事务的通知--> <tx:advice id="txAdvice" transaction-manager="transactionManager"> <tx:attributes> <tx:method name="transfer" propagation="REQUIRED" read-only="false"/> </tx:attributes> </tx:advice> <!--配置aop--> <aop:config> <aop:pointcut id="txPt" expression="execution(* wang.ismy.spring.Dao.*(..))"/> <!--建立切入点表达式与事务通知的关系--> <aop:advisor advice-ref="txAdvice" pointcut-ref="txPt"/> </aop:config></beans>
public class Dao { private JdbcTemplate jdbcTemplate; public Dao(JdbcTemplate jdbcTemplate) { this.jdbcTemplate = jdbcTemplate; } public void transfer(){ String sql = "UPDATE account SET money = money -200 WHERE uid = 41"; String sql1 = "UPDATE account SET money = money +200 WHERE uid = 45"; jdbcTemplate.update(sql); jdbcTemplate.update(sql1); }}
注解配置
@Configuration@EnableTransactionManagementpublic class Config { @Bean public DataSource dataSource(){ DriverManagerDataSource dataSource = new DriverManagerDataSource(); dataSource.setUsername("root"); dataSource.setPassword("123"); dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver"); dataSource.setUrl("jdbc:mysql:///mybatis"); return dataSource; } @Bean public JdbcTemplate jdbcTemplate(DataSource dataSource){ return new JdbcTemplate(dataSource); } @Bean public PlatformTransactionManager transactionManager(DataSource dataSource){ return new DataSourceTransactionManager(dataSource); }}
@Servicepublic class Dao { private JdbcTemplate jdbcTemplate; public Dao(JdbcTemplate jdbcTemplate) { this.jdbcTemplate = jdbcTemplate; } @Transactional(rollbackFor = Exception.class) public void transfer(){ String sql = "UPDATE account SET money = money -200 WHERE uid = 41"; String sql1 = "UPDATE account SET money = money +200 WHERE uid = 45"; jdbcTemplate.update(sql); jdbcTemplate.update(sql1); }}
事务实现原理
每个被事务支持的方法都会被切面增强
通过该方法 TransactionAspectSupport.invokeWithinTransaction 实现事务的提交、回滚等待。
根据事务的传播行为,切面会判断是否需要新启动一个连接,以及真正的方法执行完毕后,是否需要提交或回滚。
根据这个事务的实现原理,可以推断若是通过方法内部调用而非通过对象调用的方式,事务将不会生效。
编程式事务
@Beanpublic TransactionTemplate transactionTemplate(PlatformTransactionManager manager){ return new TransactionTemplate(manager);}
@Servicepublic class Dao { private JdbcTemplate jdbcTemplate; private TransactionTemplate transactionTemplate; public Dao(JdbcTemplate jdbcTemplate) { this.jdbcTemplate = jdbcTemplate; } public void transfer(){ transactionTemplate.execute((TransactionCallback<Void>) status -> { String sql = "UPDATE account SET money = money -200 WHERE uid = 41"; String sql1 = "UPDATE account SET money = money +200 WHERE uid = 45"; jdbcTemplate.update(sql); jdbcTemplate.update(sql1); return null; }); } @Autowired public void setTransactionTemplate(TransactionTemplate transactionTemplate) { this.transactionTemplate = transactionTemplate; }}