複合演算子

検索と更新

1 つのドキュメントを検索して更新するには、 MongoCollectionクラスの findOneAndUpdate()メソッドを使用します。 findOneAndUpdate()nullメソッドは見つかったドキュメントを返します。クエリに一致するドキュメントがない場合は メソッドは返します。

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)

検索と置換

1 つのドキュメントを検索して置き換えるには、 MongoCollectionクラスのfindOneAndReplace()メソッドを使用します。 findOneAndReplace()nullメソッドは見つかったドキュメントを返します。クエリに一致するドキュメントがない場合は メソッドは返します。

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

検索と削除

1 つのドキュメントを検索して削除するには、 MongoCollectionクラスのfindOneAndDelete()メソッドを使用します。 findOneAndDelete()nullメソッドは見つかったドキュメントを返します。クエリに一致するドキュメントがない場合は メソッドは返します。

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)

競合状態の例

アプリがこのbookARoomUnsafeメソッドを使用して、部屋をゲスト用にチェックアウトするとします。

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

Jan と Pat の 2 人の別々の利用者が、この方法で同時に部屋を予約しようとしているとします。

Jan には次の出力が表示されます。

You got the Blue Room, Jan

そして、Pat は次の出力を確認します。

You got the Blue Room, Pat

データベースを確認すると、次のことが表示されます。

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

パッチは Atlas がお客様のインスタンスに表示されると、Jan は自分の部屋を占有することになります。 何が起こるでしたか。

MongoDB インスタンスの観点から発生したイベントの順序は以下のとおりです。

1. 1 月の空の間を検索して返します。

2. パターン の空の間を検索して返します。

3. パターン に予約されている部屋を更新します。

4. 1 月に予約されている部屋を更新します。

一時的に、Pat がこの部屋を予約していましたが、Jan の更新操作が最後に実行されたため、ドキュメントはゲストとして"Jan"を実行していることに注意してください。

競合条件がない例

複合操作 を使用して競合状態を回避し、常にユーザーに正しいメッセージを提供できるようにしましょう。

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

Jan と Pat の 2 人の別々の利用者が、この方法で同時に部屋を予約しようとしているとします。

Jan には次の出力が表示されます。

You got the Blue Room, Jan

そして、Pat は次の出力を確認します。

Sorry, we are booked, Pat

データベースを確認すると、次のことが表示されます。

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

Pat は正しいメッセージを取得しました。 予約が取得されなかったため、

MongoDB インスタンスの観点から発生したイベントの順序は以下のとおりです。

1. 1 月 日の空の間を見つけて予約します。

2. パターン 用の空のスペースを見つけて予約してください。

3. 残りのスペースがない場合、 nullが返されます。

Updatesクラスの詳細については、 アップデート ビルダに関するガイド をご覧ください。

Filtersクラスの詳細については、 フィルター ビルダに関するガイド をご覧ください。

findOneAndUpdate()メソッドの詳細については、 MongoCollection クラスの API ドキュメントを参照してください。