背景
做了一个和navicat一样的工具，web版工具，然后数据库链接信息都是存在一个主数据库表的里，所以这里涉及到了动态切换数据源，以及一些事务等。今天说下多数据源切换时，事务失效。
一、常见的事务失效
@Transactional
1、@Transactional 应用在非 public 修饰的方法上
事务拦截器在目标方法执行前后进行拦截，内部会调用方法来获取Transactional 注解的事务配置信息，调用前会检查目标方法的修饰符是否为 public，不是 public则不会获取@Transactional 的属性配置信息。
2、@Transactional 注解属性 rollbackFor 设置错误
rollbackFor 可以指定能够触发事务回滚的异常类型。Spring默认抛出了未检查unchecked异常（继承自 RuntimeException 的异常）或者 Error才回滚事务；其他异常不会触发回滚事务。如果在事务中抛出其他类型的异常，但却期望 Spring 能够回滚事务，就需要指定rollbackFor属性。
3、同一个类中方法调用，导致@Transactional失效
开发中避免不了会对同一个类里面的方法调用，比如有一个类Test，它的一个方法A，A再调用本类的方法B（不论方法B是用public还是private修饰），但方法A没有声明注解事务，而B方法有。则外部调用方法A之后，方法B的事务是不会起作用的。这也是经常犯错误的一个地方。
那为啥会出现这种情况？其实这还是由于使用Spring AOP代理造成的，因为只有当事务方法被当前类以外的代码调用时，才会由Spring生成的代理对象来管理。
4、异常被你的 catch“吃了”导致@Transactional失效
如果你手动的catch捕获这个异常并进行处理，事务管理器会认为当前事务应该正常commit，就会导致注解失效，如果非要捕获且不失效，就必须在代码块内throw new Exception抛出异常。
5、数据库引擎不支持事务
开启事务的前提就是需要数据库的支持，我们一般使用的Mysql引擎时支持事务的，所以一般不会出现这种问题。
6、开启多线程任务时，事务管理会受到影响
因为线程不属于spring托管，故线程不能够默认使用spring的事务,也不能获取spring注入的bean在被spring声明式事务管理的方法内开启多线程，多线程内的方法不被事务控制。
如下代码，线程内调用insert方法，spring不会把insert方法加入事务就算在insert方法上加入@Transactional注解，也不起作用。
被外部调用的公共方法A有两个进行了数据操作的子方法B和子方法C的事务注解说明：
1.被外部调用的公共方法A未声明事务@Transactional，子方法B和C若是其他类的方法且各自声明事务，则事务由子方法B和C各自控制
2.被外部调用的公共方法A未声明事务@Transactional，子方法B和C若是本类的方法，则无论子方法B和C是否声明事务，事务均不会生效
3.被外部调用的公共方法A声明事务@Transactional，无论子方法B和C是不是本类的方法，无论子方法B和C是否声明事务，事务均由公共方法A控制
4.被外部调用的公共方法A声明事务@Transactional，子方法运行异常，但运行异常被子方法自己 try-catch 处理了，则事务回滚是不会生效的！
二、案例代码
数据库表
以上是目前数据库的数据，我接下来要做的是修改uuid为1的数据，和新增两条数据，以及删除uuid为2和3的，同时操作来演示事务。
代码一
@Api(tags = "动态数据源管理") @RestController @RequestMapping("/hvit/dataResource/") public class SysDataResourceController { @Autowired private SysDataResourceDataService sysDataResourceDataService; @ApiOperation("数据集查看-->插入/编辑/删除行") @PostMapping("/insertRowDataToDataTable") public ResponseEntity insertRowDataToDataTable(@RequestBody RowDataReq rowDataReq) { return ResponseEntity.ok(sysDataResourceDataService.insertRowDataToDataTable(rowDataReq)); }
@Slf4j @Service public class SysDataResourceDataService { @Autowired private SysDataDirectoryDataService sysDataDirectoryDataService; @Autowired private SysUserService sysUserService; @Autowired private SysTableStructureService sysTableStructureService; @Autowired private DBService dbService; @Autowired private SysDataResourceDataService sysDataResourceDataService; /*** * 数据集查看-->插入/编辑/删除行 * @param rowDataReq * @return * 被外部调用的公共方法A未声明事务@Transactional，子方法B和C若是其他类的方法且各自声明事务，则事务由子方法B和C各自控制 */ public R insertRowDataToDataTable(RowDataReq rowDataReq) { //try { if (StringUtils.isAnyEmpty(rowDataReq.getTableName(), rowDataReq.getPoolName())) { return R.error("缺少参数！"); } //先获取表的主键 SysDataResource sysDataResource = sysDataResourceService.getById(rowDataReq.getPoolName()); String prikey = ""; if (sysDataResource != null) { prikey = dbService.getDataTablePrimaryKey(rowDataReq.getTableName(), sysDataResource.getDataResourceName()); } insertAndUpdateAndDeleteDataTableData(rowDataReq, prikey); return R.ok(); } @Transactional(rollbackFor = Exception.class) public void insertAndUpdateAndDeleteDataTableData(RowDataReq rowDataReq, String prikey) { //处理插入行 if (!CollectionUtils.isEmpty(rowDataReq.getAddRowData())) { rowDataReq.getAddRowData().forEach(x -> { StringBuffer keyString = new StringBuffer(); StringBuffer valueString = new StringBuffer(); x.forEach((key, value) -> { keyString.append(key + ","); valueString.append("'" + value + "'" + ","); }); String k = keyString.toString().substring(0, keyString.length() - 1); String v = valueString.toString().substring(0, valueString.length() - 1); sysDataResourceDataService.insertDataTableData(rowDataReq.getTableName(), k, v); }); } //处理编辑行 if (!CollectionUtils.isEmpty(rowDataReq.getUpdateRowData())) { if (StringUtils.isNotEmpty(prikey)) { String finalPrikey = prikey; rowDataReq.getUpdateRowData().forEach(x -> { StringBuffer updateString = new StringBuffer(); StringBuffer conditionStr = new StringBuffer(); x.forEach((key, value) -> { if (key.equals(finalPrikey)) { conditionStr.append(key + "=" + "'" + value + "'"); } updateString.append(key + "=" + "'" + value + "'" + ","); }); String u = updateString.toString().substring(0, updateString.length() - 1); sysDataResourceDataService.updateDataTableData(rowDataReq.getTableName(), u, conditionStr.toString()); }); } } //处理删除 if (!CollectionUtils.isEmpty(rowDataReq.getDeleteRowData())) { if (StringUtils.isNotEmpty(prikey)) { String finalPrikey = prikey; rowDataReq.getDeleteRowData().forEach(x -> { StringBuffer conditionStr = new StringBuffer(); x.forEach((key, value) -> { if (key.equals(finalPrikey)) { conditionStr.append(key + "=" + "'" + value + "'"); } }); sysDataResourceDataService.deleteDataTableData(rowDataReq.getTableName(), conditionStr.toString()); }); } } } /*** * 动态插入表数据 * @param tableName * @param columnsName * @param values */ @ChangeDB public void insertDataTableData(String tableName, String columnsName, String values) { sysDataResourceMapper.insertDataTableData(tableName, columnsName, values); } /*** * 获取数据库主键 * @param tableName * @param dataResourceName * @return */ @ChangeDB public String getDataTablePrimaryKey(String tableName, String dataResourceName) { return sysDataResourceMapper.getDataTablePrimaryKey(tableName, dataResourceName); } /*** * 修改表数据 * @param tableName * @param updateString * @param condition */ @ChangeDB public void updateDataTableData(String tableName, String updateString, String condition) { sysDataResourceMapper.updateDataTableData(tableName, updateString, condition); } /*** * 删除表数据 * @param tableName * @param condition */ @ChangeDB public void deleteDataTableData(String tableName, String condition) { sysDataResourceMapper.deleteDataTableData(tableName, condition); } }
@ChangeDB这个是自定义注解，用于动态切换数据源。这个下一期我会说，如何aop+自定义注解来动态切换数据源。
我们来看下这个代码，不知道大家有没有发现为什么类内的方法不直接调用？而是自己把自己注入进spring中，然后再调用？大家可以思考下！
接下来进入正题，大家可以一眼发现这个调用其实事务是不会生效的，因为主方法并没有使用@Transactional(rollbackFor = Exception.class)，即使子方法使用了，但是依旧不会生效。这符合上面说的：被外部调用的公共方法A未声明事务@Transactional，子方法B和C若是本类的方法，则无论子方法B和C是否声明事务，事务均不会生效。
代码二
@Slf4j @Service public class SysDataResourceDataService { @Autowired private SysDataDirectoryDataService sysDataDirectoryDataService; @Autowired private SysUserService sysUserService; @Autowired private SysTableStructureService sysTableStructureService; @Autowired private DBService dbService; @Autowired private SysDataResourceDataService sysDataResourceDataService; /*** * 数据集查看-->插入/编辑/删除行 * @param rowDataReq * @return * 被外部调用的公共方法A未声明事务@Transactional，子方法B和C若是其他类的方法且各自声明事务，则事务由子方法B和C各自控制 */ public R insertRowDataToDataTable(RowDataReq rowDataReq) { //try { if (StringUtils.isAnyEmpty(rowDataReq.getTableName(), rowDataReq.getPoolName())) { return R.error("缺少参数！"); } //先获取表的主键 SysDataResource sysDataResource = sysDataResourceService.getById(rowDataReq.getPoolName()); String prikey = ""; if (sysDataResource != null) { prikey = dbService.getDataTablePrimaryKey(rowDataReq.getTableName(), sysDataResource.getDataResourceName()); } insertAndUpdateAndDeleteDataTableData(rowDataReq, prikey); return R.ok(); } public void insertAndUpdateAndDeleteDataTableData(RowDataReq rowDataReq, String prikey) { //处理插入行 if (!CollectionUtils.isEmpty(rowDataReq.getAddRowData())) { rowDataReq.getAddRowData().forEach(x -> { StringBuffer keyString = new StringBuffer(); StringBuffer valueString = new StringBuffer(); x.forEach((key, value) -> { keyString.append(key + ","); valueString.append("'" + value + "'" + ","); }); String k = keyString.toString().substring(0, keyString.length() - 1); String v = valueString.toString().substring(0, valueString.length() - 1); dbService.insertDataTableData(rowDataReq.getTableName(), k, v); }); } //处理编辑行 if (!CollectionUtils.isEmpty(rowDataReq.getUpdateRowData())) { if (StringUtils.isNotEmpty(prikey)) { String finalPrikey = prikey; rowDataReq.getUpdateRowData().forEach(x -> { StringBuffer updateString = new StringBuffer(); StringBuffer conditionStr = new StringBuffer(); x.forEach((key, value) -> { if (key.equals(finalPrikey)) { conditionStr.append(key + "=" + "'" + value + "'"); } updateString.append(key + "=" + "'" + value + "'" + ","); }); String u = updateString.toString().substring(0, updateString.length() - 1); dbService.updateDataTableData(rowDataReq.getTableName(), u, conditionStr.toString()); }); } } //处理删除 if (!CollectionUtils.isEmpty(rowDataReq.getDeleteRowData())) { if (StringUtils.isNotEmpty(prikey)) { String finalPrikey = prikey; rowDataReq.getDeleteRowData().forEach(x -> { StringBuffer conditionStr = new StringBuffer(); x.forEach((key, value) -> { if (key.equals(finalPrikey)) { conditionStr.append(key + "=" + "'" + value + "'"); } }); dbService.deleteDataTableData(rowDataReq.getTableName(), conditionStr.toString()); }); } } } }
dbService:
/*** * 动态插入表数据 * @param tableName * @param columnsName * @param values */ @ChangeDB @Transactional(rollbackFor = Exception.class) public void insertDataTableData(String tableName, String columnsName, String values) { sysDataResourceMapper.insertDataTableData(tableName, columnsName, values); } /*** * 获取数据库主键 * @param tableName * @param dataResourceName * @return */ @ChangeDB public String getDataTablePrimaryKey(String tableName, String dataResourceName) { return sysDataResourceMapper.getDataTablePrimaryKey(tableName, dataResourceName); } /*** * 修改表数据 * @param tableName * @param updateString * @param condition */ @ChangeDB @Transactional(rollbackFor = Exception.class) public void updateDataTableData(String tableName, String updateString, String condition) { sysDataResourceMapper.updateDataTableData(tableName, updateString, condition); } /*** * 删除表数据 * @param tableName * @param condition */ @ChangeDB @Transactional(rollbackFor = Exception.class) public void deleteDataTableData(String tableName, String condition) { sysDataResourceMapper.deleteDataTableData(tableName, condition); }
案例二的代码是SysDataResourceDataService内方法调用其他类的加了事务的方法。可以看到dbservice的几个方法都加了事务。
看代码这种方法报错后，其实也不会事务回滚的，因为它属于方法调用了两个其他类事务的方法，简单点说也就是各管各的了，所以再insertRowDataToDataTable方法内调用报错是无法使用事务回滚的，这种正好属于上面说的：被外部调用的公共方法A未声明事务@Transactional，子方法B和C若是其他类的方法且各自声明事务，则事务由子方法B和C各自控制
我的解决代码
* 数据集查看-->插入/编辑/删除行 * @param rowDataReq * @return * 被外部调用的公共方法A未声明事务@Transactional，子方法B和C若是其他类的方法且各自声明事务，则事务由子方法B和C各自控制 */ public R insertRowDataToDataTable(RowDataReq rowDataReq) { //try { if (StringUtils.isAnyEmpty(rowDataReq.getTableName(), rowDataReq.getPoolName())) { return R.error("缺少参数！"); } //先获取表的主键 SysDataResource sysDataResource = sysDataResourceService.getById(rowDataReq.getPoolName()); String prikey = ""; if (sysDataResource != null) { prikey = dbService.getDataTablePrimaryKey(rowDataReq.getTableName(), sysDataResource.getDataResourceName()); } dbService.insertAndUpdateAndDeleteDataTableData(rowDataReq, prikey); return R.ok(); }
可以看到主方法没有加 @Transactional，我们直接调用的是dbService中insertAndUpdateAndDeleteDataTableData，没错，我们把方法提取到另一个类中了。
dbService：
@ChangeDB @Transactional(rollbackFor = Exception.class) public void insertAndUpdateAndDeleteDataTableData(RowDataReq rowDataReq, String prikey) { //处理插入行 if (!CollectionUtils.isEmpty(rowDataReq.getAddRowData())) { rowDataReq.getAddRowData().forEach(x -> { StringBuffer keyString = new StringBuffer(); StringBuffer valueString = new StringBuffer(); x.forEach((key, value) -> { keyString.append(key + ","); valueString.append("'" + value + "'" + ","); }); String k = keyString.toString().substring(0, keyString.length() - 1); String v = valueString.toString().substring(0, valueString.length() - 1); sysDataResourceMapper.insertDataTableData(rowDataReq.getTableName(), k, v); }); } //处理编辑行 if (!CollectionUtils.isEmpty(rowDataReq.getUpdateRowData())) { if (StringUtils.isNotEmpty(prikey)) { String finalPrikey = prikey; rowDataReq.getUpdateRowData().forEach(x -> { StringBuffer updateString = new StringBuffer(); StringBuffer conditionStr = new StringBuffer(); x.forEach((key, value) -> { if (key.equals(finalPrikey)) { conditionStr.append(key + "=" + "'" + value + "'"); } updateString.append(key + "=" + "'" + value + "'" + ","); }); String u = updateString.toString().substring(0, updateString.length() - 1); sysDataResourceMapper.updateDataTableData(rowDataReq.getTableName(), u, conditionStr.toString()); }); } } //处理删除 if (!CollectionUtils.isEmpty(rowDataReq.getDeleteRowData())) { if (StringUtils.isNotEmpty(prikey)) { String finalPrikey = prikey; rowDataReq.getDeleteRowData().forEach(x -> { StringBuffer conditionStr = new StringBuffer(); x.forEach((key, value) -> { if (key.equals(finalPrikey)) { conditionStr.append(key + "=" + "'" + value + "'"); } }); sysDataResourceMapper.deleteDataTableData(rowDataReq.getTableName(), conditionStr.toString()); }); } } }
改成如上代码后，经过测试，修改操作报错了，新增的部分同时也会滚了。
这只是我在开发中遇到的问题。如果雷同，可以参考下。
下期：我们说下怎么通过aop+自定义注解来配置动态数据源，以及动态切换数据源。
