Spring 中的事務傳播行爲

能夠搜索微信公衆號【Jet 與編程】查看更多精彩文章java


背景介紹

Spring 框架應該是每個人 javaer 都必須接觸和學習的技術,Spring 公司所提供的各類框架是 Java 開發行業可參考的重要標準之一。mysql

Spring 中有 7 種類型的事務傳播行爲。事務傳播行爲是 Spring 框架提供的一種事務管理方式,它是 Spring 框架之中很是重要的一個技術點,畢竟事務關係到應用程序和數據庫的交互,而數據更是互聯網行業最爲重要的資源。git

平時開發過程當中事務都會有使用,可是沒有真正地總結過,尤爲是事務中嵌套事務的場景,此篇基礎知識文在此作一個簡單的學習總結,github

事務

事務的特徵

特性 說明
原子性 一個事務中全部對數據庫的操做是一個不可分割的操做序列,要麼全作要麼全不作
一致性 數據不會由於事務的執行而遭到破壞
隔離性 一個事物的執行,不受其餘事務的干擾,即併發執行的事物之間互不干擾
持久性 一個事物一旦提交,它對數據庫的改變就是永久的

事務的隔離級別

隔離級別 說明
read_uncommitted 讀未提交,一個事務能夠感知或者操做另一個未提交的事務,可能會出現髒讀、不可重複讀、幻讀
read_committed 讀已提交,一個事務只能感知或者操做另外一個已經提交的事務,可能會出現不可重複讀、幻讀
repeatable_read 可重複讀,可以避免髒讀,不可重複讀,不能避免幻讀
serializable 串行化,隔離級別最高,消耗資源最低,代價最高,可以防止髒讀, 不可重複讀,幻讀。

mysql 默認的事務隔離級別是 repeatable_readspring

Spring 事務的傳播行爲

傳播行爲 說明
Propagation.REQUIRED(默認) 若是當前存在事務,則加入該事務,若是當前不存在事務,則建立一個新的事務。
② Propagation.SUPPORTS 若是當前存在事務,則加入該事務;若是當前不存在事務,則以非事務的方式繼續運行。
③ Propagation.MANDATORY 若是當前存在事務,則加入該事務;若是當前不存在事務,則拋出異常。
Propagation.REQUIRES_NEW 從新建立一個新的事務,若是當前存在事務,延緩當前的事務。
⑤ Propagation.NOT_SUPPORTED 以非事務的方式運行,若是當前存在事務,暫停當前的事務。
⑥ Propagation.NEVER 以非事務的方式運行,若是當前存在事務,則拋出異常。
Propagation.NESTED 若是沒有,就新建一個事務;若是有,就在當前事務中嵌套其餘事務。

代碼演示

準備動做:新建一個 spring 項目,數據庫腳本見:sql

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
-- Table structure for customer
-- ----------------------------
DROP TABLE IF EXISTS `customer`;
CREATE TABLE `customer` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(255) COLLATE utf8mb4_bin DEFAULT NULL,
  `remark` varchar(255) COLLATE utf8mb4_bin DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin;

-- ----------------------------
-- Records of customer
-- ----------------------------
BEGIN;
INSERT INTO `customer` VALUES (1, 'A', 'a');
INSERT INTO `customer` VALUES (2, 'B', 'b');
INSERT INTO `customer` VALUES (3, 'C', 'c');
COMMIT;

SET FOREIGN_KEY_CHECKS = 1;
複製代碼

測試步驟爲:方法 A 中調用方法 B 和 方法 C,三個方法各自操做數據庫中的一條數據,而後方法 A、B、C 組合添加事務 僞代碼爲:數據庫

function A(){ // 方法 A
    functionB(); // 方法 B
    functionC(); // 方法 C
}
複製代碼

Propagation.REQUIRED(默認)

  • 步驟:
@Transactional
function A(){ // 有事務
    functionB(); // 無事務,代碼正常
    functionC(); // 無事務,代碼拋異常
}
複製代碼
  • 結果: 數據庫中無數據編程

  • 說明: 方法 B 和方法 C 雖然沒有本身的事務,可是外層的方法 A 是有事務的,因爲默認的事務傳播機制,因此方法 B 和 C 都加入到了 A 的事務之中,因此當 C 報錯時,B 也隨着回滾了。bash

② Propagation.SUPPORTS

  • 步驟:
function A(){ // 無事務
    functionB(); // 有事務,代碼正常,事務爲:@Transactional(propagation = Propagation.SUPPORTS)
    functionC(); // 有事務,代碼拋異常,事務爲:@Transactional(propagation = Propagation.SUPPORTS)
}
複製代碼
  • 結果: 數據庫中有兩條數據微信

  • 說明: Propagation.SUPPORTS 的意思是當前有事務則加入,沒有則不添加事務,因此,因爲 A 是沒有事務的,那麼 B 和 C 天然而然也就不加入事務中,而 C 中的報錯了,那麼天然而然也就不會進行數據回滾。

