/ /

一括操作

Overview

このガイドでは、 Node.jsドライバーを使用して 一括操作 を実行する方法を学習できます。一括操作は、サーバーへの呼び出しの回数を減らすのに役立ちます。各操作のリクエストを送信する代わりに、1 つのアクション内で複数の操作を実行できます。

Tip

一括操作の詳細については、 MongoDB Serverマニュアルの「一括書込み」を参照してください。

一括操作を使用して、コレクションに対して複数の書込み (write) 操作を実行できます。クライアントから一括操作を実行することもできます。これにより、複数の名前空間にわたって一括書込みを実行できます。MongoDBでは、名前空間は<database>.<collection>形式のデータベース名とコレクション名で構成されています。

注意

There is no limit to the amount of write operations that a driver can handle. Drivers group data into batches according to the maxWriteBatchSize, which is 100,000 and cannot be modified. If the batch contains more than 100,000 operations, the driver divides the batch into smaller groups with counts less than or equal to the maxWriteBatchSize. For example, if the operation contains 250,000 operations, the driver creates three batches: two with 100,000 operations and one with 50,000 operations.

このガイドには、次のセクションが含まれています。

Bulk Insert Operations describes how to perform bulk insert operations on your collection or client.
Bulk Replace Operations describes how to perform bulk replace operations on your collection or client.
一括更新操作では、コレクションまたはクライアントに対して一括更新操作を実行する方法について説明します。
Bulk Delete Operations describes how to perform bulk delete operations on your collection or client.
Return Type describes the return object that results from your bulk write operations.
Handling Exceptions describes the exceptions that occur if any of the operations in a bulk write operation fail.
追加情報では、このガイドで言及されている型とメソッドのリソースとAPIドキュメントへのリンクを提供します。

重要

サーバーとドライバーのバージョンの要件

コレクションレベルの一括書き込み操作には、次のバージョンが必要です。

MongoDB Serverバージョン 3.2 以降
Node.jsドライバーバージョン 3.6 以降

クライアントレベルの一括書き込み操作には、次のバージョンが必要です。

MongoDB Serverバージョン 8.0 以降
Node.jsドライバーバージョン 6.10 以降

サンプルデータ

このガイドの例では、Atlasサンプルデータセットに含まれる sample_mflixデータベース内の movies コレクションと users コレクションを使用します。MongoDB Atlasクラスターを無料で作成して、サンプルデータセットをロードする方法については、MongoDBを使い始めるガイドを参照してください。

一括挿入操作

一括挿入操作を実行するには、挿入するドキュメントごとに一括操作モデルを作成します。次に、これらのモデルのリストを bulkWrite() メソッドに渡します。

このセクションでは、次のタイプの一括操作を実行する方法について説明します。

コレクションの一括挿入
クライアント一括挿入

コレクションの一括挿入

コレクションに対して一括挿入操作を実行するには、各操作に対して InsertOneModel を作成します。次に、コレクションで bulkWrite() メソッドを呼び出し、モデルの配列をパラメーターとして渡します。InsertOneModel を作成するには、モデルの documentフィールドを指定し、挿入するドキュメントに設定します。

例

この例では、次のアクションを実行します。

配列内の 2 つの InsertOneModel インスタンスを指定します。各 InsertOneModel は、sample_mflixデータベース内の moviesコレクションに挿入するドキュメントを表します。
moviesコレクションで bulkWrite() メソッドを呼び出し、モデルの配列をパラメーターとして渡します。
挿入されたドキュメントの数を出力します。

const insertModels = [{
    insertOne: {
        document: {
            title: "The Favourite",
            year: 2018,
            rated: "R",
            released: "2018-12-21"
        }
    }
}, {
    insertOne: {
        document: {
            title: "I, Tonya",
            year: 2017,
            rated: "R",
            released: "2017-12-08"
        }
    }
}];
const insertResult = await movies.bulkWrite(insertModels);
console.log(`Inserted documents: ${insertResult.insertedCount}`);

クライアント一括挿入

