Transaktionen

Erklärt die MongoDB ClientSession-Transaktion von getTxJob, die Sitzungsweitergabe im Reactor-Kontext, die Verantwortung für Wiederholungen und die Grenzen der Spring-Transaktion.

getTxJob

java

getTxJob(...) öffnet die ClientSession mit MongoExecutionContext.startSession(), startet die Transaktion und bindet die Sitzung an den Reactor-Kontext. Bei erfolgreichem Abschluss wird ein Commit durchgeführt, bei Fehlern/Abbrüchen wird die aktive Transaktion abgebrochen, und am Ende wird die Sitzung geschlossen.

Sitzungsbereich

Die Transaktionssitzung wird nur an die gleiche DSL-Ausführung von MongoExecutionContext#getSessionScope() weitergegeben. Der Standard DriverMongoExecutionContext verwendet seinen eigenen MongoClient als Sitzungsbereich.

Verschiedene MongoClients können eine Sitzung nicht teilen.

Wenn mehrere Datenbanken/Contexts im selben MongoClient verwendet werden, kann es denselben Session-Scope geben, aber unterschiedliche Clients können nicht in einer einzigen DSL-Transaktion zusammengefasst werden.

Die Verantwortung für das Transaktions-Retry liegt beim Aufrufer.

getTxJob(...) führt kein automatisches Retry bei MongoDB-Transaktionsfehlern wie TransientTransactionError durch. Ob und wie oft ein Retry erfolgt, wird von der Idempotenz der Operation, externen Nebeneffekten und den Geschäftsregeln der aufrufenden Anwendung entschieden.

Grenzen zu Spring-Transaktionen

Spring @Transactional / TransactionalOperator

Grenzen der Transaktionen/Sitzungen, die von Spring Data MongoDB verwaltet werden.

ReactiveMongoDsl#getTxJob

DSL startet direkt ClientSession und übergibt es an den Reactor Context.

Die beiden Ausführungsmodelle verwenden nicht automatisch dieselbe Sitzung.

Wenn DSL innerhalb einer Spring-Transaktion aufgerufen wird, nimmt die DSL-Operation nicht automatisch an der Spring-Sitzung teil, und die ReactiveMongoTemplate/Repository-Operation innerhalb von getTxJob(...) nimmt ebenfalls nicht automatisch an der DSL-Sitzung teil.