/ /

CRUDコマンド

Docs Home

bulkWrite （データベースコマンド）

定義

bulkWrite

バージョン8.0の新機能。

Starting in MongoDB 8.0, you can use the new bulkWrite command to perform many insert, update, and delete operations on multiple collections in one request. The existing db.collection.bulkWrite() method only allows you to modify one collection in one request.

bulkWriteコマンドで各コレクションを指定するには、名前空間（データベースとコレクション名）を使用します。

互換性

このコマンドは、次の環境でホストされている配置で使用できます。

MongoDB Atlas: The fully managed service for MongoDB deployments in the cloud

注意

This command is supported in all MongoDB Atlas clusters. For information on Atlas support for all commands, see Unsupported Commands.

MongoDB Enterprise: サブスクリプションベースの自己管理型 MongoDB バージョン
MongoDB Community: ソースが利用可能で、無料で使用できる自己管理型の MongoDB のバージョン

構文

コマンドの構文は次のとおりです。

db.adminCommand( {
   bulkWrite: 1,
   // Include the insert, update, and delete operations
   // in the ops array
   ops: [
      {
         insert: <integer>,  // Namespace ID index for insert operation.
                             // Must match a namespace ID index in
                             // ns specified later in the nsInfo array.
         document: <document>
      },
      {
         update: <integer>,  // Namespace ID index for update operation
         filter: <document>,
         updateMods: <document>,
         arrayFilters: [ <filterDocument0>, <filterDocument1>, ...  ],
         multi: <boolean>,
         hint: <document>,
         constants: <document>,
         collation: <document>
      },
      {
         delete: <integer>,  // Namespace ID index for delete operation
         filter: <document>,
         multi: <boolean>,
         hint: <document>,
         collation: <document>
      },
      ...
      // Additional insert, update, and delete operations in any order
      ...
   ],
   // Include the namespaces with collections to modify
   // in the nsInfo array. You can add multiple namespaces here.
   nsInfo: [
      {
         ns: <string>,  // Namespace (database and collection name) to modify.
                        // Each operation namespace ID index
                        // specified in the earlier ops array must
                        // match a namespace ID index here.
         collectionUUID: <string>,
         encryptionInformation: <document>
      },
      ...
      // Additional namespaces
      ...
   ],
   // Additional fields
   ordered: <boolean>,
   bypassDocumentValidation: <boolean>,
   comment: <string>,
   let: <document>,
   errorsOnly: <boolean>,
   cursor: { batchSize: <integer> },
   maxTimeMS: <integer>,
   writeConcern: <string>
} )

コマンド構文では、複数のを指定できます。

ops配列内で任意の順序で挿入、アップデート、削除操作が実行できます。
nsInfo配列内の操作の名前空間。操作を名前空間と一致させるには、同じ名前空間IDインデックスを使用します。インデックスは0から開始されます。シャーディングされたコレクションを使用できます。

コマンドフィールド

このコマンドは、次のフィールドを使用します。

