您尚未登录,请登录后浏览更多内容！ 登录 | 立即注册

QQ登录

只需一步，快速开始

 找回密码
 立即注册

QQ登录

只需一步，快速开始

返回列表 发新帖
查看: 7917|回复: 0
打印 上一主题 下一主题

[php学习资料] PHP操作MongoDB（增删改查）php7.0以下

[复制链接]
admin
跳转到指定楼层
楼主
发表于 2019-3-5 13:50:34 | 只看该作者 回帖奖励 |倒序浏览 |阅读模式
　　MongoDB的PHP驱动提供了一些核心类来操作MongoDB，总的来说MongoDB命令行中有的功能，它都可以实现，而且参数的格式基本相似。PHP7以前的版本和PHP7之后的版本对MongoDB的操作有所不同，本文主要以PHP7以前版本为例讲解PHP对MongoDB的各种操作，最后再简单说明一下PHP7以后版本对MongoDB的操作。
一、数据插入
  1. //insert()
    % L; I  e: J) w# o
  2. //参数1：一个数组或对象
    1 q  w0 h. ^0 a. W! `" i6 {5 h  R
  3. //参数2：扩展选项
    ! x0 x3 t* F% l) A' y
  4. //  fsync：默认为false，若为true则mongo在确认数据插入成功之前将会强制把数据写入硬盘& _# F' q) V& m: o  J% }" ?4 a
  5. //  j：默认为false，若为true则mongo在确认数据插入成功之前将会强制把数据写入日志
    3 d  k3 T, ]+ L) \/ \: E- }
  6. //  w：默认为1，写操作会被（主）服务器确认，若为0则将不会得到确认，使用复制集时设置为n用于确保主服务器将数据修改成功复制到n个节点后再确认; R- `+ P& {" C3 G$ n. B5 w+ d
  7. //  wtimeout：默认为10000（毫秒），用于指定服务器等待接收确认的时间7 }# O9 ~% r- n9 h+ N& c2 r9 F
  8. //  timeout：指定客户端需要等待服务器响应的超时时间（毫秒）
    * l6 x8 U; a0 K# E/ O' ?! ^# s
  9. $mongo = new MongoClient('mongodb://localhost:27017');
    . `- a$ Z6 c! U' |8 B" @
  10. $db = $mongo->mf;//选择数据库% w. R8 g  L, |, u% f" w1 {8 D- |
  11. $collection = $db->friend;//选择文档集合
    1 B5 E4 A6 V9 s7 U6 v/ x+ S% U
  12. $doc = [//定义一个文档，即一个数组
    , z- }5 p" }% C2 K$ `- O1 z
  13.     'First Name' => 'Jet',
    3 I5 F6 E* C) L1 m
  14.     'Last Name' => 'Wu',
    ( E( X# N& L1 j; \" S0 i
  15.     'Age' => 26,/ V/ C% R% L( \* V9 C
  16.     'Phone' => '110',
    ; u' d  o) Q3 n2 H9 X
  17.     'Address' => [
    7 @, Y$ Z, c. j& f
  18.         'Country' => 'China',0 h& T3 _1 J* U% n& b3 X8 a
  19.         'City' => 'Shen Zhen'2 D. _6 Z) D+ m9 n6 N
  20.     ],
    0 _2 c6 g' D3 ~
  21.     'E-Mail' => [
    * u) j5 L$ V: S  Q7 z8 Z- R
  22.         '123456@qq.com',$ n, D' ^- C* W" F  t  `
  23.         '666666@sina.com',# D) c6 O$ `8 P: U
  24.         '8888888@qq.com',
    : a5 Y, _! j" Z: ^7 o& A/ A) k
  25.         '77887788@qq.com'
    9 o0 v/ A! M4 w9 I% A
  26.     ]+ E6 k' p/ t# M7 C$ t
  27. ];
    0 P1 R1 c/ p; \1 V) o& ?0 ~
  28. $res = $collection->insert($doc);//向集合中插入一个文档7 i2 b# U) i: h6 G8 \
  29. echo '<pre>';7 e5 f8 Z( q  d
  30. print_r($res);//$res['ok']=1表示插入成功
复制代码
二、数据查询
1. 查询单个文档：
  1. //findOne()
    ! A- Q) d# u/ Z+ o, m
  2. //参数1：搜索条件
    - w; W% _5 W+ W% A' V9 W- y/ J. T
  3. //参数2：指定返回字段，array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回，除非在第二个参数显式加入'_id'=>false。不设置则返回所有字段0 V3 Y8 c2 s2 t4 Y+ p9 ?+ T
  4. $mongo = new MongoClient('mongodb://localhost:27017');1 g$ f0 }* F9 e' @
  5. $db = $mongo->mf;
    8 _5 K9 K& A$ {6 I5 ?, y) W
  6. $collection = $db->friend;! _. b3 \/ M* A# G7 G
  7. $one = $collection->findOne(['First Name' => 'Jet']);; m0 a; S9 `$ D0 w! g
  8. echo '<pre>';
    3 G0 M, N$ w( `9 W
  9. print_r($one);//返回一个数组，查不到数据则返回NULL