複数のコレクションまたはデータベースにわたって一括挿入操作を実行するには、各操作に対して ClientBulkWriteModel を作成します。次に、クライアントで bulkWrite() メソッドを呼び出し、モデルの配列をパラメーターとして渡します。

次の表では、挿入操作を指定するために ClientBulkWriteModel に設定できるフィールドについて説明しています。

フィールド	説明
`namespace`	ドキュメントを挿入する名前空間。タイプ: `String`
`name`	実行する操作。挿入操作の場合は、このフィールドを `"insertOne"` に設定します。タイプ: `String`
`document`	挿入するドキュメント。タイプ: `Document`

例

この例では、次のアクションを実行します。

配列内の 3 つの ClientBulkWriteModel インスタンスを指定します。最初の 2 つのモデルは moviesコレクションに挿入するドキュメントを表し、最後のモデルは usersコレクションに挿入するドキュメントを表します。
クライアントで bulkWrite() メソッドを呼び出し、モデルの配列をパラメーターとして渡します。
挿入されたドキュメントの数を出力します。

const clientInserts = [{
    namespace: "sample_mflix.movies",
    name: "insertOne",
    document: {
        title: "The Favourite",
        year: 2018,
        rated: "R",
        released: "2018-12-21"
    }
}, {
    namespace: "sample_mflix.movies",
    name: "insertOne",
    document: {
        title: "I, Tonya",
        year: 2017,
        rated: "R",
        released: "2017-12-08"
    }
}, {
    namespace: "sample_mflix.users",
    name: "insertOne",
    document: {
        name: "Brian Schwartz",
        email: "bschwartz@example.com"
    }
}];
const clientInsertRes = await client.bulkWrite(clientInserts);
console.log(`Inserted documents: ${clientInsertRes.insertedCount}`);

一括置換操作

一括置換操作を実行するには、置き換えるドキュメントごとに一括操作モデルを作成します。次に、これらのモデルのリストを bulkWrite() メソッドに渡します。

このセクションでは、次のタイプの一括操作を実行する方法について説明します。

コレクションの一括置換
クライアントの一括置換

コレクションの一括置換

コレクションに対して一括置換操作を実行するには、各操作に対して ReplaceOneModel を作成します。次に、コレクションで bulkWrite() メソッドを呼び出し、モデルの配列をパラメーターとして渡します。

次の表では、ReplaceOneModel で設定できるフィールドについて説明しています。

フィールド	説明
`filter`	置き換えるドキュメントに一致するフィルター。タイプ: `Document`
`replacement`	置換ドキュメントです。タイプ: `Document`
`collation`	（任意）結果をソートするときに使用する照合。照合の詳細については、「 CRUD操作の構成」ガイドの「照合」セクションを参照してください。タイプ: `String` または `Object`
`hint`	（任意）操作に使用するインデックス。インデックスの詳細については、クエリ最適化のインデックスガイドを参照してください。タイプ: `Bson`
`upsert`	（任意）フィルターに一致するドキュメントがない場合に新しいドキュメントを作成するかどうか。デフォルトでは、このフィールドは `false` に設定されています。タイプ: `Boolean`

例

この例では、次のアクションを実行します。

配列内の 2 つの ReplaceOneModel インスタンスを指定します。 ReplaceOneModel インスタンスには、moviesコレクション内の映画を表すドキュメントを置き換えるための指示が含まれています。
moviesコレクションで bulkWrite() メソッドを呼び出し、モデルの配列をパラメーターとして渡します。
変更されたドキュメントの数を出力します。

const replaceOperations = [{
    replaceOne: {
        filter: {
            title: "The Dark Knight"
        },
        replacement: {
            title: "The Dark Knight Rises",
            year: 2012,
            rating: "PG-13"
        },
        upsert: false
    }
}, {
    replaceOne: {
        filter: {
            title: "Inception"
        },
        replacement: {
            title: "Inception Reloaded",
            year: 2010,
            rating: "PG-13"
        },
        upsert: false
    }
}];
const replaceResult = await movies.bulkWrite(replaceOperations);
console.log(`Modified documents: ${replaceResult.modifiedCount}`);

