spring 事务注解

本是古典何须时尚 2022-05-08 11:00 256阅读 0赞

# [spring-mvc+mybatis注解方式事务管理][spring-mvc_mybatis] #

配置文件：

<table> 
 <tbody> 
 <tr> 
 <td> 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 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 </td> 
 <td> <code>&lt;!-- dataSource --&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;bean id=</code><code>"dataSource"</code>&nbsp;<code>class</code><code>=</code><code>"com.alibaba.druid.pool.DruidDataSource"</code>&nbsp;<code>init-method=</code><code>"init"</code>&nbsp;<code>destroy-method=</code><code>"close"</code><code>&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"url"</code>&nbsp;<code>value=</code><code>"${db.master.url}"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"username"</code>&nbsp;<code>value=</code><code>"${db.master.user}"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"password"</code>&nbsp;<code>value=</code><code>"${db.master.password}"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;!-- 配置监控统计拦截的filters --&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"filters"</code>&nbsp;<code>value=</code><code>"mergeStat,wall,log4j2"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"initialSize"</code>&nbsp;<code>value=</code><code>"5"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"maxActive"</code>&nbsp;<code>value=</code><code>"100"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"minIdle"</code>&nbsp;<code>value=</code><code>"10"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"maxWait"</code>&nbsp;<code>value=</code><code>"60000"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"validationQuery"</code>&nbsp;<code>value=</code><code>"SELECT 'x'"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"testOnBorrow"</code>&nbsp;<code>value=</code><code>"true"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"testOnReturn"</code>&nbsp;<code>value=</code><code>"true"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"testWhileIdle"</code>&nbsp;<code>value=</code><code>"true"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"timeBetweenEvictionRunsMillis"</code>&nbsp;<code>value=</code><code>"60000"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"minEvictableIdleTimeMillis"</code>&nbsp;<code>value=</code><code>"300000"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"removeAbandoned"</code>&nbsp;<code>value=</code><code>"true"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"removeAbandonedTimeout"</code>&nbsp;<code>value=</code><code>"1800"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"logAbandoned"</code>&nbsp;<code>value=</code><code>"true"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;/bean&gt;</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;!-- Spring整合Mybatis --&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;bean id=</code><code>"sqlSessionFactory"</code>&nbsp;<code>class</code><code>=</code><code>"com.baomidou.mybatisplus.spring.MybatisSqlSessionFactoryBean"</code><code>&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"dataSource"</code>&nbsp;<code>ref=</code><code>"dataSource"</code><code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;!-- 自动扫描Mapping.xml文件 --&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"mapperLocations"</code>&nbsp;<code>value=</code><code>"classpath*:/sqlMapperXml/*.xml"</code><code>&gt;&lt;/property&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"configLocation"</code>&nbsp;<code>value=</code><code>"classpath:xml/mybatis-config.xml"</code><code>&gt;&lt;/property&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"typeAliasesPackage"</code>&nbsp;<code>value=</code><code>"com.mingwork.model"</code><code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"globalConfig"</code>&nbsp;<code>ref=</code><code>"globalConfig"</code><code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"plugins"</code><code>&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;array&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;!-- 分页插件配置 --&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;bean id=</code><code>"paginationInterceptor"</code>&nbsp;<code>class</code><code>=</code><code>"com.baomidou.mybatisplus.plugins.PaginationInterceptor"</code><code>&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"dialectType"</code>&nbsp;<code>value=</code><code>"mysql"</code><code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"optimizeType"</code>&nbsp;<code>value=</code><code>"aliDruid"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;/bean&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;/array&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;/property&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;/bean&gt;</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;!-- MP 全局配置 --&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;bean id=</code><code>"globalConfig"</code>&nbsp;<code>class</code><code>=</code><code>"com.baomidou.mybatisplus.entity.GlobalConfiguration"</code><code>&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"idType"</code>&nbsp;<code>value=</code><code>"0"</code><code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"dbColumnUnderline"</code>&nbsp;<code>value=</code><code>"true"</code><code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;/bean&gt;</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;!-- MyBatis 动态实现&nbsp; --&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;bean id=</code><code>"mapperScannerConfigurer"</code>&nbsp;<code>class</code><code>=</code><code>"org.mybatis.spring.mapper.MapperScannerConfigurer"</code><code>&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;!-- 对Dao 接口动态实现，需要知道接口在哪&nbsp; --&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"basePackage"</code>&nbsp;<code>value=</code><code>"com.mingwork.mapper"</code><code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;/bean&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;!-- 事务管理 --&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;bean id=</code><code>"transactionManager"</code>&nbsp;<code>class</code><code>=</code><code>"org.springframework.jdbc.datasource.DataSourceTransactionManager"</code><code>&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;property name=</code><code>"dataSource"</code>&nbsp;<code>ref=</code><code>"dataSource"</code><code>&gt;&lt;/property&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;/bean&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;!-- 事务注解 --&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;tx:annotation-driven transaction-manager=</code><code>"transactionManager"</code>&nbsp;<code>proxy-target-</code><code>class</code><code>=</code><code>"true"</code><code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;!-- 事务管理 属性 --&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;tx:advice id=</code><code>"transactionAdvice"</code>&nbsp;<code>transaction-manager=</code><code>"transactionManager"</code><code>&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;tx:attributes&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;tx:method name=</code><code>"select*"</code>&nbsp;<code>propagation=</code><code>"REQUIRED"</code>&nbsp;<code>read-only=</code><code>"true"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;tx:method name=</code><code>"delete*"</code>&nbsp;<code>propagation=</code><code>"REQUIRED"</code>&nbsp;<code>rollback-</code><code>for</code><code>=</code><code>"Exception"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;tx:method name=</code><code>"update*"</code>&nbsp;<code>propagation=</code><code>"REQUIRED"</code>&nbsp;<code>rollback-</code><code>for</code><code>=</code><code>"Exception"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;tx:method name=</code><code>"insert*"</code>&nbsp;<code>propagation=</code><code>"REQUIRED"</code>&nbsp;<code>rollback-</code><code>for</code><code>=</code><code>"Exception"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;tx:method name=</code><code>"*"</code>&nbsp;<code>propagation=</code><code>"REQUIRED"</code>&nbsp;<code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;/tx:attributes&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;/tx:advice&gt;</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;!-- 配置切面 --&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;aop:config expose-proxy=</code><code>"true"</code>&nbsp;<code>proxy-target-</code><code>class</code><code>=</code><code>"true"</code><code>&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;aop:advisor advice-ref=</code><code>"transactionAdvice"</code>&nbsp;<code>pointcut=</code><code>"execution(* com.mingwork.service..*.*(..))"</code><code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;/aop:config&gt;</code> </td> 
 </tr> 
 </tbody> 
