Transactions

Mono<String> result = dsl.getTxJob(
    MongoTemplateName.FRONT,
    () -> dsl
        .executeEntity(User.class, MongoTemplateName.FRONT)
        .save(user)
        .then(
            dsl.executeEntity(Audit.class, MongoTemplateName.FRONT)
                .save(audit)
        )
        .thenReturn("committed")
);

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

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

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