クライアントの一括置換

複数のコレクションまたはデータベースにわたって一括置換操作を実行するには、各操作に対して ClientBulkWriteModel を作成します。次に、クライアントで bulkWrite() メソッドを呼び出し、モデルの配列をパラメーターとして渡します。

次の表では、置換操作を指定するために ClientBulkWriteModel に設定できるフィールドについて説明しています。

フィールド	説明
`namespace`	ドキュメントを置き換える名前空間空間。タイプ: `String`
`name`	実行する操作。置換操作の場合は、このフィールドを `"replaceOne"` に設定します。タイプ: `String`
`filter`	置き換えるドキュメントに一致するフィルター。タイプ: `Document`
`replacement`	置換ドキュメントです。タイプ: `Document`
`collation`	（任意）結果をソートするときに使用する照合。照合の詳細については、「 CRUD操作の構成」ガイドの「照合」セクションを参照してください。タイプ: `String` または `Object`
`hint`	（任意）操作に使用するインデックス。インデックスの詳細については、クエリ最適化のインデックスガイドを参照してください。タイプ: `Bson`

例

この例では、次のアクションを実行します。

配列内の 3 つの ClientBulkWriteModel インスタンスを指定します。最初の 2 つのモデルには moviesコレクション内のドキュメントの置換手順が含まれ、最後のモデルには usersコレクション内のドキュメントの置換手順が含まれています。
クライアントで bulkWrite() メソッドを呼び出し、モデルの配列をパラメーターとして渡します。
変更されたドキュメントの数を出力します。

const clientReplacements = [{
    namespace: "sample_mflix.movies",
    name: "replaceOne",
    filter: {
        title: "The Dark Knight"
    },
    replacement: {
        title: "The Dark Knight Rises",
        year: 2012,
        rating: "PG-13"
    }
}, {
    namespace: "sample_mflix.movies",
    name: "replaceOne",
    filter: {
        title: "Inception"
    },
    replacement: {
        title: "Inception Reloaded",
        year: 2010,
        rating: "PG-13"
    }
}, {
    namespace: "sample_mflix.users",
    name: "replaceOne",
    filter: {
        name: "April Cole"
    },
    replacement: {
        name: "April Franklin",
        email: "aprilfrank@example.com"
    }
}];
const clientReplaceRes = await client.bulkWrite(clientReplacements);
console.log(`Modified documents: ${clientReplaceRes.modifiedCount}`);

一括更新操作

一括更新操作を実行するには、実行する更新ごとに一括操作モデルを作成します。次に、これらのモデルのリストを bulkWrite() メソッドに渡します。

このセクションでは、次のタイプの一括操作を実行する方法について説明します。

コレクションの一括更新
クライアントの一括更新

コレクションの一括更新

コレクションに対して一括更新操作を実行するには、各操作に対して UpdateOneModel または UpdateManyModel を作成します。次に、コレクションで bulkWrite() メソッドを呼び出し、モデルの配列をパラメーターとして渡します。UpdateOneModel はフィルターに一致するドキュメントを1 つだけ更新し、UpdateManyModel はフィルターに一致するすべてのドキュメントを更新します。

次の表では、UpdateOneModel または UpdateManyModel で設定できるフィールドについて説明しています。

フィールド	説明
`filter`	更新する 1 つ以上のドキュメントに一致するフィルター。`UpdateOneModel` で指定すると、最初に一致するドキュメントのみが更新されます。`UpdateManyModel` で指定すると、一致するすべてのドキュメントが更新されます。タイプ: `Document`
`update`	実行される更新。タイプ: `Document`
`arrayFilters`	（任意）配列値フィールドを更新する場合に更新を適用する配列要素を指定するフィルターのセット。タイプ: `Array`
`collation`	（任意）結果をソートするときに使用する照合。照合の詳細については、「 CRUD操作の構成」ガイドの「照合」セクションを参照してください。タイプ: `Object`
`hint`	（任意）操作に使用するインデックス。インデックスの詳細については、クエリ最適化のインデックスガイドを参照してください。タイプ: `String or Object`
`upsert`	（任意）フィルターに一致するドキュメントがない場合に新しいドキュメントを作成するかどうか。デフォルトでは、このフィールドは `false` に設定されています。タイプ: `Boolean`

