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官方文檔。