java面试知识总结--spring事务嵌套问题

目的

分析spring的事务实际使用中的嵌套问题和场景

场景一同类方法间调用,事务失效


    @Transactional
    protected void test(PayRequestDTO payRequestDTO){

        TrxOrderEntityExample entityExample = new TrxOrderEntityExample();
        TrxOrderEntity trxOrderEntity = new TrxOrderEntity();
        trxOrderEntity.setCompletedTime(new Date());
        entityExample.createCriteria().andOrderNoEqualTo(payRequestDTO.getRequestNo());
        trxOrderEntityMapper.updateByExampleSelective(trxOrderEntity, entityExample);
        throw new RuntimeException("");


    }

    @Override
    public PayResponseDTO pay(PayRequestDTO payRequestDTO) {

        test(payRequestDTO);
        return null;
    }

效果:

原数据

执行后数据

结论一:同类方法调用,事务失效
改进方法:

将test方法放到其他类中
使用编程式事务,例

   private void test(PayRequestDTO payRequestDTO){
        transactionTemplate.execute(new TransactionCallbackWithoutResult() {
            @Override
            protected void doInTransactionWithoutResult(TransactionStatus transactionStatus) {

                TrxOrderEntityExample entityExample = new TrxOrderEntityExample();
                TrxOrderEntity trxOrderEntity = new TrxOrderEntity();
                trxOrderEntity.setCompletedTime(new Date());
                entityExample.createCriteria().andOrderNoEqualTo(payRequestDTO.getRequestNo());
                trxOrderEntityMapper.updateByExampleSelective(trxOrderEntity, entityExample);
                throw new RuntimeException("");
            }
        });

    }

    @Override
    public PayResponseDTO pay(PayRequestDTO payRequestDTO) {

        test(payRequestDTO);
        return null;
    }

原数据

执行后数据

显然,编程式事务此时完美成功.

场景二对于异常的声明,抛出Exception,非RuntimeException

    @Transactional
    public void test(PayRequestDTO payRequestDTO) throws Exception {
        TrxOrderEntityExample entityExample = new TrxOrderEntityExample();
        TrxOrderEntity trxOrderEntity = new TrxOrderEntity();
        trxOrderEntity.setUpdateTime(new Date());
        entityExample.createCriteria().andOrderNoEqualTo(payRequestDTO.getRequestNo());
        trxOrderEntityMapper.updateByExampleSelective(trxOrderEntity, entityExample);
        //子方法
        testTrans.test(payRequestDTO);
        throw new Exception("");

    }

效果如下:

原数据

执行后

显然事务是失效的,因为Spring的事务处理默认为RuntimeException,此时需要声明@Transactional(rollbackFor = Exception.class),再看效果,显然事务生效了:

原数据

执行后

场景三父事务方法调用子事务方法

父方法

 @Transactional(rollbackFor = Exception.class)
    public void test(PayRequestDTO payRequestDTO) throws Exception {
        TrxOrderEntityExample entityExample = new TrxOrderEntityExample();
        TrxOrderEntity trxOrderEntity = new TrxOrderEntity();
        trxOrderEntity.setUpdateTime(new Date());
        entityExample.createCriteria().andOrderNoEqualTo(payRequestDTO.getRequestNo());
        trxOrderEntityMapper.updateByExampleSelective(trxOrderEntity, entityExample);
        //子方法
        testTrans.test(payRequestDTO);
        throw new RuntimeException("");

    }

子方法

  @Transactional
    public void test(PayRequestDTO payRequestDTO) {
        TrxOrderEntityExample entityExample = new TrxOrderEntityExample();
        TrxOrderEntity trxOrderEntity = new TrxOrderEntity();
        trxOrderEntity.setCompletedTime(new Date());
        entityExample.createCriteria().andOrderNoEqualTo(payRequestDTO.getRequestNo());
        trxOrderEntityMapper.updateByExampleSelective(trxOrderEntity, entityExample);
//        throw new RuntimeException("");

    }

分析,此时父子方法都是默认@Transactional 注解,传播机制为

PROPAGATION_REQUIRED: 父有就继承,没有就新创,代码中表示我们子方法修改了completedTime,父方法修改了updateDate,看效果:
- 子异常+父异常

//父方法:
    @Transactional
    public void test(PayRequestDTO payRequestDTO) {
        TrxOrderEntityExample entityExample = new TrxOrderEntityExample();
        TrxOrderEntity trxOrderEntity = new TrxOrderEntity();
        trxOrderEntity.setUpdateTime(new Date());
        entityExample.createCriteria().andOrderNoEqualTo(payRequestDTO.getRequestNo());
        trxOrderEntityMapper.updateByExampleSelective(trxOrderEntity, entityExample);
        //子方法
        testTrans.test(payRequestDTO);
        throw new RuntimeException("");

    }