例

この例では、次のアクションを実行します。

配列で UpdateOneModel インスタンスと UpdateManyModelインスタンスを指定します。これらのモデルには、 moviesコレクション内の映画を表すドキュメントを更新するための指示が含まれています。
moviesコレクションで bulkWrite() メソッドを呼び出し、モデルの配列をパラメーターとして渡します。
変更されたドキュメントの数を出力します。

const updateOperations = [{
    updateOne: {
        filter: {
            title: "Interstellar"
        },
        update: {
            $set: {
                title: "Interstellar Updated",
                genre: "Sci-Fi Adventure"
            }
        },
        upsert: true
    }
}, {
    updateMany: {
        filter: {
            rated: "PG-13"
        },
        update: {
            $set: {
                rated: "PG-13 Updated",
                genre: "Updated Genre"
            }
        }
    }
}];
const updateResult = await movies.bulkWrite(updateOperations);
console.log(`Modified documents: ${updateResult.modifiedCount}`);

クライアントの一括更新

複数のコレクションまたはデータベースにわたって一括更新操作を実行するには、各操作に対して ClientBulkWriteModel を作成します。次に、クライアントで bulkWrite() メソッドを呼び出し、モデルの配列をパラメーターとして渡します。

次の表では、更新操作を指定するために ClientBulkWriteModel に設定できるフィールドについて説明しています。

フィールド	説明
`namespace`	ドキュメントを更新する名前空間。タイプ: `String`
`name`	実行する操作。更新操作では、このフィールドを`"updateOne"` または `"updateMany"` に設定します。タイプ: `String`
`filter`	更新する 1 つ以上のドキュメントに一致するフィルター。モデル `name` を `"updateOne"` に設定すると、最初に一致するドキュメントのみが更新されます。`name` を `"updateMany"` に設定すると、一致するすべてのドキュメントが更新されます。タイプ: `Document`
`update`	実行される更新。タイプ: `Document` または `Document[]`
`arrayFilters`	（任意）配列値フィールドを更新する場合に更新を適用する配列要素を指定するフィルターのセット。タイプ: `Document[]`
`collation`	（任意）結果をソートするときに使用する照合。照合の詳細については、「 CRUD操作の構成」ガイドの「照合」セクションを参照してください。タイプ: `Document`
`hint`	（任意）操作に使用するインデックス。インデックスの詳細については、クエリ最適化のインデックスガイドを参照してください。タイプ: `Document` または `String`
`upsert`	（任意）フィルターに一致するドキュメントがない場合に新しいドキュメントを作成するかどうか。デフォルトでは、このフィールドは `false` に設定されています。タイプ: `Boolean`

例

この例では、次のアクションを実行します。

配列内の 2 つの ClientBulkWriteModel インスタンスを指定します。最初のモデルは moviesコレクションの更新操作数を指定し、2 番目のモデルは usersコレクションの更新 1 つの操作を指定します。
クライアントで bulkWrite() メソッドを呼び出し、モデルの配列をパラメーターとして渡します。
変更されたドキュメントの数を出力します。

const clientUpdates = [{
    namespace: "sample_mflix.movies",
    name: "updateMany",
    filter: {
        rated: "PG-13"
    },
    update: {
        $set: {
            rated: "PG-13 Updated",
            genre: "Updated Genre"
        }
    },
    upsert: false
}, {
    namespace: "sample_mflix.users",
    name: "updateOne",
    filter: {
        name: "Jon Snow"
    },
    update: {
        $set: {
            name: "Aegon Targaryen",
            email: "targaryen@example.com"
        }
    },
    upsert: false
}];
const clientUpdateRes = await client.bulkWrite(clientUpdates);
console.log(`Modified documents: ${clientUpdateRes.modifiedCount}`);

