目的
分析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 ：总是非事务地执行，如果存在一个活动事务，则抛出异常：
网友评论