mybatis-plus自定义多数据源，动态切换数据源事务失效问题
Posted 郭老师的小迷弟雅思莫了
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了mybatis-plus自定义多数据源，动态切换数据源事务失效问题相关的知识，希望对你有一定的参考价值。
背景
做了一个和navicat一样的工具，web版工具，然后数据库链接信息都是存在一个主数据库表的里，所以这里涉及到了动态切换数据源，以及一些事务等。今天说下多数据源切换时，事务失效。
目录
1、@Transactional 应用在非 public 修饰的方法上
2、@Transactional 注解属性 rollbackFor 设置错误
3、同一个类中方法调用，导致@Transactional失效
4、异常被你的 catch“吃了”导致@Transactional失效
一、常见的事务失效
@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+自定义注解来配置动态数据源，以及动态切换数据源。
mybatis-plus 动态数据源读写分离 + shardingJDBC分库分表
参考技术A 项目需要配置读写分离，分库分表，选了shardingJDBC，但是shardingJDBC又许多不支持的sql，综合了一下，选择mybaitis-plus做读写分离，遇到分库分表的时候切换sharding数据源，也就是一般情况下使用的还是jdbc，有分表的时候才会用shardingJDBCdynamic-datasource-spring-boot-starter采用3.3以上的好像就切不过来数据源，具体没找到原因
配置mybatis-plus读写分离
数据源配置
自定义分片
数据源切换
方法或者类上加上注解 @DS("salve-sharding")
配置主从的时候，有时候插入数据，马上查询，可能主从还没同步，这时候可以加上事务的注解，这样子就都会走主库了
以上是关于mybatis-plus自定义多数据源，动态切换数据源事务失效问题的主要内容，如果未能解决你的问题，请参考以下文章
springboot多数据源动态切换和自定义mybatis件分页插
记录mybatis-plus多数据源批量操作时,数据源切换失效之谜
mybatis plus自定义的mapper如何动态切换数据源
springboot2.x+MyBatis-Plus+mysql5.7 动态拼接sql语句 分页查询 自定义sql 查询条件 分组 排序