深入學習MongoDB之聚合函式
/* 1 */
{
"_id" : ObjectId("5b496ee9497e95fe15e0b935"),
"name" : "李四",
"age" : NumberLong(12),
"major" : "math",
"address" : "北京海淀區"
}
/* 2 */
{
"_id" : ObjectId("5b4995e824cd61fde7f581ee"),
"name" : "張三",
"age" : NumberLong(18),
"address" : "紐約"
}
/* 3 */
{
"_id" : ObjectId("5b497360497e95fe15e0b93e"),
"name" : "bingo",
"age" : NumberLong(19),
"major" : "computer",
"address" : "上海"
}
/* 4 */
{
"_id" : ObjectId("5b496f81497e95fe15e0b936"),
"name" : "haha",
"age" : NumberLong(21),
"major" : "chinese",
"address" : "天津"
}
/* 5 */
{
"_id" : ObjectId("5b499bf37c9fa794f8424f58"),
"name" : "yuyuyu",
"age" : NumberLong(40),
"address" : "紐約"
}
/* 6 */
{
"_id" : ObjectId("5b4995c77c9fa794f8424f57"),
"name" : "張三",
"age" : "18",
"address" : "紐約"
}
/* 7 */
{
"_id" : ObjectId("5b496f9d497e95fe15e0b937"),
"name" : "sank",
"age" : "22",
"major" : "computer",
"address" : "天津"
}
聚合基本語法
db.getCollection("test").aggregate(option)
count操作:
db.getCollection("test").count(<query>)聚合寫法:
db.getCollection("test").aggregate({$group:{_id:null,count:{$sum:1}}})
分組count:
db.getCollection("test").aggregate({$group:{_id:"$address",count:{$sum:1}}})
分組sum:
db.getCollection("test").aggregate({$group:{_id:"$address",sumage:{$sum:"$age"}}})
分組avg:
db.getCollection("test").aggregate({$group:{_id:"$address",avg:{$avg:"$age"}}})
常見的聚合表示式表示式 描述 例項
$sum 計算總和。 db.mycol.aggregate([{$group : {_id : "$name", num_tutorial : {$sum : "$age"}}}])
$avg 計算平均值 db.mycol.aggregate([{$group : {_id : "$name", num_tutorial : {$avg : "$age"}}}])
$min 獲取集合中所有文件對應值得最小值。 db.mycol.aggregate([{$group : {_id : "$name", num_tutorial : {$min : "$age"}}}])
$max 獲取集合中所有文件對應值得最大值。 db.mycol.aggregate([{$group : {_id : "$name", num_tutorial : {$max : "$age"}}}])
$push 在結果文件中插入值到一個數組中。 db.mycol.aggregate([{$group : {_id : "$name", url : {$push: "$url"}}}])
$addToSet 在結果文件中插入值到一個數組中,但不建立副本。 db.mycol.aggregate([{$group : {_id : "$name", url : {$addToSet : "$url"}}}])
$first 根據資源文件的排序獲取第一個文件資料。 db.mycol.aggregate([{$group : {_id : "$name", first_url : {$first : "$url"}}}])
$last 根據資源文件的排序獲取最後一個文件資料 db.mycol.aggregate([{$group : {_id : "$name", last_url : {$last : "$url"}}}])
管道概念,MongoDB聚合管道在一個管道處理後交給下一個管道,下面是常用的管道操作: $project:修改輸入文件的結構。可以用來重新命名、增加或刪除域,也可以用於建立計算結果以及巢狀文件。
$match:用於過濾資料,只輸出符合條件的文件。$match使用MongoDB的標準查詢操作。
$limit:用來限制MongoDB聚合管道返回的文件數。
$skip:在聚合管道中跳過指定數量的文件,並返回餘下的文件。
$unwind:將文件中的某一個數組型別欄位拆分成多條,每條包含陣列中的一個值。
$group:將集合中的文件分組,可用於統計結果。
$sort:將輸入文件排序後輸出。
$geoNear:輸出接近某一地理位置的有序文件。
示例:
db.getCollection("test").aggregate({$project:{name:1,age:1}})返回值取name和age聚合match 後 group
db.getCollection("test").aggregate({$match:{age:{$gt:10,$lte:20}}},{$group:{_id:"$address",avg:{$avg:"$age"}}})
篩選後分組
相當於where sth group by sth
db.getCollection("test").aggregate({$group:{_id:"$address",avg:{$avg:"$age"}}},{$match:{avg:{$gt:10,$lte:20}}})
分組後篩選
相當於 group by sth having sth
db.getCollection("test").aggregate(
{$group:{_id:"$address",avg:{$avg:"$age"}}},
{$match:{avg:{$gt:10,$lte:20}}},
{$sort:{avg:1}}
)
分組後篩選再排序
相當於group by sth having sth order by sth