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.

// <MongoCollection set up code here>
// Creates a projection to exclude the "_id" field from the retrieved documents
Bson projection = Projections.excludeId();
// Creates a filter to match documents with a "color" value of "green"
Bson filter = Filters.eq("color", "green");
// Creates an update document to set the value of "food" to "pizza"
Bson update = Updates.set("food", "pizza");
// Defines options that specify projected fields and permit upserts
FindOneAndUpdateOptions options = new FindOneAndUpdateOptions()
        .projection(projection)
        .upsert(true);
// Updates the first matching document with the content of the update document, applying the specified options
Document result = collection.findOneAndUpdate(filter, update, options);
// Prints the matched document in its state before the operation
System.out.println(result.toJson());

{"food": "pizza", "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"}

// <MongoCollection set up code here>
// Creates instructions to replace the matching document with a new document
Bson filter = Filters.eq("color", "green");
Document replace = new Document("music", "classical").append("color", "green");
// Defines options specifying that the operation should return a document in its post-operation state
FindOneAndReplaceOptions options = new FindOneAndReplaceOptions().
        returnDocument(ReturnDocument.AFTER);
// Atomically finds and replaces the matching document and prints the replacement document
Document result = collection.findOneAndReplace(filter, replace, options);
System.out.println(result.toJson());

{"_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.

// <MongoCollection set up code here>
Bson sort = Sorts.descending("_id");
// Creates an empty filter to match all documents in the collection
Bson filter = Filters.empty();
// Defines options that specify a descending sort on the "_id" field
FindOneAndDeleteOptions options = new FindOneAndDeleteOptions().
        sort(sort);
// Deletes the document containing the highest "_id" value and prints the deleted document
Document result = collection.findOneAndDelete(filter, options);
System.out.println(result.toJson());

{"_id": 2, "food": "pear", "color": "yellow"}

Ejemplo con condición de carrera

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

public void bookARoom() {
    // Creates a filter to match documents representing available rooms
    Bson filter = Filters.eq("reserved", false);
    // Retrieves a document that represents the first available room
    Document myRoom = this.collection.find(filter).first();
    // Prints a message if no documents representing available rooms are found
    if (myRoom == null){
        System.out.println("Sorry, we are booked " + this.guest);
        return;
    }
    String myRoomName = myRoom.getString("room");
    // Prints a message that guest that successfully booked the room
    System.out.println("You got the " + myRoomName + " " + this.guest);
    // Creates an update document to mark a room as reserved
    Bson update = Updates.combine(Updates.set("reserved", true), Updates.set("guest", guest));
    
    // Creates a filter that matches the "_id" field of the first available room
    Bson roomFilter = Filters.eq("_id", myRoom.get("_id", Integer.class));
    // Updates the first matching document to mark it as reserved
    this.collection.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": true}

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:

• Encuentra y devuelve una habitación vacía para Jan

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

• Actualizar la habitación a reservada para Pat

• 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.

public void bookARoom(){
    // Creates an update document to mark a room as reserved
    Bson update = Updates.combine(Updates.set("reserved", true), Updates.set("guest", guest));
    
    // Creates a filter to match a document representing an available room
    Bson filter = Filters.eq("reserved", false);
    // Updates the first document that matches the filter to mark it as reserved
    Document myRoom = this.collection.findOneAndUpdate(filter, update);
   
    // Prints a message when there are no available rooms
    if (myRoom == null){
        System.out.println("Sorry, we are booked " + this.guest);
        return;
    }
    // Prints the name of the guest that successfully booked the room
    String myRoomName = myRoom.getString("room");
    System.out.println("You got the " + myRoomName + " " + this.guest);
}

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":true}

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:

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

• Intenta encontrar una habitación libre para Pat y resérvala. Como no quedan 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.