Operaciones compuestas

Buscar y actualizar

Para encontrar y actualizar un documento, usa 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)

Encontrar y borrar

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)
}

Imagina que dos huéspedes diferentes, Jan y Pat, intenten 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á feliz. Cuando Pat llegue a nuestro hotel, Jan estará ocupando su habitación. ¿Qué salió mal?

Aquí está la secuencia de acontecimientos que ocurrió desde la perspectiva de nuestra instancia de MongoDB:

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

2. Encuentre y devuelva una habitación vacía para Pat.

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

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

Ten en cuenta que, por un breve momento, Pat reservó la sala, pero como la actualización de Jan fue la última en ejecutarse, nuestro documento tiene a "Jan" como invitado.

Ejemplo sin condición de competencia

Usemos una operación compuesta para evitar la condición de competencia y siempre brindar 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")
}

Imagina que dos huéspedes diferentes, Jan y Pat, intenten 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 acontecimientos que ocurrió desde la perspectiva de nuestra instancia de MongoDB:

1. Busca una sala libre 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 clase Updates, consulta nuestra guía sobre el Constructor 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 método findOneAndUpdate(), consulta la documentación de la API de la clase MongoCollection.