/ /

一括操作

Overview

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

Tip

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

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

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

一括挿入操作では、コレクションまたはクライアントに対して一括挿入操作を実行する方法について説明します。
一括置換操作では、コレクションまたはクライアントに対して一括置換操作を実行する方法について説明します。
一括更新操作では、コレクションまたはクライアントに対して一括更新操作を実行する方法について説明します。
一括削除操作では、コレクションまたはクライアントに対して一括削除操作を実行する方法について説明します。
戻り値の型は、一括書き込み操作の結果として返されるオブジェクトを記述します。
例外の処理では、一括書込み操作のいずれかの操作が失敗した場合に発生する例外について説明します。
追加情報では、このガイドで言及されている型とメソッドのリソースと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}`);

Inserted documents: 2

クライアント一括挿入

複数のコレクションまたはデータベースにわたって一括挿入操作を実行するには、各操作に対して 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}`);

Inserted documents: 3

一括置換操作

一括置換操作を実行するには、置き換えるドキュメントごとに一括操作モデルを作成します。次に、これらのモデルのリストを 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}`);

Modified documents: 2

クライアントの一括置換

複数のコレクションまたはデータベースにわたって一括置換操作を実行するには、各操作に対して 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}`);

Modified documents: 3

一括更新操作

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

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

コレクションの一括更新

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

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

フィールド	説明
`filter`	アップデートする 1 つ以上のドキュメントに一致するフィルター。`UpdateOneModelUpdateManyModel` で指定すると、最初に一致するドキュメントのみがアップデートされます。で指定すると、一致するすべてのドキュメントが更新されます。タイプ:`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}`);

Modified documents: 2320

クライアントの一括更新

複数のコレクションまたはデータベースにわたって一括更新操作を実行するには、各操作に対して 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}`);

Modified documents: 2320

一括削除操作

一括削除操作を実行するには、削除操作ごとに一括操作モデルを作成します。次に、これらのモデルのリストを 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}`);

Deleted documents: 5538

クライアントの一括削除

複数のコレクションまたはデータベースにわたって一括削除操作を実行するには、各操作に対して 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}`);

Deleted documents: 5538

戻り値の型

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

順序付き一括操作と順序なし一括操作の詳細については、 MongoDB Serverマニュアルの一括書込みガイドの「順序付き操作と順序なし操作」セクションを参照してください。

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() の例: 完全なファイル

注意

セットアップ例

この例では、接続 URI を使用してMongoDBのインスタンスに接続します。MongoDBインスタンスへの接続の詳細については、MongoDBへの接続ガイドを参照してください。この例では、Atlasサンプルデータセットに含まれる sample_mflixデータベースの moviesコレクションも使用します。MongoDB の使用開始に従って、 MongoDB Atlasの無料階層のデータベースにロードできます。

次のコードは、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

Tip

重要

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

サンプル データ

一括挿入操作

コレクションの一括挿入

例

クライアント一括挿入

例

一括置換操作

コレクションの一括置換

例

クライアントの一括置換

例

一括更新操作

コレクションの一括更新

例

クライアントの一括更新

例

一括削除操作

コレクションの一括削除

例

クライアントの一括削除

例

戻り値の型

BulkWriteResult

ClientBulkWriteResult

例外の処理

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

Tip

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

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

注意

セットアップ例

詳細情報

API ドキュメント

サンプルデータ