1 单一分组
分组后不会展示其他字段, _id为固定写法,userid为分组字段
# 比如对比sql:select userid from test group by userid
db.test.aggregate({"$group":{"_id":"$userid"}} )
2 多字段分组
_id为固定写法,userid与articleid为分组字段,多字段时需要设置一个别名
# 比如对比sql:select userid,articleid from test group by userid,articleid
db.test.aggregate({"$group":{"_id":{"userid":"$userid","articleid":"$articleid"}}})
3 条件匹配分组
$match表示匹配条件,在group前表示where,在后表示having,userid为分组字段
# 比如对比sql:select userid from test where 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 分组分页排序
限制:skip
db.test.aggregate(
{"$group":{"_id":"$userid"}},
{"$skip":1},
{"$limit":2}
)
5 聚合分组
聚合分组,分为:avg、
min、
last,聚合结果需要使用别名,并且可以结合条件和排序等元素
5.1 sum聚合-求数值总和
求某个数值总和,userid分组字段[可以用于多字段聚合],{"price}表示求price合计
db.test.aggregate({"$group":{"_id":"$userid","total":{"$sum":"$price"}}})
5.2 sum聚合-求分组后数量
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 首尾取值聚合
last-最后一个元素
vdb.test.aggregate({"$group":{"_id":"$userid","prices":{"$first":"$price"}}})
5.7 聚合分组拼接
等同于group_concat,addToSet-元素不可重复,将分组后的数据拼接为一个数组
db.test.aggregate({"$group":{"_id":"$userid","names":{"$push":"$price"}}})