PHP 函数如何使用 MongoDB 调用外部函数?
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' ] ] ] ]]);</arg2></arg1></javascript_code></field_name>
参数:
实战案例:
假设我们有一个名为 "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'], 'lang' => 'js' ] ] ] ]];$result = $collection->aggregate($pipeline);foreach ($result as $order) { echo "Order ID: " . $order['_id'] . ", Total Amount: " . $order['total_amount'] . "";}
输出:
Order ID: new ObjectId("5f4dc3f5e0f67a4721ede276"), Total Amount: 100Order ID: new ObjectId("5f4dc401e0f67a4721ede277"), Total Amount: 200