Transactions

getTxJobのMongoDB ClientSessionトランザクション、Reactorコンテキストセッション伝播、リトライ責任とSpringトランザクション境界を説明します。

getTxJob

java

getTxJob(...)はMongoExecutionContext.startSession()でClientSessionを開き、トランザクションを開始した後、Reactorコンテキストにセッションバインディングを入れます。正常に完了した場合はコミット、エラー/キャンセル時はアクティブトランザクションを中止し、最後にセッションをクローズする順序で処理します。

セッションスコープ

トランザクションセッションはMongoExecutionContext#getSessionScope()が同じDSL実行にのみ伝播されます。基本のDriverMongoExecutionContextは自身のMongoClientをセッションスコープとして使用します。

異なるMongoClientは同じセッションを共有できません

同じ MongoClient で複数のデータベース/コンテキストを使用する場合、同じセッションスコープになる可能性がありますが、異なるクライアントを使用するコンテキストを1つの DSL トランザクションにまとめることはできません。

トランザクションの再試行は呼び出し側の責任です。

getTxJob(...) は TransientTransactionError のような MongoDB トランザクションエラーを自動的に再試行しません。再試行の有無と回数は、操作の冪等性、外部の副作用、業務ルールを知っている呼び出しアプリケーションが決定します。

Spring トランザクションとの境界

Spring @Transactional / TransactionalOperator

Spring Data MongoDB が管理するトランザクション/セッションの境界です。

ReactiveMongoDsl#getTxJob

DSL が直接 ClientSession を開始し、Reactor コンテキストに渡します。

2つの実行モデルが自動的に同じセッションを使用するわけではありません。

Spring トランザクション内で DSL を呼び出しても、DSL 操作が Spring セッションに自動的に参加するわけではなく、getTxJob(...) 内の ReactiveMongoTemplate/Repository 操作も DSL セッションに自動的に参加しません。