</table>

上面配置的意思就是配置面向切面，只要servcie中的方法抛出Exception，那么insert，update，delete的sql方法都会回滚。测试时，可以在service方法中故意抛出一个异常，throw new Exception("test"); 那么数据库就不会执行成功。所以在开发时，如果需要对多张表进行操作，而又需要保持事务的一致性的时候，我们就可以把对多张表的操作，写在一个service中的方法中，这样如果有一张表执行失败，抛出异常，其他表的操作也会跟着回滚。

### @Transactional参数说明 ###

<table> 
 <thead> 
 <tr> 
 <th>参数</th> 
 <th>说明</th> 
 </tr> 
 </thead> 
 <tbody> 
 <tr> 
 <td>readOnly</td> 
 <td>是否是只读事务，true表示只读，false表示读写</td> 
 </tr> 
 <tr> 
 <td>timeout</td> 
 <td>事务超时秒数，默认值-1表示永不超时</td> 
 </tr> 
 <tr> 
 <td>isolation</td> 
 <td>隔离级别，例如(isolation = Isolation.READ_UNCOMMITTED)</td> 
 </tr> 
 <tr> 
 <td>propagation</td> 
 <td>事务传播行为，见表propagation说明，例如@Transactional(propagation=Propagation.REQUIRED)</td> 
 </tr> 
 <tr> 
 <td>rollbackFor</td> 
 <td>需要回滚的异常类数组，例如&lt;/br&gt;单一异常类：@Transactional(rollbackFor=RuntimeException.class)&lt;/br&gt; 多个异常类：@Transactional(rollbackFor={IndexOutOfBoundsException.class, OutOfMemoryException.class})</td> 
 </tr> 
 <tr> 
 <td>noRollbackFor</td> 
 <td>不需要进行回滚的异常类数组，......</td> 
 </tr> 
 <tr> 
 <td>rollbackForClassName</td> 
 <td>需要进行回滚的异常类名称数组，例如&lt;/br&gt;单一异常类名称：@Transactional(rollbackForClassName="RuntimeException") &lt;/br&gt;多个异常类名称：@Transactional(rollbackForClassName={"IndexOutOfBoundsException","OutOfMemoryException.class"})</td> 
 </tr> 
 <tr> 
 <td>noRollbackForClassName</td> 
 <td>不需要进行回滚的异常类名称数组，......</td> 
 </tr> 
 </tbody> 
