spring-transaction源碼分析(1)概述和事務傳播級別

来源:https://www.cnblogs.com/xugf/archive/2023/05/06/17376508.html
-Advertisement-
Play Games

spring-tx概述 spring-tx包使用註解驅動和AOP通知將事務開啟、提交/回滾、以及複雜的傳播機制封裝了起來，開發者不再需要編寫事務管理的代碼，而是可以只關註自己的業務邏輯。 本文將簡單介紹spring-tx使用步驟以及七種事務傳播級別。 後續文章會閱讀源碼，深入分析spring-tx ...


spring-tx概述

spring-tx包使用註解驅動和AOP通知將事務開啟、提交/回滾、以及複雜的傳播機制封裝了起來，開發者不再需要編寫事務管理的代碼，而是可以只關註自己的業務邏輯。

本文將簡單介紹spring-tx使用步驟以及七種事務傳播級別。

後續文章會閱讀源碼，深入分析spring-tx aop通知、七種事務傳播級別以及事務開啟/提交/回滾的實現方式。

使用步驟

  1. 導入spring-tx依賴
  2. 使用@EnableTransactionManagement註解為應用開啟事務支持
  3. 向spring容器註入一個TransactionManager實現，一般使用DataSourceTransactionManager類
  4. 在需要事務的業務方法上標註@Transactional註解即可為方法開啟事務通知

Transactional註解參數

  • transactionManager - 手動指定要使用的事務管理器
  • propagation - 事務傳播級別
  • isolation - 事務隔離級別
  • timeout - 事務超時時長
  • rollbackFor - 發生指定的異常時回滾事務

事務傳播級別

七種級別

  • REQUIRED - Support a current transaction, create a new one if none exists. 支持當前存在的事務，如果當前沒有事務，則新創建一個。預設的傳播級別。

  • SUPPORTS - Support a current transaction, execute non-transactionally if none exists. 支持當前存在的事務，如果當前沒有事務，則在無事務狀態下運行。

    For transaction managers with transaction synchronization, SUPPORTS is slightly different from 
no transaction at all, as it defines a transaction scope that synchronization will apply for.
As a consequence, the same resources (JDBC Connection, Hibernate Session, etc) will be shared 
for the entire specified scope. Note that this depends on the actual synchronization configuration 
of the transaction manager.

  • MANDATORY - Support a current transaction, throw an exception if none exists. 支持當前存在的事務，如果當前沒有事務，則拋出異常。

  • REQUIRES_NEW - Create a new transaction, and suspend the current transaction if one exists. 創建新事務，如果當前已存在事務則掛起這個事務，再創建新事務。

  • NOT_SUPPORTED - Execute non-transactionally, suspend the current transaction if one exists. 在無事務狀態下運行，如果當前已存在事務則掛起這個事務。

  • NEVER - Execute non-transactionally, throw an exception if a transaction exists. 在無事務狀態下運行，如果當前已存在事務，則拋出異常。

  • NESTED - Execute within a nested transaction if a current transaction exists, behave like REQUIRED otherwise. 如果當前已存在事務，則嵌入到當前事務中運行，否則和REQUIRED效果一樣。

示例方法

在測試事務傳播級別的示例中，會反覆使用以下6個方法，只是給Transactional添加的參數不同而已，此處記錄一下這幾個方法：

public void insertBlogList(List<Blog> blogList) {
  for (int i = 0; i < blogList.size(); i++) {
    this.blogMapper.insertBlog(blogList.get(i));
  }
}

public void deleteBlogByCondition(BlogSearchParameter parameter) {
  List<Blog> blogs = this.blogMapper.selectBlogByParameter(parameter);
  for (Blog blog : blogs) {
    this.blogMapper.deleteBlog(blog.getId());
  }
  // 拋出一個RuntimeException
  throw new RuntimeException("deleteBlogByCondition拋出一個異常");
}