フィールド	タイプ	必要性	説明
`insert`	integer	必須	挿入操作の名前空間IDインデックス。この操作は、 `nsInfo`配列の`ns`フィールドの名前空間IDインデックスと一致する必要があります。インデックスは`0`から開始されます。
`document`	ドキュメント	必須	コレクションに挿入するドキュメント。
`update`	integer	必須	更新操作の名前空間IDインデックス。この操作は、 `nsInfo`配列の`ns`フィールドの名前空間IDインデックスと一致する必要があります。インデックスは`0`から開始されます。
`filter`	ドキュメント	任意	アップデートまたは削除操作のドキュメントを制限するクエリセレクター。
`updateMods`	ドキュメント	任意	コレクションに対して実行する更新操作。次のいずれかを指定できます。更新演算子式を含むドキュメント。更新用のステージを持つ`[ <stage1>, <stage2>, ... ]`形式の集計パイプライン。
`arrayFilters`	ドキュメント配列	任意	配列フィールドの更新操作で変更するドキュメントを指定するフィルタードキュメントの配列。詳細については、「 `arrayFilters`を使用した配列更新操作」を参照してください。
`multi`	ブール値	任意	`multi`フィールドが`true`の場合、更新操作または削除操作により、ドキュメント`filter`に一致するすべてのドキュメントが更新または削除されます。 `false`の場合、操作によってドキュメント`filter`と一致する最初のドキュメントが更新または削除されます。マルチドキュメントトランザクションの詳細については、「トランザクション」を参照してください。デフォルトは、`false` に設定されています。
`hint`	ドキュメント	任意	ドキュメント`filter`に使用するインデックス。インデックスが存在しない場合、更新操作はエラーを返します。
`constants`	ドキュメント	任意	集計パイプラインカスタム更新の制約。
`collation`	ドキュメント	任意	アップデートまたは削除操作の照合。
`delete`	integer	必須	削除操作の名前空間IDインデックス。この操作は、 `nsInfo`配列の`ns`フィールドの名前空間IDインデックスと一致する必要があります。インデックスは`0`から開始されます。
`ns`	string	必須	操作の名前空間（データベースとコレクション）。 `ops`の各操作の名前空間IDインデックスを、 `ns`の一致する名前空間配列インデックスに設定します。インデックスは`0`から開始されます。
`collectionUUID`	string	任意	操作のコレクションを指定するUUIDの 16進値。
`encryptionInformation`	ドキュメント	任意	操作の暗号化情報スキーマとトークン。詳細については、「暗号化スキーマ」を参照してください。
`ordered`	ブール値	任意	`true`の場合は、順序付き操作を実行します。それ以外の場合は、順序なし操作を実行します。順序付けられた操作は直列で実行される。エラーが発生した場合は、残りの操作はすべてキャンセルされます。順序付けられていない操作が並列に実行されます。エラーが発生した場合、残りのステートメントが実行されます。パフォーマンスを向上させるために、サーバーによって操作の順序が並べ替えられる場合があります。したがって、アプリケーションは操作の実行順序に依存すべきではありません。デフォルトは、`true` に設定されています。
`bypassDocumentValidation`	ブール値	任意	`true`の場合、操作はスキーマ検証をバイパスします。`false`の場合、ドキュメントは有効である必要があります。デフォルトは、`false` に設定されています。
`comment`	string	任意	任意。このコマンドに添付するユーザー指定のコメント。設定すると、このコメントは以下の場所にこのコマンドの記録と合わせて表示されます。 `attr.command.cursor.comment` フィールド内のmongod ログメッセージ。 `command.comment` フィールドのデータベースプロファイラー出力。 `command.comment` フィールドの`currentOp`出力。コメントには、有効な BSON 型（string, integer, object, array など）を使用できます。
`let`	ドキュメント	任意	操作で参照する定数のリストを含むドキュメント。 `let`の例については、「 `let`オプションまたは`c`フィールドでの変数の使用と`let`での変数の使用」を参照してください。
`errorsOnly`	ブール値	任意	`true`の場合、操作はエラーのみを返し、他の出力は省略されます。デフォルトは、`false` に設定されています。
`cursor batchSize`	integer	任意	`bulkWrite`コマンドの返された結果のカーソルバッチするサイズ。詳細については、 `cursor.batchSize()`を参照してください。
`maxTimeMS`	non-negative integer	任意	時間制限をミリ秒単位で指定します。`maxTimeMS` の値を指定しない場合、操作はタイムアウトしません。値を `0` にすると、デフォルトの無制限動作を明示的に指定します。 MongoDB は、`db.killOp()` と同じメカニズムを使用して、割り当てられた時間制限を超えた操作を終了します。MongoDB は、指定された割り込みポイントのいずれかでのみ操作を終了します。
`writeConcern`	string	任意	操作の書込み保証 ( write concern ) 。サーバーのデフォルトを使用する場合は省略します。

出力

このコマンドは、次のフィールドを含むドキュメントを返します。