复制代码
2. 查询多个文档：
  1. //find(); x+ I* a, l5 e. |) ~; b: ~9 _5 m5 F- u
  2. //参数1：搜索条件: ]: U: m/ N- ~& }9 |" p
  3. //参数2：指定返回字段，array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回，除非显式设置为false不返回。不设置则返回所有字段
    2 @0 d. _* y7 {# Q& I
  4. $mongo = new MongoClient('mongodb://localhost:27017');& @1 k. z, V+ S+ g/ |* a
  5. $db = $mongo->mf;5 }# n! K1 x- H+ M; n* q
  6. $collection = $db->friend;2 D; g5 t8 f2 m' @/ z
  7. $cursor = $collection->find(['Address.Country' => 'China']);//使用点操作符查找数组元素
    2 `1 m2 L/ {$ U, B2 S0 y: M
  8. echo '<pre>';
    : j. S! U7 ]" {! O7 T% p: j7 L
  9. while($doc = $cursor->getNext()) {//循环读取每个匹配的文档
    4 |# y) E! s  }: B6 s# A5 E
  10.     print_r($doc);
    - E0 {2 Z5 O: ]; f& i" y
  11. }
复制代码
使用各种条件操作符定义查询：
  1. //mongodb分别使用$lt（小于）、$lte（下雨等于）、$eq（等于）、$gte（大于等于）、$gt（大于）、$ne（不等于）表示<、<=、=、>=、>、<>，用于整数字段查询
    7 ^: _/ b- o1 o# c8 L: Z
  2. $mongo = new MongoClient('mongodb://localhost:27017');
    3 p2 N2 y0 ~: h" j$ x1 V
  3. $db = $mongo->mf;5 M+ o9 ?+ j7 T
  4. $collection = $db->friend;
    ! p6 h' J( N: W! h0 P4 ~5 T4 y
  5. $cursor = $collection->find(['Age' => ['$gt' => 30]]);
    ; Y: A! K, t% k
  6. echo '<pre>';
    , l1 |' N4 Q0 X- h& ?% c, r/ y0 Q
  7. while($doc = $cursor->getNext()) {
    ( C. K# l- R# L+ h. W
  8.     print_r($doc);1 ]0 i& Y+ s. ^1 I$ Y; Q
  9. }
复制代码
　　//查询某个字段的所有不重复的值
; h+ l# L) k) o　　$res = $collection->distinct('Age');
  1. //$in：匹配多个值中任意一个9 C. m3 {8 g7 ?* n
  2. $cursor = $collection->find(['Address.Country' => ['$in' => ['China', 'USA']]]);
    ' q+ d, ^  Z4 X
  3.   b/ c& U& T7 [, r* O
  4. //$all：匹配多个值中所有值（用于数组字段查询）! A+ s$ m3 L6 g7 x/ b% Z
  5. $cursor = $collection->find(['E-Mail' => ['$all' => ['123456@qq.com', '77887788@qq.com']]]);; K+ i6 k' f: g# s! V% d' R+ O
  6. $ l) y+ q. `: T% I. s
  7. //$or：或查询
    + `; B8 j2 I6 M) C; z
  8. $cursor = $collection->find(['$or' => [['First Name' => 'Jet'], ['Address.Country' => 'USA']]]);
    7 }) U. B9 S6 z/ N6 Q# ~

  9. 1 W5 ?0 u+ s9 B+ V* m4 e  F
  10. //$slice：获取数组字段中指定数目的元素，位于find()函数第二个参数中
    & k; K4 `7 n4 ~2 z+ e6 d
  11. $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => 2]]);//只返回前两个email
    ) G4 Y$ |# y+ p0 C2 L4 e
  12. $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => -2]]);//只返回最后两个email9 y* |  H) A% f, N- A5 x3 F- e
  13. $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => [1, 2]]]);//忽略第一个，返回接下来两个
    # w1 r2 ^: w9 |

  14. % }2 u4 u* m' ?1 J
  15. //$exists：根据某个字段是否有设置值进行查询  V3 `: G8 q! n$ J! b0 q
  16. $cursor = $collection->find(['Hobby' => ['$exists' => false]]);//查找Hobby字段未设置值的文档
    ) e5 J; o2 y, d6 a* U' O8 v6 L& Q
  17. ' }5 I1 b2 l% Y( Y% O
  18. //正则表达式查询' h. u" `/ q9 Z7 _4 q+ C& C' w
  19. $cursor = $collection->find(['First Name' => new MongoRegex('/^Je/i')]);//查找First Name字段以Je开头的文档，忽略大小写差异
