Operaciones compuestas

Buscar y actualizar

Para buscar y actualizar un documento, utilice el findOneAndUpdate() Método de la clase MongoCollection. El método findOneAndUpdate() devuelve el documento encontrado o null si no hay documentos que coincidan con la consulta.

val filter = Filters.eq(FoodOrder::color.name, "green")
val update = Updates.set(FoodOrder::food.name, "pizza")
val options = FindOneAndUpdateOptions()
    .upsert(true)
/* The result variable contains your document in the
    state before your update operation is performed
    or null if the document was inserted due to upsert
    being true */
val result = collection.findOneAndUpdate(filter, update, options)
println(result)

FoodOrder(id=1, food=donut, color=green)

Buscar y reemplazar

Para buscar y reemplazar un documento, utilice el método findOneAndReplace() de la clase MongoCollection. El método findOneAndReplace() devuelve el documento encontrado o null si no hay documentos que coincidan con su consulta.

{"music": "classical", "color": "green"}

data class Music(
    @BsonId val id: Int,
    val music: String,
    val color: String
)
val filter = Filters.eq(FoodOrder::color.name, "green")
val replace = Music(1, "classical", "green")
val options = FindOneAndReplaceOptions()
    .returnDocument(ReturnDocument.AFTER)
val result = collection.withDocumentClass<Music>().findOneAndReplace(filter, replace, options)
println(result)

Music(id=1, music=classical, color=green)

Buscar y eliminar

Para buscar y eliminar un documento, utilice el método findOneAndDelete() de la clase MongoCollection. El método findOneAndDelete() devuelve el documento encontrado o null si no hay documentos que coincidan con su consulta.

val sort = Sorts.descending("_id")
val filter = Filters.empty()
val options = FindOneAndDeleteOptions().sort(sort)
val result = collection.findOneAndDelete(filter, options)
println(result)

FoodOrder(id=2, food=pear, color=yellow)

Ejemplo con condición de carrera

Supongamos que nuestra aplicación usa este método bookARoomUnsafe para registrar la habitación a un huésped:

suspend fun bookARoomUnsafe(guestName: String) {
    val filter = Filters.eq("reserved", false)
    val myRoom = hotelCollection.find(filter).firstOrNull()
    if (myRoom == null) {
        println("Sorry, we are booked, $guestName")
        return
    }
    val myRoomName = myRoom.room
    println("You got the $myRoomName, $guestName")
    val update = Updates.combine(Updates.set("reserved", true), Updates.set("guest", guestName))
    val roomFilter = Filters.eq("_id", myRoom.id)
    hotelCollection.updateOne(roomFilter, update)
}

Imagine que dos huéspedes distintos, Jan y Pat, intentan reservar la habitación con este método al mismo tiempo.

Jan ve este resultado:

You got the Blue Room, Jan

Y Pat ve este resultado:

You got the Blue Room, Pat

Cuando miramos nuestra base de datos, vemos lo siguiente:

 {"_id": 1, "guest": "Jan", "room": "Blue Room", "reserved": false}

Pat no estará contenta. Cuando Pat llegue a nuestro hotel, Jan ocupará su habitación. ¿Qué salió mal?

Aquí está la secuencia de eventos que ocurrieron desde la perspectiva de nuestra instancia de MongoDB:

1. Encuentra y devuelve una habitación vacía para enero.

2. Encuentra y devuelve una habitación vacía para Pat.

3. Actualice la habitación a reservada para Pat.

4. Actualizar la habitación a reservada para enero.

Tenga en cuenta que por un breve momento Pat había reservado la habitación, pero como la operación de actualización de Jan fue la última en ejecutarse, nuestro documento tiene a "Jan" como invitado.

Ejemplo sin condición de competencia

Utilicemos una operación compuesta para evitar la condición de carrera y dar siempre a nuestros usuarios el mensaje correcto.

suspend fun bookARoomSafe(guestName: String) {
    val update = Updates.combine(
        Updates.set(HotelRoom::reserved.name, true),
        Updates.set(HotelRoom::guest.name, guestName)
    )
    val filter = Filters.eq("reserved", false)
    val myRoom = hotelCollection.findOneAndUpdate(filter, update)
    if (myRoom == null) {
        println("Sorry, we are booked, $guestName")
        return
    }
    val myRoomName = myRoom.room
    println("You got the $myRoomName, $guestName")
}

Imagine que dos huéspedes distintos, Jan y Pat, intentan reservar la habitación con este método al mismo tiempo.

Jan ve este resultado:

You got the Blue Room, Jan

Y Pat ve este resultado:

Sorry, we are booked, Pat

Cuando miramos nuestra base de datos, vemos lo siguiente:

 {"_id": 1, "guest": "Jan", "room": "Blue Room", "reserved": false}

Pat recibió el mensaje correcto. Aunque esté triste por no haber conseguido la reserva, al menos sabe que no debe viajar a nuestro hotel.

Aquí está la secuencia de eventos que ocurrieron desde la perspectiva de nuestra instancia de MongoDB:

1. Encuentra una habitación vacía para Jan y resérvala.

2. Intenta encontrar una habitación vacía para Pat y resérvala.

3. Cuando no queden habitaciones, devuelve null.

Para obtener información sobre la Updates clase, consulte nuestra guía sobre el generador de actualizaciones.

Para obtener más información sobre la Filters clase, consulte nuestra guía sobre el generador de filtros.

Para obtener más información sobre el findOneAndUpdate() método, consulte la documentación de la API de la clase MongoCollection.