Operaciones compuestas

Buscar y actualizar

Para buscar y actualizar un documento, utilice el método findOneAndUpdate() de la clase MongoCollection.

val filter = equal("color", "green")
val update = set("food", "pizza")
val options = new FindOneAndUpdateOptions()
  .upsert(true)
  .maxTime(5, TimeUnit.SECONDS)
val observable: SingleObservable[Document] =
  collection.findOneAndUpdate(filter, update, options)
observable.subscribe(new Observer[Document] {
  override def onNext(doc: Document): Unit = println(doc.toJson())
  override def onError(e: Throwable): Unit = println(s"Failed: ${e.getMessage}")
  override def onComplete(): Unit = println("Completed")
})

{"_id": {"$oid": "1"}, "color": "green", "food": "pizza"}
Completed

Buscar y reemplazar

Para buscar y reemplazar un documento, utilice el método findOneAndReplace() de la clase MongoCollection.

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

val replaceFilter = equal("color", "green")
val replacement = Document(
  "music" -> "classical",
  "color" -> "green"
)
val replaceOptions = new FindOneAndReplaceOptions()
  .returnDocument(ReturnDocument.AFTER)
val replaceObservable: SingleObservable[Document] =
  collection.findOneAndReplace(replaceFilter, replacement, replaceOptions)
replaceObservable.subscribe(new Observer[Document] {
  override def onNext(doc: Document): Unit = println(doc.toJson())
  override def onError(e: Throwable): Unit = println(s"Failed: ${e.getMessage}")
  override def onComplete(): Unit = println("Completed")
})

{"_id": {"$oid": "1"}, "music": "classical", "color": "green"}
Completed

Encontrar y borrar

Para buscar y eliminar un documento, utilice el método findOneAndDelete() de la clase MongoCollection.

val deleteOptions = new FindOneAndDeleteOptions()
  .sort(descending("_id"))
val deleteObservable: SingleObservable[Document] =
  collection.findOneAndDelete(empty(), deleteOptions)
deleteObservable.subscribe(new Observer[Document] {
  override def onNext(doc: Document): Unit = println(doc.toJson())
  override def onError(e: Throwable): Unit = println(s"Failed: ${e.getMessage}")
  override def onComplete(): Unit = println("Completed")
})

{"_id": {"$oid": "2"}, "food": "pear", "color": "yellow"}
Completed

Ejemplo con condición de carrera

El siguiente ejemplo utiliza la función bookARoomUnsafe() para registrar a un huésped en una habitación. La función realiza las operaciones de búsqueda y actualización por separado.

def bookARoomUnsafe(guestName: String): Unit = {
  val availableFilter = equal("reserved", false)
  val findResults = Await.result(
    hotelCollection.find(availableFilter).first().toFuture(),
    Duration(10, TimeUnit.SECONDS)
  )
  if (Option(findResults).isEmpty) {
    println(s"Sorry, we are booked, $guestName")
    return
  }
  val room = findResults
  val roomName = room.getString("room")
  println(s"You got the $roomName, $guestName")
  val reserveUpdate = combine(
    set("reserved", true),
    set("guest", guestName)
  )
  val roomFilter = equal("_id", room.get("_id").get)
  Await.result(
    hotelCollection.updateOne(roomFilter, reserveUpdate).toFuture(),
    Duration(10, TimeUnit.SECONDS)
  )
}

Imagina que dos huéspedes, Jan y Pat, intentan reservar la misma habitación al mismo tiempo.

Jan ve este resultado:

You got the Blue Room, Jan

Pat ve este resultado:

You got the Blue Room, Pat

Al consultar la base de datos, verá el siguiente documento:

{"_id": {"$oid": "1"}, "guest": "Jan", "room": "Blue Room", "reserved": true}

Tu aplicación les indicó a Pat y a Jan que habían reservado la habitación, pero la base de datos muestra una reserva solo para Jan. Esta es la secuencia de operaciones que realizó MongoDB:

1. Encuentra y devuelve la habitación vacía a Jan.

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

3. Actualizar la habitación con la reserva de Pat

4. Actualizar la habitación con la reserva de Jan

Aunque Pat reservó la habitación por un momento, la actualización realizada por Jan sobrescribió la reserva de Pat porque se ejecutó en último lugar.

Ejemplo sin condición de competencia

El siguiente ejemplo utiliza la función bookARoomSafe() para registrar a un huésped en una habitación. La función utiliza findOneAndUpdate() para realizar las operaciones de búsqueda y actualización como una única operación atómica.

def bookARoomSafe(guestName: String): Unit = {
  val reserveUpdate = combine(
    set("reserved", true),
    set("guest", guestName)
  )
  val availableFilter = equal("reserved", false)
  val room: Document = Await.result(
    hotelCollection.findOneAndUpdate(availableFilter, reserveUpdate).toFuture(),
    Duration(10, TimeUnit.SECONDS)
  )
  if (Option(room).isEmpty) {
    println(s"Sorry, we are booked, $guestName")
    return
  }
  val roomName = room.getString("room")
  println(s"You got the $roomName, $guestName")
}

Imagina que dos huéspedes, Jan y Pat, intentan reservar la misma habitación al mismo tiempo.

Jan ve este resultado:

You got the Blue Room, Jan

Pat ve este resultado:

Sorry, we are booked, Pat

Al consultar la base de datos, verá el siguiente documento:

{"_id": {"$oid": "1"}, "guest": "Jan", "room": "Blue Room", "reserved": true}

Jan reservó la habitación y Pat recibió el mensaje correcto de que no hay habitaciones disponibles. Esta es la secuencia de operaciones que realizó MongoDB:

1. Encuentra una habitación libre para Jan y resérvala.

2. Intenta encontrar y reservar una habitación vacía para Pat.

3. No encuentre habitaciones vacías y complete sin emitir un valor.

Debido a que findOneAndUpdate() realiza la búsqueda y actualización de forma atómica, la operación de Pat no puede leer la habitación como disponible después de que finalice la reserva de Jan.

Para obtener más información sobre los métodos y las clases utilizados en esta sección, consulte la siguiente documentación de la API:

• MongoCollection

• filtro

• Updates

• Ordena