当前位置：首页 > PHP

php实现mongodb求和

2026-02-16 06:29:02PHP

PHP 实现 MongoDB 求和操作

在 PHP 中，可以通过 MongoDB 的聚合框架（Aggregation Framework）或直接使用 $sum 运算符来实现求和操作。以下是两种常见的方法：

使用聚合框架求和

聚合框架提供了 $group 阶段，可以结合 $sum 运算符对指定字段求和。

$manager = new MongoDB\Driver\Manager("mongodb://localhost:27017");

$pipeline = [
    [
        '$group' => [
            '_id' => null,
            'total' => ['$sum' => '$price'] // 假设对 price 字段求和
        ]
    ]
];

$command = new MongoDB\Driver\Command([
    'aggregate' => 'collection_name',
    'pipeline' => $pipeline,
    'cursor' => new stdClass()
]);

$cursor = $manager->executeCommand('database_name', $command);
$result = current($cursor->toArray());

echo "总和: " . $result->total;

使用 `$sum` 运算符直接求和

如果只需要对查询结果中的某个字段求和，可以使用 $sum 运算符结合 find 操作。

$manager = new MongoDB\Driver\Manager("mongodb://localhost:27017");

$filter = ['status' => 'active']; // 可选过滤条件
$options = [
    'projection' => ['price' => 1] // 只返回 price 字段
];

$query = new MongoDB\Driver\Query($filter, $options);
$cursor = $manager->executeQuery('database_name.collection_name', $query);

$total = 0;
foreach ($cursor as $document) {
    $total += $document->price;
}

echo "总和: " . $total;

使用 MongoDB 的 `mapReduce` 功能

对于更复杂的求和逻辑，可以使用 mapReduce 方法。

$manager = new MongoDB\Driver\Manager("mongodb://localhost:27017");

$map = new MongoDB\BSON\Javascript('function() { emit(null, this.price); }');
$reduce = new MongoDB\BSON\Javascript('function(key, values) { return Array.sum(values); }');

$command = new MongoDB\Driver\Command([
    'mapReduce' => 'collection_name',
    'map' => $map,
    'reduce' => $reduce,
    'out' => ['inline' => 1]
]);

$cursor = $manager->executeCommand('database_name', $command);
$result = current($cursor->toArray());

echo "总和: " . $result->results[0]->value;