快捷導(dǎo)航

我總結(jié)的幾種@Transactional失效原因說明

更新時(shí)間：2022年11月15日 15:53:49 作者：滕青山Y(jié)YDS

這篇文章主要是我總結(jié)的幾種@Transactional失效原因說明，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

總結(jié)幾種@Transactional失效原因

非public方法

spring事務(wù)是通過動(dòng)態(tài)代理的方法來實(shí)現(xiàn)的，有兩種實(shí)現(xiàn)動(dòng)態(tài)代理的方式，jdk動(dòng)態(tài)代理方式是將目標(biāo)對(duì)象放入代理對(duì)象內(nèi)部，通過代理對(duì)象來訪問目標(biāo)對(duì)象；cglib字節(jié)碼生成是通過生成目標(biāo)對(duì)象的子類，通過重寫的方式來完成對(duì)父類的增強(qiáng)。

但是它倆實(shí)際上可以為非public方法生成代理對(duì)象，只不過spring在調(diào)用動(dòng)態(tài)代理之前，會(huì)過濾掉非public方法。如果修改spring的源碼就可以為非public方法生成代理對(duì)象了。

自調(diào)用問題

若同一類中的沒有@Transactional注解的方法內(nèi)部調(diào)用有@Transactional注解的方法，那么該事務(wù)會(huì)被忽略。

原因是Spring事務(wù)是通過Spring AOP完成的，如果從外部直接訪問使用@Transactional注解的方法，那么spring實(shí)際上會(huì)調(diào)用代理對(duì)象上的方法，在代理對(duì)象中完成事務(wù)的邏輯；

但是如果從目標(biāo)對(duì)象內(nèi)部調(diào)用了使用@Transactional注解的方法，比如在method1方法中調(diào)用了method2方法，method1沒有加@Transactional 注解，就算method2加了@Transactional 注解也沒用。因?yàn)檫@時(shí)會(huì)直接調(diào)用目標(biāo)對(duì)象中的method1方法，進(jìn)而再調(diào)用目標(biāo)對(duì)象的method2方法，并沒有走代理對(duì)象導(dǎo)致代理失效。

異常相關(guān)問題

內(nèi)部捕捉了異常，沒有拋出新的異常，導(dǎo)致事務(wù)操作不會(huì)進(jìn)行回滾：

原因是spring事務(wù)源碼中是通過有沒有出現(xiàn)異常來判斷是否回滾的。

拋出非運(yùn)行時(shí)異常

所以最好給@Transactional添加上rollbackFor=Exception.class

傳播機(jī)制配置錯(cuò)誤

錯(cuò)誤地使用傳播機(jī)制也會(huì)導(dǎo)致事務(wù)失效。如果使用了NOT_SUPPORTED和NEVER傳播機(jī)制，那么事務(wù)機(jī)會(huì)失效，如果使用了SUPPORTS傳播機(jī)制并且當(dāng)前不存在事務(wù)那么事務(wù)也會(huì)失效。

TransactionDefinition.PROPAGATION_SUPPORTS: 如果當(dāng)前存在事務(wù)，則加入該事務(wù)；如果當(dāng)前沒有事務(wù)，則以非事務(wù)的方式繼續(xù)運(yùn)行。
TransactionDefinition.PROPAGATION_NOT_SUPPORTED: 以非事務(wù)方式運(yùn)行，如果當(dāng)前存在事務(wù)，則把當(dāng)前事務(wù)掛起。
TransactionDefinition.PROPAGATION_NEVER: 以非事務(wù)方式運(yùn)行，如果當(dāng)前存在事務(wù)，則拋出異常。

@Transactional事務(wù)失效場(chǎng)景類內(nèi)部調(diào)用實(shí)測(cè)

環(huán)境springboot2.7，mysql5.7

demo1

@Component
@Order(6)
@Slf4j
public class TestRunner implements ApplicationRunner {
 
    @Autowired
    TestService testService;
 
    @Override
    public void run(ApplicationArguments args) throws Exception {
        testService.insertAndUpdate();
    }
}

@Service("testService")
public class TestServiceImpl extends ServiceImpl<TestMapper, Test> implements TestService {
 
