トランザクションの伝播

は常に、トランザクションは、困難な点での事業展開であり、数え切れないほどの理論を読んで、常に彼らは良い思い出を持っていると思う、覚えていることができ、個人的に勉強するコードを書きに行かなかった、私はあなたが私と同じであるかどうかわかりません。遅かれ早かれ、ミックスのうち、今夜は意図的にトランザクションの理解と印象を深めるために、実際の生活の方法でトランザクションの伝播特性。実際には、それは同じことですが、究極の心の偽を実践しないでください。私はあなたがこの記事を読んだ後、それはもう一度ノックに従うことが最善であると信じて、その後、誰かが取引の伝播特性についてあなたに尋ねた、あなたは簡単に彼に答えることができるようになります。

トランザクションには4つの特徴があります - ACID、ここでAは原子性を表し、トランザクションが成功するか失敗するかのいずれかを意味します。このアプローチは、トランザクション単体では非常に良いプラクティスですが、バッチタスクの場合、最初の999個のタスクが非常にスムーズで、完璧で、美しく、クールで、成功裏に実行されると、最後の実行時まで、タスクの結果は非常に悲しく、非常に残念な失敗となります。この時、Springはそれまでの999個のタスクに手を振ってこう言います！もしそうなら、それは本当に "虎のように獰猛な操作、元の臼と杵を見るために固定された目 "です。

Springでは、メソッドが別のメソッドを呼び出すときに、トランザクションは、新しいトランザクションや現在のトランザクションをハングアップするなどの動作するように別の戦略を取ることができます：

package org.springframework.transaction.annotation;
import org.springframework.transaction.TransactionDefinition;
public enum Propagation {
 /**
 * トランザクションは必須であり、デフォルトの伝播動作である。，
 * そうでなければ、内側メソッドを実行するために新しいトランザクションを作成する。
 */
 REQUIRED(TransactionDefinition.PROPAGATION_REQUIRED),
 /**
 * トランザクションが存在する場合は、現在のトランザクションが使用される。，
 * 存在しない場合、内側メソッドはトランザクションなしで実行し続ける
 */
 SUPPORTS(TransactionDefinition.PROPAGATION_SUPPORTS),
 /**
 * トランザクションを使用しなければならない。トランザクションがない場合は例外がスローされる。，
 * 現在のトランザクションが存在する場合、現在のトランザクションが使用される。
 */
 MANDATORY(TransactionDefinition.PROPAGATION_MANDATORY),
 /**
 * 現在のトランザクションが存在するかどうかに関係なく、メソッドを実行するために新しいトランザクションを作成する。，
 * これにより、新しいトランザクションは現在のトランザクションから独立して新しいロックや分離レベルなどを持つことができる。
 */
 REQUIRES_NEW(TransactionDefinition.PROPAGATION_REQUIRES_NEW),
 /**
 * トランザクションはサポートされていない。 トランザクションが存在すると、そのトランザクションはハングし、メソッドが実行される。
 */
 NOT_SUPPORTED(TransactionDefinition.PROPAGATION_NOT_SUPPORTED),
 /**
 * 逆に、内側のメソッドがロールバックされた場合、外側のメソッドのコミットには影響しない。
 */
 NEVER(TransactionDefinition.PROPAGATION_NEVER),
 /** 
 * 現在のメソッドが内側のメソッドを呼び出すときに、内側のメソッドで例外が発生した場合，
 * 現在のメソッドのトランザクションではなく、内側のメソッドで実行された SQL のみをロールバックする。
 */
 NESTED(TransactionDefinition.PROPAGATION_NESTED);
 ......
}

つのフォームを用意

