PHP操作MongoDB的聚合框架深度探索

在本文中，我们将深入探讨如何使用PHP操作MongoDB的聚合框架

1. 安装和配置：

首先，确保已经安装了MongoDB和PHP的MongoDB扩展。接下来，创建一个新的PHP项目并使用Composer安装mongodb库：

composer require mongodb/mongodb

2. 连接到MongoDB：

要连接到MongoDB数据库，需要创建一个MongoDB\Client实例。例如：

<?php
require 'vendor/autoload.php';

$client = new MongoDB\Client('mongodb://localhost:27017');
$db = $client->selectDatabase('test');
$collection = $db->selectCollection('myCollection');

3. 插入数据：

为了进行聚合操作，我们需要向集合中插入一些数据。例如：

<?php
$documents = [
    ['name' => 'Alice', 'age' => 30, 'city' => 'New York'],
    ['name' => 'Bob', 'age' => 25, 'city' => 'San Francisco'],
    ['name' => 'Charlie', 'age' => 22, 'city' => 'New York'],
];

$result = $collection->insertMany($documents);

4. 聚合操作：

现在我们可以使用聚合框架对数据进行操作。以下是一些常见的聚合操作示例：

• 计算每个城市的人数：

<?php
$pipeline = [
    ['$group' => ['_id' => '$city', 'count' => ['$sum' => 1]]],
];

$cursor = $collection->aggregate($pipeline);
foreach ($cursor as $document) {
    echo "City: " . $document['_id'] . ", Count: " . $document['count'] . "\n";
}

• 按年龄排序并限制结果数量：

<?php
$pipeline = [
    ['$sort' => ['age' => 1]],
    ['$limit' => 2],
];

$cursor = $collection->aggregate($pipeline);
foreach ($cursor as $document) {
    echo "Name: " . $document['name'] . ", Age: " . $document['age'] . "\n";
}

• 计算年龄分组的平均年龄：

<?php
$pipeline = [
    ['$group' => ['_id' => '$age', 'avgAge' => ['$avg' => '$age']]],
];

$cursor = $collection->aggregate($pipeline);
foreach ($cursor as $document) {
    echo "Age: " . $document['_id'] . ", Avg Age: " . $document['avgAge'] . "\n";
}

这些仅仅是MongoDB聚合框架的一些基本示例。实际上，聚合框架非常强大，可以执行更复杂的操作，如连接多个集合、投影字段、过滤数据等。要了解更多关于聚合框架的信息，请参阅MongoDB官方文档。