前置条件:
需要安装 mongodb 扩展
使用:
<?php // 使用命名空间 use \MongoDB\Driver\Manager; use \MongoDB\Driver\BulkWrite; use \MongoDB\Driver\Query; // 连接 mongodb(副本集) $manager = new Manager("mongodb://10.0.0.11:27200,10.0.0.12:27200,10.0.0.13:27200"); $bulk = new BulkWrite(); // 新增 $bulk->insert(["name" => "lee", "age" => 30]); $bulk->insert(["name" => "zhangsan", "age" => 18]); $manager->executeBulkWrite("test.coTest", $bulk); // 删除 $bulk->delete(["name" => "zhangsan"], ["limit" => 1]); // 删除一条记录 $bulk->delete(["name" => "zhangsan"], ["limit" => 0]); // 删除全部匹配的记录 $manager->executeBulkWrite("test.coTest", $bulk); // 更新 $bulk->update( ["name" => "zhangsan"], ["\$set" => ["age" => 19]], ["multi" => false, "upsert" => false] ); $manager->executeBulkWrite("test.coTest", $bulk); // 查询 $query = new Query(["age" => ["\$lt" => 20]], ["projection" => ["_id" => 0, "name" => 1], "sort" => ["name" => -1]]); $cursor = $manager->executeQuery('test.coTest', $query); foreach ($cursor as $document) { print_r($document); }
文档更新时间: 2024-04-20 10:57 作者:lee