MongoDB聚合运算之group和aggregate聚集框架简单聚合（10）
聚合運算之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）的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 在vs2012下编译出现Msvcp120
- 下一篇： 【原创】MySQL5.7 虚拟列实现表达