MongoDB aggregate聚合管道

使用聚合管道可以对集合中的文档进行换行和组合。在实际项目中:表的关联查询,数据统计;

  • 实际开发中也是非常有用;

  • 条件操作符条件操作符条件操作符条件操作符*********

    • (>) 大于 $gt
    • (<) 小于 $lt
    • (>=) 大于等于 $gte
    • (<= ) 小于等于 $lte
    • db.access.find({type:{$gt:2}})
  • 聚合的表达式聚合的表达式*********聚合的表达式********聚合的表达式:

  • $sum 计算总和
    db.access.aggregate([
        {
            $group:{_id:"$module_name",num_tutorial:{$sum:"$type"}}
        }
    ]);
  • $avg 计算平均值
    db.access.aggregate([
        {
            $group:{_id:"$module_name",num_tutorial:{$avg:"$type"}}
        }
    ]);

(min 获取集合中所有文档对应值得最小值。 )max 获取集合中所有文档对应值得最大值。

  • 根据资源文档的排序获取最后一个文档数据
    db.access.aggregate([
        {
            $group:{_id:"$type",num_tutorial:{$min:"$type"}}
        }
    ])
  • $push 在结果文档中插入值到一个数组中。将每组匹配到的 module_name 字段push 到数组中;
    db.access.aggregate([
        {
            $group:{_id:"$type",num_tutorial:{$push:"$module_name"}}
        }
    ]);
    db.access.aggregate([
        {
            $group:{_id:"$module_name",num_tutorial:{$push:"$type"}}
        }
    ]);
  • $first 根据资源文档的排序获取第一个文档数据。 $last相反;
 db.access.aggregate([
     {
        $group:{_id:"$module_name",num_tutorial:{$last:"$type"}}
     }
 ]);
  • *聚合管道聚合管道********聚合管道
    db.access.find({});
  • $project  表示在结果中取module_name一列,不取_id;
    db.access.aggregate([
        {
            $project:{"module_name":1,"_id":0}
        }
    ])
  • $match 用于过滤数据, 只输出符合条件的文档 只取module_id为0 的文档;
    db.access.aggregate([
        {
            $match:{"module_id":"0"}
        }
    ])
  • $limit:用来限制MongoDB聚合管道返回的文档数。
    db.access.aggregate([
        {
            $limit:1
        }
    ])
  • $skip 在聚合管道中跳过指定数量的文档,并返回余下的文档。
    db.access.aggregate([
        {
            $skip:2,
        }
    ])
  • $sort 将输入文档排序后输出。1升序,-1降序;
    db.access.aggregate([
        {
            $sort:{"type":1}
        }
    ])
  • $group 将集合中的文档分组,可用于统计结果。 以type字段来分组,各组有多少条数据;num_tutorial字段是和值;
    db.access.aggregate([
        {
            $group:{_id:"$type",num_tutorial:{$sum:1}}
        }
    ])
  • 这种情况是 对 type字段进行累加;
    {
        $group:{_id:"$type",num_tutorial:{$sum:"$type"}}
    }
  • $lookup; 表关联;
    db.access.aggregate([{
        $lookup:{
            from:"需要关联的表假如为orders",
            localField:'表需要关联的键。',
            foreignField:'orders表的matching key。',
            as:'item'
        }
    }])
原文地址:https://www.cnblogs.com/kgwei520blog/p/12511809.html