PHP操作MongoDB（增删改查）php7.0以下

admin

　　MongoDB的PHP驱动提供了一些核心类来操作MongoDB，总的来说MongoDB命令行中有的功能，它都可以实现，而且参数的格式基本相似。PHP7以前的版本和PHP7之后的版本对MongoDB的操作有所不同，本文主要以PHP7以前版本为例讲解PHP对MongoDB的各种操作，最后再简单说明一下PHP7以后版本对MongoDB的操作。

一、数据插入

1. //insert()
   
2. //参数1：一个数组或对象
   * D( Y/ m* V8 X  ^
3. //参数2：扩展选项
   ) Q; b# ?6 ?, C/ Q, O* h4 O
4. //  fsync：默认为false，若为true则mongo在确认数据插入成功之前将会强制把数据写入硬盘
   
5. //  j：默认为false，若为true则mongo在确认数据插入成功之前将会强制把数据写入日志
   / S# g; [; Q% C/ g4 f2 J# Y) B! K
6. //  w：默认为1，写操作会被（主）服务器确认，若为0则将不会得到确认，使用复制集时设置为n用于确保主服务器将数据修改成功复制到n个节点后再确认
   
7. //  wtimeout：默认为10000（毫秒），用于指定服务器等待接收确认的时间
   - Z8 z: B6 k, S& ]* a
8. //  timeout：指定客户端需要等待服务器响应的超时时间（毫秒）
   % T8 C6 P+ }+ d  k' c8 X- \
9. $mongo = new MongoClient('mongodb://localhost:27017');
   % p* }0 w2 B  h$ K* o7 F, e
10. $db = $mongo->mf;//选择数据库
    
11. $collection = $db->friend;//选择文档集合
    
12. $doc = [//定义一个文档，即一个数组
    # K% Q* \/ z2 G, X; j4 K
13.     'First Name' => 'Jet',
    
14.     'Last Name' => 'Wu',
    - W) _1 C8 I. _7 m; w" Y$ e0 m
15.     'Age' => 26,
      |0 u  {- [. t1 F0 e
16.     'Phone' => '110',
    
17.     'Address' => [
    - N4 F' U8 K; T' Y1 K) J$ Y
18.         'Country' => 'China',
    
19.         'City' => 'Shen Zhen'
    
20.     ],
    
21.     'E-Mail' => [
    
22.         '123456@qq.com',
    " @' u* t0 z. R9 c
23.         '666666@sina.com',
    # E( p: @4 Y) p" N; q
24.         '8888888@qq.com',
    
25.         '77887788@qq.com'
    / `( f1 Y; q8 _, i1 L  C0 @7 T
26.     ]
    / K6 [: w4 `8 g# N) u
27. ];
    5 U+ W: B7 n. G1 s
28. $res = $collection->insert($doc);//向集合中插入一个文档
    9 A* t9 C; `0 v6 a  a& J
29. echo '<pre>';
    7 A0 `# J! |. e1 @& }  \3 Z( d  U
30. print_r($res);//$res['ok']=1表示插入成功

复制代码

二、数据查询

1. 查询单个文档：

1. //findOne()
   & F* }# [& k. M
2. //参数1：搜索条件
   
3. //参数2：指定返回字段，array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回，除非在第二个参数显式加入'_id'=>false。不设置则返回所有字段
   
4. $mongo = new MongoClient('mongodb://localhost:27017');
   
5. $db = $mongo->mf;
     |5 b: I7 g, u
6. $collection = $db->friend;
   # x  g# a( E' \# @( q6 b, _4 E/ Z
7. $one = $collection->findOne(['First Name' => 'Jet']);
   
8. echo '<pre>';
   6 J. @7 u( O% e4 W7 B, ?" t6 z" u0 d
9. print_r($one);//返回一个数组，查不到数据则返回NULL

复制代码

2. 查询多个文档：

1. //find()
   
2. //参数1：搜索条件
   
3. //参数2：指定返回字段，array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回，除非显式设置为false不返回。不设置则返回所有字段
   ) g5 e+ g  K7 f( X
4. $mongo = new MongoClient('mongodb://localhost:27017');
   
5. $db = $mongo->mf;
   
6. $collection = $db->friend;
   
7. $cursor = $collection->find(['Address.Country' => 'China']);//使用点操作符查找数组元素
   
8. echo '<pre>';
   
9. while($doc = $cursor->getNext()) {//循环读取每个匹配的文档
   
10.     print_r($doc);
    ) S2 o4 l, A% n5 X# U, z1 |6 x
11. }

