MongoDB的PHP驱动提供了一些核心类来操作MongoDB,总的来说MongoDB命令行中有的功能,它都可以实现,而且参数的格式基本相似。PHP7以前的版本和PHP7之后的版本对MongoDB的操作有所不同,本文主要以PHP7以前版本为例讲解PHP对MongoDB的各种操作,最后再简单说明一下PHP7以后版本对MongoDB的操作。 一、数据插入 - //insert()
h- I+ S* H% C( E1 V% O - //参数1:一个数组或对象
% y# U( ^, u2 B - //参数2:扩展选项
6 ^) K9 z" e, W6 \ - // fsync:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入硬盘+ o& F& u# X* y& i% x' v) Y
- // j:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入日志" ~* q/ X5 M- l4 s- i
- // w:默认为1,写操作会被(主)服务器确认,若为0则将不会得到确认,使用复制集时设置为n用于确保主服务器将数据修改成功复制到n个节点后再确认
( [3 ^& d ~) M+ N - // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间4 [ z, K6 ~& \" }# G; t6 q: a
- // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
( @8 {8 _1 M5 f- v - $mongo = new MongoClient('mongodb://localhost:27017');
% b% B/ ]( Y/ |! s3 [1 Q- } - $db = $mongo->mf;//选择数据库
: E5 |9 n* @" M+ n - $collection = $db->friend;//选择文档集合
/ ]* r# k1 c1 [4 N9 n; r& J& e - $doc = [//定义一个文档,即一个数组$ G+ k2 k! G3 W
- 'First Name' => 'Jet',$ o7 [$ h+ G Y4 K, _
- 'Last Name' => 'Wu',& J( s/ C% [; w# W. J- E# c
- 'Age' => 26,$ e+ p1 f' U# j: |$ u
- 'Phone' => '110',6 H: |+ |0 g2 V. A: ]2 {
- 'Address' => [ l% Y" M) z8 b2 y
- 'Country' => 'China',/ G, E& |; u( K' H* o! z
- 'City' => 'Shen Zhen'
" z+ z) x$ G2 z k - ],/ L* `" \; t) d% E V
- 'E-Mail' => [) [+ [- h% m! p& F
- '123456@qq.com',
8 P* ]& v3 ^* K* r' T5 a - '666666@sina.com',
6 ]- u. Y4 o7 G$ u: k% { - '8888888@qq.com',1 u, X; Y4 V0 o
- '77887788@qq.com', y( P1 y- s" r
- ]' Q! H5 M& E/ T# J( `9 v: Y
- ];
" K" l; {3 z7 I - $res = $collection->insert($doc);//向集合中插入一个文档% J: [ d* a! o b. h
- echo '<pre>';
5 ]! w8 j. N! \' B" _, y - print_r($res);//$res['ok']=1表示插入成功
复制代码二、数据查询 1. 查询单个文档: - //findOne()2 d& d$ ` z5 u: }: l
- //参数1:搜索条件
) a) `6 w) Z B3 `3 ?7 {* f' H9 H) H - //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非在第二个参数显式加入'_id'=>false。不设置则返回所有字段
* |/ a& q5 F* h. t7 f' Z8 [2 {, w' B( V - $mongo = new MongoClient('mongodb://localhost:27017');
5 H; e$ S$ {( w3 J; G0 U6 V( P - $db = $mongo->mf;
) d3 E3 X* V6 Y# K4 `* [! ?( }: Y - $collection = $db->friend;
+ z8 w) _2 Z$ u' D - $one = $collection->findOne(['First Name' => 'Jet']);8 a: H. E! h8 q
- echo '<pre>';
. O9 a2 L. x$ J& A - print_r($one);//返回一个数组,查不到数据则返回NULL
复制代码2. 查询多个文档: - //find()
' j" z. e) F, ?; b% n" i8 k* T - //参数1:搜索条件
" A! F3 w7 E) D B1 `: w9 X9 _( J - //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非显式设置为false不返回。不设置则返回所有字段
- T) _: n: T( O6 R+ ~7 z4 s - $mongo = new MongoClient('mongodb://localhost:27017');
5 o9 j# p5 N Y# g: _$ q/ p6 u" X - $db = $mongo->mf;
4 j- J: V, c4 n$ ?9 Z - $collection = $db->friend;
! ~8 [# J# s2 {, w& ^# L. I& ] - $cursor = $collection->find(['Address.Country' => 'China']);//使用点操作符查找数组元素: v% q9 g) r" L) |# |) A
- echo '<pre>';
8 n# ~. J$ K% L2 c7 l# V - while($doc = $cursor->getNext()) {//循环读取每个匹配的文档
: i k0 d9 ~. \, k$ ?" |1 n& @ - print_r($doc);6 H" _5 J9 [/ J. }
- }
复制代码使用各种条件操作符定义查询: - //mongodb分别使用$lt(小于)、$lte(下雨等于)、$eq(等于)、$gte(大于等于)、$gt(大于)、$ne(不等于)表示<、<=、=、>=、>、<>,用于整数字段查询( m' _6 t7 d$ G8 B0 E( K- X
- $mongo = new MongoClient('mongodb://localhost:27017');2 D- l% W V* N3 h. M
- $db = $mongo->mf;) \8 \: v# N6 I( }% o( G( k
- $collection = $db->friend;
% g+ G* j# S9 U" K- T \- s" E - $cursor = $collection->find(['Age' => ['$gt' => 30]]);
2 r5 q4 l8 }' G/ g0 C - echo '<pre>';
5 ]8 }0 A- S6 {. h0 x6 I+ ^ - while($doc = $cursor->getNext()) {
* F1 o) s2 m8 o0 C - print_r($doc);" y- d6 @6 R t& F5 m7 q8 o# X
- }
复制代码 //查询某个字段的所有不重复的值+ E1 y: w! C; g, X' i- }* G
$res = $collection->distinct('Age'); - //$in:匹配多个值中任意一个4 y6 l# Y% p( W
- $cursor = $collection->find(['Address.Country' => ['$in' => ['China', 'USA']]]);+ s: E$ I6 e& m. C' a8 ?
-
8 j/ z: {6 g: x# \2 \1 l - //$all:匹配多个值中所有值(用于数组字段查询)
* m( e& D+ l8 q. F' K - $cursor = $collection->find(['E-Mail' => ['$all' => ['123456@qq.com', '77887788@qq.com']]]);! k& ~0 O- I* Z N1 Q& M w
- 0 V# A' s! A/ c' ?9 w( b) |
- //$or:或查询
5 p: C0 N- [6 e! s9 [% \" M. W" ~ - $cursor = $collection->find(['$or' => [['First Name' => 'Jet'], ['Address.Country' => 'USA']]]);! f2 n4 g4 t, J: q8 m
- 1 [8 n. G/ K/ A; [' n# ^
- //$slice:获取数组字段中指定数目的元素,位于find()函数第二个参数中
1 N# @, g' w) I p4 u5 x/ p5 D - $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => 2]]);//只返回前两个email
5 v7 {3 j) `3 |+ q7 V( s - $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => -2]]);//只返回最后两个email3 k [8 M9 P( d6 G3 B7 f
- $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => [1, 2]]]);//忽略第一个,返回接下来两个; n1 z, ]# c/ S; s& a7 J% w# q
- ( \8 ~1 ]; C8 j
- //$exists:根据某个字段是否有设置值进行查询( H: A3 j- }9 ]
- $cursor = $collection->find(['Hobby' => ['$exists' => false]]);//查找Hobby字段未设置值的文档
! m8 f" G+ e; w1 _+ U) h! }- i5 C -
( ~* r- l3 v& g4 m2 ]2 k - //正则表达式查询
: B _8 {3 c& ^5 }1 [ - $cursor = $collection->find(['First Name' => new MongoRegex('/^Je/i')]);//查找First Name字段以Je开头的文档,忽略大小写差异
复制代码使用MongoCursor类提供的其他函数: - //排序:1升序,-1降序
( i/ A8 P* A& O: M8 M) F - $cursor->sort(['Age' => 1]);
' S, k/ O+ r7 e( x" K) ^/ K/ O: O1 u -
& q8 q% C; i& L2 q& T$ r% b - //忽略前n个匹配的文档
, i+ P* E# y' S1 r3 S7 G - $cursor->skip(1);
* c# c( x1 A, b! B! [8 P+ S - # g; q5 R! h3 N. k: T/ \. P b
- //只返回前n个匹配的文档(limit()与skip()结合使用可实现数据分页功能)7 w: {2 U/ J* i! J5 j9 q
- $cursor->limit(1);2 _9 w0 J2 x* {$ U9 R9 Q
-
" k+ t- Q" ^! K# | - //匹配文档的总数) \0 E+ o+ g9 e) K, @6 m6 ~) n
- $cursor->count();- }% |4 U0 R q \1 b8 j
-
( f2 }9 E, Y) M, \ - //指定查询索引, H7 W. t# G/ h6 c2 I+ \; a
- $cursor->hint(['Last Name' => -1]);//若索引不存在则会报错
复制代码聚集查询:对数据进行分组统计 - //聚合查询:对数据进行分组统计
' F. S0 {1 S2 x - $mongo = new MongoClient('mongodb://localhost:27017');8 v. N+ {; U/ H3 L# j1 ^$ m9 T
- $db = $mongo->mf;$ }* C1 _* Q7 T' x1 W0 p
- $collection = $db->friend;
1 C* G5 b; b* ]+ _5 Q+ s2 u - $res = $collection->aggregate([
, L3 r+ ]& A6 }0 Y$ O% l - '$group' => [1 x6 j' \* K9 D) j# V2 c9 q
- '_id' => '$Address.Country',//分组字段,注意要加上“$”,这里是根据数组字段某个元素值进行分组
F* K N" ?2 d7 z9 z. s. x. B3 d/ ~ - 'total' => ['$sum' => 1],//求总和,表示每匹配一个文档总和就加16 z( i+ r- S0 {, g; F5 H9 ?
- 'maxAge' => ['$max' => '$Age'],//分组中Age字段最大值
7 t; l7 G& E) A# k - 'minAge' => ['$min' => '$Age']//分组中Age字段最小值
1 A% ~' y) b# D$ | - ]5 T( A; j* F; y- ?
- ]);0 [" w( s: d6 w( n9 j
- echo '<pre>';
$ L9 G2 ~% m- R& e0 B" d - print_r($res);//返回一个数组,$ret['result']为数组,存放统计结果3 d" D4 I3 ~; j; Y
-
4 u$ [/ F( m, W0 [8 {+ P6 x - ' y8 f* Q* W5 s: _
- //存在其它操作的聚合查询:多个操作之间执行先后顺序取决于它们位置的先后顺序& \ U5 |4 D( r H4 w& X
- //聚合查询中的所有操作,包括'$group'在内,都是可选的。/ a' J- x. \0 n* g) ?
- $mongo = new MongoClient('mongodb://localhost:27017');
, U- R) |' }: X: s+ \. g7 N - $db = $mongo->mf;
6 U* j4 O* P( s* v( V# b - $collection = $db->friend;
3 ~- P' Q; |6 t: g/ G8 @! h; u - $res = $collection->aggregate([: Y& @( @/ ?# } P( }
- [//过滤条件:只对符合条件的原始文档进行聚合运算,若是放在'$group'之后则是只返回符合条件的结果文档
! K( y6 l$ u1 o- i4 d8 N2 h ` - '$match' => ['Age' => ['$gt' => 30]]
7 ^# s5 a$ R$ @ - ],
! ?9 z) L: C4 b' d/ i - [//指定分组字段、统计字段
& h7 |. x( G& q2 ~9 {3 x2 S - '$group' => [
8 @, W6 e+ ^6 J - '_id' => '$Address.Country',
% K0 e8 U Q; h u0 _ o - 'totalAge' => ['$sum' => '$Age']//计算各个分组Age字段总和. l: p5 [) J4 P
- ]2 l' a1 q. x4 \4 _/ K; r! ~
- ],% a& c5 v* \# q7 U' a
- //以下操作若是放在'$group'之前则在聚合前作用于原始文档,若放在'$group'之后则在聚合后作用于结果文档9 D. X2 u* `! _" M
- ['$unwind' => '$E-Mail'],//将包含有某个数组类型字段的文档拆分成多个文档,每个文档的同名字段的值为数组中的一个值。4 H% V$ S8 P8 R" f" J) D% p
- ['$project' => ['myAge' => '$Age', 'First Name' => '$First Name']],//指定返回字段,可以对字段进行重命名,格式:返回字段名 => $原来字段名
) g6 Y8 J; ` A6 ]) b4 J1 b - ['$skip' => 2],//跳过指定数量的文档! l+ b- E; U4 T9 a' D# ~0 G4 ~
- ['$limit' => 2],//只返回指定数量的文档) [1 @; M# m7 e( F1 {
- ['$sort' => ['totalAge' => 1]]//排序: _2 {$ d5 w; ~! a+ M
- ]);3 ^! R4 P# [# n0 H) \3 e
- echo '<pre>';$ A4 K Y! ~2 q* p7 K
- print_r($res);
复制代码
" g) q; v5 Y! g, F+ N# h% B- p7 h三、数据修改 - //update()0 h( O7 w& _# J5 T% }0 {2 O, L
- //参数1:更新条件,指定更新的目标对象。+ T i: G- L5 v" s/ B
- //参数2:指定用于更新匹配记录的对象。+ @! [0 P$ Q( C: P2 c
- //参数3:扩展选项组。
; M0 e7 H. S; R7 w3 d- f - // upsert:若设置为true,当没有匹配文档的时候会创建一个新的文档。- Q4 {- b% ]. Y( S8 \- `6 R
- // multiple:默认为false,若设置为true,匹配文档将全部被更新。
# F# y0 W% g% ]. a - // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。- a% ] H7 q. }! B
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作1 s$ S% k$ X Q8 b+ \
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。
3 z1 M2 Y, B6 \6 w# V" V - // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
! Y. i% M0 @% G* i - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)5 U/ k" ^& b+ ?& u4 ~
- //注意:若不使用任何修改操作符,则匹配文档将直接被整个替换为参数2指定的对象。& o0 _: W/ b: u- j: }
-
* T" X) t4 i# D9 f* t - //$inc:增加特定键的值,若字段不存在则新建字段并赋值& I2 ?) l" q5 I! w* G/ G4 ~
- $mongo = new MongoClient('mongodb://localhost:27017');7 A9 V5 w# U; |8 e4 s7 r& P
- $db = $mongo->mf;
+ [2 R1 k; E& ~5 h+ ` @ - $collection = $db->friend;% s2 x: P0 Y$ O
- $res = $collection->update(['First Name' => 'Jet'], ['$inc' => ['Age' => 2]]); U7 y3 l, s2 p; T7 |# M+ ^
- echo '<pre>';3 U$ W- v& M7 j
- print_r($res);//$res['ok']=1表示修改成功,$res['nModified']表示修改的文档数量; [5 e# s& F* B: J+ H" F
-
0 C" R* V: T% ^% o+ y( W. a - //$set:重置特定键的值,若字段不存在则新建字段并赋值5 \1 s9 Q" V6 a
- $res = $collection->update(['First Name' => 'Jet'], ['$set' => ['Hobby' => 'pingpong']]);
" b& w$ r$ l& G1 M. t* v0 i$ } v -
2 e) N0 S' x- q# k, k( p - //$unset:删除字段) w) f+ r( ]% F
- $res = $collection->update(['First Name' => 'Jet'], ['$unset' => ['Hobby' => 1]]);
6 z7 I( ^2 |/ Z# b# \. b1 L -
; N, b) g& q9 i+ u2 n7 o - //$rename:重命名字段,若字段不存在则不进行任何操作
; Y% O0 R& y4 V% D - $res = $collection->update(['First Name' => 'Jet'], ['$rename' => ['Hobby' => 'hobby', 'Age' => 'age']]);8 S. E" H! s* H2 ~
- //注意:如果文档中已经使用了指定名称的字段,则该字段将会被删除,然后再进行重命名操作。
9 u ?% x7 t3 _' N/ [# n -
; f' `( O& W$ b- {" H& X& \$ w$ G - //$setOnInsert:设置了upsert为true,并且发生了插入操作的时候,将某个字段设置为特定的/ j( D+ E& s7 q
- $res = $collection->update(['First Name' => 'jet'], ['$setOnInsert' => ['lang' => 'English']], ['upsert' => true]);+ i3 H1 u) a/ J: Z1 d
-
A4 h4 h3 ~; o4 D, @# U- O - //$push:向指定字段添加一个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错/ V5 g: H \2 h3 r+ ?9 }) P
- $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '123123@qq.com']]);
" E" E: D0 F4 L% o$ d4 L6 S -
6 j$ O# S* E7 I$ x8 R - //$push:向指定字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错6 b- r, w+ h3 d
- $res = $collection->update(['First Name' => 'Jet'], ['$pushAll' => ['E-Mail' => ['666@qq.com', '8888888@qq.com']]]);
, V! I! o+ _! I# r* b7 }) m: ?, I -
! x, f" K0 E3 ^9 L( x O9 Z* M - //使用$push和$each向某个字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错
4 c* o' f, `" _* o - $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);; W& i9 F3 u, ~2 N
-
. Z, O4 r2 j% L; } - //$addToSet:将数据添加到数组中(只在目标数组没有该数据的时候才将数据添加到数组中)
8 O8 D- P* Z- G. Q! o - $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => '123123@qq.com']]);$ t! I$ n6 i- A" q6 f( E W
- $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);& |1 B6 h1 O9 B0 T9 N, S! [2 Z, _
-
; t& _7 H6 V4 e - //$pop:从数组中删除一个元素,-1表示删除第一个元素,1表示删除最后一个元素(其实负数都删除第一个元素,0或正数都删除最后一个元素)& u# @2 L. X1 P6 z& J- C
- $res = $collection->update(['First Name' => 'Jet'], ['$pop' => ['E-Mail' => 1]]);' E& |/ x! A m" l; a3 {! j/ j
- [0 s8 K9 w @: L
- //$pull:删除数组中所有指定值7 X2 r! Y5 | S2 r$ W
- $res = $collection->update(['First Name' => 'Jet'], ['$pull' => ['E-Mail' => '123123@qq.com']]);
; |# ]. v* v* g* x6 d0 o7 T - ; N+ n; e4 e" z, }1 ^$ j
- //$pullAll:删除数组中多个元素的所有值
4 w$ Z( n! Z0 ^7 e6 h# r9 ] ]& ` - $res = $collection->update(['First Name' => 'Jet'], ['$pullAll' => ['E-Mail' => ['123123@qq.com', '666@qq.com']]]);
复制代码- //save()
& U# i: D6 z, p% `2 [0 N - //参数1:希望保存的信息数组
( d1 h+ c8 h4 @) J - //参数2:扩展选项
- x7 C: {* d1 K7 @# |+ f - // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。$ R( b6 N4 n" T1 o5 K3 P/ k
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作
8 p( y3 R9 u7 l! r3 f - // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。" N7 p M0 l9 t, O
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
7 z1 h7 {+ [; Z( _0 a2 n2 | - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
3 I: Q9 Q# [! E% q! s! {6 Z - //注意:若已存在则更新,若不存在则插入;更新时使用参数1指定的信息数组替换整个文档。* N+ C3 T# i6 v
- //若想更新则应该在参数1中指定_id键的值。9 r0 G, k P& u( q2 e& ^
- $mongo = new MongoClient('mongodb://localhost:27017');0 H( r6 s/ [/ O8 e1 q Y
- $db = $mongo->mf;
+ a' S. ^9 z9 Z Y2 G - $collection = $db->friend;
, F6 }+ {6 k: Q( }! q - $doc = [//定义一个文档,即一个数组
& y, o u4 Q& u( v o# I# a; ~ - 'First Name' => 'Jet',* _: W* w$ m c) u0 c% [
- 'Last Name' => 'Wu',
. T, J) w0 g" ~' ` - 'Age' => 26,
5 }5 A5 y& x, I: Y$ O# s* n5 z. g# z - 'Phone' => '110',8 b/ s8 ^. J. u# N, X; P9 P2 ]
- 'Address' => [
n1 d9 G$ ]- \. v0 c - 'Country' => 'China',6 N. r. B" Q3 h! T( q- _: \* @
- 'City' => 'Shen Zhen'
5 w1 T3 a& X7 T; Y# L% R2 ~ - ],5 B; N }# S8 Y/ G
- 'E-Mail' => [
0 y2 {+ V6 X- D* @ - '123456@qq.com',
' D# h# c) z# N! u& K - '666666@sina.com',6 `. X+ E m( e- Q- x
- '8888888@qq.com',
6 s# i( y" i* o `, D S8 L8 l( a - '77887788@qq.com'
: w) @9 u4 B3 }6 t% n9 @ U1 Q( w - ]- ]3 R2 K) G. }: J
- ];2 K5 j, {3 _, P8 Z
- $res = $collection->save($doc);9 k8 u. w5 T1 r5 T; s5 J" O
- echo '<pre>';
" B9 v) n" ?: A - print_r($res);//$res['ok']=1表示操作成功,$res['updatedExisting']=1表示更新,$res['upserted']=1表示插入1 i; ~4 r; D: e# [% J4 ^0 F
2 W4 k0 `3 |9 k7 ]8 Q
复制代码- //findAndModify()
7 t+ w4 Q% w: }/ n! _" m6 [ - //参数1:指定查询条件
* a: F0 b3 ~% }+ B - //参数2:指定用于更新文档的信息; j4 i/ s& ]" x6 |
- //参数3:可选,指定希望返回的字段+ Z. T. C5 g* m: K! ]' J* {
- //参数4:扩展选项
3 n/ N" u" k& q' r6 D) |$ ?% _# x8 E - // sort:以特定顺序对匹配文档进行排序
3 x% Z8 u" v% a# P( l - // remove:若设置为true,第一个匹配文档将被删除
7 G) E+ b( {- i0 Q" x - // update:若设置为true,将在被选择的文档上执行更新操作
8 d- v% h; [; R m3 a - // new:默认为false,若设置为true则返回更新后的文档,否则返回更新前的文档8 [/ @' Q# o* G6 t0 b* u1 q7 \: Z& [
- // upsert:若设置为true,没有找到匹配文档的时候将插入一个新的文档
7 d8 Y1 R5 l- U4 y6 W - $mongo = new MongoClient('mongodb://localhost:27017');
7 V' f: @3 |3 \6 u$ f3 H$ v, T& Y - $db = $mongo->mf;
: ?9 f& p% X- Z, t - $collection = $db->friend;: T& s% h h' Q! B, H
- $res = $collection->findAndModify(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '111@qq.com']]);6 y* i% J/ E& _4 w; J, q
- echo '<pre>';
2 {, G1 | S5 H/ X0 M+ I) ] - print_r($res);
复制代码 四、数据删除 - //remove()4 M/ C& K. c) t9 `) U
- //参数1:查询条件6 ]' y7 O5 c( k* B/ V
- //参数2:扩展选项
6 K9 ?8 ^% u9 ?0 @ - // justOne:若设置为true,则最多只有一个匹配的文档将被删除
1 |# L! {% E7 W - // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。
& q2 u! I/ x5 M- P. _( k - // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作
. q, J7 `% Z4 J' t - // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。
( |3 j' {" S( \$ q - // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
3 y7 s* o' |9 }1 O3 @ - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
& D* R# D- _( \9 h - $mongo = new MongoClient('mongodb://localhost:27017');7 X3 }/ H# `! q: T6 i0 o' a
- $db = $mongo->mf;
' P8 E- }- V! R ? - $collection = $db->friend;- I, |1 S- s# u6 p1 l( ~
- $res = $collection->remove(['First Name' => 'jet']);
3 M9 F& C s8 P. c - echo '<pre>';
. q$ s# }/ @/ Z+ p j2 ]! t - print_r($res);//$res['n']表示删除了几个文档
复制代码 ! i7 O7 s# i+ T k. [
以上是PHP7以前版本的MongoDB操作,下面简单介绍PHP7以后版本的操作。 ' C# r" o7 q* J$ }4 T4 Y- O
-----------------------------------------------PHP7分隔线--------------------------------------------------------------------- " u- P' i0 w Y) A. z
数据插入: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');; p7 [- d' z. Y+ w B3 R
- $bulk = new MongoDB\Driver\BulkWrite;
4 a2 H& Y, R2 O! k$ ~2 R! Z - $bulk->insert(['name' => 'JetWu5', 'age' => 26]);6 O7 r4 K9 y8 x
- $bulk->insert(['name' => 'JetWu6', 'age' => 26]);
, E% @, z l! G. h) c - ; P# |2 i" {. y' a! f9 ]/ A
- $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
$ E( t+ t4 M0 ]8 z( F) Z9 S - $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
9 j8 w2 j1 T9 l# W# Y% K - echo '<pre>';
. L5 P6 I! X6 r0 U! v1 p% k - print_r($res);
复制代码 ! q+ D+ a; F& E3 Y C- g
数据查询: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
. X6 ]5 x* H. p) F - $query = new MongoDB\Driver\Query(['age' => 24], ['sort' => ['age' => 1]]);+ a0 @( ~/ M$ h/ z1 r, q* g
- $cursor = $manager->executeQuery('wjt.friend', $query);
; q$ X3 B2 B7 N6 H# G9 o -
. Q3 W! L( c2 u( q# R - $data = [];" k( J+ F* @6 X
- foreach($cursor as $doc) {
8 l1 m& h8 e4 [8 C - $data[] = $doc;; s/ z# M) B: p7 D( q
- }4 q) U3 c% u9 d7 R
- echo '<pre>';
5 ?) _* O4 i6 `5 q, ~7 V2 r8 B - print_r($data);
复制代码 数据修改: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');/ Y. `" u& b g/ Y' V. @% u
- $bulk = new MongoDB\Driver\BulkWrite;
. i8 E- P7 b+ n6 ?( F% N - $bulk->update(
$ E1 p" Q$ R3 D2 O9 c% e - ['name' => 'JetWu5'],( F, v" `* J( o, D: ]0 Q; b& [
- ['$set' => ['age' => 30, 'promise' => 'always smile!']]
: h* I% f9 D* h9 j - );
1 p! K: H8 [3 [! R a+ q6 D - $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认# J7 f! M. N$ ^* G4 l
- $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);# _; `* p& T8 Y4 z: j+ n. N
- echo '<pre>';
" ]. Q) ]+ V" b) \. `5 Z& o6 z - print_r($res);
复制代码 数据删除: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
' j8 b& @; v6 f; h: B - $bulk = new MongoDB\Driver\BulkWrite;0 D- @9 s4 V% g, K
- $bulk->delete(['name' => 'JetWu3']);& w$ C! [# i0 ]1 u) q- |+ s! `
- $bulk->delete(['name' => 'JetWu4']);! e* P# S4 B( Q4 f
- $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认' t1 ~) ^$ G5 K$ c2 H& L: j% p
- $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);7 v/ f: }& U( P% v2 w5 y
- echo '<pre>';, M, ?/ k c' C0 ^" u
- print_r($res);
复制代码 4 ^) F8 F$ U: H# g: S& Q6 G2 s' m# L
7 E: _8 W. h( L& C; `# _
/ I. M d6 D) h! y+ m
0 X: I+ b% X; F2 c
( _1 g) o0 [3 p2 G0 i5 f. ] |