背景
做了一个和navicat一样的工具，web版工具，然后数据库链接信息都是存在一个主数据库表的里，所以这里涉及到了动态切换数据源，以及一些事务等。今天说下多数据源切换时，事务失效。
目录
一、常见的事务失效
@Transactional
1、@Transactional 应用在非 public 修饰的方法上
2、@Transactional 注解属性 rollbackFor 设置错误
3、同一个类中方法调用，导致@Transactional失效
4、异常被你的 catch“吃了”导致@Transactional失效
5、数据库引擎不支持事务
6、开启多线程任务时，事务管理会受到影响
二、案例代码
数据库表
代码一
代码二
我的解决代码
一、常见的事务失效
@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+自定义注解来配置动态数据源，以及动态切换数据源。
