สำหรับสิ่งนี้ ให้ใช้ $lookup การดำเนินการนี้จะทำการรวมภายนอกด้านซ้ายกับคอลเล็กชันที่ยังไม่ได้ชาร์ดในฐานข้อมูลเดียวกันเพื่อกรองเอกสารจากคอลเล็กชัน "ที่เข้าร่วม" สำหรับการประมวลผล
ให้เราสร้างคอลเลกชันที่มีเอกสารก่อน -
> db.demo395.insertOne({Name:"Chris"}); { "acknowledged" : true, "insertedId" : ObjectId("5e5e782317aa3ef9ab8ab207") } > db.demo395.insertOne({Name:"David"}); { "acknowledged" : true, "insertedId" : ObjectId("5e5e782317aa3ef9ab8ab208") }
แสดงเอกสารทั้งหมดจากคอลเล็กชันโดยใช้วิธี find() -
> db.demo395.find();
สิ่งนี้จะสร้างผลลัพธ์ต่อไปนี้ -
{ "_id" : ObjectId("5e5e782317aa3ef9ab8ab207"), "Name" : "Chris" } { "_id" : ObjectId("5e5e782317aa3ef9ab8ab208"), "Name" : "David" }
ให้เราสร้างคอลเลกชันที่สองพร้อมเอกสาร -
> db.demo396.insertOne({"details" : [ ... ObjectId("5e5e782317aa3ef9ab8ab207"), ... ObjectId("5e5e782317aa3ef9ab8ab208") ... ] ... } ... ) { "acknowledged" : true, "insertedId" : ObjectId("5e5e787817aa3ef9ab8ab209") }
แสดงเอกสารทั้งหมดจากคอลเล็กชันโดยใช้วิธี find() -
> db.demo396.find();
สิ่งนี้จะสร้างผลลัพธ์ต่อไปนี้ -
{ "_id" : ObjectId("5e5e787817aa3ef9ab8ab209"), "details" : [ ObjectId("5e5e782317aa3ef9ab8ab207"), ObjectId("5e5e782317aa3ef9ab8ab208") ] }
ต่อไปนี้เป็นแบบสอบถามเพื่อดำเนินการ $lookup กับอาร์เรย์ของรหัสวัตถุ -
> db.demo396.aggregate([ ... { "$lookup": { ... "from": "demo395", ... "let": { "details": "$details" }, ... "pipeline": [ ... { "$match": { "$expr": { "$in": [ "$_id", "$$details" ] } } } ... ], ... "as": "output" ... }} ... ])
สิ่งนี้จะสร้างผลลัพธ์ต่อไปนี้ -
{ "_id" : ObjectId("5e5e787817aa3ef9ab8ab209"), "details" : [ ObjectId("5e5e782317aa3ef9ab8ab207"), ObjectId("5e5e782317aa3ef9ab8ab208") ], "output" : [ { "_id" : ObjectId("5e5e782317aa3ef9ab8ab207"), "Name" : "Chris" }, { "_id" : ObjectId("5e5e782317aa3ef9ab8ab208"), "Name" : "David" } ] }