Mise à jour atomique

Sélectionnez la portée cible avec first/multi/upsertOne et configurez explicitement la mise à jour du document ou la mise à jour du pipeline d'agrégation.

Sélectionnez d'abord la portée et l'expression de mise à jour.

text

atomicUpdate()
  -> first() / multi() / upsertOne()
  -> document() / pipeline()
  -> update operations
  -> execute()

Mise à jour de document

java

Mono<UpdateResult> updated = dsl
    .executeEntity(User.class, MongoTemplateName.FRONT)
    .fields(pair("id", userId))
    .end()
    .atomicUpdate()
    .first()
    .document()
    .inc("loginCount", 1)
    .set("lastLoginAt", Instant.now())
    .execute();

• inc, set, unset, push, addToSet, pull

• Ajoutez la mise à jour du pilote telle quelle : driverUpdate(Bson)

• setOnInsert(...) est utilisé dans upsertOne().document().

Upsert de document unique

java

.atomicUpdate()
.upsertOne()
.document()
.set("status", "ACTIVE")
.setOnInsert("createdAt", Instant.now())
.execute();

Mise à jour de pipeline

java

.atomicUpdate()
.first()
.pipeline()
.set("updatedAt", "$$NOW")
.inc("loginCount", 1)
.nextStage()
.unset("legacyField")
.stage(Aggregates.set(new Field<>("normalized", ...)))
.execute();

nextStage() vide le $set en attente actuel en une seule étape. Les étapes de pipeline natives du pilote sont ajoutées directement avec stage(Bson).

Audit / cycle de vie

atomicUpdate ne passe pas par le cycle de vie de sauvegarde de l'entité.

Étant donné que MongoExecutionContext.beforePersist/afterPersist n'est pas appelé, même si l'audit réactif est connecté dans l'adaptateur Spring, ne vous attendez pas à ce que des éléments comme updatedAt soient automatiquement inclus dans la mise à jour, incluez-les explicitement.