db.コレクション.bulkWrite()（mongoshメソッド）

パラメーター

bulkWrite() メソッドは次のパラメータを取ります。

書込み操作

db.collection.bulkWrite( [
   { insertOne : { "document" : <document> } }
] )

db.collection.bulkWrite( [
   { updateOne :
      {
         "filter": <document>,
         "update": <document or pipeline>,
         "upsert": <boolean>,
         "collation": <document>,
         "arrayFilters": [ <filterdocument1>, ... ],
         "hint": <document|string>
      }
   }
] )

db.collection.bulkWrite( [
   { updateMany :
      {
         "filter" : <document>,
         "update" : <document or pipeline>,
         "upsert" : <boolean>,
         "collation": <document>,
         "arrayFilters": [ <filterdocument1>, ... ],
         "hint": <document|string>
      }
   }
] )

db.collection.bulkWrite([
   { replaceOne :
      {
         "filter" : <document>,
         "replacement" : <document>,
         "upsert" : <boolean>,
         "collation": <document>,
         "hint": <document|string>
      }
   }
] )

db.collection.bulkWrite([
   { deleteOne : {
      "filter" : <document>,
      "collation" : <document>                   // Available starting in 3.4
   } }
] )

db.collection.bulkWrite([
   { deleteMany: {
      "filter" : <document>,
      "collation" : <document>                    // Available starting in 3.4
   } }
] )

_id フィールド

ドキュメントで _id フィールドが指定されていない場合は、 mongod で _id フィールドが追加され、ドキュメントの挿入またはアップサートの前にユニークな ObjectId() が割り当てられます。ほとんどのドライバーでは ObjectId が作成され、 _id フィールドが挿入されますが、ドライバーやアプリケーションでこの処理が行われない場合は、 mongod で_id の作成と入力が行われます。

ドキュメントに _id フィールドが含まれる場合に重複キー エラーを回避するには、_id 値がコレクション内で一意になるようにする必要があります。

更新操作または置換操作では、元のドキュメントと異なる _id 値を指定することはできません。

操作の実行

ordered パラメーターは、操作が連続して実行されるか、任意の順序で実行されるかを制御します。

ordered : true（デフォルトでは ）の場合、操作は連続して実行されます。エラーが発生すると、後続の操作は実行されません。

ordered : false を使用すると、 操作は並列に実行される可能性があります。一部の操作が失敗した場合でも、エラーのないすべての操作が完了します。

各グループ内の操作の数は、データベースの maxWriteBatchSize の値を超えることはできません。maxWriteBatchSize のデフォルト値は 100,000 です。この値は hello.maxWriteBatchSize フィールドに表示されます。

この制限により、エラー メッセージの肥大化の問題が回避されます。この制限を超えるグループがある場合、クライアント ドライバーによって、操作数が制限値以下となる小さなグループに分割されます。たとえば、maxWriteBatchSize の値が 100,000 の場合、キューに 200,000 回の操作が含まれていると、ドライバによってそれぞれの操作回数が 100,000 回となるグループが 2 個作成されます。

1 つのバッチのエラーレポートが大きくなりすぎた場合、MongoDB では残りのすべてのエラーメッセージを切り捨てて空の文字列にします。少なくとも 2 つのエラーメッセージがあり、合計サイズが 1MB を超える場合、これらは切り捨てられます。

サイズとグループ化の仕組みは内部的パフォーマンスの細部に該当し、今後のバージョンで変更される可能性があります。

シャーディングされたコレクションで ordered 操作リストを実行すると、通常、 unordered リストの実行よりも時間がかかります。これは、ordered リストでは毎回の操作で前の操作の完了を待機する必要があるためです。

上限付きコレクション

bulkWrite() Capped コレクションには制限があります。

• updateOne アップデートによってドキュメントサイズが増加する場合には、 と により がスローされます。updateManyWriteError

• replaceOne では、置き換えドキュメントが元のドキュメントよりも大きい場合は WriteError がスローされます。

• deleteOne と deleteMany は、上限付きコレクションに対して WriteError をスローします。

Error Handling

bulkWrite() は、エラー時にBulkWriteError の例外をスローします。 「 トランザクション内でのエラー処理 」を参照してください。

