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

QQ登录

只需一步,快速开始

 找回密码
 立即注册

QQ登录

只需一步,快速开始

查看: 13078|回复: 0
打印 上一主题 下一主题

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

[复制链接]
跳转到指定楼层
楼主
发表于 2019-3-5 13:50:34 | 只看该作者 回帖奖励 |倒序浏览 |阅读模式
  MongoDB的PHP驱动提供了一些核心类来操作MongoDB,总的来说MongoDB命令行中有的功能,它都可以实现,而且参数的格式基本相似。PHP7以前的版本和PHP7之后的版本对MongoDB的操作有所不同,本文主要以PHP7以前版本为例讲解PHP对MongoDB的各种操作,最后再简单说明一下PHP7以后版本对MongoDB的操作。
一、数据插入
  1. //insert()
    6 n- R- @5 h1 q& C* ?
  2. //参数1:一个数组或对象
    - a0 Y1 b8 f- C3 g# |1 `
  3. //参数2:扩展选项5 g" y  p' A! I( P
  4. //  fsync:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入硬盘# q( s$ L3 T  `, X% [  O. h
  5. //  j:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入日志
      I- f# [1 k) @( @, Z
  6. //  w:默认为1,写操作会被(主)服务器确认,若为0则将不会得到确认,使用复制集时设置为n用于确保主服务器将数据修改成功复制到n个节点后再确认
    : `+ g' Z6 t, V7 {& X$ d; t9 A
  7. //  wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间. n: d0 o  R, s; }
  8. //  timeout:指定客户端需要等待服务器响应的超时时间(毫秒). g- m1 {: b* J/ a/ S
  9. $mongo = new MongoClient('mongodb://localhost:27017');. v: G' @  x( G
  10. $db = $mongo->mf;//选择数据库
    " w2 V" w& @0 O; j0 |
  11. $collection = $db->friend;//选择文档集合
    . ]# p$ A$ \  S8 }
  12. $doc = [//定义一个文档,即一个数组. y  G/ Z8 ]* P) j8 S& S' `' z
  13.     'First Name' => 'Jet',* a# v" s4 N7 C9 F: u
  14.     'Last Name' => 'Wu',& q( I: ~: L: q, x
  15.     'Age' => 26,( ]% t! a! W1 E( q/ Y
  16.     'Phone' => '110',
    2 ^. f4 C- C: J
  17.     'Address' => [
    7 x: |; m* V' z, \4 O: \- w' Y
  18.         'Country' => 'China',
    , K* q% U' \5 t9 U! H; g
  19.         'City' => 'Shen Zhen'
    " T& i4 U! g8 |6 m: L& }
  20.     ],9 N$ ?4 f! Z2 y# L4 U1 P5 N+ c
  21.     'E-Mail' => [
    ) K; c( x  z3 z+ C$ ^% @% b
  22.         '123456@qq.com',% l3 s9 E7 a# y( \6 H. P2 A3 Z
  23.         '666666@sina.com',
    * a& j, B* c+ n8 w
  24.         '8888888@qq.com',$ C: o: g+ U* e
  25.         '77887788@qq.com'- H  O* v. }# ?
  26.     ]
    0 C! }  }3 q' s8 @+ s" d
  27. ];0 e  h! Y8 v2 v) ?& ~9 F# G5 ~
  28. $res = $collection->insert($doc);//向集合中插入一个文档& _9 K. n+ B) h# E0 y3 B
  29. echo '<pre>';- l' O5 a8 I5 Z0 \  M# c
  30. print_r($res);//$res['ok']=1表示插入成功
