PHP中MongoDB按email_address分组统计记录的报错求助

我来帮你排查这两个新手常遇到的小问题，很快就能搞定！

错误1：变量名不匹配 #

你先定义了集合变量$collection = $db->users;，但调用聚合方法的时候却用了$collection1->aggregate($aggregate);——这里的$collection1根本没定义，所以触发了Undefined variable: collection1的报错，同时导致后续调用aggregate()时出现“Call to a member function on null”的致命错误。

解决方法：直接把$collection1改成$collection即可。

错误2：$group阶段的_id设置错误 #

你的$group阶段里，_id的email_address被设成了空字符串''，这不符合MongoDB聚合规则：$group的_id必须明确指定分组依据的字段（可以是单个字段，也可以是组合字段）。正确的写法是用$前缀来引用集合中的字段，告诉MongoDB要按照这个字段的值来分组。

解决方法：把email_address的值改成'$email_address'，如果只是按单个字段分组，甚至可以简化_id的写法（两种写法都有效，看你的需求）。

修正后的完整代码 #

$m = new MongoDB\Client("mongodb://localhost:27017");
$db = $m->mailchimp;
$collection = $db->users;
$aggregate[] = [
    '$group' => [
        '_id' => '$email_address', // 简化写法：直接指定分组字段
        // 如果你需要保留嵌套对象的格式，也可以写成：
        // '_id' => [
        //     'email_address' => '$email_address',
        // ],
        // 额外需求：如果要统计每个邮箱的记录数，可添加以下字段
        // 'record_count' => ['$sum' => 1]
    ],
];
$data = $collection->aggregate($aggregate);

补充说明 #

如果你的需求是统计每个邮箱对应的记录数量，可以在$group里加上'record_count' => ['$sum' => 1]，这样返回的结果里会包含每个邮箱的出现次数，更贴合实际使用场景。

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