นำ MongoDB Aggregate ไปใช้ - คลี่คลาย กลุ่มและโครงการ?

$unwind ใน MongoDB แยกโครงสร้างฟิลด์อาร์เรย์ออกจากเอกสารอินพุตเพื่อส่งออกเอกสารสำหรับแต่ละองค์ประกอบ

$group ใช้เพื่อจัดกลุ่มเอกสารอินพุตโดยนิพจน์ _id ที่ระบุ และสำหรับการจัดกลุ่มที่แตกต่างกันแต่ละรายการ จะส่งออกเอกสาร

$project ใช้เพื่อส่งต่อเอกสารพร้อมช่องที่ร้องขอไปยังขั้นตอนถัดไปในไปป์ไลน์

ให้เราสร้างคอลเลกชันที่มีเอกสาร -

> db.demo238.insertOne(
...   {
...
...      "EmailId" : "John@gmail.com",
...      "details" : [
...         {
...            "Name" : "Bob",
...            "isActive" : true
...         }
...      ]
...   }
...);
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5e4418e3f4cebbeaebec5152")
}
>
> db.demo238.insertOne(
...   {
...
...      "EmailId" : "Chris@gmail.com",
...      "details" : [
...         {
...            "Name" : "David"
...         }
...      ]
...   }
...);
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5e4418e3f4cebbeaebec5153")
}
>
>
> db.demo238.insertOne(
...   {
...
...      "EmailId" : "Mike@gmail.com",
...      "details" : [
...         {
...            "Name" : "Carol",
...            "isActive" : true
...         }
...      ]
...   }
...);
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5e4418e4f4cebbeaebec5154")
}

แสดงเอกสารทั้งหมดจากคอลเล็กชันโดยใช้วิธี find():

> db.demo238.find().pretty();

สิ่งนี้จะสร้างผลลัพธ์ต่อไปนี้ -

{
   "_id" : ObjectId("5e4418e3f4cebbeaebec5152"),
   "EmailId" : "John@gmail.com",
   "details" : [
      {
         "Name" : "Bob",
         "isActive" : true
      }
   ]
}
{
   "_id" : ObjectId("5e4418e3f4cebbeaebec5153"),
   "EmailId" : "Chris@gmail.com",
   "details" : [
      {
         "Name" : "David"
      }
   ]
}
{
   "_id" : ObjectId("5e4418e4f4cebbeaebec5154"),
   "EmailId" : "Mike@gmail.com",
   "details" : [
      {
         "Name" : "Carol",
         "isActive" : true
      }
   ]
}

ต่อไปนี้เป็นแบบสอบถามเพื่อใช้ MongoDB Aggregate - คลี่คลาย กลุ่มและโครงการ -

> db.demo238.aggregate(
...   [
...      { "$match": { "details.isActive": true } },
...      { "$unwind": "$details" },
...      { "$match": { "details.isActive": true } },
...      { "$group": {
...         "_id": "$details.Name",
...         "active": { "$first": "$_id" }
...      }}
...   ],
...   function(err,result) {
...
...   }
...);

สิ่งนี้จะสร้างผลลัพธ์ต่อไปนี้ -

{ "_id" : "Carol", "active" : ObjectId("5e4418e4f4cebbeaebec5154") }
{ "_id" : "Bob", "active" : ObjectId("5e4418e3f4cebbeaebec5152") }