Update Documents

Overview

このガイドでは、 Java Reactive Streams ドライバーを使用して更新操作を実行し、 MongoDBコレクション内のドキュメントを更新する方法を学習します。

更新操作は、 MongoDBコレクション内の 1 つ以上のドキュメントを更新します。 メソッドまたはupdateOne() updateMany()メソッドを使用して更新操作を実行できます。

アップデート操作

MongoDB では、次の方法で更新操作を実行できます。

• updateOne()は、検索条件に一致する最初のドキュメントを更新します。

• updateMany()は、検索条件に一致するすべてのドキュメントを更新します

各更新方法には次のパラメーターが必要です。

• クエリフィルタードキュメント。更新するドキュメントを決定します。 クエリフィルターの使用の詳細については、「フィルター」セクションを参照してください。

• ドキュメントを更新し、更新演算子（実行する更新の種類）と変更するフィールドと値を指定します。 更新演算子の詳細については、「更新演算子 」セクションを参照してください。

1 つのドキュメントの更新

MongoDBコレクション内の単一のドキュメントを更新するには、updateOne() メソッドを呼び出し、クエリフィルターと更新演算子を渡します。次に、updateOne() の結果を Mono から静的 Mono.from() メソッドに渡します。 Mono は、プロジェクト Reactor ライブラリのクラスです。Java Reactive Streams では、ドライバー メソッドはコールド Publisher インスタンスを返します。つまり、返された Publisher をサブスクライブしないと、対応する操作は実行されません。このガイドでは、Project Reactor ライブラリを使用してそれらを消費します。Mono の詳細については、 Project React ドキュメントのMongoDBを参照してください。

次の例ではupdateOne()メソッドを使用して、一致するドキュメントのnameの値を"Bagels N Buns"から"2 Bagels 2 Buns"にアップデートします。

 Publisher<UpdateResult> updatePublisher =
         restaurants.updateOne(eq("name", "Bagels N Buns"),
                 set("name", "2 Bagels 2 Buns"));
 Mono.from(updatePublisher).block();

複数のドキュメントの更新

MongoDBコレクション内の複数のドキュメントを更新するには、updateMany() メソッドを呼び出し、クエリフィルターと更新演算子を渡します。次に、updateMany() の結果を Mono から静的 Mono.from() メソッドに渡します。 Mono は、プロジェクト Reactor ライブラリのクラスです。Java Reactive Streams では、ドライバー メソッドはコールド Publisher インスタンスを返します。つまり、返された Publisher をサブスクライブしないと、対応する操作は実行されません。このガイドでは、Project Reactor ライブラリを使用してそれらを消費します。Mono の詳細については、 Project React ドキュメントのMongoDBを参照してください。

次の例ではupdateMany()メソッドを使用して、 cuisineの値が"Pizza"のすべてのドキュメントを更新して、 cuisineの値が"Pasta"になります。

 Publisher<UpdateResult> updatePublisher =
         restaurants.updateMany(eq("cuisine", "Pizza"),
                 set("cuisine", "Pasta"));
 Mono.from(updatePublisher).block();

更新操作をカスタマイズする

UpdateOptionsクラスには、アップデート メソッドの動作を変更するメソッドが含まれています。 UpdateOptionsクラスを使用するには、クラスの新しいインスタンスを作成し、そのメソッドの 1 つ以上を呼び出して 更新操作を変更します。 これらのメソッド呼び出しを連鎖させることができます。 更新操作の動作を変更するには、クラスインスタンスと連鎖したメソッド呼び出しを メソッドまたは メソッドの 3updateOne() updateMany()つ目の引数として渡します。

更新操作を変更するには、 UpdateOptionsクラスの次の任意のメソッドを使用します。

Bson filter = Filters.eq("borough", "Manhattan");
Bson update = Updates.set("borough", "Manhattan (north)");
UpdateOptions options = new UpdateOptions().upsert(true);
Publisher<UpdateResult> updateManyPublisher = restaurants.updateMany(filter, update, options);
UpdateResult result = Mono.from(updateManyPublisher).block();
System.out.println("Matched: " + result.getMatchedCount()
        + ", Modified: " + result.getModifiedCount()
        + ", Upserted ID: " + result.getUpsertedId());

Matched: 10259, Modified: 10259, Upserted ID: null

戻り値

updateOne()メソッドとupdateMany()メソッドはそれぞれUpdateResultオブジェクトを返します。 UpdateResult型には次のインスタンスメソッドが含まれています。

詳細情報

更新演算子の詳細については、 MongoDB Serverマニュアルの「更新演算子 」を参照してください。

Java Reactive Streams ドライバーを使用してドキュメントを挿入する実行可能なコード例については、 CRUD操作ガイド を参照してください。