MongoDB分组查询、聚合查询实例
作者：一恍过去
前言
在MongoDB中，可以使用分组查询（Group by）和聚合查询（Aggregation）来进行数据的分组和聚合操作。
聚合查询的灵活性使您能够根据需求对数据进行复杂的转换和分析，例如计算平均值、求和、最大值、最小值等。您可以根据具体的业务需求和查询要求，组合不同的聚合阶段来完成复杂的数据处理操作。
分组查询（Group by）：
分组查询允许您根据指定的字段将文档分组并计算各个组的统计信息。
聚合查询（Aggregation）：
聚合查询提供了更强大和灵活的聚合操作，可以通过多个阶段（Stage）来对数据进行处理和转换
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聚合-求数值总和
求某个数值总和，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"}}})
效果：
总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。