一、插入数据
1 <?php
2
3 //连接Mongodb
4 $manager = new MongoDBDriverManager("mongodb://127.0.0.1:27017");
5
6 echo "connect success!!!";
7
8 //创建变量,进行插入操作
9 $bulk = new MongoDBDriverBulkWrite;
10
11 //插入的数据(插入一条或多条)
12 $bulk->insert(["name"=>"zhangsan","age"=>25,"class"=>"jisuanjierban"]);
13 $bulk->insert(["name"=>"lisi","age"=>25,"class"=>"jisuanjisiban"]);
14
15 //插入数据到useinfo数据库下的student表
16 $manager->executeBulkWrite("useinfo.student",$bulk);
17
18 echo "insert success!!!";
19 ?>
二、查询数据
1 <?php
2
3 //连接Mongodb
4 $manager = new MongoDBDriverManager("mongodb://127.0.0.1:27017");
5
6 echo "connect success!!!".PHP_EOL;
7
8 //过滤条件
9 $filter = ['age' => ['$gt' => 20]];
10
11 //可选项
12 $option = [
13
14 'projection' => ["_id" =>0], //不显示_id,此字段用于指定显示或不显示某些字段
15
16 'sort' => ['name' => -1], //按照某些字段排序 ,-1倒叙,1正序
17
18 'limit'=>$pageSize, //取多少条数据
19
20 'skip' => ($num-1)*$pageSize //取第几页数据
21 ];
22
23 //查询数据
24 $query = new MongoDBDriverQuery($filter, $option);
25
26 //查询结果,返回数组
27 $cursor = $manager->executeQuery('useinfo.student',$query);
28
29 //循环遍历
30 foreach ($cursor as $document){
31
32 print_r($document);
33 }
34
35 echo "over";
36
37 ?>
三、更新数据
1 //更新数据
2 <?php
3 //连接Mongodb
4 $manager = new MongoDBDriverManager("mongodb://127.0.0.1:27017");
5
6 echo "connect success!!!"
7
8 $bulk->new MongoDBDriverBulkWrite;
9 $bulk->update(
10 ["name" => "zhangsan"], //过滤条件
11 ["$set" => ["name" => "kenan","class" => "softeneregy"]], //更新数据
12 ["multi" => false, "upsert" => false], //multi为true,代表更新找到的所有记录,false默认更新找到的第一条
13 //upsert为true代表如果没有此条记录就执行插入操作,默认false不插入
14 );
15 //执行更新操作
16 $result = $manager->executeBulkWrite('test.sites', $bulk);
17 ?>