Bulk Operations批量操作

Sample Data样本数据

The examples in this guide use the movies and users collections in the sample_mflix database, which is included in the Atlas sample datasets. 本指南中的示例使用了Atlas示例数据集中包含的sample_mflix数据库中的movies和users集合。To learn how to create a free MongoDB Atlas cluster and load the sample datasets, see the MongoDB Get Started guide.要了解如何创建免费的MongoDB Atlas集群并加载示例数据集，请参阅MongoDB入门指南。

Collection Bulk Inserts集合批量插入

To perform a bulk insert operation on your collection, create an InsertOneModel for each operation. Then, call the bulkWrite() method on your collection and pass an array of models as a parameter. 要对集合执行批量插入操作，请为每个操作创建InsertOneModel。然后，在你的集合上调用bulkWrite()方法，并传递一个模型数组作为参数。To create an InsertOneModel, specify the model's document field and set it to the document you want to insert.要创建InsertOneModel，请指定模型的document字段并将其设置为要插入的文档。

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

Client Bulk Inserts客户端批量插入

To perform a bulk insert operation across multiple collections or databases, create a ClientBulkWriteModel for each operation. Then, call the bulkWrite() method on your client and pass an array of models as a parameter.要跨多个集合或数据库执行批量插入操作，请为每个操作创建ClientBulkWriteModel。然后，在客户端调用bulkWrite()方法，并传递一个模型数组作为参数。

The following table describes the fields that you can set in a ClientBulkWriteModel to specify an insert operation:下表描述了可以在ClientBulkWriteModel中设置以指定插入操作的字段：

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

Collection Bulk Replacements集合批量替换

To perform a bulk replace operation on your collection, create a ReplaceOneModel for each operation. Then, call the bulkWrite() method on your collection and pass an array of models as a parameter.要对集合执行批量替换操作，请为每个操作创建一个ReplaceOneModel。然后，在你的集合上调用bulkWrite()方法，并传递一个模型数组作为参数。

The following table describes the fields that you can set in a ReplaceOneModel:下表描述了可以在ReplaceOneModel中设置的字段：

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

Client Bulk Replacements客户端批量替换

To perform a bulk replace operation across multiple collections or databases, create a ClientBulkWriteModel for each operation. Then, call the bulkWrite() method on your client and pass an array of models as a parameter.要跨多个集合或数据库执行批量替换操作，请为每个操作创建ClientBulkWriteModel。然后，在客户端调用bulkWrite()方法，并传递一个模型数组作为参数。

The following table describes the fields that you can set in a ClientBulkWriteModel to specify a replace operation:下表描述了可以在ClientBulkWriteModel中设置以指定替换操作的字段：

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

Collection Bulk Updates集合批量更新

To perform a bulk update operation on your collection, create an UpdateOneModel or UpdateManyModel for each operation. Then, call the bulkWrite() method on your collection and pass an array of models as a parameter. 要对集合执行批量更新操作，请为每个操作创建UpdateOneModel或UpdateManyModel。然后，在你的集合上调用bulkWrite()方法，并传递一个模型数组作为参数。An UpdateOneModel updates only one document that matches a filter, while an UpdateManyModel updates all documents that match a filter.UpdateOneModel只更新一个与筛选器匹配的文档，而UpdateManyModel则更新所有与筛选器相匹配的文档。

The following table describes the fields you can set in an UpdateOneModel or UpdateManyModel:下表描述了可以在UpdateOneModel或UpdateManyModel中设置的字段：

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

Client Bulk Updates客户端批量更新

To perform a bulk update operation across multiple collections or databases, create a ClientBulkWriteModel for each operation. Then, call the bulkWrite() method on your client and pass an array of models as a parameter.要跨多个集合或数据库执行批量更新操作，请为每个操作创建ClientBulkWriteModel。然后，在客户端调用bulkWrite()方法，并传递一个模型数组作为参数。

The following table describes the fields you can set in a ClientBulkWriteModel to specify an update operation:下表描述了可以在ClientBulkWriteModel中设置以指定更新操作的字段：

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

