MongoDB的PHP驱动提供了一些核心类来操作MongoDB,总的来说MongoDB命令行中有的功能,它都可以实现,而且参数的格式基本相似。PHP7以前的版本和PHP7之后的版本对MongoDB的操作有所不同,本文主要以PHP7以前版本为例讲解PHP对MongoDB的各种操作,最后再简单说明一下PHP7以后版本对MongoDB的操作。 一、数据插入 - //insert()
5 s `# b$ h c& e2 D5 A6 ~6 F - //参数1:一个数组或对象
1 y+ ]- O" `" M% T& X - //参数2:扩展选项
: J( A& I3 Z( k$ D - // fsync:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入硬盘
! m3 @" e' I! @+ K1 v1 g& I1 [ - // j:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入日志
& i2 ?) ]: `: a% D+ v3 B( q+ z o - // w:默认为1,写操作会被(主)服务器确认,若为0则将不会得到确认,使用复制集时设置为n用于确保主服务器将数据修改成功复制到n个节点后再确认& U9 l$ d& V0 z3 h. m
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间( m% ^8 Y6 L* n2 l1 l5 f: x( h
- // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)' V, V' `' V8 I
- $mongo = new MongoClient('mongodb://localhost:27017'); v- C# O& B1 v7 G
- $db = $mongo->mf;//选择数据库
o. O+ h* ^! h: ~4 n* Y - $collection = $db->friend;//选择文档集合7 E, T, G1 u4 ~7 A0 l- q0 i' d
- $doc = [//定义一个文档,即一个数组
* n. C, R5 \! k- K$ l- z - 'First Name' => 'Jet',0 O' D3 O; U/ A! ]: k
- 'Last Name' => 'Wu',. H- n+ q- ^" b- C* H j" k
- 'Age' => 26,& x0 A9 Y7 r. o1 q' {" d
- 'Phone' => '110',; ^2 s! h$ z' F. `: X2 F
- 'Address' => [
& P& y& B8 A" ^/ y - 'Country' => 'China',
8 o8 p( k+ x7 A- Q+ Y y! L - 'City' => 'Shen Zhen'! L8 u& B: V+ l5 U
- ],/ c1 _, y7 \6 P0 }' ?) ~
- 'E-Mail' => [
4 A' p5 J# {5 @- D0 s9 y - '123456@qq.com',
" B6 l E7 t4 k( f( e. |) ` - '666666@sina.com',0 Q3 J6 W" w0 `; A9 r$ e1 H( s: a
- '8888888@qq.com',- j6 F. O2 _- o# m& {
- '77887788@qq.com'
* d% h& ^3 S: j4 ]% T% S6 ~ F/ M* R - ]+ X& R+ f! s" E1 u& w( @
- ];
) n1 L! _: k/ Y8 J - $res = $collection->insert($doc);//向集合中插入一个文档0 |" a7 t( T) a
- echo '<pre>';
( ?7 p4 e. O# a' N/ H- r - print_r($res);//$res['ok']=1表示插入成功
复制代码二、数据查询 1. 查询单个文档: - //findOne()! G( b' M4 ^0 N& e5 t7 l
- //参数1:搜索条件; S7 T4 j9 k* z9 g2 F7 t3 B* s0 V
- //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非在第二个参数显式加入'_id'=>false。不设置则返回所有字段) K4 C, |7 s+ v6 `9 E% I( w
- $mongo = new MongoClient('mongodb://localhost:27017');) j5 R2 Z1 c+ I" L
- $db = $mongo->mf;% p) h6 U$ p9 f. B3 \. g
- $collection = $db->friend;5 U% S' M5 y8 m9 \3 N* S3 y
- $one = $collection->findOne(['First Name' => 'Jet']);
1 Z6 ]0 z& S* ^ - echo '<pre>';
3 v( y, f, r: F4 @" I - print_r($one);//返回一个数组,查不到数据则返回NULL
复制代码2. 查询多个文档: - //find()5 F0 D2 q8 x! s$ `
- //参数1:搜索条件
6 {; {8 e; J/ {$ V - //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非显式设置为false不返回。不设置则返回所有字段
% q# N+ d; p: W5 c5 ?) _- o - $mongo = new MongoClient('mongodb://localhost:27017');" d' L0 I* O* J- x
- $db = $mongo->mf;
% r5 h3 g3 O. E; B" W, D6 T - $collection = $db->friend;
9 X+ M+ W: [( a - $cursor = $collection->find(['Address.Country' => 'China']);//使用点操作符查找数组元素
2 q3 c) O+ g9 L, S6 D - echo '<pre>'; O' _: o" {) }+ N- H
- while($doc = $cursor->getNext()) {//循环读取每个匹配的文档# v* ]% d. } b; w1 K) |
- print_r($doc);1 i5 o7 D. X$ ~/ G& @
- }
复制代码使用各种条件操作符定义查询: - //mongodb分别使用$lt(小于)、$lte(下雨等于)、$eq(等于)、$gte(大于等于)、$gt(大于)、$ne(不等于)表示<、<=、=、>=、>、<>,用于整数字段查询
" q( n' J- g- i! b - $mongo = new MongoClient('mongodb://localhost:27017');9 `- T0 H( Z }
- $db = $mongo->mf;
& J! W' s( Y* ~5 y v2 i - $collection = $db->friend;2 H+ u* ?- M+ G* S# d0 [0 ?
- $cursor = $collection->find(['Age' => ['$gt' => 30]]);1 T+ ?5 W5 ?) Q
- echo '<pre>';: C- V Z- C8 G1 ]. M8 \' ~! n' b
- while($doc = $cursor->getNext()) {0 P9 P0 N$ s [, `6 j
- print_r($doc);
- |8 E( f3 l. X - }
复制代码 //查询某个字段的所有不重复的值
# I1 E% t" T# } H! D7 `4 ] $res = $collection->distinct('Age'); - //$in:匹配多个值中任意一个" `7 I" G; c! n- _9 y% b# [) W0 g
- $cursor = $collection->find(['Address.Country' => ['$in' => ['China', 'USA']]]);! A7 B+ G# h3 ]) `9 A
- + S7 Z" L+ n. D1 {6 z# `. b
- //$all:匹配多个值中所有值(用于数组字段查询)9 U3 B# {9 {; O9 {8 C7 o! ]
- $cursor = $collection->find(['E-Mail' => ['$all' => ['123456@qq.com', '77887788@qq.com']]]);; n$ u- p; \4 u% K# G
- 4 h+ K/ n3 r0 u
- //$or:或查询3 a3 \+ n4 ~8 Q {1 K
- $cursor = $collection->find(['$or' => [['First Name' => 'Jet'], ['Address.Country' => 'USA']]]);
3 }/ e1 d% B% ~: G -
! G) n+ x) S$ U - //$slice:获取数组字段中指定数目的元素,位于find()函数第二个参数中" y" m2 R( k l; z( t) N: a2 W# H
- $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => 2]]);//只返回前两个email
t0 {7 K1 p2 {9 c6 t* J - $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => -2]]);//只返回最后两个email
* h @* o" A% Q( m, q. P - $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => [1, 2]]]);//忽略第一个,返回接下来两个
" y3 |4 B c3 t0 q0 g5 s' l -
2 N& r9 M, `& V; P% x9 A - //$exists:根据某个字段是否有设置值进行查询+ E+ A- K+ J5 o4 F4 _
- $cursor = $collection->find(['Hobby' => ['$exists' => false]]);//查找Hobby字段未设置值的文档$ ^$ D# G* d; L! n+ G2 j' f0 ~
-
2 Q8 x+ d/ R4 ?- O - //正则表达式查询2 k! e# G/ T1 e; S
- $cursor = $collection->find(['First Name' => new MongoRegex('/^Je/i')]);//查找First Name字段以Je开头的文档,忽略大小写差异
复制代码使用MongoCursor类提供的其他函数: - //排序:1升序,-1降序* a6 I) |- N$ S+ f! Z. i+ ?% ^; w
- $cursor->sort(['Age' => 1]);" f, T+ D% Z8 S5 F: A( S# U# _
- 1 a/ M/ Z0 P8 P; J
- //忽略前n个匹配的文档8 j" L1 Q5 ]" ~) K- P3 z1 z9 l" ~
- $cursor->skip(1);! J. b8 B" e3 _' h' s: w
- 9 {! P b4 J' e# z* o
- //只返回前n个匹配的文档(limit()与skip()结合使用可实现数据分页功能)" V* ?! j" S5 O- }. T0 _7 C
- $cursor->limit(1);
0 `; ?) q# `. f -
* j3 {5 \% {1 _( W0 ` - //匹配文档的总数
: T. D, c, ^0 r* H n9 T6 v - $cursor->count();8 f' Y) A$ Q- c; P
- . Z, k4 Y! Z7 @5 R( W
- //指定查询索引# |+ s J' |# B, |: }
- $cursor->hint(['Last Name' => -1]);//若索引不存在则会报错
复制代码聚集查询:对数据进行分组统计 - //聚合查询:对数据进行分组统计
[3 Q* w/ N; e - $mongo = new MongoClient('mongodb://localhost:27017');9 j! Z& D) x" O& Z# `/ p
- $db = $mongo->mf;
& V' o2 k( s) ~4 r; m: I# P; J - $collection = $db->friend;8 v. T B/ m. e: B
- $res = $collection->aggregate([7 N% D* j% b3 g" _
- '$group' => [" O& c. t: K! I v4 ^* @# n
- '_id' => '$Address.Country',//分组字段,注意要加上“$”,这里是根据数组字段某个元素值进行分组
5 n* ^2 }9 |# f1 c - 'total' => ['$sum' => 1],//求总和,表示每匹配一个文档总和就加11 ^/ n# |( f% |! f
- 'maxAge' => ['$max' => '$Age'],//分组中Age字段最大值0 A# B1 l+ h6 A4 D! x0 B/ Y1 d) z
- 'minAge' => ['$min' => '$Age']//分组中Age字段最小值8 t+ g" c# x" V5 z# l9 e
- ]3 m9 B+ U" }6 H! _$ y) e
- ]);
$ m6 }1 t0 E6 [1 `* b - echo '<pre>';5 Z( `* v' J. |' i0 v
- print_r($res);//返回一个数组,$ret['result']为数组,存放统计结果7 G2 \) M2 _9 T% |8 \# J
-
" P9 t$ `' f+ |: f% m - 8 R- H. }- F- K+ `, Y
- //存在其它操作的聚合查询:多个操作之间执行先后顺序取决于它们位置的先后顺序
' W' w% q- ^9 I) Q/ n1 ^3 h - //聚合查询中的所有操作,包括'$group'在内,都是可选的。
, T+ |- d# Q% @; q1 l6 g - $mongo = new MongoClient('mongodb://localhost:27017');
$ r4 z# k; ^6 Z1 ` - $db = $mongo->mf;
0 F* r7 s4 r9 U# H$ }$ l w - $collection = $db->friend;
. }2 d7 X, I; ?+ [& m- z9 ` - $res = $collection->aggregate([! K5 R! K; G) f/ W" M
- [//过滤条件:只对符合条件的原始文档进行聚合运算,若是放在'$group'之后则是只返回符合条件的结果文档
5 L+ \9 a0 i; z! b1 u8 O( t: B - '$match' => ['Age' => ['$gt' => 30]]# ]( z& \) ]/ n ^, X* V* G j
- ],. I2 O9 L! ^9 C! `
- [//指定分组字段、统计字段" b$ _0 M0 R# u* K- S; I
- '$group' => [
% }3 Q+ y. f2 h! J. H - '_id' => '$Address.Country',3 T( H9 c8 W9 c1 R
- 'totalAge' => ['$sum' => '$Age']//计算各个分组Age字段总和3 r: ^5 P' B* a0 G {! z# P+ j8 f
- ]
4 u3 S( t% k8 Z6 C, } - ],
2 b1 G; q0 w& d - //以下操作若是放在'$group'之前则在聚合前作用于原始文档,若放在'$group'之后则在聚合后作用于结果文档+ T4 s- o: d# K9 Z
- ['$unwind' => '$E-Mail'],//将包含有某个数组类型字段的文档拆分成多个文档,每个文档的同名字段的值为数组中的一个值。
9 h1 x& u2 k G7 B5 f8 V6 ^" @ - ['$project' => ['myAge' => '$Age', 'First Name' => '$First Name']],//指定返回字段,可以对字段进行重命名,格式:返回字段名 => $原来字段名- m0 C9 d0 g# q/ f
- ['$skip' => 2],//跳过指定数量的文档
3 {; n5 I" P4 m: [6 S8 y - ['$limit' => 2],//只返回指定数量的文档$ j/ k6 q- A& E5 [
- ['$sort' => ['totalAge' => 1]]//排序
$ j4 i& a. \2 _1 O# V7 b1 o8 D - ]);
4 }' R1 d6 `, j* z - echo '<pre>';+ T. ~) T* x5 W4 u- S. y
- print_r($res);
复制代码
4 H" H0 U& Z+ b, I/ q* l三、数据修改 - //update()
* b W; S; S9 `7 X* z0 L. |3 K* n - //参数1:更新条件,指定更新的目标对象。$ S' \& }3 e* }6 C- f+ y @" Q) |6 t! V
- //参数2:指定用于更新匹配记录的对象。, n9 x1 j7 @! W5 F! s- ]: A" o
- //参数3:扩展选项组。
- V3 ^5 n# s1 k% i - // upsert:若设置为true,当没有匹配文档的时候会创建一个新的文档。
2 b( @ J8 n6 ^+ Y0 @# G8 Z - // multiple:默认为false,若设置为true,匹配文档将全部被更新。
( V v) L& g# y% P: t' F3 W - // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。+ T, @9 Q8 W' g4 I
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作: y% p% C* |/ q/ |
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。 b9 L" b: }& z6 X- ^; i$ D
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
# p) |! h# a; @" ^& \ - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒); I. N' U+ i( i0 {
- //注意:若不使用任何修改操作符,则匹配文档将直接被整个替换为参数2指定的对象。+ g; q# s( t) B1 `; n _0 }$ J5 Q
-
( {/ ?7 C+ q0 @8 B C - //$inc:增加特定键的值,若字段不存在则新建字段并赋值
0 Y7 b% P: n$ v# A* M - $mongo = new MongoClient('mongodb://localhost:27017');/ |7 s. z4 v+ V. e
- $db = $mongo->mf;
4 x% h4 v8 [& r6 ^- B7 F - $collection = $db->friend;3 d9 v, p; m% X' N2 @
- $res = $collection->update(['First Name' => 'Jet'], ['$inc' => ['Age' => 2]]);
& m) v+ l9 J3 h' F9 E" y0 q - echo '<pre>';
( v% s/ I; z- _# C: y - print_r($res);//$res['ok']=1表示修改成功,$res['nModified']表示修改的文档数量* h/ V' N D& V% k _3 H8 P. j/ C, O
-
" N% G& o6 f0 ~9 N6 u - //$set:重置特定键的值,若字段不存在则新建字段并赋值 V4 o) E! I6 v# \! S
- $res = $collection->update(['First Name' => 'Jet'], ['$set' => ['Hobby' => 'pingpong']]);
, F; O3 I% q7 i0 O5 I; K- S; }' w1 ]+ D+ q - & x3 W! x: p" i7 @( H0 d+ I
- //$unset:删除字段+ O' v$ p+ I$ d0 \5 f1 R
- $res = $collection->update(['First Name' => 'Jet'], ['$unset' => ['Hobby' => 1]]);. p- S# L0 F! `* Y" c
- * e3 _0 V; Z$ _, Y: n
- //$rename:重命名字段,若字段不存在则不进行任何操作 v6 O! C. s$ g7 b+ W- e z
- $res = $collection->update(['First Name' => 'Jet'], ['$rename' => ['Hobby' => 'hobby', 'Age' => 'age']]);) E0 y- j8 f& ~% k1 k; K0 Q
- //注意:如果文档中已经使用了指定名称的字段,则该字段将会被删除,然后再进行重命名操作。; [" |9 ~/ R* L: P1 F
- ! \8 I" |+ X/ p$ A1 [% S! @$ h
- //$setOnInsert:设置了upsert为true,并且发生了插入操作的时候,将某个字段设置为特定的' y1 j$ }. J& r7 p9 |
- $res = $collection->update(['First Name' => 'jet'], ['$setOnInsert' => ['lang' => 'English']], ['upsert' => true]);
+ k4 J; Y" m0 ]! G' }, G! ^ - $ |& F% W* z# [8 {6 j, K
- //$push:向指定字段添加一个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错
2 h' S2 t8 i2 p/ H/ J - $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '123123@qq.com']]);" s/ L$ r. L$ q
-
# e; f/ A' H3 c9 ?( B - //$push:向指定字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错
G: o0 n, h- |, {- }- \6 u$ N( Q0 H - $res = $collection->update(['First Name' => 'Jet'], ['$pushAll' => ['E-Mail' => ['666@qq.com', '8888888@qq.com']]]);
/ n% Y% v! S6 L4 w4 z D( c - ' l7 Y7 `3 S5 o* v, J, s
- //使用$push和$each向某个字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错
/ n- f8 U; D5 j% i+ M W" o7 M - $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);5 L7 b1 A. B4 j5 u1 d6 }
- ; t! [7 @/ ?% V: J( _, q6 O" o
- //$addToSet:将数据添加到数组中(只在目标数组没有该数据的时候才将数据添加到数组中)2 Y; C* n+ R/ I" q+ b' j" h( l! q
- $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => '123123@qq.com']]);
# `: w* F4 E: k- k) ` - $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);
5 r0 J( ^8 Y5 w( s - # b) f. n4 x! q* G
- //$pop:从数组中删除一个元素,-1表示删除第一个元素,1表示删除最后一个元素(其实负数都删除第一个元素,0或正数都删除最后一个元素)9 p0 N) q+ c A
- $res = $collection->update(['First Name' => 'Jet'], ['$pop' => ['E-Mail' => 1]]);
) T: e; Y/ E T - 0 b, {- }6 e8 \' i# e
- //$pull:删除数组中所有指定值+ {; [1 h( X. \) Q% R6 p! c4 r
- $res = $collection->update(['First Name' => 'Jet'], ['$pull' => ['E-Mail' => '123123@qq.com']]);6 X( \3 X/ M. g% b: s2 b
- & Y+ J9 Y2 O5 {4 j& g: q. Y
- //$pullAll:删除数组中多个元素的所有值) d, i1 U" l6 {0 w' Z8 B2 G( r
- $res = $collection->update(['First Name' => 'Jet'], ['$pullAll' => ['E-Mail' => ['123123@qq.com', '666@qq.com']]]);
复制代码- //save(). f# D F9 j, k( I( }* @
- //参数1:希望保存的信息数组
$ O3 P! I5 W. e - //参数2:扩展选项$ o5 n5 W. s& G& f. ]
- // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。4 m6 X! ~5 J, g9 Q$ d! N) ~
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作
& c5 r! y4 P+ { - // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。; M8 g2 S F6 o3 Q
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
9 ]. a7 A5 H8 \( k5 | - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
" v: @2 s Q+ h2 c% O3 O* }8 ] - //注意:若已存在则更新,若不存在则插入;更新时使用参数1指定的信息数组替换整个文档。
+ Y7 I4 _: n% g - //若想更新则应该在参数1中指定_id键的值。
8 L) W2 C- V/ E+ A - $mongo = new MongoClient('mongodb://localhost:27017');
5 m( a- k! g4 Q4 Q% P8 N4 N1 ] f" S - $db = $mongo->mf;
6 O* h G0 Q( \9 O5 V - $collection = $db->friend;
, _8 ], `3 j/ V: c7 v X - $doc = [//定义一个文档,即一个数组
- \/ z4 q3 L6 A6 J - 'First Name' => 'Jet',
' ]* Q( a0 ]+ O1 J% b6 t - 'Last Name' => 'Wu',
( P; ~5 l0 k) ]1 L) {0 y - 'Age' => 26,; p' W+ j$ R% X
- 'Phone' => '110',
9 ~$ Y; R: _$ R/ ?; u4 T: o - 'Address' => [$ n: \$ m7 B/ Y1 N7 _
- 'Country' => 'China',
4 V/ R9 V- j0 b, k, H - 'City' => 'Shen Zhen'' n/ I7 W( K4 j, L8 O
- ],& a4 V9 M8 B# d. p
- 'E-Mail' => [7 W# S. N7 |/ p- i, Z. B# ^# k* Y
- '123456@qq.com',* O3 U8 J! S9 K- h: W4 \% U
- '666666@sina.com',3 ?. D; C: i; U) G0 Z9 v
- '8888888@qq.com',( }0 D+ L9 t+ z9 |. _2 G
- '77887788@qq.com'7 y' |0 U+ X T- W9 j1 r4 o) q0 a
- ]9 V1 C" O# p" ^
- ];
$ x( l7 U/ n/ X# B4 c8 m - $res = $collection->save($doc);
& u a$ A/ s) F+ r3 \1 A - echo '<pre>';
" f9 w! l& A X2 U4 _" ] - print_r($res);//$res['ok']=1表示操作成功,$res['updatedExisting']=1表示更新,$res['upserted']=1表示插入' u* [) f8 [& B' Z1 s
; C" o# N* a0 s
复制代码- //findAndModify()
2 k: i0 Q* i* y( }( n - //参数1:指定查询条件
1 e3 f- C' \; C/ @8 \ ^ - //参数2:指定用于更新文档的信息
& E9 H0 |* {; g* X* g8 | - //参数3:可选,指定希望返回的字段0 D! r# r5 z2 Q1 @9 }5 }' {
- //参数4:扩展选项) N9 L, s& ^/ T+ i$ T* I
- // sort:以特定顺序对匹配文档进行排序
( G' P" D4 q+ i& Y# Y; @ - // remove:若设置为true,第一个匹配文档将被删除' k$ k/ o: O7 T8 V
- // update:若设置为true,将在被选择的文档上执行更新操作
: p& c+ _+ Q( M3 N! W+ \# k# W - // new:默认为false,若设置为true则返回更新后的文档,否则返回更新前的文档& [5 F. C: |; |1 z; v2 A
- // upsert:若设置为true,没有找到匹配文档的时候将插入一个新的文档
+ c/ s: K9 q- m' Z9 E - $mongo = new MongoClient('mongodb://localhost:27017');3 G3 @% R; O3 }6 P" L5 D) c
- $db = $mongo->mf;3 q5 Q$ g4 F" U0 J
- $collection = $db->friend;
* t# v- k6 {" Y! j/ E- `8 | - $res = $collection->findAndModify(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '111@qq.com']]);: j3 W$ Y) |# v# H" H* @$ |, }8 M" n
- echo '<pre>';
" s* `% g+ N) O, O5 H, M - print_r($res);
复制代码 四、数据删除 - //remove()
2 ~ s3 U3 D' x( j. Y, P5 g - //参数1:查询条件, O6 U5 o" F( U- n. N' |% O! N
- //参数2:扩展选项! z7 I. }! D; ~' @
- // justOne:若设置为true,则最多只有一个匹配的文档将被删除8 b. M. o/ Z' v
- // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。1 L, @7 G! I* ?% ?
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作
( D: A/ @. i$ d& c$ j1 J& O - // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。- c$ A$ f; ^5 J0 g9 q0 F
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间- d' m+ u9 M6 d6 k6 q( J5 V
- // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
, C+ o0 U- l" S/ v" Z - $mongo = new MongoClient('mongodb://localhost:27017');3 u" b8 o, B! ?. G
- $db = $mongo->mf;
4 a( R& m9 o2 s8 \) E8 K - $collection = $db->friend;
1 O# F5 D3 p1 Z8 N% @ ] - $res = $collection->remove(['First Name' => 'jet']);* V+ J: a: J4 ~& A
- echo '<pre>';. u$ c$ I) T: u1 M/ h8 n5 O
- print_r($res);//$res['n']表示删除了几个文档
复制代码
7 D9 K+ N8 l+ |1 f9 W- C以上是PHP7以前版本的MongoDB操作,下面简单介绍PHP7以后版本的操作。
7 F3 U3 X; j) p D, F: _- [2 j x-----------------------------------------------PHP7分隔线--------------------------------------------------------------------- 3 R& ?" I3 g+ f V; b3 g) g
数据插入: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');8 V5 g( ?9 p2 b0 K' M; g9 S" s
- $bulk = new MongoDB\Driver\BulkWrite;; U* z" w- L5 r, q
- $bulk->insert(['name' => 'JetWu5', 'age' => 26]);
' |) j( V) ]6 V5 G - $bulk->insert(['name' => 'JetWu6', 'age' => 26]);
1 \% \) t3 [- z6 n+ m$ \ -
+ f4 o% [" U! _ - $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
4 y+ k. C: m+ K% n6 _0 I - $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
' @8 _) Q- P# s8 {' a7 ~8 K7 @. J - echo '<pre>';
4 a6 \" M4 Z* i- K+ M" {, W - print_r($res);
复制代码
8 C0 c% `( w$ O; t; M* B: ~数据查询: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');9 Y [! m* Q' k) C
- $query = new MongoDB\Driver\Query(['age' => 24], ['sort' => ['age' => 1]]);
; V( W6 t1 d; f1 Y& l# a" }( S - $cursor = $manager->executeQuery('wjt.friend', $query);
2 @- u9 t2 F7 S- H, t - " ^1 q1 i& Q8 q: v: z' D- W) X) C9 w
- $data = [];/ I/ u/ Q. M6 o$ s
- foreach($cursor as $doc) {- r) ~% {# c' e( U2 K- p) I0 [
- $data[] = $doc;
/ [( z; {) F7 C" J2 E - }
. M; G0 g& z" e3 t% S, [/ c - echo '<pre>';+ J1 \5 @; o, l2 z' U+ p( C
- print_r($data);
复制代码 数据修改: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
2 s& D& S4 r+ n5 T2 Z5 _# r - $bulk = new MongoDB\Driver\BulkWrite;
! H# a& C4 q. i; S& O/ [ - $bulk->update(1 M( Z7 z3 l7 b" O
- ['name' => 'JetWu5'],
8 Z& h6 @0 F* }8 C# J/ R7 W. G' | - ['$set' => ['age' => 30, 'promise' => 'always smile!']]
9 A; C& s: H0 Q( K% m) j - );
% P5 y4 T: N; l- H* W* q* k3 s6 T5 l - $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认6 Y- L, c. u6 L& y5 {
- $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);/ o) q4 t' B2 a* G8 J8 U1 [
- echo '<pre>';& k6 `! a% t' ?
- print_r($res);
复制代码 数据删除: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
5 `- f1 K: T1 F' C0 W0 q+ G - $bulk = new MongoDB\Driver\BulkWrite;
' L) q2 f, V+ J - $bulk->delete(['name' => 'JetWu3']);
) c$ ~; j, f2 h% R" | - $bulk->delete(['name' => 'JetWu4']);
; g. Y$ Q( N: m/ L% ^ - $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认+ A4 a2 ~; o/ x" s+ a
- $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);9 s! T4 W$ i7 g8 S
- echo '<pre>';
* O6 N, C& c5 B$ { h/ _$ P - print_r($res);
复制代码
7 z7 R2 Z0 p8 ]9 a& v3 n% d }% K$ s9 x
& y1 U: r z# j
2 f* X7 b+ h+ ~
* Y8 _) m/ X5 Q
|