一括書き込み操作

Overview

このガイドでは、一括書込み操作を使用して、1 つのデータベース呼び出しで複数の書込み操作を実行する方法を学習できます。

コレクションにドキュメントを挿入し、複数の他のドキュメントを更新してから、ドキュメントを削除するシナリオを考えてみましょう。個々のメソッドを使用する場合、各操作には独自のデータベース呼び出しが必要です。このガイドでは、一括書き込み操作を使用してデータベースへの呼び出し回数を減らす方法について説明します。

サンプルデータ

このガイドの例では、 Atlasサンプルデータセットの sample_restaurants.restaurantsコレクションを使用します。 MongoDB Atlasクラスターを無料で作成し、サンプルデータセットをロードする方法については、「を使い始める」チュートリアルを参照してください。

重要

プロジェクトリアクターライブラリ

このガイドでは、プロジェクト Reactive ライブラリを使用して、 Java Reactive Streams ドライバーメソッドによって返されたPublisherインスタンスを消費します。 Project Reactive ライブラリとその使用方法の詳細については、「使用開始」を参照してください。（Reactor ドキュメントの参照）。このガイドでは Project React ライブラリメソッドをどのように使用しているかについて詳しくは、「 MongoDBへのデータの書込み」ガイドを参照してください。

書込み (write) 操作を定義する

実行する書込み操作ごとに、次のいずれかのクラスのインスタンスを作成します。

InsertOneModel
UpdateOneModel
UpdateManyModel
ReplaceOneModel
DeleteOneModel
DeleteManyModel

次に、これらのインスタンスのリストをbulkWrite()メソッドに渡します。

次のセクションでは、前述のクラスのインスタンスを作成して使用する方法を示します。

挿入操作

挿入操作を実行するには、 InsertOneModelのインスタンスを作成し、挿入するドキュメントを渡します。

次の例では、 InsertOneModelのインスタンスを作成しています。

InsertOneModel<Document> operation = new InsertOneModel<>(
        new Document("name", "Mongo's Deli")
                .append("cuisine", "Sandwiches"));

複数のドキュメントを挿入するには、ドキュメントごとにInsertOneModelのインスタンスを作成します。

アップデート操作

ドキュメントを更新するには、 UpdateOneModelのインスタンスを作成し、次の引数を渡します。

コレクション内のドキュメントをマッチングするために使用される基準を指定するクエリフィルター。
実行する更新操作。更新操作の詳細については、 MongoDB Serverマニュアルの「フィールド更新演算子」ガイドを参照してください。

UpdateOneModel はクエリフィルターに一致する最初のドキュメントを更新します。

次の例では、 UpdateOneModelのインスタンスを作成しています。

UpdateOneModel<Document> operation = new UpdateOneModel<>(
        eq("name", "Mongo's Deli"),
        set("cuisine", "Sandwiches and Salads"));

複数のドキュメントを更新するには、 UpdateManyModelのインスタンスを作成し、同じ引数で渡します。 UpdateManyModelは、クエリフィルターに一致するすべてのドキュメントを更新します。

次の例では、 UpdateManyModelのインスタンスを作成しています。

UpdateManyModel<Document> operation = new UpdateManyModel<>(
        eq("name", "Mongo's Deli"),
        set("cuisine", "Sandwiches and Salads"));

置換操作

置換操作すると、 _idフィールド以外の、指定されたドキュメントのすべてのフィールドと値が削除され、新しいフィールドと値に置き換えられます。置換操作を実行するには、 ReplaceOneModelのインスタンスを作成し、クエリフィルターと、一致するドキュメントに保存するフィールドと値を渡します。

次の例では、 ReplaceOneModelのインスタンスを作成しています。

ReplaceOneModel<Document> operation = new ReplaceOneModel<>(
        eq("name", "Original Pizza"),
        new Document("name", "Mongo's Pizza")
                .append("borough", "Manhattan"));

複数のドキュメントを置き換えるには、ドキュメントごとにReplaceOneModelのインスタンスを作成します。

削除操作

ドキュメントを削除するには、 DeleteOneModelのインスタンスを作成し、削除するドキュメントを指定するクエリフィルターを渡します。 DeleteOneModelは、クエリフィルターに一致する最初のドキュメントのみを削除します。

次の例では、 DeleteOneModelのインスタンスを作成しています。

DeleteOneModel<Document> operation = new DeleteOneModel<>(
        eq("restaurant_id", "5678"));

複数のドキュメントを削除するには、 DeleteManyModelのインスタンスを作成し、削除するドキュメントを指定するクエリフィルターを渡します。 DeleteManyModelは、クエリフィルターに一致するすべてのドキュメントを削除します。

次の例では、 DeleteManyModelのインスタンスを作成しています。

DeleteManyModel<Document> operation = new DeleteManyModel<>(
        eq("name", "Mongo's Deli"));

`bulkWrite()`メソッドを呼び出す

実行する操作ごとにクラスインスタンスを定義したら、これらのインスタンスのリストをbulkWrite()メソッドに渡します。デフォルトでは、メソッドはリストで定義された順序で操作を実行します。

次の例では、 bulkWrite()メソッドを使用して複数の書込み操作を実行します。

Publisher<BulkWriteResult> bulkWritePublisher = restaurants.bulkWrite(
        Arrays.asList(new InsertOneModel<>(
                        new Document("name", "Mongo's Deli")
                                .append("cuisine", "Sandwiches")
                                .append("borough", "Manhattan")
                                .append("restaurant_id", "1234")),
                new InsertOneModel<>(new Document("name", "Mongo's Deli")
                                .append("cuisine", "Sandwiches")
                                .append("borough", "Brooklyn")
                                .append("restaurant_id", "5678")),
                new UpdateManyModel<>(eq("name", "Mongo's Deli"),
                        set("cuisine", "Sandwiches and Salads")),
                new DeleteOneModel<>(eq("restaurant_id", "1234"))));
BulkWriteResult bulkResult = Mono.from(bulkWritePublisher).block();
System.out.println(bulkResult.toString());

AcknowledgedBulkWriteResult{insertedCount=2, matchedCount=2, removedCount=1, modifiedCount=2, upserts=[], inserts=[BulkWriteInsert{index=0, id=BsonObjectId{value=66a7e0a6c08025218b657208}}, BulkWriteInsert{index=1, id=BsonObjectId{value=66a7e0a6c08025218b657209}}]}

いずれかの書込み操作が失敗した場合、 Java Reactive Streams ドライバーはMongoBulkWriteExceptionをシグナルし、それ以上の個々の操作を実行しません。 MongoBulkWriteExceptionにはMongoBulkWriteException.getWriteErrors()メソッドを使用してアクセスできるBulkWriteErrorが含まれており、個々の障害の詳細が提供されます。

注意

Java Reactive Streams ドライバーが一括操作を実行する場合、操作が実行中されているコレクションのwriteConcernを使用します。ドライバーは、実行順序に関係なく、すべての操作を試行した後にすべての書込み保証 ( 書込み保証 (write concern) ) エラーを報告します。