③ Propagation.MANDATORY

  • 步驟:
function A(){ // 無事務
    functionB(); // 有事務,代碼正常,事務爲:@Transactional(propagation = Propagation.MANDATORY)
    functionC(); // 有事務,代碼拋異常,事務爲:@Transactional(propagation = Propagation.SUPPORTS)
}
複製代碼
  • 結果: 不只數據庫中無數據,並且運行時報錯: org.springframework.transaction.IllegalTransactionStateException: No existing transaction found for transaction marked with propagation 'mandatory'

  • 說明: Propagation.MANDATORY 的意思是當前有事務則加入,沒有事務則拋出異常。因此上述代碼在運行時拋出了 IllegalTransactionStateException 異常。

Propagation.REQUIRES_NEW

  • 步驟:
function A(){ // 有事務
    insert one data;
    
    functionB(); // 有事務,代碼正常,事務爲:@Transactional(propagation = Propagation.REQUIRES_NEW)
    functionC(); // 有事務,代碼拋異常,事務爲:@Transactional(propagation = Propagation.REQUIRES_NEW)
}
複製代碼
  • 結果: 數據庫中僅有方法 B 的一條數據。

  • 說明: Propagation.REQUIRES_NEW 的意思是從新建立一個新的事務,若是當前存在事務,延緩當前的事務。 這個理解起來有點拗。結合上述代碼案例來看,首先 B 和 C 都是有各自的事務的,因此在 C 拋出異常後,C 會回滾,而 B 則會正常插入一條數據,畢竟二者的事務的獨立的,可是此時 A 也是有事務的,而且 A 的事務是在 B 和 C 以後再執行的,因此當 C 拋出異常以後,A 天然而然也就捕獲到了,那麼 A 的事務也會回滾,因此數據庫中 A 插入的數據也被回滾掉了。

⑤ Propagation.NOT_SUPPORTED

  • 步驟:
function A(){ // 有事務
    functionB(); // 無事務,代碼正常,添加註解:@Transactional(propagation = Propagation.NOT_SUPPORTED)
    functionC(); // 無事務,代碼拋異常,添加註解:@Transactional(propagation = Propagation.NOT_SUPPORTED)
}
複製代碼
  • 結果: 數據庫中有 B 和 C 兩條數據。

  • 說明: Propagation.NOT_SUPPORTED 的意思是當前代碼以非事務的方式運行,就算有事務,而已暫停當前事務。 結合上面的僞代碼來看,雖然 A 是有事務的,可是 B 和 c 的註解爲 NOT_SUPPORTED,意思是我這個方法是不須要加入事務中的,因此 B 和 C 是沒有加入 A 的事務中去的,因此哪怕 B 拋出異常,因爲不參會事務,因此 B 和 C 的數據都是不會回滾的,因此數據庫中就會有 B 和 C 兩條數據。

⑥ Propagation.NEVER

  • 步驟:
function A(){ // 有事務
    functionB(); // 無事務,代碼正常,添加註解:@Transactional(propagation = Propagation.NEVER)
    functionC(); // 無事務,代碼拋異常,添加註解:@Transactional(propagation = Propagation.NEVER)
}
複製代碼
  • 結果: 數據庫中無數據,而且運行時報錯 org.springframework.transaction.IllegalTransactionStateException: Existing transaction found for transaction marked with propagation 'never'

  • 說明: Propagation.NEVER 的意思是以非事務的方式去運行,若是有事務,則拋出異常。 上述僞代碼中,A 是有事務的,可是 B 和 C 添加了 NEVER 的事務,意思是別給我加事務,我拒絕,你要是給我加了事務我就給你拋異常。

Propagation.NESTED

  • 步驟:
function A(){ // 有事務
    insert one data;
    
    functionB(); // 有事務,代碼正常,事務爲:@Transactional(propagation = Propagation.NESTED)
    functionC(); // 有事務,代碼拋異常,事務爲:@Transactional(propagation = Propagation.NESTED)
    
    throw exception;
}
複製代碼
  • 結果: 結果就是沒有結果,由於 JPA 是不支持這種循環嵌套事務的,因此在運行的時候就會拋出異常: org.springframework.transaction.NestedTransactionNotSupportedException: JpaDialect does not support savepoints - check your JPA provider's capabilities

  • 說明: Propagation.NESTED 的意思是若是外層沒有事務,則內層會添加一個,而若是外層有事務,則內層會嵌套一層事務,即內層是有兩層事務的。

其餘

demo 的源碼見:【GitHub 地址

image
相關文章
相關標籤/搜索