事务控制:事务不会滚？

可能原因一、try-catch中的代码报错，但是事务未回滚

1、问题描述

由于上传文件时通过异步来处理数据，故在异步处理数据之前向日志表中插入一条数据，处理状态为：处理中，等到处理结束，再修改处理状态为成功或失败。由于往数据库插入数据可能会抛异常，故用try/catch来处理，在正常情况下不会报错，故处理状态为成功；如果出现异常就catch，进入修改日志的处理状态为失败。上传文件并解析入库的过程可能成功也可能失败，故要使用try/catch。那么这种情况下，由于try/catch不会抛出异常，故事务不会回滚，那该如何处理呢？

代码如下：

　　 @Async
    @Transactional(rollbackFor = Exception.class)
    public void saveOutstoreInfo(Outstore outstore, UserVO userVo, List<String> codes, String path,String outstoreUploadLogTabName,String outstoreTableName,String outstoreDetailTableName,String outstoreCodeTableName) {
        try {
            // 记录日志,注意：接口调用时需要记录日志，定时任务不需要记录日志
            if (StringUtils.isNotBlank(path)) {
                uploadLog = insertUploadLog(outstore.getEntityId(), outstore.getOrderNo(), outstoreUploadLogTabName, userVo, outstore.getOrderTime(), path);
            }
            // 遍历追溯码，先获取关联关系码信息
            for (String code : codes) { // 切记不要在for循环内进行异步调用
                ...// 如果上面的都成功了，则修改日志状态未处理成功
                if (StringUtils.isNotBlank(path)) {
                    ....
                    outstoreUploadLogService.update(uploadLog);
                }
            }
        } catch (Exception e) {
            log.info(e.getMessage());
            // 手动回滚
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
            // 如果出现异常，则修改处理状态为失败
            if (StringUtils.isNotBlank(path)) {
                ...
                outstoreUploadLogService.update(uploadLog);
            }
        }

    }

2、解决办法

在catch中抛出所捕获的异常，或者添加下面代码手动回滚。

TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();

总结：

1.使用@Transactional(rollbackFor = Exception.class)注解，使用try-catch必须在catch语句中抛出异常，不然事务不回滚；

2.@Transactional注解，默认识别RuntimeException，只能在抛出RuntimeException或者Error时才会触发事务回滚，可在catch语句中直接抛出RuntimeException；

3.代码中有try-catch，需要事务回滚的话，最好添加手动回滚。

可能原因二、事务内有DDL语句

1、了解

mysql中ddl事务控制：

（1）、当执行到DDL语句时，会隐式的将当前回话的事务进行一次“COMMIT”操作，因此在MySQL中执行DDL语句时，应该严格地将DDL和DML完全分开，不能混合在一起执行。

（2）、为什么DDL语句会隐式提交？
因为DDL是数据定义语言，在我们的数据库中承担着创建，删除和修改的重要的职责。一旦发生问题，带来的后果很可能是不可估量的。二是在每执行完一次后就进行提交，可以保证流畅性，数据不会发生阻塞，同时也会提高数据库的整体性能。

（3）、DDL和DML混和执行可能带来的风险：事务中有一个DDL语句，导致事务“中途”提交一次，等最后发现异常要回滚却发现只能回滚一部分。

2、问题描述

共有四张表，前面三张表由于要分表，故先用存储过程创建表，再插入数据，第四个表b_code_year不需要建表，只插入数据。在往第四张表插入数据时认为制造一个空指针异常，结果发现前面两张表中事务没有回滚，而第三张表事务回滚了，第四张表由于报错没有数据。

3、解决办法

将创建表的语句放到事务外面先执行，即所有的表都创建完成再开启事务。

代码如下：

@Override
    public String scanCodeOutstore(JSONObject jsonObj) { // 该方法不进行事务控制
　　　　　....
// 存储过程创建这三张表，注意创建表的语句不能放到事务中，因为DDL语句会自动提交，导致事务控制失败
        buildOutstoreTable(tableName);
        //查询出库单据明细表是否存在,如果不存在则创建明细表，如果存在则新增或修改记录
        buildDetailTable(tableName);
        //查询出库码表是否存在,如果不存在则创建出库码表
        buildCodeDetailTable(tableName);
        // 异步调用,在该方法中进行事务控制
        outStoreAsycService.saveOutstoreInfo(xxx);
        return null;
    }

saveOutstoreInfo方法：

@Async
    @Transactional(rollbackFor = Exception.class)
    public void saveOutstoreInfo(xxx) {
　　　　　// 切记不要在for循环内try/catch
　　　　  try {
            // DML 语句
        } catch (Exception e) {
            log.info(e.getMessage());
            // 手动回滚
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
　　　　　　
        }

    }

 

标签：语句,控制,事务,回滚,try,DDL,catch,不会
来源： https://www.cnblogs.com/zwh0910/p/16670683.html