Mongodb aggregate聚合语法按条件分组

r囧r小猫 2024-04-01 13:32 69阅读 0赞

**Mongodb简介**  
MongoDB是一个基于分布式文件存储的数据库。由C++语言编写。旨在为WEB应用提供可扩展的高性能数据存储解决方案。

**aggregate语法**  
Mongodb的Collection对象提供了aggregate()方法来对数据进行聚合处理。语法格式为：  
aggregate(operators,\[options\],callback)

管道操作符

<table> 
 <thead> 
  <tr> 
   <th>常用管道</th> 
   <th>含义</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>$group</td> 
   <td>将collection中的document分组，可用于统计结果</td> 
  </tr> 
  <tr> 
   <td>$match</td> 
   <td>过滤数据，只输出符合结果的文档</td> 
  </tr> 
  <tr> 
   <td>$project</td> 
   <td>修改输入文档的结构(例如重命名，增加、删除字段，创建结算结果等)</td> 
  </tr> 
  <tr> 
   <td>$sort</td> 
   <td>将结果进行排序后输出</td> 
  </tr> 
  <tr> 
   <td>$limit</td> 
   <td>限制管道输出的结果个数</td> 
  </tr> 
  <tr> 
   <td>$skip</td> 
   <td>跳过制定数量的结果，并且返回剩下的结果</td> 
  </tr> 
  <tr> 
   <td>$unwind</td> 
   <td>将数组类型的字段进行拆分</td> 
  </tr> 
 </tbody> 
</table>

表达式操作符

<table> 
 <thead> 
  <tr> 
   <th>常用表达式</th> 
   <th>含义</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>$sum</td> 
   <td>计算总和,使用{ <span><span><span> s u m : ′ sum: ' </span><span><span><span style="height: 0.7519em;"></span><span>s</span><span>u</span><span>m</span><span style="margin-right: 0.2778em;"></span><span><span>:</span><span><span><span><span style="height: 0.7519em;"><span style="top: -3.063em; margin-right: 0.05em;"><span style="height: 2.7em;"></span><span><span><span>′</span></span></span></span></span></span></span></span></span></span></span></span></span>制定字段’}也能直接获取制定字段的值的总和</td> 
  </tr> 
  <tr> 
   <td>$avg</td> 
   <td>平均值</td> 
  </tr> 
  <tr> 
   <td>$min</td> 
   <td>min</td> 
  </tr> 
  <tr> 
   <td>$max</td> 
   <td>max</td> 
  </tr> 
  <tr> 
   <td>$push</td> 
   <td>将结果文档中插入值到一个数组中</td> 
  </tr> 
  <tr> 
   <td>$first</td> 
   <td>根据文档的排序获取第一个文档数据</td> 
  </tr> 
  <tr> 
   <td>$last</td> 
   <td>根据文档的排序最后一个数据</td> 
  </tr> 
 </tbody> 
</table>

**业务需求**  
查询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}}}
    ])

执行结果：

![在这里插入图片描述][cc30938a3fd84aa0b3dc48183bfd9d00.png]

[cc30938a3fd84aa0b3dc48183bfd9d00.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/d0e0f6c553014909ab8b9c87d4c7e4ac.png