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

QQ登录

只需一步,快速开始

 找回密码
 立即注册

QQ登录

只需一步,快速开始

查看: 13076|回复: 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()
    3 n" K7 ?, J$ {- {8 M
  2. //参数1:一个数组或对象
    $ W) x# W* ?. g3 I, h: n
  3. //参数2:扩展选项. V. J3 j1 ^; z
  4. //  fsync:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入硬盘
    ; G5 Y# i# `, C) y
  5. //  j:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入日志
    $ W0 S: d4 W0 u. M) G* x" ]( C
  6. //  w:默认为1,写操作会被(主)服务器确认,若为0则将不会得到确认,使用复制集时设置为n用于确保主服务器将数据修改成功复制到n个节点后再确认
    # r* s& B! G0 }. h  T* ~% l1 R
  7. //  wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间1 U4 O0 M1 g* M9 D1 m
  8. //  timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
    / V) [/ e& P/ C( i
  9. $mongo = new MongoClient('mongodb://localhost:27017');. G6 H% l$ q$ |; e  M5 E6 K1 E" D* u
  10. $db = $mongo->mf;//选择数据库8 p; Q4 A. `; R7 y
  11. $collection = $db->friend;//选择文档集合
    8 k$ i' n- r2 ]7 c
  12. $doc = [//定义一个文档,即一个数组
    . F2 V( v9 W5 n9 O2 K+ ?
  13.     'First Name' => 'Jet',
    / t/ c7 b, D- Z8 D
  14.     'Last Name' => 'Wu',8 P$ v: m+ o- t+ H3 h  l1 c' O% j
  15.     'Age' => 26,
    ! w  L9 X+ K/ c
  16.     'Phone' => '110',
    , g+ k# R" J# P$ q' O6 F6 M: [! x
  17.     'Address' => [
    / X+ G! b+ c3 ?, D; N3 Q4 r* T0 k
  18.         'Country' => 'China',
    , W# ^; ]7 o& \! R' ?
  19.         'City' => 'Shen Zhen'/ B+ m2 `# R! n, G3 U8 m
  20.     ],
    / ?  W2 f8 Y0 ^  O- {3 Z  Q
  21.     'E-Mail' => [4 Q" b& H; _8 C" _" k
  22.         '123456@qq.com',* ?& \! ]* |3 e9 d3 i4 i! J
  23.         '666666@sina.com',
    6 `. u, o1 |* o- J; Q) V
  24.         '8888888@qq.com',+ U+ o, b, e" o4 O
  25.         '77887788@qq.com'5 r6 Q' x. F/ u5 K
  26.     ]$ c0 F$ |3 z* ?, \; ?$ r: u( X+ Z
  27. ];; Y9 P$ K, a9 [3 _; L9 f" X" j
  28. $res = $collection->insert($doc);//向集合中插入一个文档
    + r/ o  w7 w+ M8 i$ g
  29. echo '<pre>';( ]6 L* s; i* {3 Y; _
  30. print_r($res);//$res['ok']=1表示插入成功
复制代码
二、数据查询
1. 查询单个文档:
  1. //findOne()
    ) Z( x$ A# ?9 k5 b' ?( u
  2. //参数1:搜索条件. z' J; r1 w  }, v$ d" \
  3. //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非在第二个参数显式加入'_id'=>false。不设置则返回所有字段# d' U5 ]+ Q& p) k
  4. $mongo = new MongoClient('mongodb://localhost:27017');
    - O) L2 `8 Z- d4 j  R9 K
  5. $db = $mongo->mf;: J( D) [4 A6 B5 E% m
  6. $collection = $db->friend;5 M+ U( M' b  T7 u. W$ p4 i
  7. $one = $collection->findOne(['First Name' => 'Jet']);0 _) t: N+ m& _% e
  8. echo '<pre>';
    - L; X" l  M; A, z
  9. print_r($one);//返回一个数组,查不到数据则返回NULL
复制代码
2. 查询多个文档:
  1. //find()
    2 Y  k, d, |' f9 V* }
  2. //参数1:搜索条件
    # t; r  b6 ^: \: L6 A0 C
  3. //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非显式设置为false不返回。不设置则返回所有字段
    # i  m! {; [. q2 z+ u1 `
  4. $mongo = new MongoClient('mongodb://localhost:27017');
    1 T' ~' e+ Q  {( F3 o
  5. $db = $mongo->mf;* P6 H; G4 V- \7 S- g
  6. $collection = $db->friend;
    " q& Z) A" Y" V4 v+ c
  7. $cursor = $collection->find(['Address.Country' => 'China']);//使用点操作符查找数组元素2 _: d& q( W6 c, _7 B% {
  8. echo '<pre>';
    ( S5 T3 T0 V" A7 Q* F) [
  9. while($doc = $cursor->getNext()) {//循环读取每个匹配的文档
    5 ?, y/ c( k3 F5 x8 e/ M% f2 w" Y" o
  10.     print_r($doc);
    % K8 x9 P. v; X. f* ^, K: G
  11. }
复制代码
使用各种条件操作符定义查询:
  1. //mongodb分别使用$lt(小于)、$lte(下雨等于)、$eq(等于)、$gte(大于等于)、$gt(大于)、$ne(不等于)表示<、<=、=、>=、>、<>,用于整数字段查询
    - a4 A7 `1 E5 N* ]; X( Y0 D) u4 ?9 o
  2. $mongo = new MongoClient('mongodb://localhost:27017');' s- Z4 h! J. ^  ]/ i
  3. $db = $mongo->mf;/ |9 R. I0 o0 U" c/ i4 i$ U2 Z
  4. $collection = $db->friend;
    ) @. j7 L; _8 z! V0 Q8 A
  5. $cursor = $collection->find(['Age' => ['$gt' => 30]]);) }' X: Z' ~' n% H+ w5 J
  6. echo '<pre>';
    ! _( p, I" S8 ~
  7. while($doc = $cursor->getNext()) {
    0 |  Y3 U& R1 u
  8.     print_r($doc);
    : z2 S: f0 x% Q! o' U
  9. }
复制代码
  //查询某个字段的所有不重复的值+ }& c4 r9 v$ A6 |! q
  $res = $collection->distinct('Age');
  1. //$in:匹配多个值中任意一个
    2 B7 f# r8 O4 x9 e6 @
  2. $cursor = $collection->find(['Address.Country' => ['$in' => ['China', 'USA']]]);" T% ^0 ^2 T, l, W' G3 y

  3. ! H' [2 p- |& V, i
  4. //$all:匹配多个值中所有值(用于数组字段查询)
    # R# u" q% I5 A8 P( X( O" J% f
  5. $cursor = $collection->find(['E-Mail' => ['$all' => ['123456@qq.com', '77887788@qq.com']]]);2 i  p2 A* K+ i8 d7 ?, F4 [8 S/ L
  6. ) @* X7 E9 d5 q. H5 s
  7. //$or:或查询
    7 x& p) K7 _- T. U9 i
  8. $cursor = $collection->find(['$or' => [['First Name' => 'Jet'], ['Address.Country' => 'USA']]]);1 r( B/ Z. C; L  {2 m; G" K3 E

  9. ' O! g. S1 ?5 H0 Q
  10. //$slice:获取数组字段中指定数目的元素,位于find()函数第二个参数中
    - m) X5 z7 C5 C  P( o
  11. $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => 2]]);//只返回前两个email* y. ^0 ^8 g4 M- ~7 _1 ]3 l
  12. $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => -2]]);//只返回最后两个email$ _. T! V3 N" c& F6 R2 l' {
  13. $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => [1, 2]]]);//忽略第一个,返回接下来两个
    + l# r2 f+ S+ P4 Q: L
  14. , O# t0 i) b8 Q2 ]
  15. //$exists:根据某个字段是否有设置值进行查询) h5 T) E% o6 ], E  n
  16. $cursor = $collection->find(['Hobby' => ['$exists' => false]]);//查找Hobby字段未设置值的文档0 ]' h1 |5 {4 J: G2 l
  17. ( `. J5 \3 Z/ i) I4 [* q
  18. //正则表达式查询; e. T; \6 i1 m4 a2 C! H: D8 _
  19. $cursor = $collection->find(['First Name' => new MongoRegex('/^Je/i')]);//查找First Name字段以Je开头的文档,忽略大小写差异
复制代码
使用MongoCursor类提供的其他函数:
  1. //排序:1升序,-1降序* K2 A: d3 x  C' f5 M' m3 Q
  2. $cursor->sort(['Age' => 1]);
    ( M% r# T1 U2 b0 x: L

  3. 3 Q0 Z9 q4 j% `; @. }0 u
  4. //忽略前n个匹配的文档
    , K, z  c4 g( y8 B
  5. $cursor->skip(1);
    0 p$ ]+ I9 q2 w: U9 z8 ?, u
  6. ; D& Y3 z5 g) r& E0 r: o
  7. //只返回前n个匹配的文档(limit()与skip()结合使用可实现数据分页功能)
    9 V* U9 l$ v7 P$ Q) O0 V
  8. $cursor->limit(1);
    5 Y, V5 o) |, g! h  D! w  C
  9. 3 t1 k! o- L: y+ }: ^" l/ r
  10. //匹配文档的总数, g+ Q- @+ c9 z8 I
  11. $cursor->count();# d# M6 v" {9 H* J

  12. $ p' v7 k9 c0 C! J: Y
  13. //指定查询索引
    # z+ C( v! K0 b- x% \' x0 W4 P; j
  14. $cursor->hint(['Last Name' => -1]);//若索引不存在则会报错
复制代码
聚集查询:对数据进行分组统计
  1. //聚合查询:对数据进行分组统计
    ! R* k* |( |. b2 Q1 K4 E2 d
  2. $mongo = new MongoClient('mongodb://localhost:27017');
    " y5 X5 N5 ?8 `0 z9 O- N
  3. $db = $mongo->mf;: `( v( z& h, n8 Q
  4. $collection = $db->friend;
    " L8 S6 G3 p, D* @, }: k* c( Y0 q
  5. $res = $collection->aggregate([
    6 H' }6 U6 J, @5 a& f) A& |5 E$ D
  6.     '$group' => [
    + D9 q5 K+ F6 A6 e
  7.         '_id' => '$Address.Country',//分组字段,注意要加上“$”,这里是根据数组字段某个元素值进行分组8 C# e9 x2 U$ L+ ]+ j0 e( b+ _2 ?
  8.         'total' => ['$sum' => 1],//求总和,表示每匹配一个文档总和就加1
    % |: e  K4 g0 Z( ~
  9.         'maxAge' => ['$max' => '$Age'],//分组中Age字段最大值6 o( B  ]- E0 A7 ^3 u
  10.         'minAge' => ['$min' => '$Age']//分组中Age字段最小值6 H# J6 g5 `7 X
  11.     ]
    ' u" S& s1 [  u6 f, Z. l. X7 X$ s
  12. ]);
    # R: V: I4 c4 l8 e0 g+ W
  13. echo '<pre>';/ \+ C4 h5 a+ t2 c% b
  14. print_r($res);//返回一个数组,$ret['result']为数组,存放统计结果: G/ d0 L  _2 b' J: W9 P

  15. , A6 |$ R# P$ o; U
  16. : @1 t- \8 R; T/ ~: f9 h
  17. //存在其它操作的聚合查询:多个操作之间执行先后顺序取决于它们位置的先后顺序
    : [6 _3 t. e( g
  18. //聚合查询中的所有操作,包括'$group'在内,都是可选的。
    / m  t2 n/ ^! Q& P7 M% L( X
  19. $mongo = new MongoClient('mongodb://localhost:27017');" T' d8 }* x& i# P
  20. $db = $mongo->mf;2 H. g% Q1 j$ m8 N
  21. $collection = $db->friend;( I' y: T5 g) z
  22. $res = $collection->aggregate([
    9 |8 E/ Y. T6 t. ~, Z
  23.     [//过滤条件:只对符合条件的原始文档进行聚合运算,若是放在'$group'之后则是只返回符合条件的结果文档0 Z% A( k7 P( D4 n- V* f7 k# U" A3 p
  24.         '$match' => ['Age' => ['$gt' => 30]]7 [, _* L' s: ~, n' j
  25.     ],! Z5 T! y: l* d: d$ x
  26.     [//指定分组字段、统计字段
    # @3 G- b  O/ l, n8 K% S# I
  27.         '$group' => [
    * v$ R# F1 m. ?- @: U8 s9 p
  28.             '_id' => '$Address.Country',9 t, y2 `) N+ s* e4 O0 K3 q
  29.             'totalAge' => ['$sum' => '$Age']//计算各个分组Age字段总和$ S3 P. B8 q4 \# N5 L8 E0 e
  30.         ]; t& t9 m9 y' z9 A
  31.     ],, G  j$ Q# L0 I. O
  32.     //以下操作若是放在'$group'之前则在聚合前作用于原始文档,若放在'$group'之后则在聚合后作用于结果文档
    ( x6 t) ^+ O3 j+ r9 B3 N
  33.     ['$unwind' => '$E-Mail'],//将包含有某个数组类型字段的文档拆分成多个文档,每个文档的同名字段的值为数组中的一个值。+ r, ~  u  V0 y& Q
  34.     ['$project' => ['myAge' => '$Age', 'First Name' => '$First Name']],//指定返回字段,可以对字段进行重命名,格式:返回字段名 => $原来字段名
    ( x$ a5 p. I2 t2 l/ M
  35.     ['$skip' => 2],//跳过指定数量的文档
    2 \( _$ F+ F  R$ ]8 {* [
  36.     ['$limit' => 2],//只返回指定数量的文档
    6 K0 }1 o! f$ T# w% ^
  37.     ['$sort' => ['totalAge' => 1]]//排序! ^% N% [0 \: C3 U3 z  W5 k2 u
  38. ]);$ d0 [4 R8 E; l, K: M
  39. echo '<pre>';7 H" ?3 q: M" D5 s  q
  40. print_r($res);
复制代码
1 w" H5 v+ ^7 `1 {
三、数据修改
  1. //update()
    2 y: p- s# i1 M) w
  2. //参数1:更新条件,指定更新的目标对象。
      F4 l$ p$ _: R& Q
  3. //参数2:指定用于更新匹配记录的对象。
    ! B+ I( O* f# ?: J) P4 a  S
  4. //参数3:扩展选项组。% Y# m+ C; M' Q9 \
  5. //  upsert:若设置为true,当没有匹配文档的时候会创建一个新的文档。# s* O1 e) s( i4 a* p) ?7 G
  6. //  multiple:默认为false,若设置为true,匹配文档将全部被更新。# n9 {+ i8 U/ H2 K
  7. //  fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。5 L6 X  {; P4 l6 }8 M! I1 D
  8. //  w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作, c& _- x- O- u) `. x/ ^% ?
  9. //  j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。3 X, u4 K4 ^2 s0 W3 B7 n' L. t2 l/ ?
  10. //  wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
    3 {! H# q" ~/ v9 a5 x7 M. y7 k5 k
  11. //  timeout:指定客户端需要等待服务器响应的超时时间(毫秒)- _1 P' ?8 K9 B3 ~; K: d
  12. //注意:若不使用任何修改操作符,则匹配文档将直接被整个替换为参数2指定的对象。
    " k# E- p. a3 J. I) y& V% ?
  13. 4 i5 N6 E+ x5 k3 `% [, o7 z4 _
  14. //$inc:增加特定键的值,若字段不存在则新建字段并赋值: d7 T1 d  V& d. b; u
  15. $mongo = new MongoClient('mongodb://localhost:27017');
      g$ d$ P- \% d) |& A
  16. $db = $mongo->mf;
    ' b( l! Z, d% w% z' b$ c
  17. $collection = $db->friend;
    " Y; ]: t- d/ a
  18. $res = $collection->update(['First Name' => 'Jet'], ['$inc' => ['Age' => 2]]);+ k( N# v4 ]/ U2 t' _
  19. echo '<pre>';
    3 Y: ]8 J- B1 U( `
  20. print_r($res);//$res['ok']=1表示修改成功,$res['nModified']表示修改的文档数量
    ) P4 o7 l5 R& E4 Z7 {2 Z' V2 ^$ x

  21. ( [8 P" P& d0 F) R+ D
  22. //$set:重置特定键的值,若字段不存在则新建字段并赋值4 M: \1 Q* ^. Q" x2 h/ @/ |1 V  Z4 B
  23. $res = $collection->update(['First Name' => 'Jet'], ['$set' => ['Hobby' => 'pingpong']]);
    . k5 [8 c3 o# }, r+ l' P4 r/ ^
  24. 2 f3 V" j( k1 c0 ~  Q7 S7 I2 ^" O
  25. //$unset:删除字段. ^/ o# M1 O! c# u1 U* R+ X( a1 m
  26. $res = $collection->update(['First Name' => 'Jet'], ['$unset' => ['Hobby' => 1]]);
    , F$ M+ F2 V4 H! c: Z6 ~
  27. ' w3 h8 Z4 y3 \  v' c% h# u
  28. //$rename:重命名字段,若字段不存在则不进行任何操作
    & d% _5 ]( F; ?3 Q4 K: [2 N
  29. $res = $collection->update(['First Name' => 'Jet'], ['$rename' => ['Hobby' => 'hobby', 'Age' => 'age']]);. C2 T+ r  W( d# A- c1 V
  30. //注意:如果文档中已经使用了指定名称的字段,则该字段将会被删除,然后再进行重命名操作。
    ; e9 m/ k& I. Q2 {" e/ R+ E
  31. % n! D$ ?) U% u4 ^: [6 H
  32. //$setOnInsert:设置了upsert为true,并且发生了插入操作的时候,将某个字段设置为特定的
    ; |( n- f$ o5 b4 B/ Q3 s+ m
  33. $res = $collection->update(['First Name' => 'jet'], ['$setOnInsert' => ['lang' => 'English']], ['upsert' => true]);$ r4 A2 q) z6 }3 d" e

  34. ' P: U4 i! |1 B6 s0 x0 i$ k$ ]% ]  M
  35. //$push:向指定字段添加一个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错
    4 ]0 @4 }  K+ g4 j# [
  36. $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '123123@qq.com']]);
    . e# Q8 A) r) w% X+ k
  37. / r: {) M% p" K# J' Z+ o$ I3 ]
  38. //$push:向指定字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错. b# d8 X+ U7 \& `2 Z0 U  V9 a
  39. $res = $collection->update(['First Name' => 'Jet'], ['$pushAll' => ['E-Mail' => ['666@qq.com', '8888888@qq.com']]]);
    , e: d. E3 F0 v- {7 z: {

  40. ) u' s& S( p. @1 n& S
  41. //使用$push和$each向某个字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错
    % p/ S! o" w" y. q
  42. $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);9 a- a! I* T( H  R' X1 X! m4 o
  43. * O! D, c( w& G+ Y# x; B4 [; s1 V. x
  44. //$addToSet:将数据添加到数组中(只在目标数组没有该数据的时候才将数据添加到数组中)
    + w& d* R* c0 g5 z$ Q4 j1 p
  45. $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => '123123@qq.com']]);; U+ ?/ b' U; a  L
  46. $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);
    5 c9 l6 ^7 l$ H4 R, P1 m- b! g
  47. / K. j7 O3 z6 {+ P, L! t
  48. //$pop:从数组中删除一个元素,-1表示删除第一个元素,1表示删除最后一个元素(其实负数都删除第一个元素,0或正数都删除最后一个元素)
    4 h. s& ]: j1 e( [0 N! Q
  49. $res = $collection->update(['First Name' => 'Jet'], ['$pop' => ['E-Mail' => 1]]);+ o+ x! K# u' g# N

  50. ( a# Y) T' {0 W! n  @" p
  51. //$pull:删除数组中所有指定值
    & v+ i1 y9 v. L, S" a) \3 q
  52. $res = $collection->update(['First Name' => 'Jet'], ['$pull' => ['E-Mail' => '123123@qq.com']]);1 v5 z1 G) r, y, n1 l8 m: ]

  53. + m( p+ r. z4 [( z2 {) u9 e
  54. //$pullAll:删除数组中多个元素的所有值
    / v1 K: _; z; c% z* J* m
  55. $res = $collection->update(['First Name' => 'Jet'], ['$pullAll' => ['E-Mail' => ['123123@qq.com', '666@qq.com']]]);
复制代码
  1. //save()
    * u/ y# C( y8 f# E& S- t8 {1 l
  2. //参数1:希望保存的信息数组
      t1 t  C1 B0 |4 O. b$ N7 L6 ^
  3. //参数2:扩展选项
    , Y; S5 y  C+ @
  4. //  fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。' _' C, F& d" t* |8 z
  5. //  w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作
    0 q* v+ J' S% q* Z* y$ P# p
  6. //  j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。
    - K6 u, p6 P/ l3 p2 w, r
  7. //  wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
    ! S# u7 Y# d: X% s$ g7 _( I4 T0 [
  8. //  timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
    % B( c) k! F) O0 V- g, X  p
  9. //注意:若已存在则更新,若不存在则插入;更新时使用参数1指定的信息数组替换整个文档。/ q, G+ P4 t) g  Z9 b0 Q2 g, ]
  10. //若想更新则应该在参数1中指定_id键的值。
    0 a# M' A# p" n
  11. $mongo = new MongoClient('mongodb://localhost:27017');7 P/ ?$ c  v, l  `3 c" y4 ^4 l
  12. $db = $mongo->mf;
    ) ^) m$ k& n  T( M3 [! L: L
  13. $collection = $db->friend;
    . t+ {9 M2 |; F) Y5 t# a
  14. $doc = [//定义一个文档,即一个数组  H# l% _* S0 I
  15.     'First Name' => 'Jet',
    ; j6 D& c9 f8 I
  16.     'Last Name' => 'Wu',, F" e: K& X2 T! ^) ?7 X! ?
  17.     'Age' => 26,. O( D- T# d  n. G# c
  18.     'Phone' => '110',
    : Z+ j( C" B$ n6 Z9 ^8 V6 }3 u4 k
  19.     'Address' => [
    5 C1 `3 J$ @# }/ H7 z
  20.         'Country' => 'China',
    & }$ n& ]+ N% k: m
  21.         'City' => 'Shen Zhen'
    ) E* O+ \3 _( J
  22.     ],0 W1 f& r' j/ v# h' }* b
  23.     'E-Mail' => [$ ]; o& {) e( M, D- k
  24.         '123456@qq.com',& k. {$ ]4 ?5 m2 o- n
  25.         '666666@sina.com',$ P* W( {) i3 q
  26.         '8888888@qq.com',
    $ v/ z# \- t) `9 p& L2 Q; j: I
  27.         '77887788@qq.com'
    7 |  G/ u! e, b: m- ?+ h8 T* i
  28.     ]0 O7 A& _/ \0 k! z1 e6 C
  29. ];8 M; a) r+ ]- c! t& S) S
  30. $res = $collection->save($doc);
    1 E. t( ^9 x8 ]1 g$ @' N3 e
  31. echo '<pre>';
    * t) q7 \& B6 a$ u/ u: r
  32. print_r($res);//$res['ok']=1表示操作成功,$res['updatedExisting']=1表示更新,$res['upserted']=1表示插入
      J9 ^9 Y( U* n1 C% N8 l6 r( g

  33. ( `( x# a9 ~7 n  y  \- R/ R
复制代码
  1. //findAndModify()) L' Y) ^2 }+ {4 K3 C7 k
  2. //参数1:指定查询条件
    6 l$ ?  P# N0 b4 P/ ]5 E
  3. //参数2:指定用于更新文档的信息
    . l! l8 E9 G4 P9 q0 R% x
  4. //参数3:可选,指定希望返回的字段
    4 o( J3 p1 H& O/ L; f2 y
  5. //参数4:扩展选项, g9 y* C9 w' k* r
  6. //  sort:以特定顺序对匹配文档进行排序$ q- x' V5 ~! G
  7. //  remove:若设置为true,第一个匹配文档将被删除! |6 I7 N; ]2 H; Y7 X$ T) h
  8. //  update:若设置为true,将在被选择的文档上执行更新操作& p, t% T" P# w* `
  9. //  new:默认为false,若设置为true则返回更新后的文档,否则返回更新前的文档  B7 d6 P# V0 m0 b
  10. //  upsert:若设置为true,没有找到匹配文档的时候将插入一个新的文档) ^# J2 P8 _% g! x7 ^. e, s
  11. $mongo = new MongoClient('mongodb://localhost:27017');2 b9 V  i% k8 T+ r: t! i% d
  12. $db = $mongo->mf;) o/ x) G7 w. W# Q
  13. $collection = $db->friend;
    & ?; {, i! O( A% j
  14. $res = $collection->findAndModify(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '111@qq.com']]);
    , I# r6 b& R" p3 f- i1 ?' n$ h
  15. echo '<pre>';
    % I0 K+ b$ [0 M$ h
  16. print_r($res);
复制代码
  
四、数据删除
  1. //remove()
      Q% x, I4 T, x$ L" |" V
  2. //参数1:查询条件  T  T0 F) I2 H4 N, a2 P
  3. //参数2:扩展选项8 O* Y' l& K5 o. A$ k. d
  4. //  justOne:若设置为true,则最多只有一个匹配的文档将被删除6 X! Z( k* n% K4 m2 A3 Z. }: b' T5 d1 E
  5. //  fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。4 a$ }% R8 m6 E1 }5 f5 `
  6. //  w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作2 m. Q# p3 O. ^) b' Q
  7. //  j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。
    : q( p  m& i3 r  T7 t$ i6 m# L
  8. //  wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
    ' J/ M* j  ~# J/ _" v
  9. //  timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
    - d0 N7 l2 U" v7 W
  10. $mongo = new MongoClient('mongodb://localhost:27017');* n" T6 M& \( z  R: V" x( T) d0 V- `
  11. $db = $mongo->mf;
    ! I6 x+ p. S  ?* Y
  12. $collection = $db->friend;
    1 U( @/ A* Y& T2 z* K) l
  13. $res = $collection->remove(['First Name' => 'jet']);2 p, V, H. w, ^) D) \5 C+ I
  14. echo '<pre>';
    * ~+ [% [3 W* z9 h! K
  15. print_r($res);//$res['n']表示删除了几个文档
复制代码

8 [: x+ {& T# U" F! s, S
以上是PHP7以前版本的MongoDB操作,下面简单介绍PHP7以后版本的操作。
) C- ^+ C; z3 k# }
-----------------------------------------------PHP7分隔线---------------------------------------------------------------------

- u, E" F1 _8 a# A  N+ w
数据插入:
  1. $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');2 w+ r* L0 L( t5 S3 @
  2. $bulk = new MongoDB\Driver\BulkWrite;3 y4 X" i3 ~- {% W
  3. $bulk->insert(['name' => 'JetWu5', 'age' => 26]);1 ~9 ]6 D+ F2 i) L. k/ t
  4. $bulk->insert(['name' => 'JetWu6', 'age' => 26]);# w% s3 Z' g, ~& u
  5. & m8 }; f- [& F. @3 |
  6. $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
    ' f6 k" H# {7 W) q" X- s
  7. $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
    ) ~$ D  i, ^, q7 E
  8. echo '<pre>';# c# ^& C3 \2 L5 H: D* s
  9. print_r($res);
复制代码
5 X" A! r, X- f! ^8 J% x1 q/ T& j
数据查询:
  1. $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');% O7 }' s6 {6 l, a! B9 _3 z- \
  2. $query = new MongoDB\Driver\Query(['age' => 24], ['sort' => ['age' => 1]]);
    * \* u" x% p# X; e+ {
  3. $cursor = $manager->executeQuery('wjt.friend', $query);
    ! R: O# ?% f3 Y4 C8 t
  4. 9 H5 U/ e' i/ H9 O& T4 ~, x) l2 f$ |
  5. $data = [];+ J& d: k% x' h% n9 V0 x. F
  6. foreach($cursor as $doc) {. j% G" r& P) p! A4 M: M6 a  E: D8 K( ~( V
  7.     $data[] = $doc;5 L- N+ R! l# m4 T6 [/ E3 p6 _
  8. }
      t# I% f& o& \& u
  9. echo '<pre>';7 ^- m$ l* s7 L; h6 h9 r; M
  10. print_r($data);
复制代码
  
数据修改:
  1. $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
    . Z3 h5 Y/ O1 R0 v; V
  2. $bulk = new MongoDB\Driver\BulkWrite;
    9 l6 [1 L& N4 B% S
  3. $bulk->update(
    0 [; C+ A) J3 T" Y
  4.     ['name' => 'JetWu5'],
    ( X6 J3 M2 C# W2 T1 E. }; \+ `1 {
  5.     ['$set' => ['age' => 30, 'promise' => 'always smile!']]0 R' h$ W0 V4 L! `7 Q2 A2 x5 h
  6. );
    4 w( B  K* ]: l$ V$ O
  7. $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认2 f6 u. ~' d" I3 G5 `6 r% }
  8. $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);6 y$ E+ M' q0 r& u. e
  9. echo '<pre>';
    ; h& }: T  ~) {" H4 Z
  10. print_r($res);
复制代码
  
数据删除:
  1. $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
    0 h! ?8 B2 n+ R7 u3 M0 B0 J( J' t4 u3 e2 Q
  2. $bulk = new MongoDB\Driver\BulkWrite;) H/ R5 z! T9 _! D+ l. i3 Q2 L) e
  3. $bulk->delete(['name' => 'JetWu3']);" x3 M1 `0 K" t3 [5 k( L- h
  4. $bulk->delete(['name' => 'JetWu4']);; ?. F/ a4 Y9 _" e8 G8 A
  5. $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
    2 P- E+ Q" ?& R' t0 ~/ o
  6. $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);2 M2 G8 X# {; D* B5 ^& Y% R
  7. echo '<pre>';
    : ]1 `- ?' w3 K8 K
  8. print_r($res);
复制代码

# v6 q8 y7 c$ K9 c% I$ R9 u- {( x; W+ F" o. }# p
* P- f. m- Q# ^  U
( R9 y; o- e  ]! @, X6 o) ~3 i( G2 b
0 I/ |, _: D3 o$ d3 I( r
分享到:  QQ好友和群QQ好友和群 QQ空间QQ空间 腾讯微博腾讯微博 腾讯朋友腾讯朋友
收藏收藏 分享分享 支持支持 反对反对
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

GMT+8, 2026-6-20 04:06 , Processed in 0.059727 second(s), 22 queries .

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