一括削除操作

一括削除操作を実行するには、削除操作ごとに一括操作モデルを作成します。次に、これらのモデルのリストを bulkWrite() メソッドに渡します。

このセクションでは、次のタイプの一括操作を実行する方法について説明します。

コレクションの一括削除
クライアントの一括削除

コレクションの一括削除

コレクションに対して一括削除操作を実行するには、各操作に対して DeleteOneModel または DeleteManyModel を作成します。次に、コレクションで bulkWrite() メソッドを呼び出し、モデルの配列をパラメーターとして渡します。DeleteOneModel はフィルターに一致するドキュメントを1 つだけ削除し、DeleteManyModel はフィルターに一致するすべてのドキュメントを削除します。

次の表では、DeleteOneModel または DeleteManyModel で設定できるフィールドについて説明しています。

フィールド	説明
`filter`	削除したい 1 つ以上のドキュメントに一致するフィルター。`DeleteOneModel` で指定すると、最初に一致したドキュメントのみが削除されます。`DeleteManyModel` で指定すると、一致するすべてのドキュメントが削除されます。タイプ: `Document`
`collation`	（任意）結果をソートするときに使用する照合。照合の詳細については、「 CRUD操作の構成」ガイドの「照合」セクションを参照してください。タイプ: `Object`
`hint`	（任意）操作に使用するインデックス。インデックスの詳細については、クエリ最適化のインデックスガイドを参照してください。タイプ: `String or Object`

例

この例では、次のアクションを実行します。

配列で DeleteOneModel インスタンスと DeleteManyModelインスタンスを指定します。これらのモデルには、moviesコレクション内のドキュメントを削除するための手順が含まれています。
moviesコレクションで bulkWrite() メソッドを呼び出し、モデルの配列をパラメーターとして渡します。
削除されたドキュメントの数を出力します。

const deleteOperations = [{
    deleteOne: {
        filter: {
            title: "Dunkirk"
        }
    }
}, {
    deleteMany: {
        filter: {
            rated: "R"
        }
    }
}];
const deleteResult = await movies.bulkWrite(deleteOperations);
console.log(`Deleted documents: ${deleteResult.deletedCount}`);

クライアントの一括削除

複数のコレクションまたはデータベースにわたって一括削除操作を実行するには、各操作に対して ClientBulkWriteModel を作成します。次に、クライアントで bulkWrite() メソッドを呼び出し、モデルの配列をパラメーターとして渡します。

次の表では、削除操作を指定するために ClientBulkWriteModel に設定できるフィールドについて説明しています。

フィールド	説明
`namespace`	ドキュメントを削除する名前空間空間。タイプ: `String`
`name`	実行する操作。削除操作の場合は、このフィールドを `"deleteOne"` または `"deleteMany"` に設定します。タイプ: `String`
`filter`	削除したい 1 つ以上のドキュメントに一致するフィルター。モデル `name` を `"deleteOne"` に設定すると、最初に一致したドキュメントのみが削除されます。`name` を `"deleteMany"` に設定すると、一致するドキュメントがすべて削除されます。タイプ: `Document`
`hint`	（任意）操作に使用するインデックス。インデックスの詳細については、クエリ最適化のインデックスガイドを参照してください。タイプ: `Document` または `String`
`collation`	（任意）結果をソートするときに使用する照合。照合の詳細については、「 CRUD操作の構成」ガイドの「照合」セクションを参照してください。タイプ: `Document`

例

この例では、次のアクションを実行します。

配列内の 2 つの ClientBulkWriteModel インスタンスを指定します。最初のモデルは moviesコレクションに対して多数の削除操作を指定し、2 番目のモデルは usersコレクションに対して 1 つの削除操作を指定します。
クライアントで bulkWrite() メソッドを呼び出し、モデルの配列をパラメーターとして渡します。
変更されたドキュメントの数を出力します。

