快捷導(dǎo)航

Spring超詳細(xì)講解事務(wù)和事務(wù)傳播機(jī)制

更新時間：2022年06月20日 10:57:38 作者：亞太地區(qū)百大最帥面孔第101名

Spring事務(wù)的本質(zhì)就是對數(shù)據(jù)庫事務(wù)的支持，沒有數(shù)據(jù)庫事務(wù)，Spring是無法提供事務(wù)功能的。Spring只提供統(tǒng)一的事務(wù)管理接口，具體實(shí)現(xiàn)都是由數(shù)據(jù)庫自己實(shí)現(xiàn)的，Spring會在事務(wù)開始時，根據(jù)當(dāng)前設(shè)置的隔離級別，調(diào)整數(shù)據(jù)庫的隔離級別，由此保持一致

為什么需要事務(wù)

事務(wù)是將一組操作封裝成一個執(zhí)行單元，要么全部成功，要么全部失敗。如果沒有事務(wù)，轉(zhuǎn)賬操作就會出現(xiàn)異常，因此需要保證原子性。

Spring 聲明事務(wù)

只需要在方法上添加@Transactional注解就可以實(shí)現(xiàn)，無需手動開啟和提交事務(wù)，如果中途發(fā)生異常就會自動回滾事務(wù)。
@Transactional既可以修飾方法也可以修飾類，修飾方法只能修飾public方法
注意：@Transactional在異常被捕獲的情況下，事務(wù)就不會自動回滾

@Transactional(isolation = Isolation.READ_COMMITTED) // 開啟事務(wù)
    @RequestMapping("/insert")
    public int insert(){
        UserInfo userInfo = new UserInfo();
        userInfo.setName("AOP");
        userInfo.setPassword("123456");
        return userService.add(userInfo);
    }
    @Transactional(isolation = Isolation.READ_COMMITTED) // 開啟事務(wù)
    @RequestMapping("/insert2")
    public int insert2(){
        UserInfo userInfo = new UserInfo();
        userInfo.setName("AOP");
        userInfo.setPassword("123456");
        int result = userService.add(userInfo);
        System.out.println("MySQL影響的行數(shù)："+result);
        int num = 10/0;
        return result;
    }

Transactional參數(shù)說明

propagation

事務(wù)的傳播行為，默認(rèn)為Propagation.REQUIRED

isolation

Spring有5種隔離級別，MySQL有四種隔離級別，Spring多了一個DEFAULT，以連接的數(shù)據(jù)庫的事務(wù)隔離級別為主

timeout

表示事務(wù)的超時時間，默認(rèn)值為-1，如果事務(wù)執(zhí)行時間超過超時時間，就會自動回滾

事務(wù)回滾失效解決方案

直接拋出異常

    @Transactional(propagation = Propagation.REQUIRED) // 開啟事務(wù)
    @RequestMapping("/insert2")
    public int insert2(){
        UserInfo userInfo = new UserInfo();
        userInfo.setName("AOP");
        userInfo.setPassword("123456");
        int result = userService.add(userInfo);
        System.out.println("MySQL影響的行數(shù)："+result);
        try {
            int num = 10/0;
        }catch (Exception e){
            result = 0;
            e.printStackTrace();
            throw e;//解決事務(wù)失效的問題
           // TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
        }
        return result;
    }

在catch中使用代碼手動進(jìn)行事務(wù)的回滾操作

      @Transactional(propagation = Propagation.REQUIRED) // 開啟事務(wù)
    @RequestMapping("/insert2")
    public int insert2(){
        UserInfo userInfo = new UserInfo();
        userInfo.setName("AOP");
        userInfo.setPassword("123456");
        int result = userService.add(userInfo);
        System.out.println("MySQL影響的行數(shù)："+result);
        try {
            int num = 10/0;
        }catch (Exception e){
            result = 0;
            e.printStackTrace();
            //throw e;//解決事務(wù)失效的問題
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
        }
        return result;
    }

@Transactional工作原理

@Transactional是基于AOP實(shí)現(xiàn)的，AOP又是使用動態(tài)代理實(shí)現(xiàn)的。如果目標(biāo)對象實(shí)現(xiàn)了接口，默認(rèn)情況下會采用JDK的動態(tài)代理，如果目標(biāo)對象沒有實(shí)現(xiàn)了接口，會使用CGLIB動態(tài)代理。

@Transactional在開始執(zhí)行業(yè)務(wù)之前，通過代理先開啟事務(wù)，在執(zhí)行成功之后再提交事務(wù)。如果中途遇到了異常，則回滾事務(wù)。