mongodb 提供 aggregate() 方法调用外部函数，用于在聚合管道阶段执行存储在 mongodb 中的 javascript 代码。该函数通过 '$function' 参数配置，包括代码主体、参数和语言（默认为 "js"）。实战案例中，通过外部函数计算了订单的总金额并输出为 "order id: , total amount: " 格式。

PHP 函数如何使用 MongoDB 调用外部函数？

MongoDB 允许通过 aggregate() 方法调用外部函数。外部函数是存储在 MongoDB 数据库中的 JavaScript 代码，可以在聚合管道阶段内调用。

语法：

立即学习“PHP免费学习笔记（深入）”；

aggregate([
    [
        '$addFields' => [
            '<field_name>' => [
                '$function' => [
                    'body' => '<javascript_code>',
                    'args' => ['<arg1>', '<arg2>', ...],
                    'lang' => 'js'
                ]
            ]
        ]
    ]
]);

参数：

• '$function'： 指定外部函数的配置。
• 'body'： 要执行的 JavaScript 代码。
• 'args'： 传递给 JavaScript 代码的函数参数（可选）。
• 'lang'： 函数的语言，默认为 "js"。

实战案例：

假设我们有一个名为 "orders" 的集合，其中包含订单数据。现在，我们想使用外部函数将每个订单的总金额计算为总额字段。

代码：

use MongoDBBSONObjectId;
use MongoDBClient;

$client = new Client();
$collection = $client->test->orders;

$pipeline = [
    [
        '$addFields' => [
            'total_amount' => [
                '$function' => [
                    'body' => 'function (order) {
                        var total = 0;
                        for (var i = 0; i < order.items.length; i++) {
                            total += order.items[i].price * order.items[i].quantity;
                        }
                        return total;
                    }',
                    'args' => ['$order'],
                    'lang' => 'js'
                ]
            ]
        ]
    ]
];

$result = $collection->aggregate($pipeline);

foreach ($result as $order) {
    echo "Order ID: " . $order['_id'] . ", Total Amount: " . $order['total_amount'] . "n";
}

输出：

Order ID: new ObjectId("5f4dc3f5e0f67a4721ede276"), Total Amount: 100
Order ID: new ObjectId("5f4dc401e0f67a4721ede277"), Total Amount: 200