复制代码

使用各种条件操作符定义查询：

1. //mongodb分别使用$lt（小于）、$lte（下雨等于）、$eq（等于）、$gte（大于等于）、$gt（大于）、$ne（不等于）表示<、<=、=、>=、>、<>，用于整数字段查询
   
2. $mongo = new MongoClient('mongodb://localhost:27017');
   8 K3 U( K$ g1 g* ~; D
3. $db = $mongo->mf;
   
4. $collection = $db->friend;
   
5. $cursor = $collection->find(['Age' => ['$gt' => 30]]);
   2 h- q* I- y+ r! ?9 H
6. echo '<pre>';
   
7. while($doc = $cursor->getNext()) {
     ~4 i3 L' M& h% D
8.     print_r($doc);
   , N  r4 T  ^, k
9. }

复制代码

　　//查询某个字段的所有不重复的值
　　$res = $collection->distinct('Age');

1. //$in：匹配多个值中任意一个
   
2. $cursor = $collection->find(['Address.Country' => ['$in' => ['China', 'USA']]]);
   
3. 
   
4. //$all：匹配多个值中所有值（用于数组字段查询）
   
5. $cursor = $collection->find(['E-Mail' => ['$all' => ['123456@qq.com', '77887788@qq.com']]]);
   + K9 ~/ ], `% o* Z0 m
6. 
     A: B6 J+ I$ G1 \* v- E! D
7. //$or：或查询
   3 W; I% x* p9 M0 Z2 J" x& ~
8. $cursor = $collection->find(['$or' => [['First Name' => 'Jet'], ['Address.Country' => 'USA']]]);
   
9. 
   
10. //$slice：获取数组字段中指定数目的元素，位于find()函数第二个参数中
    , [- s- d$ f8 o/ e" E* E
11. $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => 2]]);//只返回前两个email
    3 [2 O$ U( T# H! U
12. $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => -2]]);//只返回最后两个email
    5 |! ^3 g$ ^+ X
13. $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => [1, 2]]]);//忽略第一个，返回接下来两个
    6 m3 _; u! M9 `4 R( N
14. 
    3 S3 `4 S2 z, u, E1 F* l& h; ]
15. //$exists：根据某个字段是否有设置值进行查询
    
16. $cursor = $collection->find(['Hobby' => ['$exists' => false]]);//查找Hobby字段未设置值的文档
    , H( `/ U9 S/ A
17. 
    3 S) D8 {. J- e! F% l7 Y/ C* G
18. //正则表达式查询
    # Y4 Z7 h9 d2 o$ O( M
19. $cursor = $collection->find(['First Name' => new MongoRegex('/^Je/i')]);//查找First Name字段以Je开头的文档，忽略大小写差异

复制代码

使用MongoCursor类提供的其他函数：

1. //排序：1升序，-1降序
   3 l5 D9 L# V& n5 ]4 l; D4 k
2. $cursor->sort(['Age' => 1]);
   & `; w& D8 M9 k( w
3. 
   0 ~: X5 Y1 S4 s; s. m/ e& _
4. //忽略前n个匹配的文档
   $ s& j( n: }# W8 K1 I
5. $cursor->skip(1);
   $ r& z9 o% v2 q! D) y' ]
6. 
   ' _3 m, Y0 p6 a8 Z  Z
7. //只返回前n个匹配的文档（limit()与skip()结合使用可实现数据分页功能）
   6 r7 J7 |$ M% ?: t
8. $cursor->limit(1);
   2 J* l, G# e! V8 G, {- O
9. 
   ; ?6 y2 g& ?3 e) Z# @' @$ d; I
10. //匹配文档的总数
    
11. $cursor->count();
    * F! [/ [! D, Z& }& m) @6 p. m3 B
12. 
    ; f# w* A. Y; t. r" z5 v8 y
13. //指定查询索引
    
14. $cursor->hint(['Last Name' => -1]);//若索引不存在则会报错

复制代码

聚集查询：对数据进行分组统计

1. //聚合查询：对数据进行分组统计
   
2. $mongo = new MongoClient('mongodb://localhost:27017');
   3 Z7 p  ]. `  q; V. N% `; M) R6 k* t
3. $db = $mongo->mf;
   ) w. q$ T7 _2 \: ^
4. $collection = $db->friend;
   
5. $res = $collection->aggregate([
   0 V, f# B. U3 f' X% C
6.     '$group' => [
   
7.         '_id' => '$Address.Country',//分组字段，注意要加上“$”，这里是根据数组字段某个元素值进行分组
   - w+ j- p- s4 m/ V7 Y0 M5 m2 S
8.         'total' => ['$sum' => 1],//求总和，表示每匹配一个文档总和就加1
   
9.         'maxAge' => ['$max' => '$Age'],//分组中Age字段最大值
   $ Y' P" Q; D7 k- a- \5 l0 T
10.         'minAge' => ['$min' => '$Age']//分组中Age字段最小值
    + L3 d% T# K8 ]# e) `. i3 f( s+ ]" l
11.     ]
    