复制代码
二、数据查询
1. 查询单个文档:
  1. //findOne()
    ; T# _$ e7 H* K# f
  2. //参数1:搜索条件4 T; t, C/ R2 Q  \$ Q( U
  3. //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非在第二个参数显式加入'_id'=>false。不设置则返回所有字段- i+ d- D$ ^: T/ c3 |( R( t
  4. $mongo = new MongoClient('mongodb://localhost:27017');
    ( h1 O: \% }" R; k, i
  5. $db = $mongo->mf;
    * l( N: D4 H5 g& W6 p; N/ w- N+ {
  6. $collection = $db->friend;
    / n& a2 v$ T1 i7 T( F7 L0 P9 i
  7. $one = $collection->findOne(['First Name' => 'Jet']);) g, ]; Y3 U' d( l5 H5 u0 |
  8. echo '<pre>';
    6 _" D% \/ a( |8 ^6 p3 w
  9. print_r($one);//返回一个数组,查不到数据则返回NULL
复制代码
2. 查询多个文档:
  1. //find()
    # d; R0 }3 }2 G- }. E* v% ?" T
  2. //参数1:搜索条件8 L; J( D8 H2 ^6 f
  3. //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非显式设置为false不返回。不设置则返回所有字段+ E8 [- {: G7 {+ v  \
  4. $mongo = new MongoClient('mongodb://localhost:27017');
    9 @7 `& h: c: E; M6 u: J
  5. $db = $mongo->mf;
    : U& D2 `1 c3 S+ o
  6. $collection = $db->friend;% s8 V) U% F4 O; T3 g  i
  7. $cursor = $collection->find(['Address.Country' => 'China']);//使用点操作符查找数组元素, o5 w' s5 E. j9 s
  8. echo '<pre>';
    $ C! ~) C* i, P3 _1 _
  9. while($doc = $cursor->getNext()) {//循环读取每个匹配的文档9 R6 i  e6 H$ u$ ]
  10.     print_r($doc);
    ) E5 R& R, o2 D0 Q/ P
  11. }
