MongoDB 批量操作
MongoDB批量方法用于执行批量操作，例如批量写入和批量删除。
#1、db.collection.initializeOrderBulkOp()
initializeOrderBulkOp并为该集合提供一个新的Bulk()操作构建器。它构造了一个写操作的有序列表， MongoDB 批量运行。
下面将初始化一个批量()在用户集合上的操作生成器，添加了一系列写操作，并执行了这些操作:
var bulk = db.users.initializeOrderedBulkOp();
bulk.insert( { user: "John", status: "A", points: 0 } );
bulk.insert( { user: "Peter", status: "A", points: 0 } );
bulk.insert( { user: "Clint", status: "B", points: 0 } );
bulk.find( { status: "D" } ).remove();
bulk.find( { status: "B" } ).update( { $set: { comment: "Awaited" } } );
bulk.execute();
#2、 db.collection.initializeUnorderedBulkOp()
该方法将启动并为该集合提供一个新的Bulk()操作生成器。它构建了MongoDB批量运行的无序写入操作列表。
例如:
以下代码初始化Bulk()操作构建器并添加一个用于添加多个文档的一系列插入操作:
var bulk = db.users.initializeUnorderedBulkOp();
bulk.insert( { user: "John", status: "A", points: 0 } );
bulk.insert( { user: "Peter", status: "A", points: 0 } );
bulk.insert( { user: "Clint", status: "B", points: 0 } );
bulk.execute();
#3、 Bulk()方法
Bulk方法可用于创建写操作列表，以对一个集合进行批量执行。要使建造者不满意，请使用
db.collection.initializeOrderedBulkOp() or the db.collection.initializeUnorderedBulkOp() method.
Bulk()构建器具有以下方法:
| Bulk.insert() |
它可用于在操作列表中添加插入操作。 |
| Bulk.find() |
它指定删除或更新操作的查询条件。 |
| Bulk.find.removeOne() |
它将删除操作添加到单个文档的操作列表中。 |
| Bulk.find.remove() |
它将删除操作添加到多个文档的操作列表中。 |
| Bulk.find.replaceOne() |
它将文档替换操作添加到许多操作中。 |
| Bulk.find.updateOne() |
它将单个文档更新操作添加到一系列操作中。 |
| Bulk.find.update() |
它将多重更新操作添加到一系列操作中。 |
| Bulk.find.upsert() |
它可以用于指定更新操作正确的upsert。 |
| Bulk.execute() |
它批量执行一系列操作。 |
| Bulk.getOperations() |
它提供了在Bulk()操作对象中执行的一系列写操作。 |
| Bulk.tojson() |
它返回一个JSON文档，该文档具有Bulk()操作对象中的操作和批处理的数量。 |
| Bulk.toString() |
它以字符串形式提供Bulk.tojson()结果。 |
#4、 Bulk.execute()方法
它运行由Bulk()方法构建器构建的操作列表。
例如:
执行Bulk方法
下面的代码在items集合上初始化Bulk()操作构建器，添加一系列插入操作，并执行这些操作:
var bulk = db.items.initializeUnorderedBulkOp();
bulk.insert( { item: "abc123", status: "A", defaultQty: 500, points: 5 } );
bulk.insert( { item: "ijk123", status: "A", defaultQty: 100, points: 10 } );
bulk.execute( );
The operation returns the following BulkWriteResult() object:
BulkWriteResult({
"writeErrors" : [ ],
"writeConcernErrors" : [ ],
"nInserted" : 2,
"nUpserted" : 0,
"nMatched" : 0,
"nModified" : 0,
"nRemoved" : 0,
"upserted" : [ ]
})
#5、 Bulk.find(
)方法
它可用于指定更新或删除操作的查询条件。使用查询选择器指定查询条件，以选择文档进行更新或删除操作。要指定所有文档，请使用空文档{}。
Bulk.find()可以与以下write命令操作一起使用:
Bulk.find.removeOne()
Bulk.find.remove()
Bulk.find.replaceOne()
Bulk.find.updateOne()
Bulk.find.update()
例如:
下面给出的示例为item集合初始化Bulk()操作构建器，并添加了remove操作。还将操作更新为操作列表。借助help Bulk.find()方法删除操作并更新操作，为它们各自的动作指定条件:
var bulk = db.items.initializeUnorderedBulkOp();
bulk.find( { status: "D" } ).remove();
bulk.find( { status: "P" } ).update( { $set: { points: 0 } } )
bulk.execute();
#6、 Bulk.find.remove()方法
它将删除操作添加到批量操作列表中。 Bulk.find()方法可用于指定条件，该条件确定要删除的文档。 Bulk.find.remove()从集合中删除所有匹配的文档。
下面给出的示例为items集合初始化Bulk()操作构建器，并添加remove操作。删除操作可用于删除状态为" D"的集合中的所有文档:
var bulk = db.items.initializeUnorderedBulkOp();
bulk.find( { status: "D" } ).remove();
bulk.execute();
#7、 Bulk.find.replaceOne(
)方法
它可用于将单个文档替换操作添加到批量操作列表中。使用此方法可以指定确定必须替换的文档的条件。该方法将替换限制为单个文档。
完全替换现有文档的替换文档。仅包含字段和值对。
例如
下面给出的示例为items集合初始化Bulk()操作生成器，并添加各种replaceOne操作到操作列表。
var bulk = db.items.initializeUnorderedBulkOp();
bulk.find( { item: "abc123" } ).replaceOne( { item: "abc123", status: "P", points: 100 } );
bulk.execute();
#8、 Bulk.find.update(
)方法
可用于向批量操作列表中添加多次更新操作。该方法将更新现有文件的特定字段。
Bulk.find()方法可用于指定确定必须更新的文档的条件。该方法更新所有匹配的文档。
例如:
下面的示例为item集合初始化Bulk()操作构建器，并将各种多重更新操作添加到操作列表中
var bulk = db.items.initializeUnorderedBulkOp();
bulk.find( { status: "D" } ).update( { $set: { status: "I", points: "0" } } );
bulk.find( { item: null } ).update( { $set: { item: "TBD" } } );
bulk.execute();
#9、 Bulk.insert(
)方法
可用于将插入操作添加到批量操作列表中。
例如:
该示例为items集合初始化Bulk()操作构建器，并添加了一系列插入操作以添加多个文档:
var bulk = db.items.initializeUnorderedBulkOp();
bulk.insert( { item: "abc123", defaultQty: 100, status: "A", points: 100 } );
bulk.insert( { item: "ijk123", defaultQty: 200, status: "A", points: 200 } );
bulk.insert( { item: "mop123", defaultQty: 0, status: "P", points: 0 } );
bulk.execute();
#10、 Bulk.toString()
可用于将JSON文档以字符串形式返回输出，该文档包含Bulk()对象内部的操作和批处理数量。
例如
下面的示例在items集合上初始化Bulk()操作构建器，添加一系列写入操作，并在批量构建器对象上调用Bulk.toString()。
var bulk = db.items.initializeOrderedBulkOp();
bulk.insert( { item: "abc123", status: "A", defaultQty: 500, points: 5 } );
bulk.insert( { item: "ijk123", status: "A", defaultQty: 100, points: 10 } );
bulk.find( { status: "D" } ).removeOne();
bulk.toString();
