实施MongoDB Aggregate-展开,分组和项目?

MongoDB中的$unwind从输入文档中解构一个数组字段,以输出每个元素的文档。

$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") }