MongoDB分組查詢和聚合查詢實例教程
更新時間：2023年05月24日 11:23:57 作者：一恍過去
聚合(aggregate)是MongoDB的高級查詢語言,它允許我們通過轉化合并多個文檔的數(shù)據(jù)來生成新的在單個文檔里不存在的文檔信息,下面這篇文章主要給大家介紹了關于MongoDB分組查詢和聚合查詢的相關資料,需要的朋友可以參考下
1、單一字段分組
分組后不會展示其他字段, _id為固定寫法，userid為分組字段
# 比如對比sql：select userid from testgroup by userid
db.test.aggregate({"$group":{"_id":"$userid"}} )效果：
2、多字段分組
_id為固定寫法，userid與articleid為分組字段，多字段時需要設置一個別名
# 比如對比sql：select userid,articleid from testgroup by userid,articleid
db.test.aggregate({"$group":{"_id":{"userid":"$userid","articleid":"$articleid"}}})效果：
3、條件匹配分組
$match表示匹配條件，在group前表示where，在后表示having，userid為分組字段
# 比如對比sql：select userid from testwhere userid in("1","2") group by userid
db.test.aggregate(
{"$match":{"userid":{"$in":["1","2"]}}},
{"$group":{"_id":"$userid"}}
)
或者
# 比如對比sql：select userid,articleid from test where userid in("1","2") group by userid
db.test.aggregate(
{"$match":{"userid":{"$in":["1","2"]}}},
{"$group":{"_id":{"userid":"$userid","articleid":"$articleid"}}}
)
或者having聚合查詢
# 比如：select userid,avg(price) as avg from test where userid >'10' group by userid having avg>35
db.test.aggregate(
{"$match":{"userid":{"$gt":"10"}}},
{"$group":{"_id":"$userid",'avg':{"$avg":"$price"}}},
{"$match":{"avg":{"$gt":35}}}
)效果：
4、分組分頁排序
限制：$limit、跳過：$skip
db.test.aggregate(
{"$group":{"_id":"$userid"}},
{"$skip":1},
{"$limit":2}
)5、聚合分組
聚合分組,分為：$sum、$avg、$max、$min、$first、$last，聚合結果需要使用別名，并且可以結合條件和排序等元素
為了測試聚合，增加一下文件：
db.test.insert([{
"articleid":"1",
"price":200,
"userid":"5"
},{
"articleid":"2",
"price":300,
"userid":"5"
},{
"articleid":"3",
"price":400,
"userid":"5"
},{
"articleid":"1",
"price":200,
"userid":"6"
},{
"articleid":"2",
"price":300,
"userid":"7"
}]);5.1、sum聚合-求數(shù)值總和
求某個數(shù)值總和，userid分組字段[可以用于多字段聚合],{"$sum":$price}表示求price合計
db.test.aggregate({"$group":{"_id":"$userid","total":{"$sum":"$price"}}})
5.2、sum聚合-求分組后數(shù)量
db.test.aggregate({"$group":{"_id":"$userid","total":{"$sum":1}}})效果：
5.3、avg、max、min聚合
avg、max、min可以分開使用，也可以一起使用
db.test.aggregate({"$group":{"_id":"$userid","avg":{"$avg":"$price"},"max":{"$max":"$price"},"min":{"$min":"$price"}}})效果：
5.4、復合聚合
可以多字段聚合求值，通過sum與avg、max、min進行組合
db.test.aggregate({"$group":{"_id":"$userid"
,"total":{"$sum":"$price"}
,"avg":{"$avg":"$price"}}})效果：
5.5、聚合分組排序
對聚合結果進行排序，$sort-排序，avg-聚合結果的別名，1：升序，-1：降序
# 先按userid降序,再avg升序
db.test.aggregate({"$group":{"_id":"$userid"
,"avg":{"$avg":"$price"}}}
,{"$sort":{"avg":1}}
,{"$sort":{"_id":-1}})效果：
5.6、首尾取值聚合
$first-第一個元素、$last-最后一個元素
vdb.test.aggregate({"$group":{"_id":"$userid","prices":{"$first":"$price"}}})效果：
5.7、聚合分組拼接
等同于group_concat，$push-元素可重復，$addToSet-元素不可重復，將分組后的數(shù)據(jù)拼接為一個數(shù)組
db.test.aggregate({"$group":{"_id":"$userid","names":{"$push":"$price"}}})效果：
補充：關于MongoDB中一些復雜的聚合分組查詢操作
一、字段切割&條件判斷
匯總各個店鋪【$shop_name】在某個時間段【$patrol_time】內違規(guī)【$whether_violates == ‘Y’】的記錄數(shù)
1.$substr:[‘字段名’,開始下標,結束下標]
2.$cond:{if…then…else}
查詢SQL如下：
db.t_tbshop_patrol.aggregate([
{
"$project":
{
"yearMonthDay": {
"$substr": ["$patrol_time", 0, 10]
},
"patrol_time": 1,
"shop_name": 1,
"whether_violates": 1,
"y_count": {
"$sum": {
"$cond": {
"if": {
"$eq": ["$whether_violates", "Y"]
},
"then": 1,
"else": 0
}
}
}
}
},
{
"$match": {
"patrol_time": {
"$gte": "2021-09-29 00:00:00",
"$lte": "2021-09-29 23:59:59"
}
}
},
{
"$group": {
"_id": {
"patrol_time": "$yearMonthDay",
"shop_name": "$shop_name"
},
"violate_y": {
"$sum": "$y_count"
}
}
},
/* 只展示匯總結果大于0的店鋪數(shù)據(jù)，去掉下面{'$match'}則展示所有店鋪數(shù)據(jù) */
{
"$match": {
"violate_y": {
"$gt": 0
}
}
}
])查詢結果如下：
/* 1 */
{
"_id" : {
"patrol_time" : "2021-09-29",
"shop_name" : "VETA個護海外旗艦店"
},
"violate_y" : 5.0
}/* 2 */
{
"_id" : {
"patrol_time" : "2021-09-29",
"shop_name" : "swisseFuJun海外專賣店"
},
"violate_y" : 24.0
}/* 3 */
{
"_id" : {
"patrol_time" : "2021-09-29",
"shop_name" : "咿兒潤旗艦店"
},
"violate_y" : 1.0
}
二、聯(lián)表查詢&類型轉換&拆分數(shù)組
根據(jù)日期查詢訂單表中每條訂單數(shù)據(jù)每種商品（非贈品）的總金額（業(yè)務需要顯示倉庫，但原始數(shù)據(jù)中只有倉庫編號，所以和倉庫信息表【t_warehouse_info】使用聯(lián)表查詢）
1.$lookup
2.$toDouble、$convert
3.$unwind
原始數(shù)據(jù)示例：
{
"_id" : ObjectId("5f33abcdfc12b1f2d21b2e5d"),
/* 訂單編號 */
"order_sn" : "12023232223920",
"add_time" : "2021-09-29 20:01:25",
"complete_time" : "1596330674",
/* 倉庫編號 */
"fhck" : "151",
"last_update" : "2021-09-29 09:14:03",
"lylx" : "1",
/* 訂單商品明細：同一筆訂單下的同一商品可能有多條，所以需要根據(jù)商品編號【goods_sn】分組求和 */
"orderDetailGets" : [
{
"goods_sn" : "6925425422173",
"goods_id" : "2518",
"goods_number" : "3",
"goods_price" : "35.19",
"shop_price" : "79.00",
"share_price" : "35.19",
/* 支付金額 */
"share_payment" : "35.19",
"original_order_sn" : "12023232223920",
"goods_name" : "口力橡皮糖500g",
/* 是否贈品（1：是；0：否）*/
"is_gift" : "0",
"share_shipping_fee" : "0.00"
},
{
"goods_sn" : "6971083865227",
"goods_id" : "1569",
"goods_number" : "1",
"goods_price" : "1.87",
"shop_price" : "4.50",
"share_price" : "1.87",
"share_payment" : "1.87",
"original_order_sn" : "12023232223920",
"goods_name" : "口力組合橡皮糖隨手包30g",
"is_gift" : "0",
"share_shipping_fee" : "0.00"
},
{
"goods_sn" : "6971083865227",
"goods_id" : "1569",
"sku_id" : "1569",
"goods_number" : "2",
"goods_price" : "1.87",
"shop_price" : "4.50",
"goods_price" : "1.87",
"share_payment" : "3.74",
"original_order_sn" : "12023232223920",
"goods_name" : "口力組合橡皮糖隨手包30g",
"is_gift" : "0",
"share_shipping_fee" : "0.00"
}
],
"order_msg" : "",
"order_status" : "5",
"pay_time" : "2021-09-29 20:03:13",
"payment" : "37.06",
"sd_name" : "口力旗艦店",
"total_amount" : "84.54",
"weigh" : "0.800000"
}查詢SQL如下：
db.getCollection('t_shop_order').aggregate([
{
"$match": {
"add_time": {
"$gte": "2021-12-14 00:00:00",
"$lte": "2021-12-14 23:59:59"
}
}
},
/* $lookup聯(lián)表查詢：相當于left join；關聯(lián)后的子表數(shù)據(jù)無論是1對1還是1對多，都會形成一個數(shù)組對象 */
{
"$lookup": {
"from": "t_warehouse_info",
/* 主表的關聯(lián)字段名 */
"localField": "fhck",
/* 關聯(lián)表的字段名 */
"foreignField": "ckdm",
/* 關聯(lián)表別名，作為數(shù)據(jù)的字段名 */
"as": "warehouse_info"
}
},
/* $unwind拆分數(shù)組對象，扁平化展示 */
{
"$unwind": "$orderDetailGets"
},
{
"$project": {
"order_sn": 1,
"add_time": 1,
"goods_sn": "$orderDetailGets.goods_sn",
"is_gift": "$orderDetailGets.is_gift",
/* $convert類型轉換：將字符串轉換為int類型，以助于后面的數(shù)據(jù)統(tǒng)計 */
"goods_number": {
"$convert": {
"input": "$orderDetailGets.goods_number",
"to": "int"
}
},
"goods_name": "$orderDetailGets.goods_name",
/* $ifNull空判斷：如果對應字符串為null，則設置默認值為0 */
/* $toDouble轉換為浮點型：將數(shù)據(jù)轉換為浮點型數(shù)據(jù) */
"share_payment": {
"$ifNull": [{
"$toDouble": "$orderDetailGets.share_payment"
}, 0]
},
"ckmc": "$warehouse_info.ckmc"
}
},
{
"$match": {
"is_gift": "0"
}
},
{
"$unwind": "$ckmc"
},
{
"$group": {
_id: {
"order_sn": "$order_sn",
"add_time": "$add_time",
"goods_sn": "$goods_sn",
"goods_name": "$goods_name"
},
"goods_number": {
"$sum": "$goods_number"
},
"share_payment": {
"$sum": "$share_payment"
}
}
}
])查詢SQL如下：
/* 1 */
{
"_id" : {
"order_sn" : "12023232223920",
"add_time" : "2021-12-14 12:22:16",
"goods_sn" : "6925425422173",
"goods_name" : "口力橡皮糖500g"
},
"goods_number" : 3,
"share_payment" : 35.19
}
/* 2 */
{
"_id" : {
"order_sn" : "12023232223920",
"add_time" : "2021-12-14 22:37:09",
"goods_sn" : "6971083865227",
"goods_name" : "口力組合橡皮糖隨手包30g"
},
"goods_number" : 3,
"share_payment" : 5.61
}總結
到此這篇關于MongoDB分組查詢和聚合查詢的文章就介紹到這了,更多相關MongoDB分組查詢和聚合查詢內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
MongoDB 提供了豐富的查詢功能，包括條件組合、反向查詢、查詢結果過濾、排序等，借助 MongoDB 多樣化的查詢方式，可以完成業(yè)務上的各類查詢需要。2021-06-06
這篇文章主要為大家分享一下重裝mongodb或者升級mongdb版本后,重啟啟動也沒有任何錯誤提示,但是查看為失敗failed狀態(tài),沒有啟動成功問題的解決方法2024-05-05
MongoDB4.0在windows10下的安裝與服務配置教程詳解
本文通過圖文并茂的形式給大家介紹了MongoDB4.0在windows10下的安裝與服務配置教程，非常不錯，具有一定的參考借鑒價值,需要的朋友可以參考下2018-08-08
本文章先來給大家簡單介紹關于MongoDB 數(shù)據(jù)分頁和排序 limit,skip用戶的一些基礎語句，然后用一個實例詳細介紹MongoDB 數(shù)據(jù)分頁和排序實例方法。2014-08-08
使用mongoose和bcrypt實現(xiàn)用戶密碼加密的示例
下面小編就為大家分享一篇使用mongoose和bcrypt實現(xiàn)用戶密碼加密的示例，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2018-02-02
MongoDB單表數(shù)據(jù)的導出和恢復實例講解
MongoDB 是一個跨平臺的，面向文檔的數(shù)據(jù)庫，提供高性能，高可用性和可擴展性方便。 MongoDB 工作在收集和文件的概念。接下來通過本文給大家介紹MongoDB單表數(shù)據(jù)的導出和恢復實例講解，對mongodb導出和恢復數(shù)據(jù)知識感興趣的朋友一起學習吧2016-03-03
Mongodb數(shù)據(jù)庫誤刪后的恢復方法(兩種)
本文給大家分享兩種方法來實現(xiàn)Mongodb數(shù)據(jù)庫誤刪后的恢復，每種方法給大家介紹的都非常詳細，需要的朋友參考下吧2018-08-08
本文給大家分享的是一些使用mongoDB優(yōu)化方面的心得，有需要的小伙伴可以參考下2017-12-12
MongoDB連接和創(chuàng)建數(shù)據(jù)庫的方法講解
這篇文章介紹了MongoDB連接和創(chuàng)建數(shù)據(jù)庫的方法，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2022-03-03
這篇文章主要介紹了MongoDB教程之索引介紹,本文講解了索引基礎、唯一索引、使用explain、索引管理等內容,需要的朋友可以參考下2015-05-05