SpringBoot中try/catch异常并回滚事务（自动回滚/手动回滚/部分回滚）_try catch 回滚

在Spring官方文档中说到，当Transaction内发生unchecked exception的时候，会自动rollback，但是当Transaction内发生checked exception时，是不会自动rollback的。

这里之所以让大家清楚checked异常和unchecked异常概念，是因为：
Spring使用声明式事务处理，默认情况下，如果被注解的数据库操作方法中发生了unchecked异常，所有的数据库操作将rollback；如果发生的异常是checked异常，默认情况下数据库操作还是会提交的。

checked异常：
表示无效，不是程序中可以预测的。比如无效的用户输入，文件不存在，网络或者数据库链接错误。这些都是外在的原因，都不是程序内部可以控制的。
必须在代码中显式地处理。比如try-catch块处理，或者给所在的方法加上throws说明，将异常抛到调用栈的上一层。
继承自java.lang.Exception（java.lang.RuntimeException除外）。

unchecked异常：
表示错误，程序的逻辑错误。是RuntimeException的子类，比如IllegalArgumentException, NullPointerException和IllegalStateException。
不需要在代码中显式地捕获unchecked异常做处理。
继承自java.lang.RuntimeException（而java.lang.RuntimeException继承自java.lang.Exception）。

异常处理
1、自动回滚

    @Transactional(rollbackFor = Exception.class)
    public void asyncJob() throws Exception {
        success();
        //假如exception这个操作数据库的方法会抛出异常,方法success()对数据库的操作会回滚
        exception();
    }
1
2
3
4
5
6

2、手动回滚（进行try/catch，回滚并抛出）

    @Transactional(rollbackFor = Exception.class)
    public void asyncJob() {
        success();
        try {
            exception();
        } catch (Exception e) {
            e.printStackTrace();
            //手工回滚异常
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
        }
    }
1
2
3
4
5
6
7
8
9
10
11

3、回滚部分异常

    @Transactional(rollbackFor = Exception.class)
    public void asyncJob() {
        success();
        //设置回滚点,只回滚以下异常
        Object savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint();
        try {
            exception();
        } catch (Exception e) {
            e.printStackTrace();
            //手工回滚异常,回滚到savePoint
            TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
        }
    }

1
2
3
4
5
6
7
8
9
10
11
12
13
14

伪代码

@Autowired
private AsyncJobService asyncJobService;

@Transactional(rollbackFor = Exception.class)
public Boolean executeJob() {
    checkProcessJob();//检查是否存在流程中的任务
    Job job = new Job();
    job.setStatus(StatusEnum.IN_PROGRESS);//设置任务状态为执行中
    jobMapper.insert(job);

    asyncJobService.asyncExecute(job);//异步执行任务
    return true;
}
@Async
@Transactional(rollbackFor = Exception.class)
public void asyncExecute(Job job) {
    //设置回滚点,只回滚以下异常
    Object savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint();
    try {
        exception();
    } catch (Exception e) {
        //手工回滚异常,回滚到savePoint
        TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
        log.error("异步执行任务失败,{}", e.getMessage());
        job.setStatus(StatusEnum.FAIL);//设置任务状态为执行失败
        jobMapper.updateById(job);
        return;
    }
    job.setStatus(StatusEnum.SUCCESS);//设置任务状态为执行成功
    jobMapper.updateById(job);
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31