Operações compostas

Encontrar e atualizar

Para localizar e atualizar um documento, utilize o método findOneAndUpdate() da classe MongoCollection . O método findOneAndUpdate() retorna o documento encontrado ou null se nenhum documento corresponder à sua query.

val filter = Filters.eq(FoodOrder::color.name, "green")
val update = Updates.set(FoodOrder::food.name, "pizza")
val options = FindOneAndUpdateOptions()
    .upsert(true)
    .maxTime(5, TimeUnit.SECONDS)
/* 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)

Encontrar e substituir

Para localizar e substituir um documento, use o método findOneAndReplace() da classe MongoCollection . O método findOneAndReplace() retorna o documento encontrado ou null se nenhum documento corresponder à sua query.

{"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)

Localize e exclua

Para localizar e excluir um documento, use o método findOneAndDelete() da classe MongoCollection . O método findOneAndDelete() retorna o documento encontrado ou null se nenhum documento corresponder à sua query.

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)

Exemplo com condição de corrida

Digamos que nosso aplicativo use esse método bookARoomUnsafe para fazer o checkout do nosso quarto para um convidado:

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 dois convidados separados, Jane e Ana, tentando agendar o quarto com esse método ao mesmo tempo.

Jane vê esta saída:

You got the Blue Room, Jan

EPat vê esta saída:

You got the Blue Room, Pat

Quando analisamos nosso reconhecimento de data center, vemos o seguinte:

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

Pat ficará chateada. QuandoPapa aparecer em nosso hotel,Jan estará ocupando o quarto dela. O que deu errado?

Aqui está a sequência de eventos que aconteceram da perspectiva de nossa instância do MongoDB:

1. Encontre e devolva um quarto vazio para janeiro.

2. Encontre e devolva um quarto vazio paraPat.

3. Atualize o quarto como reservado paraPat.

4. Atualizar o quarto como reservado em Janeiro.

Observe que, por um breve momento, Ana reservou a divisão, mas como a operação de atualização de Janeiro foi a última a executar, nosso documento tem "Jan" como convidado.

Exemplo sem condição de corrida

Vamos usar uma operação composta para evitar a condição de corrida e sempre dar aos nossos usuários a mensagem correta.

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 dois convidados separados, Jane e Ana, tentando agendar o quarto com esse método ao mesmo tempo.

Jane vê esta saída:

You got the Blue Room, Jan

EPat vê esta saída:

Sorry, we are booked, Pat

Quando analisamos nosso reconhecimento de data center, vemos o seguinte:

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

Pat recebeu a mensagem correta. Embora possa estar triste por não ter conseguido a reserva, pelo menos sabe que não deve viajar para o nosso hotel.

Aqui está a sequência de eventos que aconteceram da perspectiva de nossa instância do MongoDB:

1. Encontre um quarto vazio para Jane e reserve-o.

2. Tente encontrar um quarto vazio paraPat e reservá-lo.

3. Quando não houver mais salas, devolva null.

Para obter informações sobre a classe Updates , consulte nosso guia sobre o construtor de atualizações.

Para obter mais informações sobre a classe Filters , consulte nosso guia sobre o construtor de filtros.

Para obter mais informações sobre o findOneAndUpdate() método , consulte a documentação da API para a classe MongoCollection.