フィールド	タイプ	説明
`cursor`	ドキュメント	コマンドの結果を持つカーソル。
`cursor.id`	integer	カーソル識別子。
`cursor.firstBatch`	ドキュメント配列	操作の結果。
`cursor.firstBatch.ok`	integer	`1` は、操作が成功したことを示します。それ以外の場合は、 `0` 。
`cursor.firstBatch.idx`	integer	`ops`配列内の操作に対応する操作インデックス番号。最初の操作の`idx`値は`0`です。
`cursor.firstBatch.code`	integer	エラーのコード番号。
`cursor.firstBatch.errmsg`	string	エラーの説明。
`cursor.firstBatch.keyPattern`	ドキュメント	エラーのドキュメントインデックスキーの指定。
`cursor.firstBatch.keyValue`	ドキュメント	エラーのドキュメントインデックスキー値。
`cursor.firstBatch.n`	integer	操作の影響を受けるドキュメントの合計数。
`cursor.firstBatch.nModified`	integer	更新操作によって変更されたドキュメントの数。
`nErrors`	integer	`bulkWrite`コマンドのエラーの数。
`nInserted`	integer	挿入されたドキュメントの数。
`nMatched`	integer	一致したドキュメントの数。
`nModified`	integer	変更されたドキュメントの数。
`nUpserted`	integer	アップサートされたドキュメントの数。
`nDeleted`	integer	削除されたドキュメントの数。
`ok`	integer	`1` は、 `bulkWrite`コマンドが成功したことを示します。それ以外の場合は、 `0` 。

注意

出力フィールドは、 bulkWriteコマンドで実行する操作によって異なる場合があります。

動作

複数のドキュメントフィールドと再試行可能な書込み

multiフィールドがtrueの場合、更新操作または削除操作により、ドキュメントfilterに一致するすべてのドキュメントが更新または削除されます。 falseの場合、操作によってドキュメントfilterと一致する最初のドキュメントが更新または削除されます。マルチドキュメントトランザクションの詳細については、「トランザクション」を参照してください。

再試行可能な書込みを有効にするには、「再試行可能な書込み」を参照してください。

再試行可能な書き込みと、 multiフィールドをtrueに設定すると、 bulkWrite挿入操作を使用できます。

multiフィールドをtrueに設定すると、 bulkWriteのアップデート操作と削除操作を使用できます。ただし、 multiがtrueと再試行可能な書き込みの両方でアップデート操作または削除操作を使用することはできません。

シャーディングされたクラスターでの書込み保証 (write concern) エラー

バージョン8.1.2で変更。

When bulkWrite executes on mongos in a sharded cluster, a writeConcernError is always reported in the response, even when one or more other errors occur. In previous releases, other errors sometimes caused bulkWrite to not report write concern errors.

例、ドキュメントが検証に失敗して DocumentValidationFailed エラーが発生し、書込み保証 (write concern)エラーも発生した場合、DocumentValidationFailed エラーと writeConcernError の両方が応答の最上位フィールドに返されます。

操作パフォーマンス

既存の挿入、更新、削除コマンドをbulkWriteコマンドとして書き換え、 errorsOnlyをtrueに設定すると、 bulkWriteコマンドは既存のコマンドと同様のパフォーマンスになります。 errorsOnlyをfalseに設定すると、パフォーマンスは低下します。

複数の個別の書き込み (write) コマンドを 1 つの bulkWrite コマンドに置き換えると、ネットワークレイテンシが低減され、パフォーマンスが向上します。例えば、次のシーケンスを考えてみましょう。

insert
update
delete

このシーケンスを単一の bulkWrite コマンドで置き換えます：

{
   bulkWrite: 1,
   ops: [
      insert,
      update,
      delete
   ]
}

例

単一名前空間一括書込みの例

次のbulkWriteの例では、1 つの名前空間を変更しています。

ピザの例コレクションを作成する

実行:

db.pizzas.insertMany( [
   { _id: 0, type: "pepperoni", size: "small", price: 4 },
   { _id: 1, type: "cheese", size: "medium", price: 7 },
   { _id: 2, type: "vegan", size: "large", price: 8 }
] )

ピザの例コレクションを変更します

次のbulkWriteコマンドを実行して、 pizzasコレクションに対して挿入、アップデート、削除操作を実行します。

db.adminCommand( {
   bulkWrite: 1,
   // The ops array contains the insert, update, and delete
   // operations.
   ops: [
      // Specify the namespace ID index immediately after
      // the insert, update, and delete text.
      // For example, "insert: 0" specifies the 0 namespace ID index,
      // which is the "test.pizzas" namespace in nsInfo at the end
      // of the example.
      // Insert a pizza.
      { insert: 0, document: { _id: 4, type: "sausage",
        size: "small", price: 12 } },
      // Update the price for medium pizzas.
      { update: 0, filter: { size: "medium" },
        updateMods: { $set: { price: 15 } } },
      // Delete the pizza with an _id of 2.
      { delete: 0, filter: { _id: 2 } }
   ],
   // The nsInfo array contains the namespace to apply the
   // previous operations to.
   nsInfo: [
      { ns: "test.pizzas" }  // Namespace ID index is 0.
   ]
} )