const clientDeletes = [{
    namespace: "sample_mflix.movies",
    name: "deleteMany",
    filter: {
        rated: "R"
    }
}, {
    namespace: "sample_mflix.users",
    name: "deleteOne",
    filter: {
        email: "emilia_clarke@gameofthron.es"
    }
}];
const clientDeleteRes = await client.bulkWrite(clientDeletes);
console.log(`Deleted documents: ${clientDeleteRes.deletedCount}`);

戻り値の型

BulkWriteResult

Collection.bulkWrite() メソッドは BulkWriteResultオブジェクトを返します。これは一括操作に関する情報を提供します。

次の表は、BulkWriteResultオブジェクトのフィールドを説明します。

フィールド	説明
`insertedCount`	挿入されたドキュメントの数
`matchedCount`	一致したドキュメントの数
`modifiedCount`	更新されたドキュメントの数
`upsertedCount`	アップサートされた文書の数
`deletedCount`	削除されたドキュメントの数

ClientBulkWriteResult

MongoClient.bulkWrite() メソッドは、クライアントの一括書込み操作に関する情報を含む ClientBulkWriteResultオブジェクトを返します。

次の表は、ClientBulkWriteResultオブジェクトのフィールドを説明します。

フィールド	説明
`acknowledged`	一括書き込みが確認されたかどうかを示すブール値値
`insertedCount`	挿入されたドキュメントの数
`matchedCount`	一致したドキュメントの数
`modifiedCount`	更新されたドキュメントの数
`upsertedCount`	アップサートされた文書の数
`deletedCount`	削除されたドキュメントの数
`insertResults`	成功した各挿入操作の結果
`updateResults`	成功した各更新操作の結果
`deleteResults`	成功した各削除操作の結果

例外の処理

コレクションの一括書込みの例外

コレクションで呼び出された一括書き込み操作が失敗した場合、ordered オプションが true に設定されている場合、 Node.jsドライバーは MongoBulkWriteError をスローし、それ以上の操作を実行しません。ordered が false に設定されている場合、後続の操作への続行が試行されます。

Tip

To learn more about ordered and unordered bulk operations, see the Ordered vs Unordered Operations section in the Bulk Write guide from the MongoDB Server manual.

MongoBulkWriteErrorオブジェクトには次のプロパティが含まれています。

プロパティ	説明
`message`	エラーメッセージ。タイプ: `String`
`writeErrors`	一括書き込み操作中に発生したエラーの配列。タイプ: `BulkWriteError[]`
`writeConcernErrors`	一括書き込み操作の実行中に発生した書込み保証 (write concern) エラーです。タイプ: `WriteConnectionError[]`
`result`	例外がスローされる前に実行された成功した操作の結果。タイプ: `BulkWriteResult[]`
`err`	基礎のエラーオブジェクト。これには詳細が含まれる場合があります。タイプ: `Error`

クライアント一括書込みの例外

クライアントで呼び出される一括書き込み操作が失敗した場合、 Node.jsドライバーは MongoClientBulkWriteError を生成します。デフォルトでは、ドライバーはエラーが発生すると後続の操作を実行しません。ordered オプションを bulkWrite() メソッドに渡し、それを false に設定すると、ドライバーは残りの操作を引き続き試行します。

MongoClientBulkWriteErrorオブジェクトには次のプロパティが含まれています。

プロパティ	説明
`writeConcernErrors`	各書込み保証 (write concern)エラーを指定するドキュメントの配列。タイプ: `Document[]`
`writeErrors`	個々の書き込み (write) 操作中に発生したエラーのマップ。タイプ: `Map<number, ClientBulkWriteError>`
`partialResult`	エラー前の操作の進行状況を反映したクライアント一括書込みの部分的な結果。タイプ: `ClientBulkWriteResult`

bulkWrite() の例: 完全なファイル

注意

セットアップ例

This example connects to an instance of MongoDB by using a connection URI. To learn more about connecting to your MongoDB instance, see the Connect to MongoDB guide. This example also uses the movies collection in the sample_mflix database included in the Atlas sample datasets. You can load them into your database on a free cluster in MongoDB Atlas following the MongoDB Get Started.