--------
//子方法
 @Transactional
    public void test(PayRequestDTO payRequestDTO) {
        TrxOrderEntityExample entityExample = new TrxOrderEntityExample();
        TrxOrderEntity trxOrderEntity = new TrxOrderEntity();
        trxOrderEntity.setCompletedTime(new Date());
        entityExample.createCriteria().andOrderNoEqualTo(payRequestDTO.getRequestNo());
        trxOrderEntityMapper.updateByExampleSelective(trxOrderEntity, entityExample);
        throw new RuntimeException("");
    }

此时事务生效:

原

后

子异常+父无异常
代码不演示,只是把父类的异常注释,看效果,事务有效,继承成功:

效果
子无异常+父异常
效果展示,两个时间参数还是没有变化,事务继承成功:

image.png

子事务改成@Transactional(propagation=REQUIRES_NEW),代码变成

    @Transactional(propagation=REQUIRES_NEW)
    public void test(PayRequestDTO payRequestDTO) {
        TrxOrderEntityExample entityExample = new TrxOrderEntityExample();
        TrxOrderEntity trxOrderEntity = new TrxOrderEntity();
        trxOrderEntity.setCompletedTime(new Date());
        entityExample.createCriteria().andOrderNoEqualTo(payRequestDTO.getRequestNo());
        trxOrderEntityMapper.updateByExampleSelective(trxOrderEntity, entityExample);
//        throw new RuntimeException("");
    }

测试一把,发现报错MySQLTransactionRollbackException: Lock wait timeout exceeded:

image.png

别急,此时我们修改下子方法代码,让子方法修改另外一张表,

 @Transactional(propagation=REQUIRES_NEW)
    public void test(PayRequestDTO payRequestDTO) {
//        TrxOrderEntityExample entityExample = new TrxOrderEntityExample();
//        TrxOrderEntity trxOrderEntity = new TrxOrderEntity();
//        trxOrderEntity.setCompletedTime(new Date());
//        entityExample.createCriteria().andOrderNoEqualTo(payRequestDTO.getRequestNo());
//        trxOrderEntityMapper.updateByExampleSelective(trxOrderEntity, entityExample);
//        throw new RuntimeException("");
        MerchantEntityExample merchantEntityExample=new MerchantEntityExample();
        merchantEntityExample.createCriteria().andMerchantNoEqualTo("10040067508");
        MerchantEntity merchantEntity=new MerchantEntity();
        merchantEntity.setUpdateTime(new Date());
        merchantEntityMapper.updateByExampleSelective(merchantEntity,merchantEntityExample);
    }

效果如下,merchant的表事务是不受外父级事务影响的,且因为修改了两张不同的表,没有出现死锁问题(事务的隔离会对数据加锁,因为父子两方法修改的是同一条数据,造成父等子提交,子等父提交,两个事务死锁).

merchant原数据

merchants后数据

具体其他几种propagation的概念,可参考博客https://blog.csdn.net/qq_34552004/article/details/79599275

场景四一父多子情况

    private void test(PayRequestDTO payRequestDTO) {
        transactionTemplate.execute(new TransactionCallbackWithoutResult() {
            @Override
            protected void doInTransactionWithoutResult(TransactionStatus transactionStatus) {
                testTrans.test(payRequestDTO);
                testTrans2.test(payRequestDTO);
//                throw new RuntimeException("");
            }
        });

    }

此时在父亲和两个儿子中任一个方法中抛出异常,都会回滚,说明一父多子事务机制是一样的(透传级别还是PROPAGATION_REQUIRED),一荣俱荣,一损具损

最后,附上各传播性概念:

PROPAGATION_REQUIRED：如果存在一个事务，则支持当前事务。如果没有事务则开启一个新的事务。
PROPAGATION_MANDATORY ：如果已经存在一个事务，支持当前事务。如果没有一个活动的事务，则抛出异常。
PROPAGATION_SUPPORTS ：如果存在一个事务，支持当前事务。如果没有事务，则非事务的执行。但是对于事务同步的事务管理器，PROPAGATION_SUPPORTS与不使用事务有少许不同。
PROPAGATION_REQUIRES_NEW ：总是开启一个新的事务。如果一个事务已经存在，则将这个存在的事务挂起。
PROPAGATION_NOT_SUPPORTED：总是非事务地执行，并挂起任何存在的事务。
PROPAGATION_NEVER ：总是非事务地执行，如果存在一个活动事务，则抛出异常：

java面试知识总结--spring事务嵌套问题

目的

场景一 同类方法间调用,事务失效

场景二 对于异常的声明,抛出Exception,非RuntimeException

场景三 父事务方法调用子事务方法

场景四 一父多子情况

场景一同类方法间调用,事务失效

场景二对于异常的声明,抛出Exception,非RuntimeException

场景三父事务方法调用子事务方法

场景四一父多子情况