Atualização Atômica

Seleciona o escopo de destino com first/multi/upsertOne e configura explicitamente a atualização do documento ou o pipeline de agregação.

Selecione primeiro o escopo e a expressão de atualização.

text

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

Atualização de documento

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

• Adiciona a atualização do Driver diretamente: driverUpdate(Bson)

• setOnInsert(...) é usado em upsertOne().document()

Upsert de documento único

java

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

Atualização de pipeline

java

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

nextStage() esvazia o $set pendente atual em um único estágio. O estágio do pipeline nativo do Driver é adicionado diretamente com stage(Bson).

Auditoria / ciclo de vida

atomicUpdate não passa pelo ciclo de vida de salvamento da entidade.

Como MongoExecutionContext.beforePersist/afterPersist não é chamado, mesmo que a auditoria reativa seja conectada no adaptador Spring, não espere que updatedAt da atualização atômica seja automaticamente incluído, inclua explicitamente na atualização.