一括操作

挿入操作

挿入操作を実行するには、挿入するドキュメントを指定するInsertOneModelを作成します。 複数のドキュメントを挿入するには、挿入するドキュメントごとにInsertOneModelを作成する必要があります。

InsertOneModel<Document> juneDoc = new InsertOneModel<>(new Document("name", "June Carrie")
                                                            .append("age", 17));
                                                  
InsertOneModel<Document> kevinDoc = new InsertOneModel<>(new Document("name", "Kevin Moss")
                                                            .append("age", 22));

try {
    List<WriteModel<Document>> bulkOperations = new ArrayList<>();
    // Creates instructions to insert documents
    InsertOneModel<Document> doc1 = new InsertOneModel<>(new Document("_id", 1));
    InsertOneModel<Document> doc3 = new InsertOneModel<>(new Document("_id", 3));
    
    bulkOperations.add(doc1);
    bulkOperations.add(doc3);
    
    // Runs a bulk write operation for the specified insert WriteModels
    collection.bulkWrite(bulkOperations); 
// Prints a message if any exceptions occur during the bulk write operation
} catch (MongoBulkWriteException e){
    System.out.println("A MongoBulkWriteException occurred with the following message: " + e.getMessage());
}

A MongoBulkWriteException occurred with the following message:
Bulk write operation error on server sample-shard-00-02.pw0q4.mongodb.net:27017.
Write errors: [BulkWriteError{index=0, code=11000, message='E11000 duplicate key
error collection: crudOps.bulkWrite index: _id_ dup key: { _id: 1 }', details={}}].

置換操作

置換操作を実行するには、置換ドキュメントで置き換えるドキュメントのクエリフィルターを指定するReplaceOneModelを作成します。

ReplaceOneModel<Document> celineDoc = new ReplaceOneModel<>(
                                    Filters.eq("_id", 1), 
                                    new Document("name", "Celine Stork")
                                        .append("location", "San Diego, CA"));

ReplaceOptions options = ReplaceOptions.sort(Sorts.ascending("_id"));

アップデート操作

アップデート操作を実行するには、アップデート内容を使用してアップデートするドキュメントのクエリフィルターを指定するUpdateOneModelまたはUpdateManyModelを作成します。

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

UpdateOneModel<Document> updateDoc = new UpdateOneModel<>(
                                    Filters.eq("_id", 2), 
                                    Updates.set("age", 31));

UpdateOptions options = UpdateOptions.sort(Sorts.ascending("_id"));

削除操作

削除操作を実行するには、削除するドキュメントのクエリフィルターを指定するDeleteOneModelまたはDeleteManyModelを作成します。

DeleteOneModelはクエリフィルターに一致する最初のドキュメントを削除し、 DeleteManyModelはクエリフィルターに一致するすべてのドキュメントを削除します。

DeleteOneModel<Document> deleteDoc = new DeleteOneModel<>(Filters.eq("_id", 1));

実行順序

bulkWrite()メソッドでは、一括操作の実行が順序付きか順序なしかを指定する 2 番目のパラメータとして任意のBulkWriteOptionsを受け入れます。

List<WriteModel<Document>> bulkOperations = new ArrayList<>();
// Creates instructions to insert a document
InsertOneModel<Document> insertDoc = new InsertOneModel<>(new Document("_id", 6)
                                                        .append("name", "Zaynab Omar")
                                                        .append("age", 37));
// Creates instructions to replace the first document matched by the query                                       
ReplaceOneModel<Document> replaceDoc = new ReplaceOneModel<>(Filters.eq("_id", 1), 
                                        new Document("name", "Sandy Kane")
                                            .append("location", "Helena, MT")); 
// Creates instructions to update the first document matched by the query                                                                 
UpdateOneModel<Document> updateDoc = new UpdateOneModel<>(Filters.eq("name", "Zaynab Omar"), 
                                        Updates.set("name", "Zaynab Hassan"));
// Creates instructions to delete all documents matched by the query                                
DeleteManyModel<Document> deleteDoc = new DeleteManyModel<>(Filters.gt("age", 50));
bulkOperations.add(insertDoc);
bulkOperations.add(replaceDoc);
bulkOperations.add(updateDoc);
bulkOperations.add(deleteDoc);
// Runs a bulk write operation for the specified the insert, replace, update, and delete WriteModels in order
collection.bulkWrite(bulkOperations);               

{ "_id": 1, "name": "Sandy Kane", "location": "Helena, MT" }
{ "_id": 8, "name": "Shayla Ray", "age": 20 }
{ "_id": 6, "name": "Zaynab Hassan", "age": 37 }

BulkWriteOptions options = new BulkWriteOptions().ordered(false);
// Runs a bulk write operation for the specified insert, replace, update, and delete WriteModels in any order
collection.bulkWrite(bulkOperations, options); 

{ "_id": 1, "name": "Sandy Kane", "location": "Helena, MT" }
{ "_id": 8, "name": "Shayla Ray", "age": 20 }
{ "_id": 6, "name": "Zaynab Omar", "age": 37 }

挿入例

この例では、 bulkWrite() メソッドを使用して 2 つのドキュメントを挿入する方法を示しています。一方のドキュメントは db.peopleコレクションに挿入され、もう一方のドキュメントは db.thingsコレクションに挿入されます。 MongoNamespaceインスタンスは、各書き込み操作が適用されるデータベースとコレクションを定義します。

MongoNamespace peopleNamespace = new MongoNamespace("db", "people");
MongoNamespace thingsNamespace = new MongoNamespace("db", "things");
List<ClientNamespacedWriteModel> bulkOperations = new ArrayList<>();
bulkOperations.add(ClientNamespacedWriteModel
   .insertOne(
      peopleNamespace,
      new Document("name", "Julia Smith")
   )
);
bulkOperations.add(ClientNamespacedWriteModel
   .insertOne(
      thingsNamespace,
      new Document("object", "washing machine")
   )
);
ClientBulkWriteResult result = mongoClient.bulkWrite(bulkOperations);

置き換えの例

次の例では、 bulkWrite() メソッドを使用して、db.people コレクションと db.things コレクション内の既存のドキュメントを置き換える方法を示します。

MongoNamespace peopleNamespace = new MongoNamespace("db", "people");
MongoNamespace thingsNamespace = new MongoNamespace("db", "things");
List<ClientNamespacedWriteModel> bulkOperations = new ArrayList<>();
bulkOperations.add(ClientNamespacedWriteModel.replaceOne(
      peopleNamespace,
      Filters.eq("_id", 1),
      new Document("name", "Frederic Hilbert")
   )
);
bulkOperations.add(ClientNamespacedWriteModel.replaceOne(
      thingsNamespace,
      Filters.eq("_id", 1),
      new Document("object", "potato")
   )
);
ClientBulkWriteResult result = mongoClient.bulkWrite(bulkOperations);

この例が正常に実行されると、peopleコレクション内の _id 値が 1 であるドキュメントは、新しいドキュメントに置き換えられます。 _id 値が 1 である thingsコレクション内のドキュメントは、 新しいドキュメントに置き換えられます。

一括書込みオプション

一括書き込み操作を実行中ときにオプションを指定するには、ClientBulkWriteOptions のインスタンスを bulkWrite() メソッドに渡します。

MongoNamespace namespace = new MongoNamespace("db", "people");
ClientBulkWriteOptions options = ClientBulkWriteOptions
        .clientBulkWriteOptions()
        .ordered(false);
List<ClientNamespacedWriteModel> bulkOperations = new ArrayList<>();
bulkOperations.add(
   ClientNamespacedWriteModel.insertOne(
      namespace,
      new Document("_id", 1).append("name", "Rudra Suraj")
   )
);
// Causes a duplicate key error
bulkOperations.add(
   ClientNamespacedWriteModel.insertOne(
      namespace,
      new Document("_id", 1).append("name", "Mario Bianchi")
   )
);
bulkOperations.add(
   ClientNamespacedWriteModel.insertOne(
      namespace,
      new Document("name", "Wendy Zhang")
   )
);
ClientBulkWriteResult result = mongoClient.bulkWrite(bulkOperations, options);

MongoCollection.bulkWrite()

一括操作を実行するには、作成して WriteModel インスタンスのリストを bulkWrite() メソッドに渡します。

6 には異なる WriteModel サブタイプがあります: InsertOneModel、ReplaceOneModel、UpdateOneModel、UpdateManyModel、DeleteOneModel、DeleteManyModel

bulkWrite()メソッドを実行するには次の 2 つの方法があります。

• 順序付き: エラーが発生するまで一括操作を順番に実行します

• 順序付けなし: すべての一括操作を任意の順序で実行し、終了時にエラーを報告します

コレクションbulkWrite コマンドの詳細については、 db を参照してください。 MongoDB Serverマニュアルのコレクション.bulkWrite() メソッド参照。

MongoClient.bulkWrite()

MongoDB Serverバージョン 8.0 以降を実行中配置に接続する場合、MongoClient.bulkWrite() メソッドを使用して、複数のデータベースとコレクションに対して一括操作を一度に実行できます。

クライアント一括操作 を実行するには、ClientNamespacedWriteModel インスタンスのリストを作成してこのメソッドに渡します。

書込み操作を表すために使用される ClientNamespacedWriteModel には 6 つのサブタイプがあります。これらの書込みモデルを構築するには、対応する ClientNamespacedWriteModel メソッド insertOne()、updateOne()、updateMany()、replaceOne()、deleteOne()、deleteMany() を使用できます。これらのメソッドは、書き込み先のデータベースとコレクションを定義する MongoNamespaceオブジェクトを受け取ります。

MongoClient.bulkWrite() メソッドは ClientBulkWriteOptionsオブジェクトを受け取り、コマンドの実行方法に関するさまざまなオプションを指定することもできます。

クライアントbulkWrite コマンドの詳細については、 MongoDB Serverマニュアルの bulkWrite() メソッドに関する参照を参照してください。