    @Override
    public boolean updateByIdOne() {
        LambdaUpdateWrapper<Test> lambdaUpdateWrapper = new UpdateWrapper<Test>().lambda();
        lambdaUpdateWrapper.eq(Test::getId,1);
        lambdaUpdateWrapper.set(Test::getName,"test");
 
        return this.update(lambdaUpdateWrapper);
    }
 
    @Transactional(rollbackFor = RuntimeException.class)
    @Override
    public boolean insertAndUpdate() {
        boolean b = this.updateByIdOne();
 
 
        Test test = new Test();
        test.setName("2222");
 
 
        boolean save = this.save(test);
        if(b){
            throw new RuntimeException("ts");
        }
        return save;
    }
}

以上代碼先跑一遍，看看拋出異常情況，能不能回滾

看庫毫無變化

看主鍵遞增量其實(shí)是插入過了，我覺得事務(wù)還是生效了

demo2

@Service("testService")
public class TestServiceImpl extends ServiceImpl<TestMapper, Test> implements TestService {
 
    @Transactional(rollbackFor = RuntimeException.class)
    @Override
    public boolean updateByIdOne() {
        LambdaUpdateWrapper<Test> lambdaUpdateWrapper = new UpdateWrapper<Test>().lambda();
        lambdaUpdateWrapper.eq(Test::getId,1);
        lambdaUpdateWrapper.set(Test::getName,"test");
        boolean update = this.update(lambdaUpdateWrapper);
 
        if(update){
            throw new RuntimeException("updateByIdOne");
        }
 
        LambdaUpdateWrapper<Test> lambdaUpdateWrapper2 = new UpdateWrapper<Test>().lambda();
        lambdaUpdateWrapper2.eq(Test::getId,2);
        lambdaUpdateWrapper2.set(Test::getName,"test");
        boolean update1 = this.update(lambdaUpdateWrapper2);
 
        return update;
    }
 
    @Transactional(rollbackFor = RuntimeException.class)
    @Override
    public boolean insertAndUpdate() {
 
        Test test = new Test();
        test.setName("2222");
        boolean save = this.save(test);
 
        boolean b = this.updateByIdOne();
 
        return save;
    }
}

執(zhí)行結(jié)果

子父方法都有事務(wù)注解，事務(wù)生效

demo3

@Service("testService")
public class TestServiceImpl extends ServiceImpl<TestMapper, Test> implements TestService {
 
    @Override
    public boolean updateByIdOne() {
        LambdaUpdateWrapper<Test> lambdaUpdateWrapper = new UpdateWrapper<Test>().lambda();
        lambdaUpdateWrapper.eq(Test::getId,1);
        lambdaUpdateWrapper.set(Test::getName,"test");
        boolean update = this.update(lambdaUpdateWrapper);
 
        if(update){
            throw new RuntimeException("updateByIdOne");
        }
 
        return update;
    }
    @Transactional(rollbackFor = RuntimeException.class)
    @Override
    public boolean insertAndUpdate() {
 
        Test test = new Test();
        test.setName("2222");
        boolean save = this.save(test);
 
 
        boolean b = this.updateByIdOne();
        return b;
    }
}

insertAndUpdate插入成功后又回滾，update 更新成功也回滾，事務(wù)生效

demo4

@Service("testService")
public class TestServiceImpl extends ServiceImpl<TestMapper, Test> implements TestService {
 
    @Transactional(rollbackFor = RuntimeException.class)
    @Override
    public boolean updateByIdOne() {
        LambdaUpdateWrapper<Test> lambdaUpdateWrapper = new UpdateWrapper<Test>().lambda();
        lambdaUpdateWrapper.eq(Test::getId,1);
        lambdaUpdateWrapper.set(Test::getName,"test");
        boolean update = this.update(lambdaUpdateWrapper);
 
        if(update){
            throw new RuntimeException("updateByIdOne");
        }
 
        LambdaUpdateWrapper<Test> lambdaUpdateWrapper2 = new UpdateWrapper<Test>().lambda();
        lambdaUpdateWrapper2.eq(Test::getId,2);
        lambdaUpdateWrapper2.set(Test::getName,"test");
        boolean update1 = this.update(lambdaUpdateWrapper2);
 
        return update;
    }
 
    @Override
    public boolean insertAndUpdate() {
        boolean b = this.updateByIdOne();
 
        return b;
    }
}