复制代码
使用各种条件操作符定义查询:
  1. //mongodb分别使用$lt(小于)、$lte(下雨等于)、$eq(等于)、$gte(大于等于)、$gt(大于)、$ne(不等于)表示<、<=、=、>=、>、<>,用于整数字段查询
    5 G+ i6 e. }4 P+ J# q
  2. $mongo = new MongoClient('mongodb://localhost:27017');
    . _+ I) q& G% U3 t- ~6 Q0 o4 I: y9 R
  3. $db = $mongo->mf;
    * ~$ d1 Z+ w( X1 `
  4. $collection = $db->friend;( N, u, t3 l  s
  5. $cursor = $collection->find(['Age' => ['$gt' => 30]]);
    + I1 `$ p( @( i! ~
  6. echo '<pre>';
    ' `! d& V# ?' k$ r, S
  7. while($doc = $cursor->getNext()) {; o/ Q- f  q8 i$ m2 {- h9 k6 f
  8.     print_r($doc);
    9 G3 x2 S, B; `
  9. }
复制代码
  //查询某个字段的所有不重复的值
. }- V+ A) Z2 [" f  g7 D- s* v& I  $res = $collection->distinct('Age');
  1. //$in:匹配多个值中任意一个1 \$ A( ~: x* a9 R% ?0 h
  2. $cursor = $collection->find(['Address.Country' => ['$in' => ['China', 'USA']]]);1 @: Z7 @( @: g" ^& s1 l2 V

  3. 7 T2 N" \) E, `0 G& Z! p
  4. //$all:匹配多个值中所有值(用于数组字段查询)# h% W5 u+ n1 t8 H
  5. $cursor = $collection->find(['E-Mail' => ['$all' => ['123456@qq.com', '77887788@qq.com']]]);
    9 d8 `% {  o- c) W4 N5 K! n# a6 z

  6. 5 O! l! D, U7 s* W
  7. //$or:或查询
    1 x+ a9 R' d8 r! u5 F7 c! P
  8. $cursor = $collection->find(['$or' => [['First Name' => 'Jet'], ['Address.Country' => 'USA']]]);4 k5 `, Z; M! Y1 F
  9. , d% b0 M4 C" N; f# m- n- N
  10. //$slice:获取数组字段中指定数目的元素,位于find()函数第二个参数中
    3 K* f" u& v, N) e
  11. $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => 2]]);//只返回前两个email
    ; l* ]: T5 j2 Z# P* S" Q
  12. $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => -2]]);//只返回最后两个email
    / Y5 n3 M# o4 P5 Y
  13. $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => [1, 2]]]);//忽略第一个,返回接下来两个' [. \0 T4 H/ i0 C

  14. 0 [# N6 Z9 Z! X+ U
  15. //$exists:根据某个字段是否有设置值进行查询
    8 ~6 d* s3 E9 ^" G% x( p
  16. $cursor = $collection->find(['Hobby' => ['$exists' => false]]);//查找Hobby字段未设置值的文档0 N4 b8 V5 _; L$ d

  17. 4 |1 k4 {- q" V/ V
  18. //正则表达式查询
      {6 \* E# A$ M$ D4 w# {
  19. $cursor = $collection->find(['First Name' => new MongoRegex('/^Je/i')]);//查找First Name字段以Je开头的文档,忽略大小写差异
复制代码
使用MongoCursor类提供的其他函数:
  1. //排序:1升序,-1降序, }6 |( Q9 {$ J
  2. $cursor->sort(['Age' => 1]);
    - S0 z- s: F$ x, |! b& V
  3.   r0 L' A1 b+ E, x, p
  4. //忽略前n个匹配的文档
      c' s: p0 Q% N9 L2 x$ X
  5. $cursor->skip(1);; ]6 O, Y) H: B3 ?3 @/ i9 T

  6. 7 Y( k& S* h5 M
  7. //只返回前n个匹配的文档(limit()与skip()结合使用可实现数据分页功能)
    1 z  }3 R# Y) M% k3 c/ D
  8. $cursor->limit(1);
    5 F7 B0 M' l- L; O7 |6 S) `
  9. % Z5 a2 B9 F, {
  10. //匹配文档的总数
    2 H3 |3 b3 p, b5 b2 P- ~$ e
  11. $cursor->count();* z+ {* k  A' |3 ]( Q
  12. ; b" s5 p% ~* i  s" Y
  13. //指定查询索引5 l1 Z  n' @# O: w$ P7 E: t
  14. $cursor->hint(['Last Name' => -1]);//若索引不存在则会报错
复制代码
聚集查询:对数据进行分组统计
  1. //聚合查询:对数据进行分组统计
    , x+ G+ q* T* j% u7 `0 L
  2. $mongo = new MongoClient('mongodb://localhost:27017');5 Y! m) E6 ~# y- Z3 t+ o
  3. $db = $mongo->mf;& I3 F4 {, m& q+ k, v; s
  4. $collection = $db->friend;5 y7 c2 |1 o  u, Y. }
  5. $res = $collection->aggregate([
    # X( x8 o; m( |. s
  6.     '$group' => [
    0 H( k  M- j- E7 ^9 T
  7.         '_id' => '$Address.Country',//分组字段,注意要加上“$”,这里是根据数组字段某个元素值进行分组6 D# @& j' u. r( Q& E8 d8 Q( P6 A7 Z
  8.         'total' => ['$sum' => 1],//求总和,表示每匹配一个文档总和就加1
    0 H$ L# U, Q: {* C/ N$ x
  9.         'maxAge' => ['$max' => '$Age'],//分组中Age字段最大值8 j* ?8 j2 y# |2 {2 f* q
  10.         'minAge' => ['$min' => '$Age']//分组中Age字段最小值/ M) b: i; z1 D  i* I1 S
  11.     ]. A1 X# _7 Q7 e# u. }
  12. ]);
    ! e( P& M: r0 ^& g# q( @
  13. echo '<pre>';; {) [$ Q7 q0 e, y% L$ u7 q; j
  14. print_r($res);//返回一个数组,$ret['result']为数组,存放统计结果- G! [* f0 S7 q2 }
  15. & M' c! |# _8 f6 _
  16. " Z. n- Y+ B% y( V  J. G2 f! I" q& q
  17. //存在其它操作的聚合查询:多个操作之间执行先后顺序取决于它们位置的先后顺序
    " o* Y, u7 z- F; ?
  18. //聚合查询中的所有操作,包括'$group'在内,都是可选的。6 K" g( h  @3 U8 p
  19. $mongo = new MongoClient('mongodb://localhost:27017');4 m0 k! b) a; g2 R7 J' `# \* J; u3 b2 R
  20. $db = $mongo->mf;
    / f# o; L% d. S0 q& j7 b
  21. $collection = $db->friend;
    3 k1 }2 X- T$ I) B2 v
  22. $res = $collection->aggregate([4 m( O  }# o! ~' m0 D; d8 m+ B$ O# l  B1 _
  23.     [//过滤条件:只对符合条件的原始文档进行聚合运算,若是放在'$group'之后则是只返回符合条件的结果文档
    ! a( ~2 V0 s* c" K* R
  24.         '$match' => ['Age' => ['$gt' => 30]]& C/ z0 F% M# m) ?; G4 I
  25.     ],# v( v5 h1 H4 c; _9 w3 `
  26.     [//指定分组字段、统计字段) h/ Y7 I1 }3 P- Q& P5 o
  27.         '$group' => [
    9 `0 |" c! R9 ], T" ~# N- x
  28.             '_id' => '$Address.Country',+ M, G7 T, x% H. i( x  U) Q- m
  29.             'totalAge' => ['$sum' => '$Age']//计算各个分组Age字段总和
    . g0 z+ D# A$ @
  30.         ]
    3 A! U. _9 a: S. O* s9 k& M2 I
  31.     ],
    " d! M/ |$ z/ H* M6 Q0 @. q
  32.     //以下操作若是放在'$group'之前则在聚合前作用于原始文档,若放在'$group'之后则在聚合后作用于结果文档+ y5 w% P8 k1 i0 e2 ^
  33.     ['$unwind' => '$E-Mail'],//将包含有某个数组类型字段的文档拆分成多个文档,每个文档的同名字段的值为数组中的一个值。
    % E4 X* H. b$ _0 \
  34.     ['$project' => ['myAge' => '$Age', 'First Name' => '$First Name']],//指定返回字段,可以对字段进行重命名,格式:返回字段名 => $原来字段名) T! X5 e" z' A+ k2 I
  35.     ['$skip' => 2],//跳过指定数量的文档, r% e# ?5 X0 ?5 M" L* B: D* l8 D
  36.     ['$limit' => 2],//只返回指定数量的文档
    ; D2 b( E2 e4 y: r
  37.     ['$sort' => ['totalAge' => 1]]//排序
    8 L7 ?, b, h3 f
  38. ]);
    4 c8 t, U0 l' U: ]. Y+ ^
  39. echo '<pre>';2 ?/ u( t" w) t7 Z
  40. print_r($res);
复制代码
4 F8 A( |; T( p! }6 k
三、数据修改
  1. //update()8 G. C: {# X( |3 j; ~' D
  2. //参数1:更新条件,指定更新的目标对象。
    3 j9 e: h9 V& I/ W& g
  3. //参数2:指定用于更新匹配记录的对象。. P, B- e+ L$ K% d
  4. //参数3:扩展选项组。. P1 {% X, B5 o( |8 r2 K$ i! n
  5. //  upsert:若设置为true,当没有匹配文档的时候会创建一个新的文档。
      S: g/ W- A. L
  6. //  multiple:默认为false,若设置为true,匹配文档将全部被更新。5 [4 Y) C- ^6 q5 M) m. I
  7. //  fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。/ T; x! ~" O, ~* |" v+ R" ^
  8. //  w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作
    . g* I' R, N% T) Y. r1 n2 N
  9. //  j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。
    1 `( l9 e6 u3 [& n5 e" B9 o
  10. //  wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
    $ y5 Z% \% v, b
  11. //  timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
    4 I6 Q0 x, _% _+ W
  12. //注意:若不使用任何修改操作符,则匹配文档将直接被整个替换为参数2指定的对象。3 q  N1 Q5 l7 o7 E/ \+ v0 ~9 Z

  13. - b' A- j- g% {. m& _  g7 p
  14. //$inc:增加特定键的值,若字段不存在则新建字段并赋值
    7 M. `  j' C% ?+ _
  15. $mongo = new MongoClient('mongodb://localhost:27017');
    " O5 ^* I- Y- C  X) u) n3 i6 U5 Z
  16. $db = $mongo->mf;3 `8 j4 h) {9 C$ `" G$ }
  17. $collection = $db->friend;% d- q5 y5 P4 Y6 e: Z! a0 Q1 Y% }
  18. $res = $collection->update(['First Name' => 'Jet'], ['$inc' => ['Age' => 2]]);) Z8 U4 m( U- Q& v$ b
  19. echo '<pre>';
    - f$ G5 K* _% \- u: U; `9 Z5 W
  20. print_r($res);//$res['ok']=1表示修改成功,$res['nModified']表示修改的文档数量% N! `: l# m7 U  Q

  21. 8 |( o2 S7 Q2 I& |
  22. //$set:重置特定键的值,若字段不存在则新建字段并赋值
    9 [, N% R/ q/ g4 S$ T) D
  23. $res = $collection->update(['First Name' => 'Jet'], ['$set' => ['Hobby' => 'pingpong']]);
    & h, Z. e) a2 `7 ?+ `

  24. : P' U4 f$ C* [% l% ]7 i* L
  25. //$unset:删除字段
    9 q; i$ e" O0 G9 W6 K
  26. $res = $collection->update(['First Name' => 'Jet'], ['$unset' => ['Hobby' => 1]]);
    7 ]  {( F8 J4 K2 p4 u; A! t

  27. 5 ~' B; M% I" |
  28. //$rename:重命名字段,若字段不存在则不进行任何操作9 K- m$ ^, h4 a0 S1 X) b
  29. $res = $collection->update(['First Name' => 'Jet'], ['$rename' => ['Hobby' => 'hobby', 'Age' => 'age']]);6 o: i. b  P# Y) ?% q* c% P6 e
  30. //注意:如果文档中已经使用了指定名称的字段,则该字段将会被删除,然后再进行重命名操作。
    ; V2 V0 O, t9 f) a/ P7 q
  31. * ~$ Z7 `# B" e+ x) I5 O9 Y
  32. //$setOnInsert:设置了upsert为true,并且发生了插入操作的时候,将某个字段设置为特定的4 j; h- ?! g6 X
  33. $res = $collection->update(['First Name' => 'jet'], ['$setOnInsert' => ['lang' => 'English']], ['upsert' => true]);
    " Z: o0 \' s4 ?5 s' U, x
  34. 6 B& n. ^3 S& Y! D+ u  k% S
  35. //$push:向指定字段添加一个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错4 n- j: q; v/ `7 S; z5 l
  36. $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '123123@qq.com']]);5 t7 z: n  [- c" @7 ]

  37. ) s/ \& U/ G! D2 v; B/ V
  38. //$push:向指定字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错
    ( g6 [  Q7 b8 p3 p* \
  39. $res = $collection->update(['First Name' => 'Jet'], ['$pushAll' => ['E-Mail' => ['666@qq.com', '8888888@qq.com']]]);4 ]0 O- k& p# O& I+ d
  40. 4 Q" }2 ]: V7 h1 E
  41. //使用$push和$each向某个字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错& b+ h4 M* }( N% ^
  42. $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);5 `# X0 ^/ {* L) [/ J% K
  43. 2 h/ s' Y1 v/ q' @( Y; R
  44. //$addToSet:将数据添加到数组中(只在目标数组没有该数据的时候才将数据添加到数组中)
    . e1 L, L% V/ D+ [# c$ E; Q  j
  45. $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => '123123@qq.com']]);
    ( e* W7 B- K0 v, G, P& f
  46. $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);! _: w: T" A5 \+ H( |+ C
  47. 4 B; V3 g! _1 r% ?! E
  48. //$pop:从数组中删除一个元素,-1表示删除第一个元素,1表示删除最后一个元素(其实负数都删除第一个元素,0或正数都删除最后一个元素)
      C  u5 l0 Z9 s/ E3 o0 a' ]" Q0 k
  49. $res = $collection->update(['First Name' => 'Jet'], ['$pop' => ['E-Mail' => 1]]);  V! ^& d- I+ {0 E  y
  50. 3 Z, z; n  n% l% a$ @
  51. //$pull:删除数组中所有指定值5 |; X- [( W6 ?9 R9 ]
  52. $res = $collection->update(['First Name' => 'Jet'], ['$pull' => ['E-Mail' => '123123@qq.com']]);- Z" R: r; M7 R, Q# @: u; ]( b7 X

  53. ) U# R% B4 z" j8 S: e
  54. //$pullAll:删除数组中多个元素的所有值
    2 n7 R# [; m  F( J5 c. r
  55. $res = $collection->update(['First Name' => 'Jet'], ['$pullAll' => ['E-Mail' => ['123123@qq.com', '666@qq.com']]]);
复制代码
  1. //save()* `, f" s! M. m: z* R0 d; T4 C& e
  2. //参数1:希望保存的信息数组0 f0 D, m, D- W4 C9 N; Y5 X
  3. //参数2:扩展选项
    " r9 t5 ^, e: C9 n' D" U
  4. //  fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。0 h0 \- v1 M1 I; V* l
  5. //  w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作
    & Q, `" k  _! O
  6. //  j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。
    8 `; z% H* c) Y3 J. I
  7. //  wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
    * Y5 B8 [: p4 x# h
  8. //  timeout:指定客户端需要等待服务器响应的超时时间(毫秒)4 y. x' U  y+ w: ~
  9. //注意:若已存在则更新,若不存在则插入;更新时使用参数1指定的信息数组替换整个文档。
    9 a# {% H0 |6 g* k9 l9 Q4 H
  10. //若想更新则应该在参数1中指定_id键的值。
    5 q6 F4 f9 l0 Q/ g4 ~" S) |
  11. $mongo = new MongoClient('mongodb://localhost:27017');& [3 L8 O, b0 m1 `
  12. $db = $mongo->mf;7 I5 y1 c' B7 S2 m/ T* n' ~6 z
  13. $collection = $db->friend;
    1 M$ p% g2 B  Q4 H3 ?2 \
  14. $doc = [//定义一个文档,即一个数组
    * w; M1 S5 e$ M- O7 k# S
  15.     'First Name' => 'Jet',& ~- H" A! k8 i( w6 n+ I
  16.     'Last Name' => 'Wu',1 S; ]% Q$ r  D! i1 l1 s
  17.     'Age' => 26,
    0 y+ T5 s7 S- m6 @  l) S! P
  18.     'Phone' => '110',
    / y& Q8 P1 p, e. t9 j/ P( v9 j
  19.     'Address' => [+ ^5 d) [* {8 K# D6 l$ n5 S
  20.         'Country' => 'China',1 R  u3 F9 D: q5 Z( O4 J
  21.         'City' => 'Shen Zhen'
    / C0 V  Z# u- }: {9 t, Z7 o( w( z
  22.     ],
    2 n7 J1 o6 S4 x$ ]$ ~! Z. m1 o
  23.     'E-Mail' => [
    ; a% ~$ B9 N- _3 m5 Q. k" ^
  24.         '123456@qq.com',
    8 m+ p8 O- b/ q6 D
  25.         '666666@sina.com',
    " ~. B4 @# v) S. a% n
  26.         '8888888@qq.com',5 U2 K) n% Y1 j. h# i" J1 `
  27.         '77887788@qq.com'  e9 @& {% q0 O
  28.     ]
    * M5 }8 \: r8 `2 O. x9 m; d
  29. ];
    % j: y' i: a  L, r3 y" C. w( l* |
  30. $res = $collection->save($doc);& M' n% f0 h# n9 J! @
  31. echo '<pre>';/ L" h- G, P! t
  32. print_r($res);//$res['ok']=1表示操作成功,$res['updatedExisting']=1表示更新,$res['upserted']=1表示插入
    # Y  j- B9 ?8 k% H: t: b
  33. , W3 H% P& V& l: n, w8 H* g
复制代码
  1. //findAndModify()
    ) @1 e; w, S2 w) `  f
  2. //参数1:指定查询条件# o/ Q9 m2 J: X; P& T8 i% `
  3. //参数2:指定用于更新文档的信息
    . w  g! I" {3 r
  4. //参数3:可选,指定希望返回的字段
    2 b* z, Q0 C1 N* X: F% H' {
  5. //参数4:扩展选项
    8 r# `( H- z/ \
  6. //  sort:以特定顺序对匹配文档进行排序, i8 X# W: t4 S
  7. //  remove:若设置为true,第一个匹配文档将被删除
    - i7 t6 }! X& V+ P" W
  8. //  update:若设置为true,将在被选择的文档上执行更新操作
    3 ~; y* Y+ S* c0 M6 J6 k' p
  9. //  new:默认为false,若设置为true则返回更新后的文档,否则返回更新前的文档! [( t! K6 z! q0 H
  10. //  upsert:若设置为true,没有找到匹配文档的时候将插入一个新的文档
    + u/ F2 ]" j! y3 q% V) X
  11. $mongo = new MongoClient('mongodb://localhost:27017');3 n# R6 z/ |7 g" l6 C, y
  12. $db = $mongo->mf;! b$ n. [+ {$ j; B0 _5 n7 k% p
  13. $collection = $db->friend;5 V& n) Z  i+ r
  14. $res = $collection->findAndModify(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '111@qq.com']]);# F% c) A0 M8 h- `; H% A, }, i! B
  15. echo '<pre>';
    9 [! ~$ a. ?1 x! h. T+ A
  16. print_r($res);
复制代码
  
四、数据删除
  1. //remove()1 Z( U4 ~/ \# I& Y6 T( s8 R
  2. //参数1:查询条件# R7 o4 C( b8 H
  3. //参数2:扩展选项
    / R; {$ m* u& t8 H; C) C0 ?4 ?" g
  4. //  justOne:若设置为true,则最多只有一个匹配的文档将被删除; W; [( \6 H; g- w( a
  5. //  fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。
    7 w: j! G- y' q  t' M
  6. //  w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作
    8 X4 [3 B9 P0 L$ n. k# {9 ]
  7. //  j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。
    3 ^8 R% B- @$ `7 L" T; F  b7 u
  8. //  wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
    9 Q/ b3 d9 x" c7 J
  9. //  timeout:指定客户端需要等待服务器响应的超时时间(毫秒)* A$ e! L7 [8 G7 O8 k  W
  10. $mongo = new MongoClient('mongodb://localhost:27017');
    , }# F% k/ Q! f8 e, s
  11. $db = $mongo->mf;1 G: H9 O2 }- f. m0 c7 z4 y
  12. $collection = $db->friend;" x# b1 K) r7 D6 }$ P7 w9 C. L
  13. $res = $collection->remove(['First Name' => 'jet']);
    + q* x9 P- n; Z6 q$ z* e! Z
  14. echo '<pre>';- C# U! S7 O6 L
  15. print_r($res);//$res['n']表示删除了几个文档
复制代码

9 ]% K  t0 t0 k( p) X1 N" x, ?
以上是PHP7以前版本的MongoDB操作,下面简单介绍PHP7以后版本的操作。

( d4 }) c+ J$ @5 Y
-----------------------------------------------PHP7分隔线---------------------------------------------------------------------

" Q; q5 q. W/ s% y% Q2 Z9 l+ o
数据插入:
  1. $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');3 z$ Y* O5 L6 R
  2. $bulk = new MongoDB\Driver\BulkWrite;  G7 k$ m: `0 _1 \0 S0 A
  3. $bulk->insert(['name' => 'JetWu5', 'age' => 26]);  e) N% c, y1 ~* |  f, y
  4. $bulk->insert(['name' => 'JetWu6', 'age' => 26]);
    & |  q; {; Z5 E* k9 E  [& W
  5. ( b! F) {0 R) C  `& P) I$ G( ?' s
  6. $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
    ; i5 a2 u: F* _# p
  7. $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
    1 J& b" W8 _+ R# e
  8. echo '<pre>';
    $ c( w6 t4 f2 @5 T/ ~
  9. print_r($res);
复制代码
1 j. u; ?! M; `
数据查询:
  1. $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');3 i  J: d# p. v$ H9 u4 d
  2. $query = new MongoDB\Driver\Query(['age' => 24], ['sort' => ['age' => 1]]);7 H, `% T7 v7 Z" K' J0 U
  3. $cursor = $manager->executeQuery('wjt.friend', $query);
    ( b* \' ?3 ~7 N9 d! \
  4.   [0 W2 x/ z# b6 A4 n" B
  5. $data = [];% p2 n+ Y2 F3 f6 H) X6 z
  6. foreach($cursor as $doc) {
    0 u; K$ W9 H' l2 l) B2 ~! n
  7.     $data[] = $doc;# s, p' M6 q3 M9 B$ Q
  8. }& i$ k1 i+ D+ o$ H/ y2 D4 g
  9. echo '<pre>';
    1 u9 J( ^. c- u  C0 E* g
  10. print_r($data);
复制代码
  
数据修改:
  1. $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
    / n! |7 z4 u* I7 ]' d
  2. $bulk = new MongoDB\Driver\BulkWrite;
    0 D1 a1 {2 e( j& b  }6 ]0 ^) G
  3. $bulk->update(1 Z# p3 n3 B0 _# v! e* M5 T: `; G
  4.     ['name' => 'JetWu5'],5 j9 x. {9 F; o8 X& h
  5.     ['$set' => ['age' => 30, 'promise' => 'always smile!']]
    7 d1 d% D7 O. j2 D6 {
  6. );9 i# _& [# ^" r1 N
  7. $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认1 {4 H$ W: S$ z+ X0 g$ y: F7 U1 J9 Z6 D
  8. $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);( P5 B& y3 t# w3 N
  9. echo '<pre>';8 u3 N  P$ r; s
  10. print_r($res);
复制代码
  
数据删除:
  1. $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');' K0 C% ~' n3 k6 L: I+ a- p
  2. $bulk = new MongoDB\Driver\BulkWrite;0 n4 J0 v' `1 |9 i7 y. S' v
  3. $bulk->delete(['name' => 'JetWu3']);
    + R- h8 |/ ^4 h2 b; P: t
  4. $bulk->delete(['name' => 'JetWu4']);! W! a7 Z% l9 h0 U$ s
  5. $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
    : s2 N1 X0 \" w* D5 x4 M
  6. $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);( I# x  z" y% ^4 D, X
  7. echo '<pre>';1 Q% E5 ^- a( N  b/ t( A
  8. print_r($res);
复制代码

7 K$ I# a( N% X8 m- |1 e& f8 p# A- T. i. |/ F0 `8 I

# D$ Y7 C* z, u/ n/ x9 Z6 |

5 A0 ]/ [7 ]# n( h( i5 ]  x7 ~" l* `- P' [% v
分享到:  QQ好友和群QQ好友和群 QQ空间QQ空间 腾讯微博腾讯微博 腾讯朋友腾讯朋友
收藏收藏 分享分享 支持支持 反对反对
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

GMT+8, 2026-6-20 04:19 , Processed in 0.069478 second(s), 20 queries .

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