聚合運算之group

語法：

db.collection.group(

{

key:{key1:1,key2:1},

cond:{},

reduce: function(curr,result) {

},

initial:{},

finalize:function() {

}

}

?

)

key: 分組字段

cond:查詢條件

reduce:聚合函數

initial:初始化

finalize:統計一組后的回調函數

?

?

#查詢每個欄目下的商品數量

db.goods.group(

{

key:{cat_id:1},

cond:{},

reduce:function(curr,result) {

??? result.cnt += 1;

},

initial:{cnt:0}

}

)

?

#查詢每個欄目下價格高于50元的商品數量

db.goods.group(

{

key:{cat_id:1},

cond:{shop_price:{$gt:50}},

reduce:function(curr,result) {

??? result.cnt += 1;

},

initial:{cnt:0}

}

)

?

?

?

#每個欄目下的商品庫存量 sum()操作

db.goods.group(

{

key:{cat_id:1},

cond:{},

reduce:function(curr,result) {

??? result.num += curr.goods_number;

},

initial:{num:0}

}

)

?

#查詢每個欄目最貴的商品價格, max()操作

db.goods.group(

{

key:{cat_id:1},

cond:{},

reduce:function(curr , result) {

??? if(curr.shop_price > result.max) {

??????? result.max = curr.shop_price;

??? }

},

initial:{max:0}

}

)

?

?

?

?

#查詢每個欄目下商品的平均價格

db.goods.group(

{

key:{cat_id:1},

cond:{},

reduce:function(curr , result) {

??? result.cnt += 1;

??? result.sum += curr.shop_price;

},

initial:{sum:0,cnt:0},

finalize:function(result) {

??? result.avg = result.sum/result.cnt;

}

}

)

?

?

?

使用aggregate聚集框架簡單聚合

?

#查詢每個欄目下的商品數量

db.collection.aggregate

(

[

{$group:{_id:"$cat_id",total:{$sum:1}}}

]

);

#查詢goods下有多少條商品,select count(*) from goods

db.collection.aggregate

(

?

[

{$group:{_id:null,total:{$sum:1}}}

]

)

?

#查詢每個欄目下 價格大于50元的商品個數

db.collection.aggregate

(

[

{$match:{shop_price:{$gt:50}}},

{$group:{_id:"$cat_id",total:{$sum:1}}}

]

)

?

#查詢每個欄目下 價格大于50元的商品個數

#并篩選出"滿足條件的商品個數" 大于等于3的欄目

db.collection.aggregate

(

[

{$match:{shop_price:{$gt:50}}},

{$group:{_id:"$cat_id",total:{$sum:1}}},

{$match:{total:{$gte:3}}}

]

)

?

?

#查詢每個欄目下的庫存量

db.collection.aggregate

(

[

{$group:{_id:"$cat_id" , total:{$sum:"$goods_number"}}},

]

)

?

#查詢每個欄目下的庫存量,并按庫存量排序

db.collection.aggregate

(

[

{$group:{_id:"$cat_id" , total:{$sum:"$goods_number"}}},

{$sort:{total:1}}

]

)

?

#查詢每個欄目下的庫存量,并按庫存量排序

db.collection.aggregate

(

[

{$group:{_id:"$cat_id" , total:{$sum:"$goods_number"}}},

{$sort:{total:1}},

{$limit:3}

]

)

?

#查詢每個欄目的商品平均價格,并按平均價格由高到低排序

db.collection.aggregate

(

[

{$group:{_id:"$cat_id" , avg:{$avg:"$shop_price"}}},

{$sort:{avg:-1}}

]

)

總結

以上是生活随笔為你收集整理的MongoDB聚合运算之group和aggregate聚集框架简单聚合（10）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。