码迷,mamicode.com
首页 > 其他好文 > 详细

Mongoose: aggregate聚合 $group使用说明

时间:2019-10-11 17:57:41      阅读:528      评论:0      收藏:0      [点我收藏+]

标签:ast   记录   时间   小数   执行   指定   code   计算   管道   

aggregate聚合是通过管道操作实现的。聚合管道里的每一步输出,都会作为下一步的输入,每一步在输入文档执行完操作后生成输出文档。

聚合管道: 

 $project 修改输入文档的结构。可以用来重命名、增加或删除域,也可以用于创建计算结果以及嵌套文档。对应project()方法 

 $match 用于过滤数据,只输出符合条件的文档。$match使用MongoDB的标准查询操作。对应match() 

 $limit 用来限制MongoDB聚合管道返回的文档数。对应limit()方法 

 $skip 在聚合管道中跳过指定数量的文档,并返回余下的文档。对应skip() 

 $unwind 将文档中的某一个数组类型字段拆分成多条,每条包含数组中的一个值。对应unwind()方法 

 $group 将集合中的文档分组,可用于统计结果。对应group()方法 

 $sort 将输入文档排序后输出。对应sort()方法 

 $geoNear 输出接近某一地理位置的有序文档。对应near() 

$group表达式说明: 

 $sum  计算总和 

 $avg  计算平均值  

 $min  获取每一组集合中所有文档对应值得最小值 

 $max  获取每一组集合中所有文档对应值得最大值 

 $push  在结果文档中插入值到一个数组中 

 $addToSet  在结果文档中插入值到一个数组中,但不创建副本 

 $first  根据资源文档的排序获取第一个文档数据

 $last  根据资源文档的排序获取最后一个文档数据 

举例说明aggregate聚合 $group使用

商品属性:_id,  createTime,  nowPriceL,  nowPriceH,  number

    统计每一天内店铺商品的最低价和最高价,平均最低价, 

执行完$match管道后,得到的查询结果会输入到$project管道,执行完$project管道,得到的结果格式为{day,nowPriceL,nowPriceH},把这个结果输入$group管道,
$group管道执行完毕,输出的结果输入到$sort管道,$sort执行完毕,输出最终结果集

Goods.aggregate([
      {
        $match: {
          number: {$gte:100} //匹配number>=100的记录
       }
      },
      {
         $project : {
             day : {$substr: [{"$add":["$createTime", 28800000]}, 0, 10] },//时区数据校正,8小时换算成毫秒数为8*60*60*1000=288000后分割成YYYY-MM-DD日期格式便于分组
             "nowPriceL": 1, //设置原有nowPriceL为1,表示结果显示原有字段nowPriceL
             "nowPriceH":1, //设置原有nowPriceH为1,表示结果显示原有字段nowPriceH
             avgNowPriceL:{$toDouble:"$nowPriceL"},//把最低价转换为小数
             avgNowPriceH:{$toDouble:"$nowPriceH"},//把最高价转换为小数
             "dayNumber":1 //每组内有多少个成员
         },
      },
    
    { 
      $group: { 
        _id:"$day", //按照$day进行分组(一组为1天) 
        nowPriceL:{$min: "$nowPriceL"}, //查找组内最小的nowPriceL 
        nowPriceH:{$max: "$nowPriceH"}, //查找组内最大的nowPriceH  
        avgNowPriceL:{$avg:"$avgNowPriceL"},//统计每一天内店铺商品的平均最低价
        avgNowPriceH:{$avg:"$avgNowPriceH"},//统计每一天内店铺商品的平均最高价
        dayNumber:{$sum:1}   
      } 
    }, 
    { 
      $sort: {
        nowPriceL: 1//执行完 $group,得到的结果集按照nowPriceL升序排列
      }
    }]).exec(function (err, goods){
    //返回结果  
    console.log(goods);
    });

 

注意:
mongoodb存储的数据是按照世界时间存储的,因此进行分割操作时需要对时间进行时区校正,使用$add加上时区差8小时(毫秒数)才能得到正确的数据
$substr: [ <string>, <start>, <length> ] }
https://docs.mongodb.com/manual/reference/operator/aggregation/toDouble/#exp._S_toDouble


Mongoose: aggregate聚合 $group使用说明

标签:ast   记录   时间   小数   执行   指定   code   计算   管道   

原文地址:https://www.cnblogs.com/greenteaone/p/11655543.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!