</table>

### propagation说明 ###

<table> 
 <thead> 
 <tr> 
 <th>参数</th> 
 <th>说明</th> 
 </tr> 
 </thead> 
 <tbody> 
 <tr> 
 <td>REQUIRED</td> 
 <td>有事务，加入事务，没有新建一个</td> 
 </tr> 
 <tr> 
 <td>NOT_SUPPORTED</td> 
 <td>以非事务方式执行操作，如果当前存在事务，就把当前事务挂起</td> 
 </tr> 
 <tr> 
 <td>REQUIRES_NEW</td> 
 <td>新建事务，如果当前存在事务，把当前事务挂起</td> 
 </tr> 
 <tr> 
 <td>MANDATORY</td> 
 <td>使用当前的事务，如果当前没有事务，就抛出异常</td> 
 </tr> 
 <tr> 
 <td>NEVER</td> 
 <td>以非事务方式执行，如果当前存在事务，则抛出异常</td> 
 </tr> 
 <tr> 
 <td>SUPPORTS</td> 
 <td>支持当前事务，如果当前没有事务，就以非事务方式执行</td> 
 </tr> 
 <tr> 
 <td>NESTED</td> 
 <td>如果当前存在事务，则在嵌套事务内执行，如果当前没有事务，则执行与REQUIRED类似的操作</td> 
 </tr> 
 </tbody> 
</table>

## ##

Q：我们的工程里，事务的开启跟关闭是由Spring负责的，但具体的SQL语句却是由Mybatis执行的。那么问题来了，Mybatis怎么保证自己执行的SQL语句是处在Spring的事务上下文中？

仔细思考一下这个过程，@Transactional是由spring进行处理的，spring做的事情是从数据源（一般为数据库连接池，比如说druid，c3p0等）获取一个数据库连接，然后在进入方法逻辑前执行setAutoCommit(false)操作，最后在处理成功或者出现异常的时候分别执行commit或者rollback操作。

那么问题来了，开启跟结束事务是由spring获取到数据库连接以后进行操作的，但我们实际执行的update或者insert语句却是由mybatis获取数据库连接进行操作的，可以想到如果想让事务生效，那么spring跟mybatis使用的必须是同一个连接，真实情况是什么样呢？它们之间如何进行无缝衔接？让我们通过源码来分析一下。

具体可以参考下面的链接

https://www.jianshu.com/p/6a880d20a61f

[spring-mvc_mybatis]: https://www.cnblogs.com/kangjianrong/p/9144977.html