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

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

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

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

语法：

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

aggregate([
    [
        '$addFields' => [
            '' => [
                '$function' => [
                    'body' => '',
                    'args' => ['', '', ...],
                    'lang' => 'js'
                ]
            ]
        ]
    ]
]);

参数：

TWE-Commerce

一个功能强大的B2B与B2C的购物平台，除了原本OSC功能外，增加更新的功能： 一、 取消了register_globals必须开启的限制 二、 將HTML程式碼与PHP程式碼完全分离，採用了smarty 樣板引擎 三、 每支档案includes所需函数与资料库连结，使的网页显示速度明显提升 四、 检视、购买商品群组权限设定 五、 十八岁以下禁购机制 六、 折价券购物抵扣机制 七、 礼券购物机制

下载

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

实战案例：

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

代码：

use MongoDB\BSON\ObjectId;
use MongoDB\Client;

$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