准备数据

use test4;
db.c1.insert({ _id: 1, name: "a", sex: 1, age: 1 });
db.c1.insert({ _id: 2, name: "a", sex: 1, age: 2 });
db.c1.insert({ _id: 3, name: "b", sex: 2, age: 3 });
db.c1.insert({ _id: 4, name: "c", sex: 2, age: 4 });
db.c1.insert({ _id: 5, name: "d", sex: 2, age: 5 });

db.c1.find();

语法

db.集合名.aggregate([
    { 
        管道：{ 表达式 }
    },
    ...
])

例子： 查询男生、女生的总年龄
db.c1.aggregate([
    {
        $group: {
            # _id是固定格式, $sex是字段名
            _id: "$sex", 
            # $result是统计结果的列名，$sum是表达式(参照下面), $age是统计字段
            result: { $sum: "$age"}, 
        }
    }
])

常用管道

常用表达式

例子1: 统计男生、女生的总人数

db.c1.aggregate([
    {
        $group: {
            _id: "$sex",
            result: { $sum: 1} 
        }
    }
])

例子2： 求学生总数和平均年龄

db.c1.aggregate([
    {
        $group: {
            _id: null,
            total_num: { $sum: 1},
            total_age: { $avg: "$age"},
        }
    }
])

例子3: 查询男生、女生人数，按人数升序

db.c1.aggregate([
    {
        $group: {
            _id: "$sex",
            result: { $sum: 1 },
        },
    },
    {
        $sort: {
            result: 1
        }
    }
])