MongoDB查询实现聚合功能
首先让我们创建一个包含文档的集合-
> db.demo121.insertOne(
... {
... "Id" : 101,
... "Details" : [
... {
... "SubjectId" : "1",
... "SubjectName" : "MongoDB",
... "Score" : 76
... },
... {
... "SubjectId" : "2",
... "SubjectName" : "MySQL",
... "Score" : 76
... },
... {
... "SubjectId" : "3",
... "SubjectName" : "Java",
... "Score" : 76
... }
... ]
... }
... );
{
"acknowledged" : true,
"insertedId" : ObjectId("5e2f1c60140daf4c2a3544b3")
}在find()方法的帮助下显示集合中的所有文档-
> db.demo121.find();
这将产生以下输出-
{
"_id" : ObjectId("5e2f1c60140daf4c2a3544b3"), "Id" : 101, "Details" : [
{ "SubjectId" : "1", "SubjectName" : "MongoDB", "Score" : 76 },
{ "SubjectId" : "2", "SubjectName" : "MySQL", "Score" : 76 },
{ "SubjectId" : "3", "SubjectName" : "Java", "Score" : 76 }
]
}以下是实现聚合功能的查询-
> db.demo121.aggregate([
... { "$match": { "Id": 101 } },
... { "$unwind": "$Details" },
... {
... "$group": {
... "_id": "$Details.SubjectId",
... "count": { "$sum": 1 },
... "Details": {
... "$push": {
... "SubjectName": "$Details.SubjectName"
... }
... }
... }
... },
... {
... "$group": {
... "_id": null,
... "List": {
... "$push": {
... "SubId": "$_id",
... "Details": "$Details"
... }
... }
... }
... }
... ], function (err, out) {
... res.json(out);
... });这将产生以下输出-
{
"_id" : null, "List" : [
{ "SubId" : "3", "Details" : [ { "SubjectName" : "Java" } ] },
{ "SubId" : "2", "Details" : [ { "SubjectName" : "MySQL" } ] },
{ "SubId" : "1", "Details" : [ { "SubjectName" : "MongoDB" } ] }
]
}