書込み保証（ write concern ） エラーを除き、順序付き操作はエラーの発生後に停止します。一方、順序なし操作は、トランザクション内で実行されない限り、キューにある残りの書込み操作の処理を続行します。 「トランザクション内でのエラー処理 」を参照してください。

書込み保証エラーは writeConcernErrors フィールドに表示され、その他すべてのエラーは writeErrors フィールドに表示されます。エラーが発生した場合、挿入された_id 値の代わりに、成功した書き込み操作の数が表示されます。実行順序の決まった操作では、発生したエラーが 1 つだけ表示され、実行順序のない操作では 1 つの配列内のそれぞれのエラーが表示されます。

トランザクション

bulkWrite() 分散トランザクション内で使用できます。

順序付けなし一括書込みの例

順序付けられていない bulkWrite() を指定するには、ordered を false に設定します。

順序付けられていない bulkWrite() の操作リストでは次のようになります。

• 操作は並行して実行可能です（保証はされません）。詳細については順序付き操作と順序なし操作を参照してください。

• エラーのある操作は完了しません。

• エラーのないすべての操作が完了します。

次の例を参照してください。

• bulkWrite() は users コレクションに対して順序のない操作を実行します。

• コメントアウトされている 2 番目の insertOne操作 の_id は 1 番目の insertOne と同じであるため、重複キー エラーが発生します。

db.users.bulkWrite( [
   { insertOne: { 
      document: { 
         _id: ObjectId("67a1b2c3d4e5f6a7b8c9d0e9"),
         name: "Sansa Stark",
         email: "sansa.stark@example.com",
         password: "$2b$12$UREFwsRUoyF0CRqGNK0LzO0HM/jLhgUCNNIJ9RJAqMUQ74crlJ1Vu"
      } 
   } },
   // This insert operation with the same _id value as the one above will fail
   // { insertOne: { 
   //    document: { 
   //       _id: ObjectId("67a1b2c3d4e5f6a7b8c9d0e9"), // Duplicate _id value
   //       name: "Bran Stark",
   //       email: "bran.stark@example.com",
   //       password: "$2b$12$UREFwsRUoyF0CRqGNK0LzO0HM/jLhgUCNNIJ9RJAqMUQ74crlJ1Vu"
   //    } 
   // } },
   { updateOne: {
      filter: { name: "Catelyn Stark" },
      update: { $set: { email: "cat.stark@example.com" } }
   } },
   { deleteOne: { filter: { name: "Ned Stark" } } },
   { replaceOne: {
      filter: { name: "Robb Stark" },
      replacement: { 
         name: "Robb Stark",
         email: "robb.stark@example.com",
         password: "$2b$12$NewPasswordHashHere123456789012345678901234567890"
      }
   } }
],
{ ordered: false } 
)

重複キー エラーのため、2 番目の insertOne操作は正常に実行されません。順序付けられていない bulkWrite() では、 MongoDB はすべての操作をエラーなく完了します。

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

bulkWrite()mongosがシャーディングされたクラスター内のwriteConcernError で実行されると、他のエラーが 1 つ以上発生した場合でも、レスポンスには常に が報告されます。以前のリリースでは、他のエラーによって が書込み保証bulkWrite() (write concern)エラーを報告しないことがあります。

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

書込み保証を使用した一括書込みの例

次の bulkWrite() の例では、 users コレクションに対して操作を実行し、100 ミリ秒のタイムアウトで"majority"書込み保証 (write concern) を設定します。

db.users.bulkWrite( [
   { updateMany: {
      filter: { name: { $regex: /Stark$/ } },
      update: { $set: { house: "Stark", verified: false } }
   } },
   { updateOne: {
      filter: { name: "Ned Stark" },
      update: { $set: { title: "Lord of Winterfell" } }
   } },
   { updateOne: {
      filter: { name: "Catelyn Stark" },
      update: { $set: { title: "Lady of Winterfell" } }
   } } ],
   { writeConcern: { w: "majority", wtimeout: 100 } }
)

レプリカセットノードの過半数が操作を確認するまでの時間が wtimeout を超えると、この例では書込み保証 (write concern)エラーと完了した操作の概要が返されます。