12. ]);
    2 ]8 `' P% u+ k. ^
13. echo '<pre>';
      z: ^) p( ^9 Q! s3 ?* N
14. print_r($res);//返回一个数组，$ret['result']为数组，存放统计结果
    - O4 D, s1 l3 v; g
15. 
    
16. 
    % G3 N- S, `) `% B/ s+ v* [4 @8 a
17. //存在其它操作的聚合查询：多个操作之间执行先后顺序取决于它们位置的先后顺序
    
18. //聚合查询中的所有操作，包括'$group'在内，都是可选的。
    6 K) G: N; Z- h! H. u
19. $mongo = new MongoClient('mongodb://localhost:27017');
    
20. $db = $mongo->mf;
    
21. $collection = $db->friend;
    # G/ M5 {& E8 ?) b7 c/ m
22. $res = $collection->aggregate([
    
23.     [//过滤条件：只对符合条件的原始文档进行聚合运算，若是放在'$group'之后则是只返回符合条件的结果文档
    
24.         '$match' => ['Age' => ['$gt' => 30]]
    $ m$ e, D& H2 ~! F$ k
25.     ],
    * g' X+ F7 X" s# r# M
26.     [//指定分组字段、统计字段
    . s$ y1 n7 W) U( l' Y. b
27.         '$group' => [
    
28.             '_id' => '$Address.Country',
    
29.             'totalAge' => ['$sum' => '$Age']//计算各个分组Age字段总和
    8 @/ V# p) G, c$ }7 c8 z' U$ {9 c: L, }
30.         ]
    
31.     ],
    5 w3 F7 U% g7 N' S+ c' A
32.     //以下操作若是放在'$group'之前则在聚合前作用于原始文档，若放在'$group'之后则在聚合后作用于结果文档
    ) x1 G1 `% C( T/ X5 w
33.     ['$unwind' => '$E-Mail'],//将包含有某个数组类型字段的文档拆分成多个文档，每个文档的同名字段的值为数组中的一个值。
    9 Q# U& C6 R3 u
34.     ['$project' => ['myAge' => '$Age', 'First Name' => '$First Name']],//指定返回字段，可以对字段进行重命名，格式：返回字段名 => $原来字段名
    # e3 _4 ^9 n+ Z0 o/ S
35.     ['$skip' => 2],//跳过指定数量的文档
    
36.     ['$limit' => 2],//只返回指定数量的文档
    $ a* [' h: S% l
37.     ['$sort' => ['totalAge' => 1]]//排序
    
38. ]);
    ; M% W0 j( y, _( K- k4 \, V
39. echo '<pre>';
    
40. print_r($res);

复制代码

三、数据修改

1. //update()
   # I4 N4 ?; @9 G/ q
2. //参数1：更新条件，指定更新的目标对象。
   / r5 {6 h2 v; n4 `8 m6 h* V, j
3. //参数2：指定用于更新匹配记录的对象。
   
4. //参数3：扩展选项组。
   * V3 ~, V: b% I2 l; y7 x/ r
5. //  upsert：若设置为true，当没有匹配文档的时候会创建一个新的文档。
   
6. //  multiple：默认为false，若设置为true，匹配文档将全部被更新。
   
7. //  fsync：若设置为true，w参数将被覆盖为0，数据将在更新结果返回前同步到磁盘。
   / V# D+ j3 ^$ s- \6 v
8. //  w：默认为1；若设置为0，更新操作将不会得到确认；使用复制集时可设置为n，确保主服务器在将修改复制到n个节点后才确认该更新操作
   ( i8 `9 v/ F$ k4 U0 L
9. //  j：默认为false，若设置为true，数据将在更新结果返回之前写入到日志中。
   
10. //  wtimeout：默认为10000（毫秒），用于指定服务器等待接收确认的时间
    / V" |, v; ~! W! k. K
11. //  timeout：指定客户端需要等待服务器响应的超时时间（毫秒）
    
12. //注意：若不使用任何修改操作符，则匹配文档将直接被整个替换为参数2指定的对象。
    
13. 
    - b. X6 y5 U- X$ t  z/ q. E8 e( L
14. //$inc：增加特定键的值，若字段不存在则新建字段并赋值
    1 K$ R3 W) R3 [7 L* ]8 D
15. $mongo = new MongoClient('mongodb://localhost:27017');
    
16. $db = $mongo->mf;
    
17. $collection = $db->friend;
    
18. $res = $collection->update(['First Name' => 'Jet'], ['$inc' => ['Age' => 2]]);
    " R/ W" n8 N7 ~- {9 U$ t
19. echo '<pre>';
    # l3 X7 R/ F- i& Y# J  h
20. print_r($res);//$res['ok']=1表示修改成功，$res['nModified']表示修改的文档数量
    
21. 
      c& g7 B1 _) P8 s- _
22. //$set：重置特定键的值，若字段不存在则新建字段并赋值
    ( V+ {& z. m1 r! F
23. $res = $collection->update(['First Name' => 'Jet'], ['$set' => ['Hobby' => 'pingpong']]);
    
24. 
    
25. //$unset：删除字段
    
26. $res = $collection->update(['First Name' => 'Jet'], ['$unset' => ['Hobby' => 1]]);
    6 l3 `$ c; }6 W7 q, `7 P
27. 
    7 T' _+ t7 ?! s
28. //$rename：重命名字段，若字段不存在则不进行任何操作
    
29. $res = $collection->update(['First Name' => 'Jet'], ['$rename' => ['Hobby' => 'hobby', 'Age' => 'age']]);
    3 _5 h0 j6 P% k6 @0 x
30. //注意：如果文档中已经使用了指定名称的字段，则该字段将会被删除，然后再进行重命名操作。
    7 _- {5 a! [, ^( U3 A# L
31. 
    3 O1 V/ R5 w  s) p( ~3 j$ L* v
32. //$setOnInsert：设置了upsert为true，并且发生了插入操作的时候，将某个字段设置为特定的
    
33. $res = $collection->update(['First Name' => 'jet'], ['$setOnInsert' => ['lang' => 'English']], ['upsert' => true]);
    
34. 
    % ^9 k5 {3 V: z, i; _) f7 v  |+ @
35. //$push：向指定字段添加一个值（作用于数组字段），若字段不存在会先创建字段，若字段值不是数组会报错
    
36. $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '123123@qq.com']]);
    , z$ B: D' m3 \! J4 O
37. 
    0 W( Y7 @3 t5 F. \
38. //$push：向指定字段添加多个值（作用于数组字段），若字段不存在会先创建字段，若字段值不是数组会报错
    8 O: ?# `+ B) B! p6 J  X3 z
39. $res = $collection->update(['First Name' => 'Jet'], ['$pushAll' => ['E-Mail' => ['666@qq.com', '8888888@qq.com']]]);
    
40. 
    ! U5 K3 x! K2 s& I' ]: {: S
41. //使用$push和$each向某个字段添加多个值（作用于数组字段），若字段不存在会先创建字段，若字段值不是数组会报错
    " @! B3 b/ b) o& |! q% [$ i
42. $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);
    6 R, ]3 f# z2 h) B, n$ o
43. 
    
44. //$addToSet：将数据添加到数组中（只在目标数组没有该数据的时候才将数据添加到数组中）
    
45. $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => '123123@qq.com']]);
    
46. $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);
    
