一括操作

挿入操作

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

val juneDoc = InsertOneModel(Person(3, "June Carrie", 17))
val kevinDoc = InsertOneModel(Person(4, "Kevin Moss", 22))

try {
    val bulkOperations = listOf(
        (InsertOneModel(Person(1, "James Smith", 13))),
        (InsertOneModel(Person(3, "Colin Samuels")))
    )
    val bulkWrite = collection.bulkWrite(bulkOperations)
} catch (e: MongoBulkWriteException) {
    println("A MongoBulkWriteException occurred with the following message: " + e.message)
}

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を作成します。

val filter = Filters.eq("_id", 1)
val insert = Person(1, "Celine Stork", location = "San Diego, CA")
val doc = ReplaceOneModel(filter, insert)

val opts = ReplaceOptions().sort(Sorts.ascending("_id"))

アップデート操作

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

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

val filter = Filters.eq("_id", 2)
val update = Updates.inc(Person::age.name, 1)
val doc = UpdateOneModel<Person>(filter, update)

val opts = UpdateOptions().sort(Sorts.ascending("_id"))

削除操作

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

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

val deleteId1 = DeleteOneModel<Person>(Filters.eq("_id", 1))
val deleteAgeLt30 = DeleteManyModel<Person>(Filters.lt(Person::age.name, 30))

実行順序

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

val insertMdl = InsertOneModel(Person(6, "Zaynab Omar", 37))
val replaceMdl = ReplaceOneModel(
    Filters.eq("_id", 1),
    Person(1, "Sandy Kane", location = "Helena, MT")
)
val updateMdl  = UpdateOneModel<Person>(
        Filters.eq("_id", 6),
        Updates.set(Person::name.name, "Zaynab Hassan")
    )
val deleteMdl = DeleteManyModel<Person>(Filters.gt(Person::age.name, 50))
val bulkOperations = listOf(
    insertMdl,
    replaceMdl,
    updateMdl,
    deleteMdl
)
val result = 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 }

val options = BulkWriteOptions().ordered(false)
val unorderedResult = 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 つのドキュメントを挿入する方法を示しています。 一方のドキュメントは sample_db.peopleコレクションに挿入され、もう一方のドキュメントは sample_db.objectsコレクションに挿入されます。 MongoNamespaceインスタンスは、各書き込み操作が適用されるデータベースとコレクションを定義します。

val docsToInsert = mutableListOf<ClientNamespacedWriteModel>()
docsToInsert.add(
    ClientNamespacedWriteModel
        .insertOne(
            MongoNamespace("sample_db", "people"),
            Person(2, "Julia Smith")
        )
)
docsToInsert.add(
    ClientNamespacedWriteModel
        .insertOne(
            MongoNamespace("sample_db", "objects"),
            Object(2, "washing machine")
        )
)
val clientBulkResult = client.bulkWrite(docsToInsert)

アップデート操作

The following example shows how to use the bulkWrite() method to update existing documents in the sample_db.people and sample_db.objects collections:

val docsToInsert = mutableListOf<ClientNamespacedWriteModel>()
docsToInsert.add(
    ClientNamespacedWriteModel
        .updateOne(
            MongoNamespace("sample_db", "people"),
            Filters.eq(Person::name.name, "Freya Polk"),
            Updates.inc(Person::age.name, 1)
        )
)
docsToInsert.add(
    ClientNamespacedWriteModel
        .updateMany(
            MongoNamespace("sample_db", "objects"),
            Filters.eq(Object::category.name, "electronic"),
            Updates.set(Object::manufacturer.name, "Premium Technologies")
        )
)
val clientBulkResult = client.bulkWrite(docsToInsert)

This example increments the value of the age field by 1 in the document that has a name value of "Freya Polk" in the people collection. It also sets the value of the manufacturer field to "Premium Technologies" in all documents that have a category value of "electronic" in the objects collection.

If multiple documents match the query filter specified in a ClientNamespacedUpdateOneModel instance, the operation updates the first result. You can specify a sort order in a ClientUpdateOneOptions instance to apply an order to matched documents before the server performs the update operation, as shown in the following code:

val options =  ClientUpdateOneOptions
    .clientUpdateOneOptions()
    .sort(Sorts.ascending("_id"))

置換操作

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

val docsReplacements = mutableListOf<ClientNamespacedWriteModel>()
docsReplacements.add(
    ClientNamespacedWriteModel
        .replaceOne(
            MongoNamespace("sample_db", "people"),
            Filters.eq(Person::id.name, 1),
            Person(1, "Frederic Hilbert")
        )
)
docsReplacements.add(
    ClientNamespacedWriteModel
        .replaceOne(
            MongoNamespace("sample_db", "objects"),
            Filters.eq(Object::id.name, 1),
            Object(1, "ironing board")
        )
)
val clientBulkResult = client.bulkWrite(docsReplacements)

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

If multiple documents match the query filter specified in a ClientNamespacedReplaceOneModel instance, the operation replaces the first result. You can specify a sort order in a ClientReplaceOneOptions instance to apply an order to matched documents before the driver performs the replace operation, as shown in the following code:

val options =  ClientReplaceOneOptions
    .clientReplaceOneOptions()
    .sort(Sorts.ascending("_id"))

一括書込みオプション

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

val namespace = MongoNamespace("sample_db", "people")
val options = ClientBulkWriteOptions
    .clientBulkWriteOptions()
    .ordered(false)
val bulkOperations = listOf(
    ClientNamespacedWriteModel.insertOne(
        namespace,
        Person(2, "Rudra Suraj")
    ),
    // Causes duplicate key error
    ClientNamespacedWriteModel.insertOne(
        namespace,
        Person(2, "Wendy Zhang")
    ),
    ClientNamespacedWriteModel.insertOne(
        namespace,
        Person(4, "Mario Bianchi")
    )
)
val result = client.bulkWrite(bulkOperations, options)

MongoCollection.bulkWrite()

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

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

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

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

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

コレクションbulkWrite コマンドの詳細については、 db を参照してください。コレクション.bulkWrite()MongoDB参照をサーバーしてください。

MongoClient.bulkWrite()

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

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

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

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

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