复制代码
使用MongoCursor类提供的其他函数：
  1. //排序：1升序，-1降序3 c% G8 `/ [5 ]2 M1 w
  2. $cursor->sort(['Age' => 1]);  M4 s, ?/ p0 H' w1 @

  3. / q% c2 v- m6 O# p
  4. //忽略前n个匹配的文档1 ~) \9 |) e  E
  5. $cursor->skip(1);  I$ `6 H) r( h8 j/ s

  6. : h, E. H) P* E+ x9 ~% U
  7. //只返回前n个匹配的文档（limit()与skip()结合使用可实现数据分页功能）
    0 z# V4 [6 n% \3 `: t5 s
  8. $cursor->limit(1);
    $ C3 g0 I# W, k0 O8 m
  9. 8 R* n1 e2 e% @" [' f
  10. //匹配文档的总数
    . X8 G+ G: q8 G/ M  u
  11. $cursor->count();/ d8 i1 N; q3 i9 ~/ k: b: B

  12. ' f# H6 H+ a2 B1 v) P6 h0 L
  13. //指定查询索引
    + W% {  o7 m6 Z7 R* `; m% v
  14. $cursor->hint(['Last Name' => -1]);//若索引不存在则会报错
复制代码
聚集查询：对数据进行分组统计
  1. //聚合查询：对数据进行分组统计. O5 e/ [9 m$ Z) d2 F8 u
  2. $mongo = new MongoClient('mongodb://localhost:27017');
    5 B4 e; g: g- Z' A3 c
  3. $db = $mongo->mf;! u6 l, _8 w, M" ]8 r* e- J& C
  4. $collection = $db->friend;# |9 f) w6 X4 S% L1 E
  5. $res = $collection->aggregate([4 o( `) x, J. X7 t
  6.     '$group' => [9 C# d- g, y3 b
  7.         '_id' => '$Address.Country',//分组字段，注意要加上“$”，这里是根据数组字段某个元素值进行分组6 \) a' Z$ D) C% P$ i: N
  8.         'total' => ['$sum' => 1],//求总和，表示每匹配一个文档总和就加1- V7 |$ b5 m: d' S1 j
  9.         'maxAge' => ['$max' => '$Age'],//分组中Age字段最大值
    ( N+ K5 Y2 k2 x' g  P1 p: \
  10.         'minAge' => ['$min' => '$Age']//分组中Age字段最小值5 t$ C3 K; i2 N
  11.     ]
    * T) K! N5 B% a8 ]$ t# I3 o$ v
  12. ]);3 T" Z+ E- `/ J
  13. echo '<pre>';3 ?, A* b( r& h% Q
  14. print_r($res);//返回一个数组，$ret['result']为数组，存放统计结果! S0 y. r2 z5 s+ @/ m; Y

  15. $ ^+ {) l! ]& \, |0 |" w3 b
  16. ' v0 I% j) V7 O8 F3 @/ T
  17. //存在其它操作的聚合查询：多个操作之间执行先后顺序取决于它们位置的先后顺序% v2 ~8 ?; [5 @0 R- O7 r) e
  18. //聚合查询中的所有操作，包括'$group'在内，都是可选的。
    ( G5 n6 G( R' ]2 v9 _( L
  19. $mongo = new MongoClient('mongodb://localhost:27017');6 P! [7 Y. u4 F# a3 w. T/ m
  20. $db = $mongo->mf;, F+ C- r1 q" p6 R7 }
  21. $collection = $db->friend;/ `. E, J3 T% Q, Q6 E
  22. $res = $collection->aggregate([
    ; V' f. r1 I1 P% U% p% h
  23.     [//过滤条件：只对符合条件的原始文档进行聚合运算，若是放在'$group'之后则是只返回符合条件的结果文档" U! R; a2 g' J' \$ b
  24.         '$match' => ['Age' => ['$gt' => 30]]9 ~, \4 c6 r( R+ m# r+ \: I5 w0 H
  25.     ],- a  }  i- j* F1 G8 J
  26.     [//指定分组字段、统计字段5 H6 q" {3 J/ l) ]$ P, p2 |
  27.         '$group' => [
    * c* ?& ]% J4 T3 T9 y
  28.             '_id' => '$Address.Country',
    " ]7 N# _2 C+ S2 U
  29.             'totalAge' => ['$sum' => '$Age']//计算各个分组Age字段总和
    2 `( C# L, Q3 `- G' L
  30.         ]# d0 `9 @% P; D% W3 ]7 J2 o
  31.     ],1 c! t, [1 s0 Y3 |3 k# m  u! v5 x+ K
  32.     //以下操作若是放在'$group'之前则在聚合前作用于原始文档，若放在'$group'之后则在聚合后作用于结果文档
    ' F9 ]; ]2 r/ }* v
  33.     ['$unwind' => '$E-Mail'],//将包含有某个数组类型字段的文档拆分成多个文档，每个文档的同名字段的值为数组中的一个值。
    . G0 j( Z5 K8 e& @* W9 |) u
  34.     ['$project' => ['myAge' => '$Age', 'First Name' => '$First Name']],//指定返回字段，可以对字段进行重命名，格式：返回字段名 => $原来字段名
    : O2 r# ~) \& y
  35.     ['$skip' => 2],//跳过指定数量的文档( Q, }* @0 ^8 p  W  \$ U& Y, i
  36.     ['$limit' => 2],//只返回指定数量的文档$ t; Y/ w7 s" X0 O
  37.     ['$sort' => ['totalAge' => 1]]//排序
    * y; _* [1 m( Z' C8 \" V& J! R
  38. ]);+ a" u3 R1 O( r( Z+ U
  39. echo '<pre>';
    ) G+ V  {, o0 m/ Z
  40. print_r($res);
复制代码

/ [# ~- e: ~) j; h
三、数据修改
  1. //update()
    ; O% |) n5 j4 w/ J- ]  P$ q8 U
  2. //参数1：更新条件，指定更新的目标对象。6 \1 U( }# g: i; S9 a7 m
  3. //参数2：指定用于更新匹配记录的对象。
    8 N2 N6 Y9 u5 G
  4. //参数3：扩展选项组。
    & A# T- h8 i. p4 {! X) G( {
  5. //  upsert：若设置为true，当没有匹配文档的时候会创建一个新的文档。
    6 }" r) e0 J) w2 A# h( k% H
  6. //  multiple：默认为false，若设置为true，匹配文档将全部被更新。' `8 b: \& \- b5 X4 Q( L  w
  7. //  fsync：若设置为true，w参数将被覆盖为0，数据将在更新结果返回前同步到磁盘。
    * @3 H, s: J# w$ P! B* d  b; `% n
  8. //  w：默认为1；若设置为0，更新操作将不会得到确认；使用复制集时可设置为n，确保主服务器在将修改复制到n个节点后才确认该更新操作3 i. P, e8 ]% {
  9. //  j：默认为false，若设置为true，数据将在更新结果返回之前写入到日志中。: l  A8 Z) t) s) K! D% k0 X+ f
  10. //  wtimeout：默认为10000（毫秒），用于指定服务器等待接收确认的时间( Y. e; u: ], u% H" s
  11. //  timeout：指定客户端需要等待服务器响应的超时时间（毫秒）' L- d$ h& K! f( K, S# f3 B
  12. //注意：若不使用任何修改操作符，则匹配文档将直接被整个替换为参数2指定的对象。
    % }9 W' R# a% |- g% A
  13. 5 c/ g+ P- ?8 u6 {$ x/ F
  14. //$inc：增加特定键的值，若字段不存在则新建字段并赋值  S9 V3 p4 G0 `7 z
  15. $mongo = new MongoClient('mongodb://localhost:27017');
    4 x% J7 W( V  H* u0 n
  16. $db = $mongo->mf;
    ' k' V: \3 {7 ?
  17. $collection = $db->friend;+ Q- D: Y' ^5 p% U: d
  18. $res = $collection->update(['First Name' => 'Jet'], ['$inc' => ['Age' => 2]]);
    2 c5 K2 m5 D6 `, {% C& i
  19. echo '<pre>';
    3 j5 ~; ?9 m  ^. G8 A$ Q
  20. print_r($res);//$res['ok']=1表示修改成功，$res['nModified']表示修改的文档数量
    & r: C. V9 ~  a4 h: l) G, `; ^; s

  21. 7 p( X3 i) A. k3 @" }& U
  22. //$set：重置特定键的值，若字段不存在则新建字段并赋值- j! a' l4 q1 P8 h* e/ P
  23. $res = $collection->update(['First Name' => 'Jet'], ['$set' => ['Hobby' => 'pingpong']]);
    * O+ p2 f# o# j( B0 E3 K
  24. 1 e- C- g. d2 p* B3 T9 x( _& x
  25. //$unset：删除字段% ]9 G* ?# v) q( x
  26. $res = $collection->update(['First Name' => 'Jet'], ['$unset' => ['Hobby' => 1]]);9 [3 o+ n9 [* v, G$ t) j4 N

  27. 8 F/ g' m( U* E
  28. //$rename：重命名字段，若字段不存在则不进行任何操作
    $ y# E9 ^3 A% F/ V+ N6 w
  29. $res = $collection->update(['First Name' => 'Jet'], ['$rename' => ['Hobby' => 'hobby', 'Age' => 'age']]);
    3 X9 d; I4 j9 K0 f0 U
  30. //注意：如果文档中已经使用了指定名称的字段，则该字段将会被删除，然后再进行重命名操作。8 o( j. \, a- ]; x" Y
  31. 1 s0 w' c( Z, [. @
  32. //$setOnInsert：设置了upsert为true，并且发生了插入操作的时候，将某个字段设置为特定的3 p7 A) r4 T6 p# T
  33. $res = $collection->update(['First Name' => 'jet'], ['$setOnInsert' => ['lang' => 'English']], ['upsert' => true]);
    1 F& H2 d1 a& p  @1 Y

  34. ( i3 {: v2 P8 n3 A/ x- h5 D
  35. //$push：向指定字段添加一个值（作用于数组字段），若字段不存在会先创建字段，若字段值不是数组会报错
    2 g- P' m. V! B* _) `+ |8 m
  36. $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '123123@qq.com']]);
    6 H0 ^( G1 D5 h
  37. & ~. @/ K. z4 J' E
  38. //$push：向指定字段添加多个值（作用于数组字段），若字段不存在会先创建字段，若字段值不是数组会报错
    3 G$ G( ~, s. x, h# w) Z
  39. $res = $collection->update(['First Name' => 'Jet'], ['$pushAll' => ['E-Mail' => ['666@qq.com', '8888888@qq.com']]]);1 r2 F# e" E0 j3 Q% O
  40. : V2 p# y* k7 h- |& E' H, ~- p
  41. //使用$push和$each向某个字段添加多个值（作用于数组字段），若字段不存在会先创建字段，若字段值不是数组会报错
    ( s3 k5 W$ j  G+ U8 n9 q6 d
  42. $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);
    , M2 j( P1 \" G7 c- [
  43. ! j  U( D1 P# `$ m3 `% q' S$ |
  44. //$addToSet：将数据添加到数组中（只在目标数组没有该数据的时候才将数据添加到数组中）
    ' S( u9 d* V& m) u& x1 g3 O
  45. $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => '123123@qq.com']]);; t- G9 @2 `. d$ b* [
  46. $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);
    ! I6 S, I. k0 i  E7 ^
  47. ; c+ ], o/ C# a+ A. ?9 C; Z, _
  48. //$pop：从数组中删除一个元素，-1表示删除第一个元素，1表示删除最后一个元素（其实负数都删除第一个元素，0或正数都删除最后一个元素）3 P1 {. h) j& a# G6 E% x$ z
  49. $res = $collection->update(['First Name' => 'Jet'], ['$pop' => ['E-Mail' => 1]]);
    - i- @; r. v" b: F/ v* E
  50. ; b  K! N1 u& W- h: y7 L: M
  51. //$pull：删除数组中所有指定值+ y0 t! n9 t) w! Y* \% D- U  P
  52. $res = $collection->update(['First Name' => 'Jet'], ['$pull' => ['E-Mail' => '123123@qq.com']]);
    7 R* W" V9 P5 E& f7 r. H

  53. : p' f9 s& J2 b! r2 Y/ T7 L
  54. //$pullAll：删除数组中多个元素的所有值
    % I* t9 @$ P3 T' Z+ ^( m
  55. $res = $collection->update(['First Name' => 'Jet'], ['$pullAll' => ['E-Mail' => ['123123@qq.com', '666@qq.com']]]);
复制代码
  1. //save()
    , p3 H" u7 B  g
  2. //参数1：希望保存的信息数组
    - _1 r( {0 t, b3 O* r& f4 H# s
  3. //参数2：扩展选项
    $ J- h1 a+ m6 g5 O# z9 O
  4. //  fsync：若设置为true，w参数将被覆盖为0，数据将在更新结果返回前同步到磁盘。
    ) h! E  _- G  x* g0 p% j% B
  5. //  w：默认为1；若设置为0，更新操作将不会得到确认；使用复制集时可设置为n，确保主服务器在将修改复制到n个节点后才确认该更新操作
    ! l9 N/ c6 r' ]- j& v: f" }
  6. //  j：默认为false，若设置为true，数据将在更新结果返回之前写入到日志中。
    * g) U- C3 @% `+ C: }
  7. //  wtimeout：默认为10000（毫秒），用于指定服务器等待接收确认的时间
    # J! n0 M  k8 \4 V) q  @: B
  8. //  timeout：指定客户端需要等待服务器响应的超时时间（毫秒）
    2 m) T! |. V" \  @  J, o/ n6 m
  9. //注意：若已存在则更新，若不存在则插入；更新时使用参数1指定的信息数组替换整个文档。8 v* _* t  S! Q- A
  10. //若想更新则应该在参数1中指定_id键的值。
    7 D% A9 `1 }# x5 p( d8 U3 I* Z; B
  11. $mongo = new MongoClient('mongodb://localhost:27017');
    8 F, u  ^' W7 x; [% {. O6 J! Y* H
  12. $db = $mongo->mf;
    $ Y8 @, d8 e! [" D# s7 A' ^# u
  13. $collection = $db->friend;
    4 R) X- J# @7 Y9 T
  14. $doc = [//定义一个文档，即一个数组( ^& y9 }2 s6 U; i
  15.     'First Name' => 'Jet',0 i& j# n( Y6 K; b; D
  16.     'Last Name' => 'Wu',, U' u% l9 H% S8 }
  17.     'Age' => 26,# Q9 R  ^9 Z  ]' ?5 p1 A0 \- ^/ B3 R
  18.     'Phone' => '110',
    ( P! O4 K" I2 ^/ t2 K
  19.     'Address' => [
    ( h# h5 O# w" s" O3 P6 v
  20.         'Country' => 'China',9 p- D) I  i& ^. E4 }
  21.         'City' => 'Shen Zhen'0 }- I- v+ v7 H( ~8 |
  22.     ],
    & x: b% I, a( X* S4 N9 e" e$ q
  23.     'E-Mail' => [) }- K( h4 M+ \( N/ F+ K, U5 s
  24.         '123456@qq.com',2 O" m# s+ m1 n/ L
  25.         '666666@sina.com',* @8 h4 m: ?. c( W0 Z$ v
  26.         '8888888@qq.com'," i$ z2 W& F8 @4 ]- |
  27.         '77887788@qq.com'+ v# J  z8 M2 S
  28.     ]" [2 j  z* p1 e9 F# w% }2 d
  29. ];- V/ k6 V/ E7 [& z
  30. $res = $collection->save($doc);
    6 a( p2 C+ O& I( ^3 F
  31. echo '<pre>';
    : r/ G* x, |: }( }) N
  32. print_r($res);//$res['ok']=1表示操作成功，$res['updatedExisting']=1表示更新，$res['upserted']=1表示插入
    + x/ t' Z: n) |' Y" S
  33. ( w+ |9 O6 P( ?7 P! y
复制代码
  1. //findAndModify()
    5 F/ b- m: `' f5 e2 Z/ ^! f$ G
  2. //参数1：指定查询条件
    4 b. y# w5 l: R4 h6 \8 k! f
  3. //参数2：指定用于更新文档的信息4 B" E9 C3 ]$ H) ]
  4. //参数3：可选，指定希望返回的字段2 O- J5 O, o  Y5 a' \
  5. //参数4：扩展选项4 A: _: Z; y( w
  6. //  sort：以特定顺序对匹配文档进行排序
    . |& J" g0 R/ K6 b
  7. //  remove：若设置为true，第一个匹配文档将被删除6 x+ O. Y+ X, A( g+ @
  8. //  update：若设置为true，将在被选择的文档上执行更新操作
    5 a+ i8 G$ A& Z' c0 q3 f7 Z! s
  9. //  new：默认为false，若设置为true则返回更新后的文档，否则返回更新前的文档
    4 @4 }, n/ U0 V6 n6 w) ~, \, Z
  10. //  upsert：若设置为true，没有找到匹配文档的时候将插入一个新的文档
    $ i% b0 a* B  i" A/ A
  11. $mongo = new MongoClient('mongodb://localhost:27017');0 V* ]' f# r9 Z$ r8 y0 ^. G2 W5 ?
  12. $db = $mongo->mf;
    % V* y: o* }9 A+ ~
  13. $collection = $db->friend;, V6 q+ N& Z2 g$ ~
  14. $res = $collection->findAndModify(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '111@qq.com']]);) M7 T4 K) Q5 C# g
  15. echo '<pre>';
    - o9 x* X: v2 G
  16. print_r($res);
