• 聚合(aggregate)主要用于計(jì)算數(shù)據(jù)，類似sql中的sum()、avg()
• 語法：db.集合名稱.aggregate({管道:{表達(dá)式}})

管道

• 管道在Unix和Linux中一般用于將當(dāng)前命令的輸出結(jié)果作為下一個(gè)命令的輸入

ps ajx | grep mongo

• 常用管道
• $group：將集合中的文檔分組，可用于統(tǒng)計(jì)結(jié)果
• $match：過濾數(shù)據(jù)，只輸出符合條件的文檔
• $project：修改輸入文檔的結(jié)構(gòu)，如重命名、增加、刪除字段、創(chuàng)建計(jì)算結(jié)果
• $sort：將輸入文檔排序后輸出
• $limit：限制聚合管道返回的文檔數(shù)
• $skip：跳過指定數(shù)量的文檔，并返回余下的文檔
• $unwind：將數(shù)組類型的字段進(jìn)行拆分

?

表達(dá)式：處理輸入文檔并輸出

• 語法：表達(dá)式:'$列名'

常用表達(dá)式

• $sum：計(jì)算總和，$sum:1 表示以一倍計(jì)數(shù)
• $avg：計(jì)算平均值
• $min：獲取最小值
• $max：獲取最大值
• $push：在結(jié)果文檔中插入值到一個(gè)數(shù)組中
• $first：根據(jù)資源文檔的排序獲取第一個(gè)文檔數(shù)據(jù)
• $last：根據(jù)資源文檔的排序獲取最后一個(gè)文檔數(shù)據(jù)

?

$group

• 將集合中的文檔分組，可用于統(tǒng)計(jì)結(jié)果
• _id表示分組的依據(jù)，使用某個(gè)字段的格式為'$字段'
• 例1：統(tǒng)計(jì)男生、女生的總?cè)藬?shù)

db.stu.aggregate(
??? {$group:
??????? {
??????????? _id:'$gender',
??????????? counter:{$sum:1}
??????? }
??? }
)

Group by null

• 將集合中所有文檔分為一組
• 例2：求學(xué)生總?cè)藬?shù)、平均年齡

db.stu.aggregate(
??? {$group:
??????? {
??????????? _id:null,
??????????? counter:{$sum:1},
???????????avgAge:{$avg:'$age'}
??????? }
??? }
)

透視數(shù)據(jù)

• 例3：統(tǒng)計(jì)學(xué)生性別及學(xué)生姓名

db.stu.aggregate(
??? {$group:
??????? {
??????????? _id:'$gender',
??????????? name:{$push:'$name'}
??????? }
??? }
)

• 使用$$ROOT可以將文檔內(nèi)容加入到結(jié)果集的數(shù)組中，代碼如下

db.stu.aggregate(
??? {$group:
??????? {
??????????? _id:'$gender',
??????????? name:{$push:'$$ROOT'}
??????? }
??? }
)

?

$match

• 用于過濾數(shù)據(jù)，只輸出符合條件的文檔
• 使用MongoDB的標(biāo)準(zhǔn)查詢操作
• 例1：查詢年齡大于20的學(xué)生

db.stu.aggregate(
??? {$match:{age:{$gt:20}}}
)

?

$project

• 修改輸入文檔的結(jié)構(gòu)，如重命名、增加、刪除字段、創(chuàng)建計(jì)算結(jié)果

• 例1：查詢學(xué)生的姓名、年齡

db.stu.aggregate(
???{$project:{_id:0,name:1,age:1}}
)

?

$sort

• 將輸入文檔排序后輸出

• 例1：查詢學(xué)生信息，按年齡升序

b.stu.aggregate({$sort:{age:1}})

?

$limit

• 限制聚合管道返回的文檔數(shù)
• 例1：查詢2條學(xué)生信息

db.stu.aggregate({$limit:2})

$skip

• 跳過指定數(shù)量的文檔，并返回余下的文檔
• 例2：查詢從第3條開始的學(xué)生信息

db.stu.aggregate({$skip:2})

• 例3：統(tǒng)計(jì)男生、女生人數(shù)，按人數(shù)升序，取第二條數(shù)據(jù)

db.stu.aggregate(
???{$group:{_id:'$gender',counter:{$sum:1}}},
??? {$sort:{counter:1}},
??? {$skip:1},
??? {$limit:1}
)

• 注意順序：先寫skip，再寫limit

?

?

$unwind

• 將文檔中的某一個(gè)數(shù)組類型字段拆分成多條，每條包含數(shù)組中的一個(gè)值

語法1對某字段值進(jìn)行拆分

db.集合名稱.aggregate({$unwind:'$字段名稱'})

• 構(gòu)造數(shù)據(jù)

db.t2.insert({_id:1,item:'t-shirt',size:['S','M','L']})

• 查詢

db.t2.aggregate({$unwind:'$size'})

語法2對某字段值進(jìn)行拆分

• 處理空數(shù)組、非數(shù)組、無字段、null情況
• 屬性preserveNullAndEmptyArrays值為false表示丟棄屬性值為空的文檔
• 屬性preserveNullAndEmptyArrays值為true表示保留屬性值為空的文檔

db.inventory.aggregate({
??? $unwind:{
?????? ?path:'$字段名稱',
???????preserveNullAndEmptyArrays:<boolean> #防止數(shù)據(jù)丟失
??? }
})

?

• 構(gòu)造數(shù)據(jù)

db.t3.insert([
{ "_id" : 1, "item" : "a", "size": ["S", "M", "L"] },
{ "_id" : 2, "item" : "b", "size" : [ ]},
{ "_id" : 3, "item" : "c", "size":"M" },
{ "_id" : 4, "item" : "d" },
{ "_id" : 5, "item" : "e", "size" :null }
])

• 使用語法1查詢

db.t3.aggregate({$unwind:'$size'})

• 查看查詢結(jié)果，發(fā)現(xiàn)對于空數(shù)組、無字段、null的文檔，都被丟棄了
• 問：如何能不丟棄呢？
• 答：使用語法2查詢

db.t3.aggregate({$unwind:{path:'$size',preserveNullAndEmptyArrays:

true}})

?

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎勵(lì)來咯，堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎

總結(jié)

以上是生活随笔為你收集整理的4.聚合aggregate的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。