public void insertAndDeleteBlogList1(List<Blog> blogList, BlogSearchParameter parameter) {

  // 這裡從spring容器獲取service對象，避免事務失效
  BlogRequiredTxService blogService =
      this.applicationContext.getBean(BlogRequiredTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  blogService.deleteBlogByCondition(parameter);
}

public void insertAndDeleteBlogList2(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogRequiredTxService blogService =
      this.applicationContext.getBean(BlogRequiredTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  try {
    blogService.deleteBlogByCondition(parameter);
  } catch (Exception e) {
    System.err.printf("Err:%s%n", e.getMessage());
  }

  System.out.println("繼續插入數據");

  // 繼續插入數據
  blogService.insertBlogList(blogList);
}

public void insertAndDeleteBlogList3(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogRequiredTxService blogService =
      this.applicationContext.getBean(BlogRequiredTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  blogService.deleteBlogByCondition(parameter);
}

public void insertAndDeleteBlogList4(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogRequiredTxService blogService =
      this.applicationContext.getBean(BlogRequiredTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  try {
    blogService.deleteBlogByCondition(parameter);
  } catch (Exception e) {
    System.err.printf("Err:%s%n", e.getMessage());
  }

  System.out.println("繼續插入數據");

  // 繼續插入數據
  blogService.insertBlogList(blogList);
}

傳播級別詳細說明

REQUIRED

Support a current transaction, create a new one if none exists.

支持當前存在的事務，如果當前沒有事務，則新創建一個。預設的傳播級別。

@Transactional(propagation = Propagation.REQUIRED)
public void insertBlogList(List<Blog> blogList) {
  for (int i = 0; i < blogList.size(); i++) {
    this.blogMapper.insertBlog(blogList.get(i));
  }
}

@Transactional(propagation = Propagation.REQUIRED)
public void deleteBlogByCondition(BlogSearchParameter parameter) {
  List<Blog> blogs = this.blogMapper.selectBlogByParameter(parameter);
  for (Blog blog : blogs) {
    this.blogMapper.deleteBlog(blog.getId());
  }
  // 拋出一個RuntimeException
  throw new RuntimeException("deleteBlogByCondition拋出一個異常");

  // 如果調用方法前，沒有事務，則delete操作都會回滾
  // 如果調用方法前，已經存在事務，則之前的事務操作都會回滾
}

@Transactional(propagation = Propagation.REQUIRED)
public void insertAndDeleteBlogList1(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogRequiredTxService blogService =
      this.applicationContext.getBean(BlogRequiredTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  blogService.deleteBlogByCondition(parameter);

  // deleteBlogByCondition方法拋出異常之後，則insertAndDeleteBlogList1方法的操作會回滾
  // 如果insertAndDeleteBlogList1方法在另一個事務中，則之前的事務操作都會回滾
}

@Transactional(propagation = Propagation.REQUIRED)
public void insertAndDeleteBlogList2(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogRequiredTxService blogService =
      this.applicationContext.getBean(BlogRequiredTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  try {
    blogService.deleteBlogByCondition(parameter);
  } catch (Exception e) {
    System.err.printf("Err:%s%n", e.getMessage());
  }

  System.out.println("繼續插入數據");

  // 繼續插入數據
  blogService.insertBlogList(blogList);

  // deleteBlogByCondition方法拋出異常之後，會執行catch代碼塊，之後繼續向下執行，
  // 執行blogService.insertBlogList(blogList)方法之後，
  // 在commit的時候檢測到insertAndDeleteBlogList2方法rollback-only狀態，會拋出異常:
  // org.springframework.transaction.UnexpectedRollbackException: 
  // Transaction rolled back because it has been marked as rollback-only
}

public void insertAndDeleteBlogList3(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogRequiredTxService blogService =
      this.applicationContext.getBean(BlogRequiredTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  blogService.deleteBlogByCondition(parameter);

  // 由於insertAndDeleteBlogList3方法沒有標註Transactional註解:
  // blogService.insertBlogList(blogList)方法插入的數據會提交保存下來
  // blogService.deleteBlogByCondition(parameter)方法的刪除操作會回滾
}

public void insertAndDeleteBlogList4(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogRequiredTxService blogService =
      this.applicationContext.getBean(BlogRequiredTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  try {
    blogService.deleteBlogByCondition(parameter);
  } catch (Exception e) {
    System.err.printf("Err:%s%n", e.getMessage());
  }

  System.out.println("繼續插入數據");

  // 繼續插入數據
  blogService.insertBlogList(blogList);

  // 由於insertAndDeleteBlogList3方法沒有標註Transactional註解:
  // blogService.insertBlogList(blogList)方法插入的數據會提交保存下來
  // blogService.deleteBlogByCondition(parameter)方法的刪除操作會回滾
  // 之後會繼續執行blogService.insertBlogList(blogList)再插入數據
}

REQUIRES_NEW

Create a new transaction, and suspend the current transaction if one exists.

創建新事務，如果當前已存在事務則掛起這個事務，再打開一個新的資料庫連接創建新事務。

@Transactional(propagation = Propagation.REQUIRES_NEW)
public void insertBlogList(List<Blog> blogList) {
  for (Blog blog : blogList) {
    this.blogMapper.insertBlog(blog);
  }
  try {
    TimeUnit.SECONDS.sleep(15);
  } catch (InterruptedException e) {
    e.printStackTrace();
  }
}

@Transactional(propagation = Propagation.REQUIRES_NEW)
public void deleteBlogByCondition(BlogSearchParameter parameter) {
  List<Blog> blogs = this.blogMapper.selectBlogByParameter(parameter);
  for (Blog blog : blogs) {
    this.blogMapper.deleteBlog(blog.getId());
  }
  // 拋出一個RuntimeException
  throw new RuntimeException("deleteBlogByCondition拋出一個異常");

  // 只會回滾delete操作，因為該方法是新創建的事務
}

@Transactional
public void insertAndDeleteBlogList1(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogRequiresNewTxService blogService =
      this.applicationContext.getBean(BlogRequiresNewTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  blogService.deleteBlogByCondition(parameter);

  // blogService.insertBlogList(blogList)成功
  // blogService.deleteBlogByCondition(parameter)會回滾
  // 同時insertAndDeleteBlogList1中的事務也會回滾

  // 如果使用show processlist查看客戶端進程，
  // 可以看到insertBlogList和deleteBlogByCondition方法創建了新的資料庫連接
}

@Transactional
public void insertAndDeleteBlogList2(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogRequiresNewTxService blogService =
      this.applicationContext.getBean(BlogRequiresNewTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  try {
    blogService.deleteBlogByCondition(parameter);
  } catch (Exception e) {
    System.err.printf("Err:%s%n", e.getMessage());
  }

  System.out.println("繼續插入數據");

  // 繼續插入數據
  blogService.insertBlogList(blogList);

  // blogService.insertBlogList(blogList)成功
  // blogService.deleteBlogByCondition(parameter)會回滾
  // 此時insertAndDeleteBlogList1中的事務不會回滾，因為deleteBlogByCondition(parameter)的異常被"吞掉了"
  // 後續的blogService.insertBlogList(blogList)也會成功
}

public void insertAndDeleteBlogList3(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogRequiresNewTxService blogService =
      this.applicationContext.getBean(BlogRequiresNewTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  blogService.deleteBlogByCondition(parameter);

  // blogService.insertBlogList(blogList)成功
  // blogService.deleteBlogByCondition(parameter)會回滾
}

public void insertAndDeleteBlogList4(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogRequiresNewTxService blogService =
      this.applicationContext.getBean(BlogRequiresNewTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  try {
    blogService.deleteBlogByCondition(parameter);
  } catch (Exception e) {
    System.err.printf("Err:%s%n", e.getMessage());
  }

  System.out.println("繼續插入數據");

  // 繼續插入數據
  blogService.insertBlogList(blogList);

  // blogService.insertBlogList(blogList)成功
  // blogService.deleteBlogByCondition(parameter)會回滾
  // 後續的blogService.insertBlogList(blogList)也會成功
}

MANDATORY

Support a current transaction, throw an exception if none exists.

支持當前存在的事務，如果當前沒有事務，則拋出異常。

@Transactional(propagation = Propagation.MANDATORY)
public void insertBlogList(List<Blog> blogList) {
  for (Blog blog : blogList) {
    this.blogMapper.insertBlog(blog);
  }

  // 單獨調用此方法時拋錯:
  // org.springframework.transaction.IllegalTransactionStateException:
  // No existing transaction found for transaction marked with propagation 'mandatory'
}

@Transactional(propagation = Propagation.MANDATORY)
public void deleteBlogByCondition(BlogSearchParameter parameter) {
  List<Blog> blogs = this.blogMapper.selectBlogByParameter(parameter);
  for (Blog blog : blogs) {
    this.blogMapper.deleteBlog(blog.getId());
  }
  // 拋出一個RuntimeException
  throw new RuntimeException("deleteBlogByCondition拋出一個異常");

  // 單獨調用此方法時拋錯:
  // org.springframework.transaction.IllegalTransactionStateException:
  // No existing transaction found for transaction marked with propagation 'mandatory'
}

@Transactional
public void insertAndDeleteBlogList1(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogMandatoryTxService blogService =
      this.applicationContext.getBean(BlogMandatoryTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  blogService.deleteBlogByCondition(parameter);

  // deleteBlogByCondition方法拋出異常之後，則insertAndDeleteBlogList1方法的操作會回滾
  // 如果insertAndDeleteBlogList1方法在另一個事務中，則之前的事務操作都會回滾
}

@Transactional
public void insertAndDeleteBlogList2(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogMandatoryTxService blogService =
      this.applicationContext.getBean(BlogMandatoryTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  try {
    blogService.deleteBlogByCondition(parameter);
  } catch (Exception e) {
    System.err.printf("Err:%s%n", e.getMessage());
  }

  System.out.println("繼續插入數據");

  // 繼續插入數據
  blogService.insertBlogList(blogList);

  // deleteBlogByCondition方法拋出異常之後，會執行catch代碼塊，之後繼續向下執行，
  // 執行blogService.insertBlogList(blogList)方法之後，
  // 在commit的時候檢測到insertAndDeleteBlogList2方法rollback-only狀態，會拋出異常:
  // org.springframework.transaction.UnexpectedRollbackException: 
  // Transaction rolled back because it has been marked as rollback-only
}

public void insertAndDeleteBlogList3(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogMandatoryTxService blogService =
      this.applicationContext.getBean(BlogMandatoryTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  blogService.deleteBlogByCondition(parameter);

  // 拋錯:
  // org.springframework.transaction.IllegalTransactionStateException:
  // No existing transaction found for transaction marked with propagation 'mandatory'
}

public void insertAndDeleteBlogList4(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogMandatoryTxService blogService =
      this.applicationContext.getBean(BlogMandatoryTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  try {
    blogService.deleteBlogByCondition(parameter);
  } catch (Exception e) {
    System.err.printf("Err:%s%n", e.getMessage());
  }

  System.out.println("繼續插入數據");

  // 繼續插入數據
  blogService.insertBlogList(blogList);

  // 拋錯:
  // org.springframework.transaction.IllegalTransactionStateException:
  // No existing transaction found for transaction marked with propagation 'mandatory'
}

SUPPORTS

Support a current transaction, execute non-transactionally if none exists.

支持當前存在的事務，如果當前沒有事務，則在無事務狀態下運行。

@Transactional(propagation = Propagation.SUPPORTS)
public void insertBlogList(List<Blog> blogList) {
  for (Blog blog : blogList) {
    this.blogMapper.insertBlog(blog);
  }
}

@Transactional(propagation = Propagation.SUPPORTS)
public void deleteBlogByCondition(BlogSearchParameter parameter) {
  List<Blog> blogs = this.blogMapper.selectBlogByParameter(parameter);
  for (Blog blog : blogs) {
    this.blogMapper.deleteBlog(blog.getId());
  }
  // 拋出一個RuntimeException
  throw new RuntimeException("deleteBlogByCondition拋出一個異常");

  // 單獨調用時刪除操作成功，因為沒有事務
  // 如果在一個事務中執行該方法，則會回滾
}

@Transactional
public void insertAndDeleteBlogList1(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogSupportsTxService blogService =
      this.applicationContext.getBean(BlogSupportsTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  blogService.deleteBlogByCondition(parameter);

  // deleteBlogByCondition方法拋出異常之後，則insertAndDeleteBlogList1方法的操作會回滾
  // 如果insertAndDeleteBlogList1方法在另一個事務中，則之前的事務操作都會回滾
}

@Transactional
public void insertAndDeleteBlogList2(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogSupportsTxService blogService =
      this.applicationContext.getBean(BlogSupportsTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  try {
    blogService.deleteBlogByCondition(parameter);
  } catch (Exception e) {
    System.err.printf("Err:%s%n", e.getMessage());
  }

  System.out.println("繼續插入數據");

  // 繼續插入數據
  blogService.insertBlogList(blogList);

  // deleteBlogByCondition方法拋出異常之後，會執行catch代碼塊，之後繼續向下執行，
  // 執行blogService.insertBlogList(blogList)方法之後，
  // 在commit的時候檢測到insertAndDeleteBlogList2方法rollback-only狀態，會拋出異常:
  // org.springframework.transaction.UnexpectedRollbackException: 
  // Transaction rolled back because it has been marked as rollback-only
}

public void insertAndDeleteBlogList3(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogSupportsTxService blogService =
      this.applicationContext.getBean(BlogSupportsTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  blogService.deleteBlogByCondition(parameter);

  // 由於insertAndDeleteBlogList3方法沒有開啟事務
  // 插入和刪除都會成功，但是deleteBlogByCondition(parameter)還是會拋出異常
}

public void insertAndDeleteBlogList4(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogSupportsTxService blogService =
      this.applicationContext.getBean(BlogSupportsTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  try {
    blogService.deleteBlogByCondition(parameter);
  } catch (Exception e) {
    System.err.printf("Err:%s%n", e.getMessage());
  }

  System.out.println("繼續插入數據");

  // 繼續插入數據
  blogService.insertBlogList(blogList);

  // 由於insertAndDeleteBlogList4方法沒有開啟事務
  // 插入和刪除都會成功
}

NOT_SUPPORTED

Execute non-transactionally, suspend the current transaction if one exists.

在無事務狀態下運行，如果當前已存在事務則掛起這個事務。

@Transactional
public void insertBlogList(List<Blog> blogList) {
  for (Blog blog : blogList) {
    this.blogMapper.insertBlog(blog);
  }
}

@Transactional(propagation = Propagation.NOT_SUPPORTED)
public void deleteBlogByCondition(BlogSearchParameter parameter) {
  List<Blog> blogs = this.blogMapper.selectBlogByParameter(parameter);
  for (Blog blog : blogs) {
    this.blogMapper.deleteBlog(blog.getId());
  }
  // 拋出一個RuntimeException
  throw new RuntimeException("deleteBlogByCondition拋出一個異常");

  // 刪除操作始終都會成功，但還是會拋出異常
}

@Transactional
public void insertAndDeleteBlogList1(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogNotSupportedTxService blogService =
      this.applicationContext.getBean(BlogNotSupportedTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  blogService.deleteBlogByCondition(parameter);

  // blogService.deleteBlogByCondition(parameter)的刪除操作成功
  // deleteBlogByCondition方法拋出異常之後，則insertAndDeleteBlogList1方法的操作會回滾
  // 如果insertAndDeleteBlogList1方法在另一個事務中，則之前的事務操作都會回滾
}

@Transactional
public void insertAndDeleteBlogList2(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogNotSupportedTxService blogService =
      this.applicationContext.getBean(BlogNotSupportedTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  try {
    blogService.deleteBlogByCondition(parameter);
  } catch (Exception e) {
    System.err.printf("Err:%s%n", e.getMessage());
  }

  System.out.println("繼續插入數據");

  // 繼續插入數據
  blogService.insertBlogList(blogList);

  // 插入數據和刪除操作都會成功
}

public void insertAndDeleteBlogList3(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogNotSupportedTxService blogService =
      this.applicationContext.getBean(BlogNotSupportedTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  blogService.deleteBlogByCondition(parameter);

  // 插入數據和刪除操作都會成功
  // 但是會拋出異常
}

public void insertAndDeleteBlogList4(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogNotSupportedTxService blogService =
      this.applicationContext.getBean(BlogNotSupportedTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  try {
    blogService.deleteBlogByCondition(parameter);
  } catch (Exception e) {
    System.err.printf("Err:%s%n", e.getMessage());
  }

  System.out.println("繼續插入數據");

  // 繼續插入數據
  blogService.insertBlogList(blogList);

  // 插入數據和刪除操作都會成功
}

NEVER

Execute non-transactionally, throw an exception if a transaction exists.在無事務狀態下運行，如果當前已存在事務，則拋出異常。

@Transactional
public void insertBlogList(List<Blog> blogList) {
  for (Blog blog : blogList) {
    this.blogMapper.insertBlog(blog);
  }
}

@Transactional(propagation = Propagation.NEVER)
public void deleteBlogByCondition(BlogSearchParameter parameter) {
  List<Blog> blogs = this.blogMapper.selectBlogByParameter(parameter);
  for (Blog blog : blogs) {
    this.blogMapper.deleteBlog(blog.getId());
  }
  // 拋出一個RuntimeException
  throw new RuntimeException("deleteBlogByCondition拋出一個異常");
}

@Transactional
public void insertAndDeleteBlogList1(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogNeverTxService blogService =
      this.applicationContext.getBean(BlogNeverTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  blogService.deleteBlogByCondition(parameter);

  // 插入數據操作回滾
  // 因為blogService.deleteBlogByCondition(parameter)檢查到存在事務會拋出異常:
  // org.springframework.transaction.IllegalTransactionStateException:
  // Existing transaction found for transaction marked with propagation 'never'
}

@Transactional
public void insertAndDeleteBlogList2(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogNeverTxService blogService =
      this.applicationContext.getBean(BlogNeverTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  try {
    blogService.deleteBlogByCondition(parameter);
  } catch (Exception e) {
    System.err.printf("Err:%s%n", e.getMessage());
  }

  System.out.println("繼續插入數據");

  // 繼續插入數據
  blogService.insertBlogList(blogList);

  // 兩次插入操作會成功
  // 但是刪除操作失敗，因為blogService.deleteBlogByCondition(parameter)檢查到存在事務會拋出異常:
  // org.springframework.transaction.IllegalTransactionStateException:
  // Existing transaction found for transaction marked with propagation 'never'
}

public void insertAndDeleteBlogList3(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogNeverTxService blogService =
      this.applicationContext.getBean(BlogNeverTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  blogService.deleteBlogByCondition(parameter);

  // 插入和刪除都成功
  // 但是會拋出異常
}

public void insertAndDeleteBlogList4(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogNeverTxService blogService =
      this.applicationContext.getBean(BlogNeverTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  try {
    blogService.deleteBlogByCondition(parameter);
  } catch (Exception e) {
    System.err.printf("Err:%s%n", e.getMessage());
  }

  System.out.println("繼續插入數據");

  // 繼續插入數據
  blogService.insertBlogList(blogList);

  // 插入和刪除都成功
}

NESTED

Execute within a nested transaction if a current transaction exists, behave like REQUIRED otherwise.

如果當前已存在事務，則嵌入到當前事務中運行，否則和REQUIRED效果一樣。

@Transactional(propagation = Propagation.NESTED)
public void insertBlogList(List<Blog> blogList) {
  for (Blog blog : blogList) {
    this.blogMapper.insertBlog(blog);
  }
}

@Transactional(propagation = Propagation.NESTED)
public void deleteBlogByCondition(BlogSearchParameter parameter) {
  List<Blog> blogs = this.blogMapper.selectBlogByParameter(parameter);
  for (Blog blog : blogs) {
    this.blogMapper.deleteBlog(blog.getId());
  }
  // 拋出一個RuntimeException
  throw new RuntimeException("deleteBlogByCondition拋出一個異常");
}

@Transactional
public void insertAndDeleteBlogList1(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogNestedTxService blogService =
      this.applicationContext.getBean(BlogNestedTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  blogService.deleteBlogByCondition(parameter);

  // 所有操作都會回滾
}

@Transactional
public void insertAndDeleteBlogList2(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogNestedTxService blogService =
      this.applicationContext.getBean(BlogNestedTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  try {
    blogService.deleteBlogByCondition(parameter);
  } catch (Exception e) {
    System.err.printf("Err:%s%n", e.getMessage());
  }

  System.out.println("繼續插入數據");

  // 繼續插入數據
  blogService.insertBlogList(blogList);

  // 前後兩次插入操作成功，
  // 中間的刪除操作因為拋出異常，會回滾，
  // 又因為blogService.deleteBlogByCondition(parameter)的異常被try...catch了，
  // 沒有拋到insertAndDeleteBlogList2中，所以insertAndDeleteBlogList2的操作可以成功提交
}

public void insertAndDeleteBlogList3(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogNestedTxService blogService =
      this.applicationContext.getBean(BlogNestedTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  blogService.deleteBlogByCondition(parameter);

  // 插入成功，刪除回滾
}

public void insertAndDeleteBlogList4(List<Blog> blogList, BlogSearchParameter parameter) {

  BlogNestedTxService blogService =
      this.applicationContext.getBean(BlogNestedTxService.class);

  // 插入數據
  blogService.insertBlogList(blogList);

  // 刪除數據
  try {
    blogService.deleteBlogByCondition(parameter);
  } catch (Exception e) {
    System.err.printf("Err:%s%n", e.getMessage());
  }

  System.out.println("繼續插入數據");

  // 繼續插入數據
  blogService.insertBlogList(blogList);

  // 插入成功，刪除回滾
}

小結

本文通過示例介紹了spring-tx的七種事務傳播級別，後續的文章將閱讀源碼，分析spring-tx的實現方式。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Django筆記三十六之單元測試彙總介紹
    本文首發於公眾號：Hunter後端 原文鏈接：Django筆記三十六之單元測試彙總介紹 Django 的單元測試使用了 Python 的標準庫：unittest。 在我們創建的每一個 application 下麵都有一個 tests.py 文件，我們通過繼承 django.test.TestCase ...
  • 用go設計開發一個自己的輕量級登錄庫/框架吧
    用go設計開發一個自己的輕量級登錄庫/框架吧 幾乎每個項目都會有登錄，退出等用戶功能，而登錄又不單僅僅是登錄，我們要考慮很多東西。 token該怎麼生成？生成什麼樣的？ 是在Cookie存token還是請求頭存token？讀取的時候怎麼讀取？ 允許同一個賬號被多次登錄嗎？多次登錄他們的token是一 ...
  • 2023-5-6第一次創建博客的第一篇文章
    關於最近學習記下來的一些要點以及模糊的地方總結 對象類型和引用類型可以用鏈式結構 2進位是toBinaryString 10進位是Decimal 16進位是toHexString 8進位是octal final 1.修飾類 不能被繼承 2.修飾方法 不能被重寫，能被重載 3.修飾變數 值不可被重新賦 ...
  • 日期與時間【Date/SimpleDateFormat/Calendar】
    視頻鏈接:https://www.bilibili.com/video/BV1Cv411372m?p=121&vd_source=9140dcc493e34a9f4e95ca2f8f71bbd3 1 Data 1.1 Date類概述 Date類的對象在java中代表的是當前所在系統的此刻日期時間。 ...
  • 28基於java的簡單酒店數據管理
    初學java後，需要一個小練手的java web項目，酒店數據信息管理。酒店CRUD項目。基於java的酒店管理，基於vue實現的酒店項目，酒店管理系統。 ...
  • 27基於java的學生線上考試系統
    一、項目簡介 隨著互聯網迅速發展，人們的生活已經越來越離不開互聯網，人們足不出戶就可以工作、學習等。對於在校學生，通過網路教育不僅可以隨時進行網路學習，也可以根據學習的情況自我檢測，有利於學生高效、快捷地掌握所學的知識。 本系統預設計的基於網路的學生自測系統將實現多種用戶（包括學生、教師、管理員）同 ...
  • SpringBoot 自動掃描第三方包及spring.factories失效的問題
    概述(Java doc) 該註解開啟spring的註解驅動事務管理功能，通常標註在@Configuration類上面用於開啟命令式事務管理或響應式事務管理。 @Configuration @EnableTransactionManagement public class AppConfig { @B ...
  • 26基於java的電影院售票管理系統設計
    基於java的電影院售票管理系統設計，電影院管理系統，影院會員，影院售票平臺，電影院會員管理平臺，線上售票平臺 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類