//StudentServiceImpl.java
@Transactional(propagation = Propagation.REQUIRED)
public class StudentServiceImpl implements StudentService{
 @Autowired
 private CourseService courseService;
 @Resource
 private StudentMapper studentMapper;
 @Override
 public int insert(Student record) {
 int insert = studentMapper.insert(record);
 courseService.deleteByPrimaryKey(1);
 return insert;
 }
}
// CourseServiceImpl.java
@Transactional(propagation = Propagation.REQUIRED)
@Service
public class CourseServiceImpl implements CourseService{
 public int deleteByPrimaryKey(Integer id) {
 int res = 1 / 0; //内側トランザクションの失敗
 return courseMapper.deleteByPrimaryKey(id);
 }

REQUIRED(共に生き、共に死ぬ)

結論：ロールバックが発生すると、すべてのインターフェイスがロールバックされます。

内部レイヤーの障害シナリオ

//トランザクションの作成
- Creating new transaction with name [com.cxf.data.service.impl.StudentServiceImpl.insert]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT 
 //現在のトランザクションへのデータベース接続を取得する
- Acquired Connection [HikariProxyConnection@2096598149 wrapping com.mysql.cj.jdbc.ConnectionImpl@ebe067d] for JDBC transaction
 //接続を手動コミットに切り替える
 - Switching JDBC Connection [HikariProxyConnection@2096598149 wrapping com.mysql.cj.jdbc.ConnectionImpl@ebe067d] to manual commit
 - ==> Preparing: insert into student (`name`, age) values (?, ?) 
 - ==> Parameters: tanakasan(String), null
 - <== Updates: 1
//現在のトランザクションを追加する
 - Participating in existing transaction
//トランザクションへの参加に失敗し、現在のトランザクションにロールバックのマークを付ける
 - Participating transaction failed - marking existing transaction as rollback-only
 - Setting JDBC transaction [HikariProxyConnection@2096598149 wrapping com.mysql.cj.jdbc.ConnectionImpl@ebe067d] rollback-only
// 
 - Initiating transaction rollback
 - Rolling back JDBC transaction on Connection [HikariProxyConnection@2096598149 wrapping com.mysql.cj.jdbc.ConnectionImpl@ebe067d]
//接続を解放する
 - Releasing JDBC Connection [HikariProxyConnection@2096598149 wrapping com.mysql.cj.jdbc.ConnectionImpl@ebe067d] after transaction

//StudentServiceImpl.java
@Transactional(propagation = Propagation.REQUIRED)
public class StudentServiceImpl implements StudentService{
 @Autowired
 private CourseService courseService;
 @Resource
 private StudentMapper studentMapper;
 @Override
 public int insert(Student record) {
 int insert = studentMapper.insert(record);
 int res = 1 / 0; //外側トランザクションの失敗
 courseService.deleteByPrimaryKey(1);
 return insert;
 }
}
// CourseServiceImpl.java
@Transactional(propagation = Propagation.REQUIRED)
@Service
public class CourseServiceImpl implements CourseService{
 public int deleteByPrimaryKey(Integer id) {
 return courseMapper.deleteByPrimaryKey(id);
 }

外側レイヤーの障害シナリオ

//トランザクションの作成
- Creating new transaction with name [com.cxf.data.service.impl.StudentServiceImpl.insert]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT
HikariPool-1 - Starting...
HikariPool-1 - Start completed.
- Acquired Connection [HikariProxyConnection@2096598149 wrapping com.mysql.cj.jdbc.ConnectionImpl@ebe067d] for JDBC transaction
- Switching JDBC Connection [HikariProxyConnection@2096598149 wrapping com.mysql.cj.jdbc.ConnectionImpl@ebe067d] to manual commit
// 
- Initiating transaction rollback
- Rolling back JDBC transaction on Connection [HikariProxyConnection@2096598149 wrapping com.mysql.cj.jdbc.ConnectionImpl@ebe067d]
- Releasing JDBC Connection [HikariProxyConnection@2096598149 wrapping com.mysql.cj.jdbc.ConnectionImpl@ebe067d] after transaction

ログは以下の通りです。

@Transactional(propagation = Propagation.REQUIRES_NEW)
@Service
public class CourseServiceImpl implements CourseService{
 public int deleteByPrimaryKey(Integer id) {
 int res = 1 / 0;
 return courseMapper.deleteByPrimaryKey(id);
 }

REQUIRES_NEW(は外側レイヤーの影響を受けません)。

内部メソッドの伝播動作が REQUIRES_NEW に設定されている場合、内部メソッドは外部メソッドのトランザクションをハングし、新しいトランザクションをオープンし、内部メソッドの実行が終了すると外部トランザクションをコミットします。

結論

1. 内部ロールバックにより、外部トランザクションもロールバックされます。
2. 外側層のロールバックは内側層のコミットには影響しません。

内部レイヤーの障害シナリオ

//トランザクションの作成
- Creating new transaction with name [com.cxf.data.service.impl.StudentServiceImpl.insert]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT
 HikariPool-1 - Starting...
 HikariPool-1 - Start completed.
 - Acquired Connection [HikariProxyConnection@1700751834 wrapping com.mysql.cj.jdbc.ConnectionImpl@43b5021c] for JDBC transaction
 - Switching JDBC Connection [HikariProxyConnection@1700751834 wrapping com.mysql.cj.jdbc.ConnectionImpl@43b5021c] to manual commit
 //現在のトランザクションを一時停止し、新しいトランザクションを作成する
 - Suspending current transaction, creating new transaction with name [com.cxf.data.service.impl.CourseServiceImpl.deleteByPrimaryKey]
 - Acquired Connection [HikariProxyConnection@1888400144 wrapping com.mysql.cj.jdbc.ConnectionImpl@6ebc9573] for JDBC transaction
 - Switching JDBC Connection [HikariProxyConnection@1888400144 wrapping com.mysql.cj.jdbc.ConnectionImpl@6ebc9573] to manual commit
 // 
 - Initiating transaction rollback
 - Rolling back JDBC transaction on Connection [HikariProxyConnection@1888400144 wrapping com.mysql.cj.jdbc.ConnectionImpl@6ebc9573]
 - Releasing JDBC Connection [HikariProxyConnection@1888400144 wrapping com.mysql.cj.jdbc.ConnectionImpl@6ebc9573] after transaction
//内部トランザクションのロールバック完了後に保留中のトランザクションをウェイクアップする
 - Resuming suspended transaction after completion of inner transaction
//ロールバックの実行
 - Initiating transaction rollback
 - Rolling back JDBC transaction on Connection [HikariProxyConnection@1700751834 wrapping com.mysql.cj.jdbc.ConnectionImpl@43b5021c]
 - Releasing JDBC Connection [HikariProxyConnection@1700751834 wrapping com.mysql.cj.jdbc.ConnectionImpl@43b5021c] after transaction

ログ出力は以下の通りです。

//StudentServiceImpl.java
@Transactional(propagation = Propagation.REQUIRED)
public class StudentServiceImpl implements StudentService{
 @Autowired
 private CourseService courseService;
 @Resource
 private StudentMapper studentMapper;
 @Override
 public int insert(Student record) {
 int insert = studentMapper.insert(record);
 courseService.deleteByPrimaryKey(1);
 int res = 1 / 0; //外側トランザクションの失敗
 return insert;
 }
}
// CourseServiceImpl.java
@Transactional(propagation = Propagation.REQUIRED)
@Service
public class CourseServiceImpl implements CourseService{
 public int deleteByPrimaryKey(Integer id) {
 return courseMapper.deleteByPrimaryKey(id);
 }

外側レイヤーの障害シナリオ

外側のレイヤーが失敗しても、内側のトランザクションのコミットの成功には影響しません。

//トランザクションの作成
- Creating new transaction with name [com.cxf.data.service.impl.StudentServiceImpl.insert]: PROPAGATION_REQUIRES_NEW,ISOLATION_DEFAULT
 - Acquired Connection [HikariProxyConnection@674667952 wrapping com.mysql.cj.jdbc.ConnectionImpl@30893e08] for JDBC transaction
 - Switching JDBC Connection [HikariProxyConnection@674667952 wrapping com.mysql.cj.jdbc.ConnectionImpl@30893e08] to manual commit
 - ==> Preparing: insert into student (`name`, age) values (?, ?) 
 - ==> Parameters: tanakasan(String), null
 - <== Updates: 1
 //現在のトランザクションを一時停止し、新しいトランザクションを作成する。
 - Suspending current transaction, creating new transaction with name [com.cxf.data.service.impl.CourseServiceImpl.deleteByPrimaryKey]
 - Acquired Connection [HikariProxyConnection@1857852787 wrapping com.mysql.cj.jdbc.ConnectionImpl@1e977098] for JDBC transaction
 - Switching JDBC Connection [HikariProxyConnection@1857852787 wrapping com.mysql.cj.jdbc.ConnectionImpl@1e977098] to manual commit
Preparing: delete from course where id = ? 
arameters: 1(Integer)
 Updates: 1
 //内側のトランザクションをコミットする --- 内側の階層が成功し、データベースをチェックしてレコードが正常に削除されたことに注意する。
 - Initiating transaction commit
 - Committing JDBC transaction on Connection [HikariProxyConnection@1857852787 wrapping com.mysql.cj.jdbc.ConnectionImpl@1e977098]
 - Releasing JDBC Connection [HikariProxyConnection@1857852787 wrapping com.mysql.cj.jdbc.ConnectionImpl@1e977098] after transaction
 - Resuming suspended transaction after completion of inner transaction
 //外側トランザクションをロールバックする
 - Initiating transaction rollback
 - Rolling back JDBC transaction on Connection [HikariProxyConnection@674667952 wrapping com.mysql.cj.jdbc.ConnectionImpl@30893e08]
 - Releasing JDBC Connection [HikariProxyConnection@674667952 wrapping com.mysql.cj.jdbc.ConnectionImpl@30893e08] after transaction

ログは以下の通りです。

//StudentServiceImpl.java
@Transactional(propagation = Propagation.REQUIRED)
public class StudentServiceImpl implements StudentService{
 public int insert(Student record) {
 int insert = studentMapper.insert(record);
 courseService.deleteByPrimaryKey(1);
 return insert;
 }
//CourseServiceImpl.java 
@Transactional(propagation = Propagation.NESTED)//トランザクション伝播メカニズムの変更点に注意する
@Service
public class CourseServiceImpl implements CourseService{
 @Override
 public int deleteByPrimaryKey(Integer id) {
 int res = 1 / 0; //インナーレイヤーの失敗
 return courseMapper.deleteByPrimaryKey(id);
 }

NESTED(は内側レイヤーの影響を受けません)。

内部メソッドの伝播動作が NESTED に設定されている場合、内部メソッドは新しいネストされたトランザクションを開きます。

各NESTEDトランザクションは、現在のNESTEDトランザクションの実行が失敗した場合、それは、現在のNESTEDトランザクションの実装の結果は影響を受けないように、ロールバックの内側のメソッドは、それがコミットの外側のメソッドに影響を与えないように、セーブポイントと呼ばれる、現在の操作の実行前に保存されます。

NESTED 外部トランザクションがコミットした後に、トランザクション自身がコミットします。

外側レイヤーは必須です。

内部レイヤーの障害シナリオ

結論：内側のロールバックは外側の実行に影響しない

//トランザクションの作成
- Creating new transaction with name [com.cxf.data.service.impl.StudentServiceImpl.insert]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT
 HikariPool-1 - Starting...
 HikariPool-1 - Start completed.
 - Acquired Connection [HikariProxyConnection@2096598149 wrapping com.mysql.cj.jdbc.ConnectionImpl@ebe067d] for JDBC transaction
 - Switching JDBC Connection [HikariProxyConnection@2096598149 wrapping com.mysql.cj.jdbc.ConnectionImpl@ebe067d] to manual commit
 - ==> Preparing: insert into student (`name`, age) values (?, ?) 
 - ==> Parameters: tanakasan(String), null
 - <== Updates: 1
 //入れ子トランザクションの作成、外側トランザクションのハングアップ
 - Creating nested transaction with name [com.cxf.data.service.impl.CourseServiceImpl.deleteByPrimaryKey]
 //入れ子トランザクションのセーブポイントへのロールバック
 - Rolling back transaction to savepoint
 - Initiating transaction rollback
 - Rolling back JDBC transaction on Connection [HikariProxyConnection@2096598149 wrapping com.mysql.cj.jdbc.ConnectionImpl@ebe067d]
//外側トランザクションを続ける
 - Releasing JDBC Connection [HikariProxyConnection@2096598149 wrapping com.mysql.cj.jdbc.ConnectionImpl@ebe067d] after transaction

ログは以下の通りです。

//StudentServiceImpl.java
@Transactional(propagation = Propagation.REQUIRED)
public class StudentServiceImpl implements StudentService{
 public int insert(Student record) {
 int insert = studentMapper.insert(record);
 courseService.deleteByPrimaryKey(1);
 int res = 1 / 0; //外側レイヤーが失敗する
 return insert;
 }
//CourseServiceImpl.java 
@Transactional(propagation = Propagation.NESTED)//トランザクション伝播メカニズムの変更点に注意する
@Service
public class CourseServiceImpl implements CourseService{
 @Override
 public int deleteByPrimaryKey(Integer id) {
 
 return courseMapper.deleteByPrimaryKey(id);
 }

外側レイヤーの障害シナリオ

アウターレイヤーの破損がインナーレイヤーの巻き戻しを誘発

//新しいトランザクション
- Creating new transaction with name [com.cxf.data.service.impl.StudentServiceImpl.insert]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT
 HikariPool-1 - Starting...
 HikariPool-1 - Start completed.
 - Acquired Connection [HikariProxyConnection@247334525 wrapping com.mysql.cj.jdbc.ConnectionImpl@3a4ab7f7] for JDBC transaction
 - Switching JDBC Connection [HikariProxyConnection@247334525 wrapping com.mysql.cj.jdbc.ConnectionImpl@3a4ab7f7] to manual commit
 - ==> Preparing: insert into student (`name`, age) values (?, ?) 
 - ==> Parameters: tanakasan(String), null
 - <== Updates: 1
 //入れ子トランザクションの作成
 - Creating nested transaction with name [com.cxf.data.service.impl.CourseServiceImpl.deleteByPrimaryKey]
Preparing: delete from course where id = ? 
arameters: 1(Integer)
 Updates: 1
 //セーブポイントを解放する
 - Releasing transaction savepoint
 //入れ子トランザクションのロールバック
 - Initiating transaction rollback
 - Rolling back JDBC transaction on Connection [HikariProxyConnection@247334525 wrapping com.mysql.cj.jdbc.ConnectionImpl@3a4ab7f7]
 - Releasing JDBC Connection [HikariProxyConnection@247334525 wrapping com.mysql.cj.jdbc.ConnectionImpl@3a4ab7f7] after transaction

ログは以下の通りです。

Should roll back transaction but cannot - no transaction available
org.springframework.transaction.IllegalTransactionStateException: No existing transaction found for transaction marked with propagation 'mandatory'

データベースを見ると、外側ティアの障害が内側ティアをロールバックさせることがわかります。

MANDATORY

既存のトランザクションの中で実行されなければなりません。

外層がNOT_SUPPORTEDで内層がMANDATORYの場合、例外がスローされます。

//トランザクションの作成
- Creating new transaction with name [com.cxf.data.service.impl.StudentServiceImpl.insert]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT
 - Acquired Connection [HikariProxyConnection@2096598149 wrapping com.mysql.cj.jdbc.ConnectionImpl@ebe067d] for JDBC transaction
 - Switching JDBC Connection [HikariProxyConnection@2096598149 wrapping com.mysql.cj.jdbc.ConnectionImpl@ebe067d] to manual commit
 - ==> Preparing: insert into student (`name`, age) values (?, ?) 
 - ==> Parameters: tanakasan(String), null
 - <== Updates: 1
//既存のトランザクションを追加する
 - Participating in existing transaction
 - Participating transaction failed - marking existing transaction as rollback-only
 - Setting JDBC transaction [HikariProxyConnection@2096598149 wrapping com.mysql.cj.jdbc.ConnectionImpl@ebe067d] rollback-only
 - Initiating transaction rollback
 - Rolling back JDBC transaction on Connection [HikariProxyConnection@2096598149 wrapping com.mysql.cj.jdbc.ConnectionImpl@ebe067d]
 - Releasing JDBC Connection [HikariProxyConnection@2096598149 wrapping com.mysql.cj.jdbc.ConnectionImpl@ebe067d] after transaction

NEVEL

トランザクションを持たないトランザクションで実行されなければなりません。

SUPPORTS

もう一方のBeanがこのメソッドを呼び出すときにトランザクションを宣言していれば、そのトランザクションを使用します。

アウターレイヤーにはREQUIREDを、インナーレイヤーにはSUPPORTSを使用してください。

概要

相違点

REQUIRES_NEWは最もシンプルで、現在のトランザクションに関係なく、それは、外部トランザクションに影響を与えず、他の内部トランザクション、実際の井戸水、会社、独立に影響を与えず、全く新しいトランザクションを開きます。

外部取引がない場合は、他の内部取引に影響を与えることなく取引が開始され、外部取引がある場合は、外部取引や他の内部取引と運命を共にします。また、外部取引がある場合は、外部取引や他の内部取引と同じ運命をたどります。条件がある場合はそのまま実行されますが、条件がない場合は、自ら条件を作って実行されます。

NESTEDは外部トランザクションがないときはREQUIREDと同じ効果を持ち、外部トランザクションがあるときは、外部トランザクションとともに生き、外部トランザクションとともに死にますが、他の内部トランザクションとは生きません。あなたは一人であるか、あるいは主君に従うことを誓っているかのどちらかです。

伝播

1. REQUIRED(生きるも死ぬも一緒)

両方のメソッドの伝搬メカニズムがREQUIREDの場合、ロールバックが発生すると、両方のメソッドが

1. REQUIRES_NEW(インナーレイヤーは独立してコミット可能)

内側メソッド伝搬メカニズムがREQUIRES_NEWの場合、新しいトランザクションがオープンされ、メソッドが個別にコミットされるため、外側メソッドのロールバックは内側メソッドのトランザクション・コミットに影響しません。

1. NESTED（アウターレイヤーは別途提出可）

   外側メソッドがREQUIREDで、内側メソッドがNESTEDの場合、内側メソッドはネストされたトランザクションを開きます；

   逆に、内側のメソッドがロールバックされても、外側のメソッドのコミットには影響しません。