Collection Bulk Deletes批量删除集合

To perform a bulk delete operation on your collection, create a DeleteOneModel or DeleteManyModel for each operation. 要对集合执行批量删除操作，请为每个操作创建DeleteOneModel或DeleteManyModel。Then, call the bulkWrite() method on your collection and pass an array of models as a parameter. 然后，在你的集合上调用bulkWrite()方法，并传递一个模型数组作为参数。A DeleteOneModel deletes only one document that matches a filter, while a DeleteManyModel deletes all documents that match a filter.DeleteOneModel仅删除一个与筛选器匹配的文档，而DeleteManyModel则删除所有与筛选器相匹配的文档。

The following table describes the fields you can set in a DeleteOneModel or DeleteManyModel:下表描述了可以在DeleteOneModel或DeleteManyModel中设置的字段：

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

Client Bulk Deletes客户端批量删除

To perform a bulk delete operation across multiple collections or databases, create a ClientBulkWriteModel for each operation. Then, call the bulkWrite() method on your client and pass an array of models as a parameter.要跨多个集合或数据库执行批量删除操作，请为每个操作创建ClientBulkWriteModel。然后，在客户端调用bulkWrite()方法，并传递一个模型数组作为参数。

The following table describes the fields you can set in a ClientBulkWriteModel to specify a delete operation:下表描述了可以在ClientBulkWriteModel中设置的字段，以指定删除操作：

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

The Collection.bulkWrite() method returns a BulkWriteResult object, which provides information about your bulk operation.Collection.bulkWrite()方法返回一个BulkWriteResult对象，该对象提供有关批量操作的信息。

The following tables describes the fields of a BulkWriteResult object:下表描述了BulkWriteResult对象的字段：

ClientBulkWriteResult

The MongoClient.bulkWrite() method returns a ClientBulkWriteResult object, which includes information about the client bulk write operation.MongoClientbulkWrite()方法返回一个ClientBulkWriteResult对象，其中包含有关客户端批量写入操作的信息。

The following tables describes the fields of a ClientBulkWriteResult object:下表描述了ClientBulkWriteResult对象的字段：

Collection Bulk Write Exceptions集合批量写入异常

If any bulk write operations called on a collection are unsuccessful, the Node.js driver throws a MongoBulkWriteError and does not perform any further operations if the ordered option is set to true. 如果对集合调用的任何批量写入操作都不成功，Node.js驱动程序会抛出MongoBulkWriteError，如果ordered选项设置为true，则不会执行任何进一步的操作。If ordered is set to false, it will attempt to continue with subsequent operations.如果ordered设置为false，它将尝试继续后续操作。

A MongoBulkWriteError object contains the following properties:MongoBulkWriteError对象包含以下属性：

Client Bulk Write Exceptions客户端批量写入异常

If any bulk write operations called on your client are unsuccessful, the Node.js driver generates a MongoClientBulkWriteError. 如果在客户端上调用的任何批量写入操作都不成功，Node.js驱动程序将生成MongoClientBulkWriteError。By default, the driver does not perform any subsequent operations after encountering an error. 默认情况下，驱动程序在遇到错误后不会执行任何后续操作。If you pass the ordered option to the bulkWrite() method and set it to false, the driver continues to attempt the remaining operations.如果将ordered选项传递给bulkWrite()方法并将其设置为false，则驱动程序将继续尝试其余操作。

A MongoClientBulkWriteError object contains the following properties:MongoClientBulkWriteError对象包含以下属性：

API Documentation文档

To learn more about any of the methods or types discussed in this guide, see the following API documentation:要了解有关本指南中讨论的任何方法或类型的更多信息，请参阅以下API文档：

• Collection.bulkWrite()
• MongoClient.bulkWrite()
• BulkWriteResult
• ClientBulkWriteResult
• ClientBulkWriteModel
• InsertOneModel
• InsertOne
• ReplaceOne
• ReplaceOneModel
• UpdateOne
• UpdateMany
• UpdateOneModel
• DeleteOne
• DeleteMany
• DeleteOneModel