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