47. 
    ! f: M: a/ G: D; i/ B/ Z5 B
48. //$pop：从数组中删除一个元素，-1表示删除第一个元素，1表示删除最后一个元素（其实负数都删除第一个元素，0或正数都删除最后一个元素）
    
49. $res = $collection->update(['First Name' => 'Jet'], ['$pop' => ['E-Mail' => 1]]);
    
50. 
    + T. Q) k8 P" n; C/ ~1 o' E
51. //$pull：删除数组中所有指定值
    5 {. O3 c2 X+ v, y0 Z! B
52. $res = $collection->update(['First Name' => 'Jet'], ['$pull' => ['E-Mail' => '123123@qq.com']]);
    
53. 
    
54. //$pullAll：删除数组中多个元素的所有值
    , g& W! z/ |7 j3 x
55. $res = $collection->update(['First Name' => 'Jet'], ['$pullAll' => ['E-Mail' => ['123123@qq.com', '666@qq.com']]]);

复制代码

1. //save()
   5 b# ?8 M/ H* O1 |2 a
2. //参数1：希望保存的信息数组
   & i8 {  }+ u, e, U( `# I' I
3. //参数2：扩展选项
   2 Y' i8 d# _% W" G3 n: G/ ^; }$ U
4. //  fsync：若设置为true，w参数将被覆盖为0，数据将在更新结果返回前同步到磁盘。
   
5. //  w：默认为1；若设置为0，更新操作将不会得到确认；使用复制集时可设置为n，确保主服务器在将修改复制到n个节点后才确认该更新操作
   8 c9 j# `. B( X+ u1 C
6. //  j：默认为false，若设置为true，数据将在更新结果返回之前写入到日志中。
   
7. //  wtimeout：默认为10000（毫秒），用于指定服务器等待接收确认的时间
   " }: x$ A3 K+ r! h, _! C
8. //  timeout：指定客户端需要等待服务器响应的超时时间（毫秒）
   $ `- o8 Z9 f4 ^* _9 t" l' {
9. //注意：若已存在则更新，若不存在则插入；更新时使用参数1指定的信息数组替换整个文档。
   
10. //若想更新则应该在参数1中指定_id键的值。
    * G2 I2 o. T' L- t- I
11. $mongo = new MongoClient('mongodb://localhost:27017');
    
12. $db = $mongo->mf;
    + ^, a# U! Y, P/ v, P. G( d5 P
13. $collection = $db->friend;
    : V$ S! p* q2 M& A
14. $doc = [//定义一个文档，即一个数组
    
15.     'First Name' => 'Jet',
    
16.     'Last Name' => 'Wu',
    1 E! o0 r4 q& A' s1 q+ F9 c' B9 [
17.     'Age' => 26,
      w0 }0 v2 r+ s; B  B1 A3 P( k  o
18.     'Phone' => '110',
    
19.     'Address' => [
    
20.         'Country' => 'China',
    $ T4 H5 A5 |& S6 y- K
21.         'City' => 'Shen Zhen'
    , j9 o( w) }) ?2 |' W! W: m
22.     ],
    
23.     'E-Mail' => [
    
24.         '123456@qq.com',
    $ ^: M- x7 i8 N$ }
25.         '666666@sina.com',
    6 B  {" W+ I; d
26.         '8888888@qq.com',
    ' j) r9 f) P9 w# z; I* O; f; W
27.         '77887788@qq.com'
    1 v. Y3 ]1 ?, t, H" H
28.     ]
    
29. ];
    5 h( s: O+ c  ~# O% T* V4 m
30. $res = $collection->save($doc);
    ( L' W9 |  P5 s+ x5 P+ F4 e4 j
31. echo '<pre>';
    
32. print_r($res);//$res['ok']=1表示操作成功，$res['updatedExisting']=1表示更新，$res['upserted']=1表示插入
    
33. 
      X: I8 Y7 S) ^* L' x* u; E% V4 r

复制代码

1. //findAndModify()
   
2. //参数1：指定查询条件
   
3. //参数2：指定用于更新文档的信息
   
4. //参数3：可选，指定希望返回的字段
   
5. //参数4：扩展选项
   
6. //  sort：以特定顺序对匹配文档进行排序
   " c% Z' i+ u: `' P; S: }
7. //  remove：若设置为true，第一个匹配文档将被删除
   0 i( C  @+ X, ^  K+ n4 ]/ H
8. //  update：若设置为true，将在被选择的文档上执行更新操作
   
9. //  new：默认为false，若设置为true则返回更新后的文档，否则返回更新前的文档
   / E: V$ l% Z: I1 z" i. q+ \. z
10. //  upsert：若设置为true，没有找到匹配文档的时候将插入一个新的文档
    " Q: B# }- ]( j. u0 K. q8 ]% @$ h
11. $mongo = new MongoClient('mongodb://localhost:27017');
    " L+ B0 \4 q. A7 j& W$ {
12. $db = $mongo->mf;
    2 s% P/ x5 Q. j: S
13. $collection = $db->friend;
    
14. $res = $collection->findAndModify(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '111@qq.com']]);
    
15. echo '<pre>';
    2 ]/ l/ O- U4 O% T0 D! ]8 M3 W
