สำหรับสิ่งนี้ ให้ใช้ initializeOrderedBulkOp() มันเริ่มต้นและส่งคืนตัวสร้างการดำเนินการ Bulk() ใหม่สำหรับคอลเลกชัน ตัวสร้างสร้างรายการคำสั่งของการดำเนินการเขียนที่ MongoDB ดำเนินการเป็นกลุ่ม
ให้เราสร้างคอลเลกชันที่มีเอกสาร -
>db.demo550.insertOne({"Name":"Chris","details":[{"Marks":49,Result:"fail"},{"Marks":58,Result:"fail"}]});
{
"acknowledged" : true,
"insertedId" : ObjectId("5e8e35bd9e5f92834d7f05e4")
} แสดงเอกสารทั้งหมดจากคอลเล็กชันโดยใช้วิธี find() -
> db.demo550.find();
สิ่งนี้จะสร้างผลลัพธ์ต่อไปนี้ -
{ "_id" : ObjectId("5e8e35bd9e5f92834d7f05e4"), "Name" : "Chris", "details" : [ { "Marks" : 49, "Result" : "fail" }, { "Marks" : 58, "Result" : "fail" } ] } ต่อไปนี้เป็นแบบสอบถามเพื่ออัปเดตองค์ประกอบในอาร์เรย์ใน MongoDB และดำเนินการเป็นกลุ่ม -
> var all= db.demo550.initializeOrderedBulkOp(),
... itr = 0;
> db.demo550.find({ "Name": "Chris", "details.Result": "fail" }).forEach(function(doc) {
... doc.details.filter(function(d){ return d.Result = "fail" }).forEach(function(d) {
... all.find({ "_id": doc._id, "details.Result": "fail" }).updateOne({
... "$set": { "details.$.Result": "PASS" }
... });
... itr++;
... if ( itr % 10== 0 ) {
... all.execute();
... all = db.demo550.initializeOrderedBulkOp();
... }
... });
... if ( itr % 10 != 0 )
... all.execute();
... }); แสดงเอกสารทั้งหมดจากคอลเล็กชันโดยใช้วิธี find() -
> db.demo550.find();
สิ่งนี้จะสร้างผลลัพธ์ต่อไปนี้ -
{ "_id" : ObjectId("5e8e35bd9e5f92834d7f05e4"), "Name" : "Chris", "details" : [ { "Marks" : 49, "Result" : "PASS" }, { "Marks" : 58, "Result" : "PASS" } ] }