MongoDB聚合和投影


为此,请使用$project和aggregate()。聚合中的$project将带有请求字段的文档传递到管道的下一个阶段。

让我们创建一个包含文档的集合-

> db.demo762.insertOne({
...    "_id" : {
...       "userId":101,
...       "userName":"Chris"
...    },
..   . "countryName" : "US",
...
...    "details" : [
...       {
...          "Name" : "Robert",
...          "DueDate" : "2020-04-10"
...
...       },
...
...       {
...          "Name" : "Robert",
...          "DueDate" : "2020-04-09"
...       },
...       {
...          "Name" : "Robert",
...          "DueDate" : "2020-03-06"
...       }
...    ]
... }
... );
{
   "acknowledged" : true,
   "insertedId" : {
      "userId" : 101,
      "userName" : "Chris"
   }
}

在find()方法的帮助下显示集合中的所有文档-

> db.demo762.find();

这将产生以下输出-

{ "_id" : { "userId" : 101, "userName" : "Chris" }, "countryName" : "US", "details" : [ { "Name" : "Robert", "DueDate" : "2020-04-10" }, { "Name" : "Robert", "DueDate" : "2020-04-09" }, { "Name" : "Robert", "DueDate" : "2020-03-06" } ] }

以下是对MongoDB聚合和投影的查询-

> db.demo762.aggregate([
...    { "$match": {
...       "_id": { "$eq": { userId:101,userName:"Chris" }}
...    }},
...    { "$unwind": "$details" },
...    { "$sort": { "details.DueDate": 1 }},
...    { "$group": {
...       "_id": "$_id",
...       "details": { "$push": "$details" },
...       "countryName": { "$first": "$countryName" }
...    }},
... { "$project": { "details": { "$slice": ["$details", 2] } ,"countryName": 1 }}
... ]).pretty();

这将产生以下输出-

{
   "_id" : {
      "userId" : 101,
      "userName" : "Chris"
   },
   "countryName" : "US",
   "details" : [
      {
         "Name" : "Robert",
         "DueDate" : "2020-03-06"
      },
      {
         "Name" : "Robert",
         "DueDate" : "2020-04-09"
      }
   ]
}