背景

做了一个和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的事务注解说明：

被外部调用的公共方法A未声明事务@Transactional，子方法B和C若是其他类的方法且各自声明事务，则事务由子方法B和C各自控制

被外部调用的公共方法A未声明事务@Transactional，子方法B和C若是本类的方法，则无论子方法B和C是否声明事务，事务均不会生效

被外部调用的公共方法A声明事务@Transactional，无论子方法B和C是不是本类的方法，无论子方法B和C是否声明事务，事务均由公共方法A控制

被外部调用的公共方法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@Servicepublic class SysDataResourceDataService {    @Autowired    private SysDataDirectoryDataService sysDataDirectoryDataService;    @Autowired    private SysUserService sysUserService;    @Autowired    private SysTableStructureService sysTableStructureService;    @Autowired    private DBService dbService;    @Autowired    private SysDataResourceDataService sysDataResourceDataService;     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());                });            }        }    }    @ChangeDB    public void insertDataTableData(String tableName, String columnsName, String values) {        sysDataResourceMapper.insertDataTableData(tableName, columnsName, values);    }        @ChangeDB    public String getDataTablePrimaryKey(String tableName, String dataResourceName) {        return sysDataResourceMapper.getDataTablePrimaryKey(tableName, dataResourceName);    }        @ChangeDB    public void updateDataTableData(String tableName, String updateString, String condition) {        sysDataResourceMapper.updateDataTableData(tableName, updateString, 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@Servicepublic class SysDataResourceDataService {    @Autowired    private SysDataDirectoryDataService sysDataDirectoryDataService;    @Autowired    private SysUserService sysUserService;    @Autowired    private SysTableStructureService sysTableStructureService;    @Autowired    private DBService dbService;    @Autowired    private SysDataResourceDataService sysDataResourceDataService;     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:

    @ChangeDB    @Transactional(rollbackFor = Exception.class)    public void insertDataTableData(String tableName, String columnsName, String values) {        sysDataResourceMapper.insertDataTableData(tableName, columnsName, values);    }        @ChangeDB    public String getDataTablePrimaryKey(String tableName, String dataResourceName) {        return sysDataResourceMapper.getDataTablePrimaryKey(tableName, dataResourceName);    }        @ChangeDB    @Transactional(rollbackFor = Exception.class)    public void updateDataTableData(String tableName, String updateString, String condition) {        sysDataResourceMapper.updateDataTableData(tableName, updateString, 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+自定义注解来配置动态数据源，以及动态切换数据源。 

来源地址：https://blog.csdn.net/qq_23126581/article/details/128345382