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

2019-03-16  本文已影响0人  爱编程的凯哥

目的

分析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;
    }

效果:


原数据
执行后数据

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

  1. 将test方法放到其他类中
  2. 使用编程式事务,例
   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),再看效果,显然事务生效了:

原数据
执行后

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

  1. 父方法
 @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 注解,传播机制为

  1. 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("");
    }

此时事务生效:


原
后
  1. 子事务改成@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),一荣俱荣,一损具损

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

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

猜你喜欢

热点阅读