Bulk()
提示
MongoDB 还提供了用于执行批量写入操作的 db.collection.bulkWrite()
方法。
说明
Bulk()
批量操作构建者用于构造要为单个集合批量执行的写入操作列表。要实例化构建者,请使用
db.collection.initializeOrderedBulkOp()
或db.collection.initializeUnorderedBulkOp()
方法。
有序和无序批量操作
构建者可以将操作列表设为有序或无序。
有序操作
使用有序 操作列表,MongoDB 将按顺序执行列表中的写入操作。如果在处理其中一个写入操作期间发生错误,MongoDB 将返回而不处理列表中任何剩余的写入操作。
使用 db.collection.initializeOrderedBulkOp()
来创建写命令有序列表的构建器。
执行 ordered
操作列表时,MongoDB 会根据 operation type
和连续性对操作进行分组;也就是说,相同类型的连续 操作会被分在一组。例如,如果有序列表有两个插入操作,后跟一个更新操作,然后是另一个插入操作,则 MongoDB 将这些操作分为三个单独的组:第一组包含两个插入操作,第二组包含更新操作,第三组包含最后一次插入操作。这种行为在未来版本中可能会有所更改。
mongosh
中的 Bulk()
操作以及驱动程序中的类似方法对群组中的操作数量不设限制。要了解如何对这些操作进行分组以执行批量操作,请在执行后调用 Bulk.getOperations()
。
在分片集合上执行操作的 ordered
列表通常比执行 unordered
列表慢,因为对于有序列表,每个操作都必须等待前一个操作完成。
无序操作
通过无序操作列表,MongoDB 可并行以及以不确定的顺序执行列表中的写入操作。如果在处理其中一个写入操作期间出现错误,MongoDB 将继续处理列表中剩余的写入操作。
使用 db.collection.initializeUnorderedBulkOp()
创建写命令无序列表的构建器。
执行 unordered
操作列表时,MongoDB 会对操作进行分组。对于无序批量操作,可以对列表中的操作进行重新排序以提高性能。因此,在执行 unordered
批量操作时,应用程序不应依赖排序。
mongosh
中的 Bulk()
操作以及驱动程序中的类似方法对群组中的操作数量不设限制。要了解如何对这些操作进行分组以执行批量操作,请在执行后调用 Bulk.getOperations()
。
事务
对于 Bulk.insert()
操作,必须存在集合。
对于 Bulk.find.upsert()
,如果操作导致 upsert,则必须存在集合。
如果是在事务中运行,则请勿显式设置此操作的写关注。要将写关注与事务一起使用,请参阅事务和写关注。
重要
在大多数情况下,与单文档写入操作相比,分布式事务会产生更高的性能成本,并且分布式事务的可用性不应取代有效的模式设计。在许多情况下,非规范化数据模型(嵌入式文档和数组)仍然是数据和使用案例的最佳选择。换言之,对于许多场景,适当的数据建模将最大限度地减少对分布式事务的需求。
有关其他事务使用注意事项(如运行时间限制和 oplog 大小限制),另请参阅生产注意事项。
方法
Bulk()
构建器具有以下方法:
名称 | 说明 |
---|---|
将插入操作添加到操作列表中。 | |
指定更新或删除操作的查询条件。 | |
将多文档删除操作添加到操作列表中。 | |
将单个文档删除操作添加到操作列表中。 | |
Bulk.find.delete() 的别名。 | |
Bulk.find.deleteOne() 的别名。 | |
将单个文档替换操作添加到操作列表中。 | |
将单文档更新操作添加到操作列表中。 | |
将 multi 更新操作添加到操作列表中。 | |
为更新操作指定 upsert: true 。 | |
批量执行操作列表。 | |
返回在 Bulk() 操作对象中执行的一组写入操作。 | |
返回 JSON 文档,其中包含 Bulk() 操作对象中的操作和批次数。 | |
以字符串形式返回 Bulk.toJSON() 结果。 |