pizzasコレクションはデフォルトのtestデータベースにあるため、 ns名前空間は"test.pizzas"です。名前空間IDインデックスは0で、これはops配列の挿入、アップデート、削除操作の最初のフィールドに設定されています。

出力を確認します。

さまざまなok: 1フィールドとnErrors: 0を例次のbulkWriteの出力は、すべての操作が成功したことを示しています。

{
   cursor: {
      id: Long('0'),
      firstBatch: [
         { ok: 1, idx: 0, n: 1 },
         { ok: 1, idx: 1, n: 1, nModified: 1 },
         { ok: 1, idx: 2, n: 1 }
       ],
       ns: 'admin.$cmd.bulkWrite'
   },
   nErrors: 0,
   nInserted: 1,
   nMatched: 1,
   nModified: 1,
   nUpserted: 0,
   nDeleted: 1,
   ok: 1
}

For details about the output fields, see the Output section.

複数の名前空間の一括書込みの例

bulkWriteコマンドで複数の名前空間を指定できます。

次のbulkWriteの例には、2 つの名前空間に対する挿入、アップデート、削除操作が含まれています。

ピザの例コレクションを作成する

testデータベースにpizzasコレクションがすでにある場合は、 db.collection.drop()メソッドを使用してまず削除し、次に次のコマンドを実行します。

db.pizzas.insertMany( [
   { _id: 0, type: "pepperoni", size: "small", price: 4 },
   { _id: 1, type: "cheese", size: "medium", price: 7 },
   { _id: 2, type: "vegan", size: "large", price: 8 }
] )

ピザ注文の例コレクションを作成する

実行:

db.pizzaOrders.insertMany( [
   { _id: 0, type: "pepperoni", number: 5,
     orderDate: new Date( "2023-01-15T12:00:00Z" ) },
   { _id: 1, type: "cheese", number: 15,
     orderDate: new Date( "2023-01-23T11:12:32Z" ) },
   { _id: 2, type: "vegan", number: 20,
     orderDate: new Date( "2023-03-20T10:01:12Z" ) }
] )

例コレクションを変更します

次のbulkWriteコマンドを実行して、例コレクションに対して挿入、アップデート、削除操作を実行します。

db.adminCommand( {
   bulkWrite: 1,
   // The ops array contains the insert, update, and delete
   // operations.
   ops: [
      // Specify the namespace ID indexes immediately after
      // the insert, update, and delete. For example, "insert: 0"
      // specifies the 0 namespace ID index, which is the "test.pizzas"
      // namespace. And, "insert: 1" specifies "test.pizzaOrders".
      // Insert pizzas.
      // Namespace ID is 0 for "test.pizzas", which
      // is specified as "insert: 0".
      { insert: 0, document: { _id: 5, type: "sausage",
        size: "small", price: 12 } },
      { insert: 0, document: { _id: 6, type: "vegan cheese",
        size: "large", price: 25 } },
      // Update the price for cheese pizzas.
      { update: 0, filter: { type: "cheese" },
        updateMods: { $set: { price: 15 } } },
      // Delete pizzas with a price less than 7.
      { delete: 0, filter: { price: { $lt: 7 } } },
      // Insert pizza orders.
      // Namespace ID is 1 for "test.pizzaOrders".
      { insert: 1, document: { _id: 3, type: "sausage", number: 7,
        orderDate: new Date( "2023-04-15T12:02:15Z" ) } },
      { insert: 1, document: { _id: 4, type: "vegan", number: 16,
        orderDate: new Date( "2023-05-12T11:03:11Z" ) } },
      // Update the number of pizza orders for cheese pizzas.
      { update: 1, filter: { type: "cheese" },
        updateMods: { $set: { number: 50 } } },
      // Delete the pizza order with an _id of 2.
      { delete: 1, filter: { _id: 2 } },
      // Delete pizza orders placed before March 15, 2023.
      { delete: 1, filter: { orderDate:
        { $lte: ISODate( "2023-03-15T00:00:00Z" ) } } }
   ],
   // Namespaces
   nsInfo: [
      { ns: "test.pizzas" }, // Namespace ID index is 0.
      { ns: "test.pizzaOrders" }  // Namespace ID index is 1.
   ]
} )

