MongoDB分组查询、聚合查询
目录
- 1、单一字段分组
- 2、多字段分组
- 3、条件匹配分组
- 4、分组分页排序
- 5、聚合分组
-
- 5.1、sum聚合-求数值总和
- 5.2、sum聚合-求分组后数量
- 5.3、avg、max、min聚合
- 5.4、复合聚合
- 5.5、聚合分组排序
- 5.6、首尾取值聚合
- 5.7、聚合分组拼接
1、单一字段分组
分组后不会展示其他字段, _id为固定写法,userid为分组字段
# 比如对比sql:select userid from testgroup by useriddb.test.aggregate({"$group":{"_id":"$userid"}} )
效果:
2、多字段分组
_id为固定写法,userid与articleid为分组字段,多字段时需要设置一个别名
# 比如对比sql:select userid,articleid from testgroup by userid,articleiddb.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 useriddb.test.aggregate( {"$match":{"userid":{"$in":["1","2"]}}}, {"$group":{"_id":"$userid"}})或者# 比如对比sql:select userid,articleid from test where userid in("1","2") group by useriddb.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>35db.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聚合-求数值总和
求某个数值总和,userid分组字段[可以用于多字段聚合],{"$sum":$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、首尾取值聚合
$first-第一个元素、$last-最后一个元素
vdb.test.aggregate({"$group":{"_id":"$userid","prices":{"$first":"$price"}}})
效果:
5.7、聚合分组拼接
等同于group_concat,$push-元素可重复,$addToSet-元素不可重复
,将分组后的数据拼接为一个数组
db.test.aggregate({"$group":{"_id":"$userid","names":{"$push":"$price"}}})
效果: