Spring事務簡單小結

時間 2020-07-06

原文原文鏈接

Spring 爲事務管理提供了豐富的功能支持。Spring 事務管理分爲編程式和聲明式的兩種方式。編程式事務指的是經過編碼方式實現事務；聲明式事務基於 AOP,將具體業務邏輯與事務處理解耦。聲明式事務管理使業務代碼邏輯不受污染, 所以在實際使用中聲明式事務用的比較多。聲明式事務有兩種方式，一種是在配置文件（xml）中作相關的事務規則聲明，另外一種是基於 @Transactional 註解的方式。html

須要明確聲明式事物的前提：java

默認配置下Spring只會回滾 運行時異常（繼承自RuntimeException）或 Error；（參考這裏）
@Transactional註解只能應用到public方法纔有效；參考這裏 Method visibility and @Transactional
使用：只需簡單的加上 @Transactional註解便可， spring boot 會自動配置一個 DataSourceTransactionManager，可配置屬性

異常複習：spring

若是不對運行時異常進行捕獲，那麼出現運行時異常後將會終止線程或主程序，此時事物會發生回滾，若是不想終止，可使用catch進行異常捕獲；捕獲後，接下來的代碼將繼續正常執行，事務不發生回滾；

非運行時異常（除RuntimeException之外），如IOException，SQLException等等，必須使用catch進行捕獲，不然程序就沒法經過；由於異常被捕獲，因此沒法發生回滾；sql

事務的傳播級別

經過配置propagation 屬性，能夠選擇事務的傳播行爲數據庫

可選的值有：編程

Propagation.REQUIRED（默認）app

若是當前存在事務，則加入該事務，若是當前不存在事務，則建立一個新的事務。ide

使用示例：spring-boot

@Transactional(propagation = Propagation.REQUIRED)
@Override
public int insertExample(AccompanyRecord accompanyRecord) {
    Student student = new Student();
  
    // myabtis接口
    studentMapper.updateAttention(student);
    accompanyRecordMapper.insertAccompanyRecord(accompanyRecord);
  
    if (true) {
      // 拋異常 回滾
      throw new RuntimeException();
    }
}
複製代碼

以上兩條sql執行完後，又拋出了運行時異常，因此上面兩條sql都會進行回滾；編碼

Propagation.SUPPORTS

若是當前存在事務，則加入該事務；若是當前不存在事務，則以非事務的方式繼續運行。
Propagation.MANDATORY

若是當前存在事務，則加入該事務；若是當前不存在事務，則拋出異常。
Propagation.REQUIRES_NEW

從新建立一個新的事務，若是當前存在事務，暫停當前的事務。
Propagation.NOT_SUPPORTED

以非事務的方式運行，若是當前存在事務，暫停當前的事務。
Propagation.NEVER

以非事務的方式運行，若是當前存在事務，則拋出異常。
Propagation.NESTED

和 Propagation.REQUIRED 效果同樣。

事務使用的注意事項：

在默認的代理模式下，只有目標方法由外部調用，才能被 Spring 的事務攔截器攔截。在同一個類中的兩個方法直接調用，是不會被 Spring 的事務攔截器攔截；【參照Spring官方文檔】

示例：

在有需求以下，就算 save 方法的後面拋異常了，也不能影響 method1 方法的數據插入。直接給 method1 頁加入一個新的事務，這樣 method1 就會在這個新的事務中執行，原來的事務不會影響到新的事務。好比 method1 方法上面再加入註解 @Transactional，設置 propagation 屬性爲 Propagation.REQUIRES_NEW，代碼以下。

@Transactional(propagation = Propagation.REQUIRED)
@Override
public void save() {

    method1();

    User user = new User("服部半藏");
    userMapper.insertSelective(user);

    if (true) {
        throw new RuntimeException("save 拋異常了");
    }
}

@Transactional(propagation = Propagation.REQUIRES_NEW)
public void method1() {
    User user = new User("宮本武藏");
    userMapper.insertSelective(user);
}
複製代碼