Mongo.bulkWrite() (mongosh method方法)

Definition定义

Mongo.bulkWrite(operations, options)

bulkWrite() performs multiple write operations across multiple databases and collections in a single call. 在单个调用中跨多个数据库和集合执行多个写入操作。This method replaces db.collection.bulkWrite(), which performs multiple write operations to a specific collection in a single call.此方法替换db.collection.bulkWrite()，后者在一次调用中对特定集合执行多个写入操作。

Syntax语法

You can call bulkWrite() on the current Mongo() instance by using the following syntax:您可以使用以下语法在当前Mongo()实例上调用bulkWrite()：

db.getMongo().bulkWrite(
  [
    {
      namespace: "<db1.collection1>",
      name: "insertOne",
      document: { ... }
    },
    {
      namespace: "<db2.collection2>",
      name: "replaceOne",
      filter: { ... }
    }
  ],
  {
    ordered: boolean,
    verboseResults: boolean,
    bypassDocumentValidation: boolean,
    let: Document
  }
)

You can also call it on a different Mongo instance, like in the following example:您还可以在不同的Mongo实例上调用它，如下例所示：

const otherMongo = Mongo("<other connection string>");

otherMongo.bulkWrite([{ namespace: "<db.collection>", ... }]);

bulkWrite() accepts two parameters:接受两个参数：

A document in operations can represent one of six operations:operations中的文档可以表示六种操作之一：

• insert one
• replace one
• update one
• update many
• delete one
• delete many

The following sections describe the syntax you must use for documents that represent each operation.以下部分描述了表示每个操作的文档必须使用的语法。

{
   namespace: '<db.collection>',
   name: 'insertOne',
   document: Document
}

{
   namespace: '<db>.<collection>',
   name: 'updateOne' | 'updateMany',
   filter: Document,
   update: Document | Document[],
   arrayFilters?: Document[],
   hint?: Document | string,
   collation?: Document,
   upsert?: boolean
}

{
   namespace: '<db>.<collection>',
   name: 'replaceOne',
   filter: Document,
   replacement: Document,
   hint?: Document | string,
   collation?: Document
}

{
   namespace: '<db>.<collection>',
   name: 'deleteOne' | 'deleteMany',
   filter: Document,
   hint?: Document | string,
   collation?: Document
}

{
   ordered?: boolean,
   verboseResults?: boolean,
   bypassDocumentValidation?: boolean,
   let?: Document
}

Output输出

bulkWrite() returns an object with the following fields:返回一个包含以下字段的对象：

{
   acknowledged: boolean,
   insertedCount: int,
   matchedCount: int,
   modifiedCount: int,
   deletedCount: int,
   upsertedCount: int,
   insertResults?: map(int, document),
   updateResults?: map(int, document),
   deleteResults?: map(int, document)
}

Examples示例

This example uses Mongo.bulkWrite() to perform the following operations in order:此示例使用Mongo.bulkWrite()按顺序执行以下操作：

• inserts a document into the db.authors collection将文档插入到db.authors集合中
• inserts a document into the db.books collection将文档插入db.books集合中
• updates the previous document更新上一个文档

db.getMongo().bulkWrite(
   [
      {
         namespace: 'db.authors',
         name: 'insertOne',
         document: { name: 'Stephen King' }
      },
      {
         namespace: 'db.books',
         name: 'insertOne',
         document: { name: 'It' }
      },
      {
         namespace: 'db.books',
         name: 'updateOne',
         filter: { name: 'it' },
         update: { $set: { year: 1986 } }
      }
   ],
   {
      ordered: true,
      bypassDocumentValidation: true
   }
)

mongosh performs the bulk write in order and returns the following document:按顺序执行批量写入并返回以下文档：

{
   acknowledged: true,
   insertedCount: 2,
   matchedCount: 1,
   modifiedCount: 1,
   deletedCount: 0,
   upsertedCount: 0,
   insertResults: { '1': { insertedId: ObjectId('67ed8ce8efd926c84cab7945') },
                    '2': { insertedId: ObjectId('67ed8ce8efd926c84cab7946') } }
   updateResults: { '1': { matchedCount: 1, modifiedCount: 1, didUpsert: false } }
}