次のコードは、sample_mflixデータベース内の theatersコレクションに対して一括書き込み操作を実行する完全なスタンドアロンファイルです。operations パラメータには、insertOne、updateMany、deleteOne の書き込み操作の例が含まれています。

1 // Bulk write operation
2 
3 // Import MongoClient from the MongoDB node driver package
4 const { MongoClient } = require("mongodb");
5 
6 // Replace the uri string with your MongoDB deployment's connection string
7 const uri = "<connection string uri>";
8 
9 const client = new MongoClient(uri);
10 
11 async function run() {
12   try {
13     const database = client.db("sample_mflix");
14     const theaters = database.collection("theaters");
15 
16     // Insert a new document into the "theaters" collection
17     const result = await theaters.bulkWrite([
18       {
19         insertOne: {
20           document: {
21             location: {
22               address: {
23                 street1: "3 Main St.",
24                 city: "Anchorage",
25                 state: "AK",
26                 zipcode: "99501",
27               },
28             },
29           },
30         },
31       },
32       {
33         insertOne: {
34           document: {
35             location: {
36               address: {
37                 street1: "75 Penn Plaza",
38                 city: "New York",
39                 state: "NY",
40                 zipcode: "10001",
41               },
42             },
43           },
44         },
45       },
46       {
47         // Update documents that match the specified filter
48         updateMany: {
49           filter: { "location.address.zipcode": "44011" },
50           update: { $set: { is_in_ohio: true } },
51           upsert: true,
52         },
53       },
54       {
55         // Delete a document that matches the specified filter
56         deleteOne: { filter: { "location.address.street1": "221b Baker St" } },
57       },
58     ]);
59     // Log the result of the bulk write operation 
60     console.log(result);
61   } finally {
62     // Close the database connection when the operations are completed or if an error occurs
63     await client.close();
64   }
65 }
66 run().catch(console.dir);

1 import { MongoClient } from "mongodb";
2 
3 // Replace the uri string with your MongoDB deployment's connection string.
4 const uri = "<connection string uri>";
5 
6 const client = new MongoClient(uri);
7 
8 interface Address {
9   street1: string;
10   city: string;
11   state: string;
12   zipcode: string;
13 }
14 
15 interface Theater {
16   location: { address: Address };
17   is_in_ohio?: boolean;
18 }
19 
20 async function run() {
21   try {
22     const database = client.db("sample_mflix");
23     const theaters = database.collection<Theater>("theaters");
24 
25     const result = await theaters.bulkWrite([
26       {
27         insertOne: {
28           document: {
29             location: {
30               address: {
31                 street1: "3 Main St.",
32                 city: "Anchorage",
33                 state: "AK",
34                 zipcode: "99501",
35               },
36             },
37           },
38         },
39       },
40       {
41         insertOne: {
42           document: {
43             location: {
44               address: {
45                 street1: "75 Penn Plaza",
46                 city: "New York",
47                 state: "NY",
48                 zipcode: "10001",
49               },
50             },
51           },
52         },
53       },
54       {
55         updateMany: {
56           // Important: You lose type safety when you use dot notation in queries
57           filter: { "location.address.zipcode": "44011" },
58           update: { $set: { is_in_ohio: true } },
59           upsert: true,
60         },
61       },
62       {
63         deleteOne: {
64           filter: { "location.address.street1": "221b Baker St" },
65         },
66       },
67     ]);
68 
69     console.log(result);
70   } finally {
71     await client.close();
72   }
73 }
74 run().catch(console.dir);

上記の例を実行すると、次の出力が生成されます。

BulkWriteResult {
  insertedCount: 2,
  matchedCount: 1,
  modifiedCount: 1,
  deletedCount: 0,
  upsertedCount: 0,
  upsertedIds: {},
  insertedIds: {
    '0': new ObjectId("..."),
    '1': new ObjectId("...")
  }
}

詳細情報

