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 个操作组成，则驱动程序将创建 2 个群组，每个群组包含 100,000 个操作。

如果单个批处理的错误报告变得过大，MongoDB 会将所有剩余的错误消息截断为空字符串。如果至少存在两条总大小大于 1MB 的错误消息，则会将其截断。

大小和分组机制是内部性能细节，在未来版本中可能会有变化。

在分片集合上执行操作的 ordered 列表通常比执行 unordered 列表慢，因为对于有序列表，每个操作都必须等待前一个操作完成。

固定大小集合

bulkWrite() 对固定大小集合有限制：

• updateOne 和 updateMany 会在更新增加文档大小时抛出 WriteError。

• replaceOne 如果替换文档大于原始文档，则会抛出 WriteError。

• deleteOne 和 deleteMany 对固定大小集合抛出 WriteError。

Error Handling

bulkWrite() BulkWriteError会在出现错误时引发 异常。请参阅事务中的错误处理。

当排除了写关注错误时，有序操作将在发生错误之后停止，而无序操作会继续处理队列中的任何剩余写操作（除非在事务内运行）。请参阅事务中的错误处理。

写关注错误显示在 writeConcernErrors 字段中，所有其他错误显示在 writeErrors 字段中。如果遇到错误，将显示成功的写入操作的数量，而不是插入的 _id 值。有序操作会显示遇到的单个错误，而无序操作会显示数组中的每个错误。

事务

bulkWrite() 可用于分布式事务。

无序批量写入示例

要指定无序 bulkWrite()，请将 ordered设立为 false。

在无序列表的 bulkWrite() 操作列表中：

• 操作可以并行运行（不保证）。有关详细信息，请参阅有序操作和无序操作。

• 出现错误的操作未完成。

• 所有无错误的操作都已完成。

在以下示例中：

• bulkWrite() 对 users 集合运行无序操作。

• 已注释掉的第二个 insertOne 操作具有与第一个 insertOne 相同的 _id，这会导致重复键错误。

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 } 
)

由于重复键错误，第二个 insertOne 操作失败。在无序 bulkWrite() 中， MongoDB完成任何操作都不会出现错误。

分片集群中的写关注错误

当bulkWrite() mongos在分片集群中的writeConcernError 上执行时，即使出现一个或多个其他错误，响应中也始终会报告 。在以前的版本中，其他错误有时会导致bulkWrite() 不报告写关注（write concern）错误。

示例，如果文档验证失败，触发 DocumentValidationFailed 错误，并且还发生写关注（write concern）错误，则 DocumentValidationFailed 错误和 writeConcernError 都会在响应的顶级字段中返回。

带有写关注的批量写入示例

以下 bulkWrite() 示例对 users 集合运行操作，并设置 "majority" 写关注和 100 毫秒超时：

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）错误和已完成操作的摘要。