出力を確認します。

次のbulkWriteの出力の例は、操作が成功したことを示しています。

{
   cursor: {
      id: Long('0'),
      firstBatch: [
         { ok: 1, idx: 0, n: 1 },
         { ok: 1, idx: 1, n: 1 },
         { ok: 1, idx: 2, n: 1, nModified: 1 },
         { ok: 1, idx: 3, n: 1 },
         { ok: 1, idx: 4, n: 1 },
         { ok: 1, idx: 5, n: 1 },
         { ok: 1, idx: 6, n: 1, nModified: 1 },
         { ok: 1, idx: 7, n: 1 },
         { ok: 1, idx: 8, n: 1 }
      ],
      ns: 'admin.$cmd.bulkWrite'
   },
   nErrors: 0,
   nInserted: 4,
   nMatched: 2,
   nModified: 2,
   nUpserted: 0,
   nDeleted: 3,
   ok: 1
}

エラーを含む操作の一括書込みの例

次のbulkWriteの例には、エラーのある操作とドキュメントを変更しない操作が含まれています。

ピザの例コレクションを作成する

testデータベースにpizzasコレクションがすでにある場合は、 db.collection.drop()メソッドを使用してまず削除し、次に次のコマンドを実行します。

db.pizzas.insertMany( [
   { _id: 0, type: "pepperoni", size: "small", price: 4 },
   { _id: 1, type: "cheese", size: "medium", price: 7 },
   { _id: 2, type: "vegan", size: "large", price: 8 }
] )

ピザの例コレクションの変更を試みる

次のbulkWriteコマンドを実行して、 pizzasコレクションに対して挿入、アップデート、削除操作を実行します。

db.adminCommand( {
   bulkWrite: 1,
   // The ops array contains the insert, update, and delete
   // operations.
   ops: [
      // The namespace ID indexes are specified immediately after
      // the insert, update, and delete text.
      // For example, "insert: 0" specifies the 0 namespace ID index,
      // which is the "test.pizzas" namespace in nsInfo.
      // Attempt to add a duplicate document with an
      // _id of 1, which already exists and causes an error.
      { insert: 0, document: { _id: 1, type: "tomato",
        size: "small", price: 12 } },
      // Attempt to add another duplicate document.
      { insert: 0, document: { _id: 2, type: "pepper",
        size: "small", price: 12 } },
      // Attempt to change the price for extra large pizzas,
      // which don't exist. This doesn't cause an error but
      // doesn't update any documents.
      { update: 0, filter: { size: "extra large" },
        updateMods: { $set: { price: 15 } } },
      // Attempt to remove a document that doesn't exist.
      // This doesn't cause an error but doesn't delete any documents.
      { delete: 0, filter: { _id: 8 } }
   ],
   // The nsInfo array contains the namespace to apply the
   // previous operations to.
   nsInfo: [
      { ns: "test.pizzas" }  // Namespace ID index is 0.
   ],
   // Set the ordered field to false to run the remaining operations
   // after an operation returns an error.
   ordered: false
} )

出力を確認します。

次のbulkWrite出力の例は、エラーを示しています。

{
   cursor: {
      id: Long("0"),
      firstBatch: [
         {
            ok: 0,
            idx: 0,
            code: 11000,
            errmsg: 'E11000 duplicate key error collection:
            test.pizzas index: _id_ dup key: { _id: 1 }',
            keyPattern: { _id: 1 },
            keyValue: { _id: 1 },
            n: 0
         },
         {
            ok: 0,
            idx: 1,
            code: 11000,
            errmsg: 'E11000 duplicate key error collection:
            test.pizzas index: _id_ dup key: { _id: 2 }',
            keyPattern: { _id: 1 },
            keyValue: { _id: 2 },
            n: 0
         },
         { ok: 1, idx: 2, n: 0, nModified: 0 },
         { ok: 1, idx: 3, n: 0 }
      ],
      ns: 'admin.$cmd.bulkWrite'
   },
   nErrors: 2,
   nInserted: 0,
   nMatched: 0,
   nModified: 0,
   nUpserted: 0,
   nDeleted: 0,
   ok: 1
}