一括操作の詳細については、 MongoDB Serverマニュアルの「一括書込み」を参照してください。

API ドキュメント

このガイドで説明したメソッドや型の詳細については、次の API ドキュメントを参照してください。

戻る

Delete Documents

複合演算子

1	// Bulk write operation
2
3	// Import MongoClient from the MongoDB node driver package
4	const { MongoClient } = require("mongodb");
5
6	// Replace the uri string with your MongoDB deployment's connection string
7	const uri = "<connection string uri>";
8
9	const client = new MongoClient(uri);
10
11	async function run() {
12	try {
13	const database = client.db("sample_mflix");
14	const theaters = database.collection("theaters");
15
16	// Insert a new document into the "theaters" collection
17	const result = await theaters.bulkWrite([
18	{
19	insertOne: {
20	document: {
21	location: {
22	address: {
23	street1: "3 Main St.",
24	city: "Anchorage",
25	state: "AK",
26	zipcode: "99501",
27	},
28	},
29	},
30	},
31	},
32	{
33	insertOne: {
34	document: {
35	location: {
36	address: {
37	street1: "75 Penn Plaza",
38	city: "New York",
39	state: "NY",
40	zipcode: "10001",
41	},
42	},
43	},
44	},
45	},
46	{
47	// Update documents that match the specified filter
48	updateMany: {
49	filter: { "location.address.zipcode": "44011" },
50	update: { $set: { is_in_ohio: true } },
51	upsert: true,
52	},
53	},
54	{
55	// Delete a document that matches the specified filter
56	deleteOne: { filter: { "location.address.street1": "221b Baker St" } },
57	},
58	]);
59	// Log the result of the bulk write operation
60	console.log(result);
61	} finally {
62	// Close the database connection when the operations are completed or if an error occurs
63	await client.close();
64	}
65	}
66	run().catch(console.dir);

1	import { MongoClient } from "mongodb";
2
3	// Replace the uri string with your MongoDB deployment's connection string.
4	const uri = "<connection string uri>";
5
6	const client = new MongoClient(uri);
7
8	interface Address {
9	street1: string;
10	city: string;
11	state: string;
12	zipcode: string;
13	}
14
15	interface Theater {
16	location: { address: Address };
17	is_in_ohio?: boolean;
18	}
19
20	async function run() {
21	try {
22	const database = client.db("sample_mflix");
23	const theaters = database.collection<Theater>("theaters");
24
25	const result = await theaters.bulkWrite([
26	{
27	insertOne: {
28	document: {
29	location: {
30	address: {
31	street1: "3 Main St.",
32	city: "Anchorage",
33	state: "AK",
34	zipcode: "99501",
35	},
36	},
37	},
38	},
39	},
40	{
41	insertOne: {
42	document: {
43	location: {
44	address: {
45	street1: "75 Penn Plaza",
46	city: "New York",
47	state: "NY",
48	zipcode: "10001",
49	},
50	},
51	},
52	},
53	},
54	{
55	updateMany: {
56	// Important: You lose type safety when you use dot notation in queries
57	filter: { "location.address.zipcode": "44011" },
58	update: { $set: { is_in_ohio: true } },
59	upsert: true,
60	},
61	},
62	{
63	deleteOne: {
64	filter: { "location.address.street1": "221b Baker St" },
65	},
66	},
67	]);
68
69	console.log(result);
70	} finally {
71	await client.close();
72	}
73	}
74	run().catch(console.dir);

一括操作

Overview

サンプル データ

一括挿入操作

コレクションの一括挿入

例

クライアント一括挿入

例

一括置換操作

コレクションの一括置換

例

クライアントの一括置換

例

一括更新操作

コレクションの一括更新

例

クライアントの一括更新

例

一括削除操作

コレクションの一括削除

例

クライアントの一括削除

例

戻り値の型

BulkWriteResult

ClientBulkWriteResult

例外の処理

コレクションの一括書込みの例外

クライアント一括書込みの例外

bulkWrite() の例: 完全なファイル

詳細情報

API ドキュメント

サンプルデータ