mongdb group聚合操作
阿新 • • 發佈：2019-01-04
1、資料準備
[{"goods_id":1,"cat_id":4,"goods_name":"KD876","goods_number":1,"click_count":7,"shop_price":1388.00,"add_time":1240902890},{"goods_id":4,"cat_id":8,"goods_name":"\u8bfa\u57fa\u4e9aN85\u539f\u88c5\u5145\u7535\u5668","goods_number":17,"click_count":0,"shop_price":58.00,"add_time":1241422402},{"goods_id":3,"cat_id":8,"goods_name":"\u8bfa\u57fa\u4e9a\u539f\u88c55800\u8033\u673a","goods_number":24,"click_count":3,"shop_price":68.00,"add_time":1241422082},{"goods_id":5,"cat_id":11,"goods_name":"\u7d22\u7231\u539f\u88c5M2\u5361\u8bfb\u5361\u5668","goods_number":8,"click_count":3,"shop_price":20.00,"add_time":1241422518},{"goods_id":6,"cat_id":11,"goods_name":"\u80dc\u521bKINGMAX\u5185\u5b58\u5361","goods_number":15,"click_count":0,"shop_price":42.00,"add_time":1241422573},{"goods_id":7,"cat_id":8,"goods_name":"\u8bfa\u57fa\u4e9aN85\u539f\u88c5\u7acb\u4f53\u58f0\u8033\u673aHS-82","goods_number":20,"click_count":0,"shop_price":100.00,"add_time":1241422785},{"goods_id":8,"cat_id":3,"goods_name":"\u98de\u5229\
2、group引數解析
官方給出引數結構：
{
group:
{
ns: <namespace>,
key: <key>,
$reduce: <reduce function>,
$keyf: <key function>,
cond: <query>,
finalize: <finalize function>
}
}
重要引數解析：
key：作為分組的key
reduce：這些函式可以返回一個sum或count。該函式接受兩個引數(curr,result)：curr(當前文件)和result(分組聚集的結果文件)。
initial：初始化聚合結果文件變數，為空時自動為每列提供初始變數。
keyf：可選。替代的key 欄位。指定一個函式建立一個“key object”作為分組的key。使用keyf而是通過group by領域而不是現有的文件域鍵組。
cond：過濾條件
finalize：在db.collection.group()返回最終結果之前，此功能可以修改的結果文件或替換的結果文件作為一個整體。
3、執行順序解析
1、key-->2、initial-->3、cond-->4、reduce 將本組資訊儲存，然後其他組迴圈2，3，4執行
4、執行案例
#key：表示分組的欄位 #cond：分組後查詢的條件 #reduce：聚合操作，其中curr表示當前文件的指標，result表示分組聚集的文件 #initial:引數初始化操作 #finalize:最終執行函式，類似java中的finally程式碼塊 #查詢每個欄目下的商品數量 { key:{cat_id:1}, cond:{}, reduce:function(curr,result) { result.cnt += 1; }, initial:{cnt:0} } #查詢每個欄目下價格高於50元的商品數量 { key:{cat_id:1}, cond:{shop_price:{$gt:50}}, reduce:function(curr,res){ res.cnt +=1; }, initial:{cnt:0} } #每個欄目下的商品庫存量 sum()操作 { key:{cat_id:1}, cond:{}, reduce:function(curr,res){ res.num +=curr.goods_number; }, initial:{num:0} } #查詢每個欄目最貴的商品價格, max()操作 { key:{cat_id:1}, cond:{}, reduce:function(curr,res){ if(res.price<curr.shop_price){ res.price = curr.shop_price; } }, initial:{price:0} } #查詢每個欄目下商品的平均價格 { key:{cat_id:1}, cond:{}, reduce:function(curr,res){ res.cnt +=1; res.sum += curr.shop_price; }, initial:{sum:0,cnt:0}, finalize:function(res){ res.avg = res.sum/res.cnt; } }
歡迎留言，一起學習、進步。