For details about the output fields, including the error codes and messages, see the earlier Output section.

errorsOnly が有効な場合の一括書込みの例

次のbulkWriteの例では、 errorsOnlyをtrueに設定して、エラー出力のみを表示します。

ピザの例コレクションを作成する

testデータベースにpizzasコレクションがすでにある場合は、 db.collection.drop()メソッドを使用してまず削除し、次に次のコマンドを実行します。

db.pizzas.insertMany( [
   { _id: 0, type: "pepperoni", size: "small", price: 4 },
   { _id: 1, type: "cheese", size: "medium", price: 7 },
   { _id: 2, type: "vegan", size: "large", price: 8 }
] )

ピザの例コレクションの変更を試みる

次のbulkWriteコマンドを実行し、 errorsOnlyをtrueに設定して、 pizzasコレクションに対して挿入、アップデート、削除操作を実行します。

db.adminCommand( {
   bulkWrite: 1,
   // The ops array contains the insert, update, and delete
   // operations.
   ops: [
      // The namespace ID indexes are specified immediately after
      // the insert, update, and delete text.
      // For example, "insert: 0" specifies the 0 namespace ID index,
      // which is the "test.pizzas" namespace in nsInfo.
      // Attempt to add a duplicate document with an
      // _id of 1, which already exists and causes an error.
      { insert: 0, document: { _id: 1, type: "tomato",
        size: "small", price: 12 } },
      // Attempt to add another duplicate document.
      { insert: 0, document: { _id: 2, type: "pepper",
        size: "small", price: 12 } },
      // Attempt to change the price for extra large pizzas,
      // which don't exist. This doesn't cause an error but
      // doesn't update any documents.
      { update: 0, filter: { size: "extra large" },
        updateMods: { $set: { price: 15 } } },
      // Attempt to remove a document that doesn't exist.
      // This doesn't cause an error but doesn't delete any documents.
      { delete: 0, filter: { _id: 8 } }
   ],
   // The nsInfo array contains the namespace to apply the
   // previous operations to.
   nsInfo: [
      { ns: "test.pizzas" }  // Namespace ID index is 0.
   ],
   // Set the ordered field to false to run the remaining operations
   // after an operation returns an error.
   ordered: false,
   // Set the errorsOnly field to true to only output the errors.
   errorsOnly: true
} )

出力を確認します。

次のbulkWrite出力の例は、エラーを示しています。

{
   cursor: {
      id: Long("0"),
      firstBatch: [
         {
            ok: 0,
            idx: 0,
            code: 11000,
            errmsg: 'E11000 duplicate key error collection:
            test.pizzas index: _id_ dup key: { _id: 1 }',
            keyPattern: { _id: 1 },
            keyValue: { _id: 1 },
            n: 0
         },
         {
            ok: 0,
            idx: 1,
            code: 11000,
            errmsg: 'E11000 duplicate key error collection:
            test.pizzas index: _id_ dup key: { _id: 2 }',
            keyPattern: { _id: 1 },
            keyValue: { _id: 2 },
            n: 0
         },
      ],
      ns: 'admin.$cmd.bulkWrite'
   },
   nErrors: 2,
   nInserted: 0,
   nMatched: 0,
   nModified: 0,
   nUpserted: 0,
   nDeleted: 0,
   ok: 1
}

詳細

戻る

集計

count

bulkWrite （データベースコマンド）

定義

互換性

構文

コマンドフィールド

出力

動作

複数のドキュメント フィールドと再試行可能な書込み

シャーディングされたクラスターでの書込み保証 (write concern) エラー

操作パフォーマンス

例

単一名前空間一括書込みの例

ピザの例コレクションを作成する

ピザの例コレクションを変更します

出力を確認します。

複数の名前空間の一括書込みの例

ピザの例コレクションを作成する

ピザ注文の例コレクションを作成する

例コレクションを変更します

出力を確認します。

エラーを含む操作の一括書込みの例

ピザの例コレクションを作成する

ピザの例コレクションの変更を試みる

出力を確認します。

errorsOnly が有効な場合の一括書込みの例

ピザの例コレクションを作成する

ピザの例コレクションの変更を試みる

出力を確認します。

詳細

複数のドキュメントフィールドと再試行可能な書込み