Mongodb简介
MongoDB是一个基于分布式文件存储的数据库。由C++语言编写。旨在为WEB应用提供可扩展的高性能数据存储解决方案。
aggregate语法
Mongodb的Collection对象提供了aggregate()方法来对数据进行聚合处理。语法格式为：
aggregate(operators,[options],callback)
管道操作符
| 常用管道 | 含义 |
|---|---|
| $group | 将collection中的document分组，可用于统计结果 |
| $match | 过滤数据，只输出符合结果的文档 |
| $project | 修改输入文档的结构(例如重命名，增加、删除字段，创建结算结果等) |
| $sort | 将结果进行排序后输出 |
| $limit | 限制管道输出的结果个数 |
| $skip | 跳过制定数量的结果，并且返回剩下的结果 |
| $unwind | 将数组类型的字段进行拆分 |
表达式操作符
| 常用表达式 | 含义 |
|---|---|
| $sum | 计算总和,使用{
s u m : ′ sum: ‘ sum:′制定字段’}也能直接获取制定字段的值的总和 |
| $avg | 平均值 |
| $min | min |
| $max | max |
| $push | 将结果文档中插入值到一个数组中 |
| $first | 根据文档的排序获取第一个文档数据 |
| $last | 根据文档的排序最后一个数据 |
业务需求
查询2021-10-01 到 2022-11-03，通话时间大于等於30秒的通话数量，按照打电话的人进行分组并统计组内数量
定义查询语句
db.getCollection('conversation_info').aggregate([
{$match:{"connectMode":"tel","mediaType":"voice",
"$and":[{"createTime":{"$gte":new Date("2021-10-01 00:00:00")}},{"createTime":{"$lt":new Date("2022-11-03 00:00:00")}}],
"billSec":{$gte:NumberLong(30)}}},
{$group:{"_id":'$senderId',counter:{$sum:1}}}
])
执行结果：
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/154671.html
