MongoDB聚合函数使用方法及PHP7替代PHP5 MongoClient聚合方案问询

嗨，针对你的两个问题，我来一步步给你解答：

MongoDB的聚合操作核心是聚合管道（Aggregation Pipeline），简单说就是把文档按顺序经过多个处理阶段，每个阶段完成过滤、分组、计算等操作，最终输出你想要的结果。这是最常用也最高效的聚合方式，下面给你拆解核心要点：

• 常用的聚合阶段：
  • $match：先过滤掉不需要的文档，和find()的查询逻辑一样，能减少后续处理的数据量，提升效率
  • $group：按指定字段分组，搭配累加器（比如$sum统计数量、$avg计算平均值、$max取最大值）做统计
  • $project：重新整理文档结构，比如只保留需要的字段、重命名字段，或者计算新字段
  • $sort：对结果排序，1是升序，-1是降序
  • $limit：限制返回的结果数量

举个实际场景的例子：假设你有个products集合，想统计每个商品分类下，价格大于10的商品总数和平均价格，代码在MongoDB Shell里是这样的：

db.products.aggregate([
  // 先过滤价格>10的商品
  { $match: { price: { $gt: 10 } } },
  // 按category分组，统计数量和均价
  {
    $group: {
      _id: "$category",
      totalItems: { $sum: 1 },
      averagePrice: { $avg: "$price" }
    }
  },
  // 按商品总数降序排
  { $sort: { totalItems: -1 } },
  // 只取前5个分类
  { $limit: 5 }
])

除了聚合管道，MongoDB还有mapReduce和简单聚合（比如count()、distinct()），但日常用聚合管道足够应对绝大多数场景了。

你遇到的问题本质是PHP7不再支持旧的mongo扩展（就是原来MongoClient所在的扩展），换成了全新的mongodb扩展，两者API差异很大，所以旧的聚合代码没法直接复用。下面给你两种可行的解决方式：

方式一：直接用MongoDB\Driver\Command执行聚合命令 #

如果就想用你现在的MongoDB\Driver\Manager连接方式，可以通过发送聚合命令来实现，步骤很清晰：

// 你的现有连接代码
$manager = new MongoDB\Driver\Manager("mongodb://".MONGOHOST.":27017");

// 构造聚合管道，以统计users集合中每个城市的用户数为例
$pipeline = [
  ['$group' => [
    '_id' => '$city',
    'userCount' => ['$sum' => 1]
  ]],
  ['$sort' => ['userCount' => -1]]
];

// 构造聚合命令，指定集合名和管道，必须加cursor参数否则返回单个文档
$command = new MongoDB\Driver\Command([
  'aggregate' => 'users', // 要操作的集合名称
  'pipeline' => $pipeline,
  'cursor' => []
]);

// 执行命令，记得传入数据库名
$cursor = $manager->executeCommand(MONGODB, $command);

// 遍历结果
foreach ($cursor as $document) {
  var_dump($document);
}

方式二：用MongoDB\Collection类（推荐，迁移成本更低） #

为了更贴近旧代码的使用习惯，我推荐你通过Composer安装mongodb/mongodb库——它是基于底层mongodb扩展的上层封装，API更友好，和旧的MongoClient用法更接近：

1. 先通过Composer安装依赖：

composer require mongodb/mongodb

2. 然后就可以像下面这样写代码，和旧的聚合逻辑几乎无缝衔接：

// 替代旧MongoClient的客户端初始化
$client = new MongoDB\Client(
  "mongodb://".MONGOHOST.":27017",
  [
    'username' => MONGOUSER,
    'password' => MONGOPASS,
    'db' => MONGODB
  ]
);

// 获取要操作的集合
$collection = $client->selectCollection(MONGODB, 'users');

// 执行聚合，参数就是聚合管道数组，和Shell里的结构一致
$cursor = $collection->aggregate([
  ['$group' => [
    '_id' => '$city',
    'userCount' => ['$sum' => 1]
  ]],
  ['$sort' => ['userCount' => -1]]
]);

// 遍历结果
foreach ($cursor as $document) {
  var_dump($document);
}

这种方式写起来更顺手，后续维护也更方便，优先推荐这个方案。

内容的提问来源于stack exchange，提问作者user9207697