1. 前置条件:
    需要安装 mongodb 扩展

  2. 使用:

     <?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