Transactions

Explique la transaction ClientSession MongoDB de getTxJob, la propagation de session du contexte Reactor, la responsabilité de retry et les frontières de transaction Spring.

getTxJob

java

getTxJob(...) ouvre un ClientSession avec MongoExecutionContext.startSession(), commence la transaction, puis lie la session au contexte Reactor. En cas de succès, il effectue un commit, en cas d'erreur/annulation, il abandonne la transaction active, et enfin ferme la session.

Portée de session

La session de transaction est propagée uniquement à la même exécution DSL par MongoExecutionContext#getSessionScope(). Le DriverMongoExecutionContext par défaut utilise son propre MongoClient comme portée de session.

Des MongoClient différents ne peuvent pas partager une même session.

Lorsqu'on utilise plusieurs bases de données/contextes avec le même MongoClient, il peut y avoir le même scope de session, mais on ne peut pas regrouper des contextes utilisant des clients différents dans une seule transaction DSL.

La responsabilité de la réessai de transaction incombe à l'appelant.

getTxJob(...) ne réessaie pas automatiquement les erreurs de transaction MongoDB comme TransientTransactionError. La décision de réessayer et le nombre de tentatives sont déterminés par l'idempotence de l'opération, les effets secondaires externes et les règles métier connues de l'application appelante.

Frontière avec la transaction Spring.

Spring @Transactional / TransactionalOperator.

Frontière de transaction/session gérée par Spring Data MongoDB.

ReactiveMongoDsl#getTxJob.

Le DSL démarre directement le ClientSession et le transmet au contexte Reactor.

Les deux modèles d'exécution n'utilisent pas automatiquement la même session.

Appeler le DSL dans une transaction Spring ne signifie pas que l'opération DSL participe automatiquement à la session Spring, et les opérations ReactiveMongoTemplate/Repository dans getTxJob(...) ne participent pas automatiquement à la session DSL.