Transaktionen

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(...) ö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.

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

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.