16. print_r($res);

复制代码

　　

四、数据删除

1. //remove()
   3 e$ K+ y( }; [" x% z$ R7 \% N
2. //参数1：查询条件
   5 `9 b: U7 B$ t) ~/ G+ X4 Z1 R" F
3. //参数2：扩展选项
   # k8 E* N6 d. D
4. //  justOne：若设置为true，则最多只有一个匹配的文档将被删除
   * C% v8 Q: j4 R3 ?) j
5. //  fsync：若设置为true，w参数将被覆盖为0，数据将在更新结果返回前同步到磁盘。
   6 X. K4 N& y7 r) Y
6. //  w：默认为1；若设置为0，更新操作将不会得到确认；使用复制集时可设置为n，确保主服务器在将修改复制到n个节点后才确认该更新操作
   ) ~) C* {. Y/ U; ~% D7 ~: Q0 A/ L
7. //  j：默认为false，若设置为true，数据将在更新结果返回之前写入到日志中。
   
8. //  wtimeout：默认为10000（毫秒），用于指定服务器等待接收确认的时间
   
9. //  timeout：指定客户端需要等待服务器响应的超时时间（毫秒）
   ; u( O4 ~- B% b/ x( B
10. $mongo = new MongoClient('mongodb://localhost:27017');
    ( s  e6 ]7 V- ?0 f, ^3 R
11. $db = $mongo->mf;
    
12. $collection = $db->friend;
    $ g1 {. N& B, d. s
13. $res = $collection->remove(['First Name' => 'jet']);
    " M3 W/ @% k$ d' g( t! F* o5 O
14. echo '<pre>';
    
15. print_r($res);//$res['n']表示删除了几个文档

复制代码

以上是PHP7以前版本的MongoDB操作，下面简单介绍PHP7以后版本的操作。

; T( T/ x  N: n; N8 H& [

-----------------------------------------------PHP7分隔线---------------------------------------------------------------------

数据插入：

1. $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
   ) L4 m8 h9 N9 c; L5 ~- X1 \
2. $bulk = new MongoDB\Driver\BulkWrite;
   
3. $bulk->insert(['name' => 'JetWu5', 'age' => 26]);
   
4. $bulk->insert(['name' => 'JetWu6', 'age' => 26]);
   - K5 O' B* O- J* g6 x/ S
5. 
   
6. $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选，修改确认
   % o9 A' \) z' c0 A. b; [
7. $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
   # a# H$ }2 @! P" I) u5 L
8. echo '<pre>';
   & |: i& V+ Q0 m! N# K
9. print_r($res);

复制代码

" P  s# u3 G! l% C$ V

数据查询：

1. $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
   ; _- w: M$ Y/ n( `0 s9 f6 l
2. $query = new MongoDB\Driver\Query(['age' => 24], ['sort' => ['age' => 1]]);
   
3. $cursor = $manager->executeQuery('wjt.friend', $query);
   
4. 
   
5. $data = [];
   , ^3 }( l! |; L& F8 K0 G6 E
6. foreach($cursor as $doc) {
   * r+ T' O" @, L/ U
7.     $data[] = $doc;
   : a4 q( z1 `; D, y
8. }
   ; |1 {2 F4 S9 E3 J5 M4 }
9. echo '<pre>';
   
10. print_r($data);

复制代码

　　

数据修改：

1. $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
   
2. $bulk = new MongoDB\Driver\BulkWrite;
   ! L- B3 d, g1 c; i4 \# z2 g8 D/ r
3. $bulk->update(
   # h# u5 X2 X6 |( \9 ^$ B- o
4.     ['name' => 'JetWu5'],
   
5.     ['$set' => ['age' => 30, 'promise' => 'always smile!']]
   # Z& m$ n7 a$ M7 W0 ^
6. );
   ' ]  }; h; h! y) b' p2 Q
7. $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选，修改确认
   
8. $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
   
9. echo '<pre>';
   ' T5 U* L, K/ l
10. print_r($res);

复制代码

　　

数据删除：

1. $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
   7 p2 s: }8 Q" }+ {; r& Q/ n- {' c
2. $bulk = new MongoDB\Driver\BulkWrite;
   ' p. W0 ]# I/ Z( D4 Q8 {1 h& w% h+ i
3. $bulk->delete(['name' => 'JetWu3']);
   9 Y/ h7 `* c' ~! A/ a# X
4. $bulk->delete(['name' => 'JetWu4']);
   ! C: `, H( C# ?; A4 n! g6 y
5. $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选，修改确认
   ' k3 z" I4 z; T3 U* R( I/ G
6. $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
   0 m: F( F$ q# I& W* R
7. echo '<pre>';
   
8. print_r($res);

复制代码

" x, u" c7 l( J9 |' w
) O4 l8 c* d" q" h* I' {0 T: v