复制代码
　　
四、数据删除
  1. //remove()
    * u4 p) l, s9 D1 z8 E- X, u: {
  2. //参数1：查询条件
    * g# R& k( O- m' H, p/ H
  3. //参数2：扩展选项4 W) P$ t" ^$ C9 v$ y
  4. //  justOne：若设置为true，则最多只有一个匹配的文档将被删除
    $ @- M+ b% C) v3 k: U$ ?
  5. //  fsync：若设置为true，w参数将被覆盖为0，数据将在更新结果返回前同步到磁盘。( Y! B: j; A* ]$ a. F( o
  6. //  w：默认为1；若设置为0，更新操作将不会得到确认；使用复制集时可设置为n，确保主服务器在将修改复制到n个节点后才确认该更新操作2 z$ A& {; r; a- n
  7. //  j：默认为false，若设置为true，数据将在更新结果返回之前写入到日志中。0 s$ z. J0 [9 h6 _$ G7 W3 ^; g
  8. //  wtimeout：默认为10000（毫秒），用于指定服务器等待接收确认的时间
    ( I& F% E8 q! z) r. E8 D! t5 R
  9. //  timeout：指定客户端需要等待服务器响应的超时时间（毫秒）! g0 L8 Y' j% i0 `! J2 ~/ Z
  10. $mongo = new MongoClient('mongodb://localhost:27017');
    ; ~6 Y5 X) p, _" J/ K0 V
  11. $db = $mongo->mf;
    : {% y8 d! _# a, b2 l5 O
  12. $collection = $db->friend;
      x! N3 m1 L: Y1 A
  13. $res = $collection->remove(['First Name' => 'jet']);
    8 k# M! z7 L4 ?1 N
  14. echo '<pre>';
    8 g& e8 f- Z! s0 H, M
  15. print_r($res);//$res['n']表示删除了几个文档
复制代码
" \# {) `9 `1 w) g
以上是PHP7以前版本的MongoDB操作，下面简单介绍PHP7以后版本的操作。
% V% m- ^* t  o
-----------------------------------------------PHP7分隔线---------------------------------------------------------------------

" t$ R+ q  s: v+ v2 P+ B0 o6 P
数据插入：
  1. $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
    3 T+ I" V5 f! O: @6 Z/ D
  2. $bulk = new MongoDB\Driver\BulkWrite;
    5 @' z% U% Q; [+ Q- y! ]
  3. $bulk->insert(['name' => 'JetWu5', 'age' => 26]);- P" j# f, |# E
  4. $bulk->insert(['name' => 'JetWu6', 'age' => 26]);
    1 v  ^5 X, t2 K1 j; G/ P

  5. 8 T* e* R5 i# I1 g+ `0 x7 u
  6. $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选，修改确认
    9 ?& q# s. T# N+ k& ^
  7. $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
    ' B* z" y& e* b; D" E! `( Z
  8. echo '<pre>';; P0 o- q% L2 q! d" A7 z% E3 Z2 [
  9. print_r($res);
复制代码
/ j; Z9 W( _1 M+ X9 }" |* D: z
数据查询：
  1. $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');! G2 o$ m, k' D; }+ B
  2. $query = new MongoDB\Driver\Query(['age' => 24], ['sort' => ['age' => 1]]);3 Q; A1 O5 g- N$ U) f4 |
  3. $cursor = $manager->executeQuery('wjt.friend', $query);
    % F6 o+ F; ?8 a. b$ d9 I/ U
  4. ' v! A* z* p8 n+ r7 _* p
  5. $data = [];
    : n& U+ e) k- E6 g% ]
  6. foreach($cursor as $doc) {
    , H4 s$ w% `5 Q* T7 O
  7.     $data[] = $doc;
    8 r& _* @$ |* Q) R5 |
  8. }$ @" j6 z/ c" X& K
  9. echo '<pre>';
    % \: {8 T; m0 h1 Q
  10. print_r($data);
复制代码
　　
数据修改：
  1. $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
    ) h. X  S% j7 V5 k' q% g
  2. $bulk = new MongoDB\Driver\BulkWrite;% E: X9 Y6 w! d  X
  3. $bulk->update(
    1 g( t+ J( v6 _6 a
  4.     ['name' => 'JetWu5'],! O5 f3 H4 J7 m0 H0 x
  5.     ['$set' => ['age' => 30, 'promise' => 'always smile!']]: ^5 K4 i9 ~: q! i9 m
  6. );
    ; F  o$ Z. z- B; [0 U
  7. $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选，修改确认7 K+ K! T& W- j' q# M. t; ~2 q
  8. $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);5 q8 z# ?0 w1 u8 X
  9. echo '<pre>';* E& U9 D/ W9 a8 n. m1 d" H
  10. print_r($res);
复制代码
　　
数据删除：
  1. $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');1 f4 s! R. k# m& M  ~! a
  2. $bulk = new MongoDB\Driver\BulkWrite;
    5 J: i) b/ M4 M" e
  3. $bulk->delete(['name' => 'JetWu3']);+ S( p! V( P/ j9 P2 w
  4. $bulk->delete(['name' => 'JetWu4']);
    , {8 S5 D' p5 L: M0 |6 g3 \4 B
  5. $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选，修改确认% E$ h: c! J: Q/ Y3 F  F
  6. $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);3 [, {, W2 ?9 D% p
  7. echo '<pre>';
    6 L- W4 }. r: ~/ B( K; R7 ^5 V
  8. print_r($res);
复制代码
. j* V' V+ _7 |+ m2 C& A
. [6 }& M, Y* f/ e( a" U
7 v, h+ f1 ^7 z2 g2 `
' e' s0 z2 G6 G: i$ W- z
# d( C+ w5 i) G2 F# I
分享到:  QQ好友和群QQ好友和群 QQ空间QQ空间 腾讯微博腾讯微博 腾讯朋友腾讯朋友
收藏收藏 分享分享 支持支持 反对反对
回复

使用道具 举报

返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

GMT+8, 2024-5-7 20:06 , Processed in 0.141671 second(s), 19 queries .

Copyright © 2001-2024 Powered by cncml! X3.2. Theme By cncml!