MongoDB的PHP驱动提供了一些核心类来操作MongoDB,总的来说MongoDB命令行中有的功能,它都可以实现,而且参数的格式基本相似。PHP7以前的版本和PHP7之后的版本对MongoDB的操作有所不同,本文主要以PHP7以前版本为例讲解PHP对MongoDB的各种操作,最后再简单说明一下PHP7以后版本对MongoDB的操作。 一、数据插入 - //insert()
3 N' d; Y5 ?4 y. N& i - //参数1:一个数组或对象
1 i( [7 `% U& `* W* Q - //参数2:扩展选项
% P+ o5 S) I' a" U - // fsync:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入硬盘7 O- F+ V5 ]7 q
- // j:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入日志
# q' O# X* o' g" @1 Z7 T* C! R: }: l - // w:默认为1,写操作会被(主)服务器确认,若为0则将不会得到确认,使用复制集时设置为n用于确保主服务器将数据修改成功复制到n个节点后再确认9 Q' }. Z1 b" `0 N% |
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
0 Y4 h) o! j6 H) V7 D - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)% o7 }9 b8 r) I h
- $mongo = new MongoClient('mongodb://localhost:27017');. U3 n5 s- v& e* @$ l2 O8 P- A* c
- $db = $mongo->mf;//选择数据库
0 V& ]0 ?% Y. j - $collection = $db->friend;//选择文档集合
4 N6 c+ K; m# G$ V3 S2 b% p - $doc = [//定义一个文档,即一个数组0 w ^2 l; @+ [" Z( b0 Y# @
- 'First Name' => 'Jet',
) F( s' f2 A7 `' @9 W% _ K - 'Last Name' => 'Wu',
+ F6 N' p5 V3 G9 ~ - 'Age' => 26,4 O j5 Q8 W% Y' m* R5 r
- 'Phone' => '110',
2 m& K) `% T2 {' }" K" d - 'Address' => [
* y$ w- h, N: X2 ?! @ - 'Country' => 'China',
; {" `/ h7 v4 B - 'City' => 'Shen Zhen'' }: b' r1 E' I7 m
- ],
. h& Z: b- }' K1 a" u3 O - 'E-Mail' => [+ p" W# X3 ^8 _$ P' I) b, T
- '123456@qq.com',% Y2 c# g+ w' G" x
- '666666@sina.com',( L! n, @1 X9 R
- '8888888@qq.com',
4 n1 i1 T6 _: l& b3 }, A9 b& a) S - '77887788@qq.com'
1 ~5 l0 u% [( d1 F! W3 Q7 t$ c - ]
5 X6 [% R$ O% f/ U - ];
* i/ I( L. J. L: g N - $res = $collection->insert($doc);//向集合中插入一个文档& E2 V8 e" O$ P
- echo '<pre>';, w* ^/ x2 `; ?9 a% j
- print_r($res);//$res['ok']=1表示插入成功
复制代码二、数据查询 1. 查询单个文档: - //findOne()
9 u U1 V$ B2 v% _0 X: p; i6 F - //参数1:搜索条件
0 g y$ M, {, M( u$ y- l - //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非在第二个参数显式加入'_id'=>false。不设置则返回所有字段# F+ r) h2 e. r! ~4 g W
- $mongo = new MongoClient('mongodb://localhost:27017');% k, ?( @5 P5 l e: Z
- $db = $mongo->mf;
0 L6 a" d/ O6 Q8 ^. j; G9 M+ ^ - $collection = $db->friend;
& d9 Q& s( Y3 @' c! R9 F( _ - $one = $collection->findOne(['First Name' => 'Jet']);1 n) q2 G; u( m9 ~* m5 r) P
- echo '<pre>';9 F [' x' [+ S3 w8 m
- print_r($one);//返回一个数组,查不到数据则返回NULL
复制代码2. 查询多个文档: - //find()
( g; n: Q8 f8 t! | - //参数1:搜索条件/ \* n- P* ~" Y$ J- G( r) J
- //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非显式设置为false不返回。不设置则返回所有字段
* G" Z8 C1 |( u/ x5 C - $mongo = new MongoClient('mongodb://localhost:27017');
- w! N. I3 @4 }' \ - $db = $mongo->mf;
) b$ [! h% V& x2 v/ [/ d - $collection = $db->friend;+ y: ]/ p% D' B4 ~" y
- $cursor = $collection->find(['Address.Country' => 'China']);//使用点操作符查找数组元素
) q3 f3 I# f* U - echo '<pre>';
8 r. X. v2 G& K5 l A - while($doc = $cursor->getNext()) {//循环读取每个匹配的文档
1 _6 K8 f$ y' ^* P - print_r($doc);. R" M' O, t: g; [& ^! b
- }
复制代码使用各种条件操作符定义查询: - //mongodb分别使用$lt(小于)、$lte(下雨等于)、$eq(等于)、$gte(大于等于)、$gt(大于)、$ne(不等于)表示<、<=、=、>=、>、<>,用于整数字段查询! x* H7 ^; v' j" B0 M. J% G
- $mongo = new MongoClient('mongodb://localhost:27017');# n( Y+ }! j6 H) J! X1 Q- t
- $db = $mongo->mf;3 O2 g# Z! t6 \! H7 }9 e2 {
- $collection = $db->friend;+ d. X: S3 J& p; y2 W/ q
- $cursor = $collection->find(['Age' => ['$gt' => 30]]);# r c3 c1 U# [( ~$ r0 z a" j p1 R
- echo '<pre>';7 j' g/ Y8 v7 V* Q
- while($doc = $cursor->getNext()) {! t9 m" O% A4 d7 ~; X
- print_r($doc);5 X* N0 m) q a1 T
- }
复制代码 //查询某个字段的所有不重复的值
; f3 P) C/ O+ I# e: Z6 _ $res = $collection->distinct('Age'); - //$in:匹配多个值中任意一个
/ C8 G4 _% Z) ?% S* x4 ?. K - $cursor = $collection->find(['Address.Country' => ['$in' => ['China', 'USA']]]);
, d! j4 w0 i# c( v - ( u" l3 _2 b4 Z- r2 ^- d
- //$all:匹配多个值中所有值(用于数组字段查询)) z2 t% @6 V4 j
- $cursor = $collection->find(['E-Mail' => ['$all' => ['123456@qq.com', '77887788@qq.com']]]);, ~# U. z/ [4 v6 b
-
/ `& M$ \; ]& `2 P: g - //$or:或查询0 a3 p' H* l. M6 F. v7 ~) a: P
- $cursor = $collection->find(['$or' => [['First Name' => 'Jet'], ['Address.Country' => 'USA']]]);) L" l6 |, w" y7 t1 I y3 l2 A
-
' v" g. J) w2 l6 M" k! H - //$slice:获取数组字段中指定数目的元素,位于find()函数第二个参数中, }( _7 o% r b6 e0 k
- $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => 2]]);//只返回前两个email, e8 L M5 j% c8 G' C7 x' }; m* I1 h
- $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => -2]]);//只返回最后两个email
% o) S* r- ~1 E* [6 Y - $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => [1, 2]]]);//忽略第一个,返回接下来两个7 ]9 o+ s4 X* J: Y! S& i7 k& T2 U, Y
-
9 F4 N5 s2 \/ @) G# c - //$exists:根据某个字段是否有设置值进行查询
9 W+ w& Q0 [+ b/ e1 f - $cursor = $collection->find(['Hobby' => ['$exists' => false]]);//查找Hobby字段未设置值的文档- d" u, ~" ]7 R
- / W" o0 D. c+ s/ `" r
- //正则表达式查询* n/ Z) X5 ~5 z- Q. |+ g" W+ w( a
- $cursor = $collection->find(['First Name' => new MongoRegex('/^Je/i')]);//查找First Name字段以Je开头的文档,忽略大小写差异
复制代码使用MongoCursor类提供的其他函数: - //排序:1升序,-1降序) U9 a* r: k) D
- $cursor->sort(['Age' => 1]);
+ P( b/ O; S/ V - : [8 E A* b2 v; A5 D
- //忽略前n个匹配的文档
$ h3 Z" Z7 D. [ - $cursor->skip(1);! c1 v$ I5 G Q9 I: _
- % e2 K. O. @0 ^
- //只返回前n个匹配的文档(limit()与skip()结合使用可实现数据分页功能)
8 B- J1 l( F1 r; w+ W8 z7 ^6 ? - $cursor->limit(1);
$ e/ f- ^6 B# j: c - ( k& G7 p! m+ ]
- //匹配文档的总数4 Q7 r5 g5 N2 D# n: J9 c8 Q
- $cursor->count();1 x' G5 j' U @ D, s. ^) a3 r
-
9 |1 ~- l5 o1 y5 o - //指定查询索引
1 l) e3 p6 C; m+ Z- h - $cursor->hint(['Last Name' => -1]);//若索引不存在则会报错
复制代码聚集查询:对数据进行分组统计 - //聚合查询:对数据进行分组统计
. l0 f/ \- q( A' d" }5 Q/ P/ O - $mongo = new MongoClient('mongodb://localhost:27017');
& w4 p( b4 s5 r- |$ s; D) z. S - $db = $mongo->mf;
0 A1 n2 W+ E; y) D' r3 p+ E$ c- b7 A: L( y - $collection = $db->friend;) e2 ~1 o$ a: y0 s |0 P8 D
- $res = $collection->aggregate([+ t, U& P R/ ?5 G/ C$ R
- '$group' => [6 D" j, h' ^4 I5 f
- '_id' => '$Address.Country',//分组字段,注意要加上“$”,这里是根据数组字段某个元素值进行分组
# d. l$ h# ~* |6 d* p - 'total' => ['$sum' => 1],//求总和,表示每匹配一个文档总和就加18 O( w$ H0 d: I* E2 E/ D& F4 A
- 'maxAge' => ['$max' => '$Age'],//分组中Age字段最大值8 P, Q& Q3 B6 Y( H
- 'minAge' => ['$min' => '$Age']//分组中Age字段最小值
8 b3 E/ V! k# { - ]8 U8 t7 q( _' m, k" P6 l0 o
- ]);# h \( e) V+ w" z4 G% I) y
- echo '<pre>'; {' F, {: f9 ^
- print_r($res);//返回一个数组,$ret['result']为数组,存放统计结果
/ t5 y1 O; u3 O" L, A9 i/ ` - 3 U0 `% K: M4 o2 c7 l" a
- ) q, N% l6 ?* W' B
- //存在其它操作的聚合查询:多个操作之间执行先后顺序取决于它们位置的先后顺序
# E8 F3 Z* N8 f' a- m$ }( K: z: [ - //聚合查询中的所有操作,包括'$group'在内,都是可选的。
) Y: |4 o( P; }* a& Q3 m - $mongo = new MongoClient('mongodb://localhost:27017');* U) j8 m- e4 Y/ h3 A0 b* x, a
- $db = $mongo->mf;
7 ]7 l1 u8 [& z, p' d. e& o9 T - $collection = $db->friend;
5 e! ?1 Y$ U0 E f - $res = $collection->aggregate([
) B# |. U$ J+ h - [//过滤条件:只对符合条件的原始文档进行聚合运算,若是放在'$group'之后则是只返回符合条件的结果文档
M( P/ j4 V) x1 N - '$match' => ['Age' => ['$gt' => 30]]
2 c _/ y$ v9 W - ],
# ~/ p/ n& m. S0 O$ ? - [//指定分组字段、统计字段( R# s: T$ Z* Q5 a# k& ?
- '$group' => [
/ n! _9 _; u' }2 c/ J& E- _) O - '_id' => '$Address.Country',& ?& d& q. y! L' d" K
- 'totalAge' => ['$sum' => '$Age']//计算各个分组Age字段总和
) }9 f1 K- i8 n5 b" ] - ]! J5 Z+ A# i! U7 k7 n, C2 b
- ],
+ H7 d+ D3 g) t$ `- V4 e2 P - //以下操作若是放在'$group'之前则在聚合前作用于原始文档,若放在'$group'之后则在聚合后作用于结果文档
# a% F4 k% G' p) f7 E6 [ - ['$unwind' => '$E-Mail'],//将包含有某个数组类型字段的文档拆分成多个文档,每个文档的同名字段的值为数组中的一个值。
8 i2 m& s" D/ r4 q3 y0 t" Q5 s$ M - ['$project' => ['myAge' => '$Age', 'First Name' => '$First Name']],//指定返回字段,可以对字段进行重命名,格式:返回字段名 => $原来字段名
% k$ D- l0 T; c$ G$ N - ['$skip' => 2],//跳过指定数量的文档6 Q. v6 S6 A9 p# C6 z
- ['$limit' => 2],//只返回指定数量的文档
$ e: g0 B" I" Z2 ]. t% J2 _" \' z - ['$sort' => ['totalAge' => 1]]//排序
A8 T8 u( ?4 L" G - ]);/ M) H9 x& f* ?, l- `2 F
- echo '<pre>';
: b9 R$ j' ~6 p+ n- e - print_r($res);
复制代码
; V# j8 D. L6 b' A7 q三、数据修改 - //update()% q4 H: f& j) d' \: O. z% K
- //参数1:更新条件,指定更新的目标对象。1 Z0 @1 S, H! r8 C! u8 v% P
- //参数2:指定用于更新匹配记录的对象。4 d5 `# V. v8 X$ _* `
- //参数3:扩展选项组。
D1 K1 P1 W/ H/ d* R) E; I# z0 N - // upsert:若设置为true,当没有匹配文档的时候会创建一个新的文档。2 `( s8 }4 o& ?6 D; ?
- // multiple:默认为false,若设置为true,匹配文档将全部被更新。! l* l4 j) _' G5 N# d
- // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。
( c7 H! F+ U- ^# |4 r - // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作# R, ?1 b0 t2 W
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。
+ Y$ D* D- m) D: l: l - // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
' O' \% ]8 q5 U; [2 A9 N - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)5 _8 v0 F2 g, P! O4 B9 u- ~: [) Q
- //注意:若不使用任何修改操作符,则匹配文档将直接被整个替换为参数2指定的对象。
3 ~' a+ t* C7 z5 B1 B/ w - ) q' U- P! r, }9 {, ^2 w
- //$inc:增加特定键的值,若字段不存在则新建字段并赋值* ` L, m& k7 V
- $mongo = new MongoClient('mongodb://localhost:27017');* m p# a1 `( H' A
- $db = $mongo->mf;
2 g2 Z- i s8 f; G0 t - $collection = $db->friend;
P6 |( H! Q& [ - $res = $collection->update(['First Name' => 'Jet'], ['$inc' => ['Age' => 2]]); A& W {* q" \- t- u$ J- S* b. V
- echo '<pre>'; U# s: w# A# m- V; y0 s
- print_r($res);//$res['ok']=1表示修改成功,$res['nModified']表示修改的文档数量
, Y' ]! ~8 `+ f" G2 S* U- n -
. X7 ]/ T S$ n6 o) \: R - //$set:重置特定键的值,若字段不存在则新建字段并赋值
1 u) m1 e* P, I: O/ J! F - $res = $collection->update(['First Name' => 'Jet'], ['$set' => ['Hobby' => 'pingpong']]);0 h8 v: J( J% M( c* s( P7 h
-
7 i* R' j+ t" A5 L# n - //$unset:删除字段
2 c2 F. w( y& }+ p& I) M - $res = $collection->update(['First Name' => 'Jet'], ['$unset' => ['Hobby' => 1]]);' @8 E4 [, }: _. B9 @- `
- 7 U3 E- V9 Z* |- A
- //$rename:重命名字段,若字段不存在则不进行任何操作
! ]" t6 H5 |( U$ D& H - $res = $collection->update(['First Name' => 'Jet'], ['$rename' => ['Hobby' => 'hobby', 'Age' => 'age']]);* f, ]* V. [% K% V' q8 S; j3 C& g
- //注意:如果文档中已经使用了指定名称的字段,则该字段将会被删除,然后再进行重命名操作。( a7 I4 m f+ Y. M B
-
- t: M& R% G, S$ M/ D _ - //$setOnInsert:设置了upsert为true,并且发生了插入操作的时候,将某个字段设置为特定的" X! H9 \0 q# q; u9 }! W! g' c
- $res = $collection->update(['First Name' => 'jet'], ['$setOnInsert' => ['lang' => 'English']], ['upsert' => true]);, I0 }" [0 g t% D! U
- 3 I6 v0 X9 I+ x6 w" t, n5 M
- //$push:向指定字段添加一个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错! P2 d; j# w' C8 s% T
- $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '123123@qq.com']]);
Q& I+ ~, o- \' g -
n) P& d. M7 W2 a1 } - //$push:向指定字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错0 ]8 f5 j4 I6 y5 G* j
- $res = $collection->update(['First Name' => 'Jet'], ['$pushAll' => ['E-Mail' => ['666@qq.com', '8888888@qq.com']]]);/ x5 f1 g+ _" |1 u
- ( F! B6 q: k4 T0 Y. l" v# d: Q! A* \
- //使用$push和$each向某个字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错
/ R, m* f: o- E9 x - $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);
* L5 c* I/ Y4 s" a6 j -
$ e; B) A+ I% I4 q" U - //$addToSet:将数据添加到数组中(只在目标数组没有该数据的时候才将数据添加到数组中)3 L8 q" I9 v/ j* n4 u
- $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => '123123@qq.com']]);
; @1 y+ R6 f/ N4 T A - $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);
" L8 a+ w3 ?* b) f, R" d+ S1 O- U1 y. f -
' V$ A0 d7 x6 l; N - //$pop:从数组中删除一个元素,-1表示删除第一个元素,1表示删除最后一个元素(其实负数都删除第一个元素,0或正数都删除最后一个元素)
r. i; Q s& B+ k- i( R. F - $res = $collection->update(['First Name' => 'Jet'], ['$pop' => ['E-Mail' => 1]]);
9 n( n6 w. d5 i+ A5 Y: t x! Y - 0 e! l( h" a+ ?/ J2 u; I" ~/ ^
- //$pull:删除数组中所有指定值
: t" N: G, v' W: Q5 K# j - $res = $collection->update(['First Name' => 'Jet'], ['$pull' => ['E-Mail' => '123123@qq.com']]);) m- b) v2 ^4 u u; \& x
- 7 l( }2 ?) y( S
- //$pullAll:删除数组中多个元素的所有值$ b: F8 A+ d! Z/ D+ A/ t: @
- $res = $collection->update(['First Name' => 'Jet'], ['$pullAll' => ['E-Mail' => ['123123@qq.com', '666@qq.com']]]);
复制代码- //save()' Z, p" U1 F+ W
- //参数1:希望保存的信息数组
( z* j# a* q! M2 @, F - //参数2:扩展选项
- B* l& X; g: \2 n. m9 P) t, I" | - // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。" @+ ?( L5 S2 F* a3 g, @0 D
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作7 [1 c/ _9 g+ o( U7 i$ e
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。, {' d9 q3 K5 ] x* p
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间* S ?7 R/ j, v& Q
- // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
% k5 }& a6 p, P/ D( _, j - //注意:若已存在则更新,若不存在则插入;更新时使用参数1指定的信息数组替换整个文档。! s/ Y. |' ^0 k9 Y; k
- //若想更新则应该在参数1中指定_id键的值。# E% y; R7 @9 p! e" O
- $mongo = new MongoClient('mongodb://localhost:27017');
7 B, Q* e1 z/ {. z/ `$ c5 z, r - $db = $mongo->mf;! t% P0 l; b$ O( w4 X [
- $collection = $db->friend;
$ n7 d1 _2 b, [ ? - $doc = [//定义一个文档,即一个数组3 Q4 N) ^4 Y( s+ X3 Y
- 'First Name' => 'Jet',
, @! j1 l9 U7 ~2 V4 r - 'Last Name' => 'Wu',
: A0 Z+ F& d5 Q* Z/ w; H6 |9 h8 @$ J - 'Age' => 26,
/ b% x/ l9 W# p) H - 'Phone' => '110',
9 F+ B0 h5 A5 e0 I0 a - 'Address' => [" v0 J6 a* a! l7 w, |; r% ?# a
- 'Country' => 'China',
3 c& E4 F/ o& S7 X. \- ^ - 'City' => 'Shen Zhen'9 h) Q3 r, Z% J5 _
- ],1 T, q- b) _: v9 R; }4 |) @& r9 G
- 'E-Mail' => [
6 `, o! q- K s9 m" h- F# m - '123456@qq.com',
( l8 K% E' D: v- k - '666666@sina.com',2 ^2 C; k5 y3 W6 |* [* V# V
- '8888888@qq.com',9 j# a9 b! P) b/ s9 J% {. }, t$ S
- '77887788@qq.com'
( b7 N, C4 P! } - ]. T& l# H/ `# g, a' L$ w
- ];2 K8 U: |) A/ J+ E
- $res = $collection->save($doc);
) _4 n- G$ n, o# @+ ] a: ` - echo '<pre>';; t; i K9 [ y' r; _) V
- print_r($res);//$res['ok']=1表示操作成功,$res['updatedExisting']=1表示更新,$res['upserted']=1表示插入
4 N) s+ p" { d& o5 f+ U - ; e. q& C+ E$ e) \, j- D
复制代码- //findAndModify()
0 r' e9 Q+ `: Q4 h( \+ [5 V* Y5 P - //参数1:指定查询条件
9 Q) w- v8 A) x - //参数2:指定用于更新文档的信息
+ V) j( O& ~) ^; n& Q! G - //参数3:可选,指定希望返回的字段
) U; t6 G) \! l. b( V9 k$ n - //参数4:扩展选项
. `3 k T8 @$ S, Y9 Y- ]1 D% w - // sort:以特定顺序对匹配文档进行排序
& a" [8 U1 B; Y7 V& ^2 U0 t - // remove:若设置为true,第一个匹配文档将被删除
( \( S [' W3 C ]: p/ I9 h9 z0 ^ - // update:若设置为true,将在被选择的文档上执行更新操作5 U) c1 v6 k7 d8 R" D8 p( g6 E H
- // new:默认为false,若设置为true则返回更新后的文档,否则返回更新前的文档
: e% h9 O4 ~2 ~1 F' P6 }$ C - // upsert:若设置为true,没有找到匹配文档的时候将插入一个新的文档- o& ^- P# T* w2 ?) ?) O" U* I
- $mongo = new MongoClient('mongodb://localhost:27017');
7 A2 N% j& L& x - $db = $mongo->mf;$ ^# K4 F# q7 }5 B, d0 [% h
- $collection = $db->friend;
% {$ s2 |( E- Z6 I - $res = $collection->findAndModify(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '111@qq.com']]);
; z$ u% c* A" ?5 l6 m& {' x$ m7 k - echo '<pre>';
+ P/ P9 v1 B8 @% F( A: t# ~ - print_r($res);
复制代码 四、数据删除 - //remove()$ W. {; R1 S" c! A' C. s+ _: j; T
- //参数1:查询条件
! `) i" x* j5 J, R - //参数2:扩展选项& W$ z; y1 R9 F i
- // justOne:若设置为true,则最多只有一个匹配的文档将被删除
, H) w7 v2 t7 @ u - // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。6 M: Z3 r: h& W9 `3 f/ ^. D1 ~
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作
: u$ u3 c4 B* ]' T - // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。
]4 T$ B" @& @, J' n2 w - // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间/ p" x; W( {; f4 V) j2 y4 i3 F2 S
- // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)+ f# J; `" S3 A: t! ]+ ~- a
- $mongo = new MongoClient('mongodb://localhost:27017');, X. a3 _! G& \# v* n
- $db = $mongo->mf;+ Z0 s3 z0 ]( G! o/ d2 ~6 |
- $collection = $db->friend;% k$ e6 ^8 n& R, R% J% {, F
- $res = $collection->remove(['First Name' => 'jet']);
+ b+ m! ~6 W1 j. B/ C - echo '<pre>';/ Q. M8 p8 c! r: Y* D
- print_r($res);//$res['n']表示删除了几个文档
复制代码
% S+ F# R$ B/ C Q- d) R以上是PHP7以前版本的MongoDB操作,下面简单介绍PHP7以后版本的操作。
% O5 @; z& N/ N& w+ O- A% I# A3 k' z-----------------------------------------------PHP7分隔线---------------------------------------------------------------------
* ^. Q# v9 @/ t数据插入: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');1 ?; [2 c3 o( ]5 {( Z: N
- $bulk = new MongoDB\Driver\BulkWrite;
4 Z0 s1 {0 X7 i' m5 l. Z - $bulk->insert(['name' => 'JetWu5', 'age' => 26]);
: U1 w7 `( c, w8 x - $bulk->insert(['name' => 'JetWu6', 'age' => 26]);. Q6 A3 g- l1 a/ x, j. d
- : e8 T! n7 Q- \: F7 r8 l j5 v
- $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认! q/ g# q' D! Z7 N7 ]) N. a1 z+ }
- $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);+ @3 N+ g! Y, C0 g; V' J4 Q
- echo '<pre>';
8 T) X( E/ z+ h: {7 ~: A/ Z. G - print_r($res);
复制代码 : N3 C8 @6 R) n: ^7 ?( J9 u
数据查询: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');5 M' z1 n6 h& I Z
- $query = new MongoDB\Driver\Query(['age' => 24], ['sort' => ['age' => 1]]);
3 q) _" ^' M5 m; }3 g: z - $cursor = $manager->executeQuery('wjt.friend', $query);) r+ {& j; }& M# S7 i
-
# ~; B+ e# Q0 ^) L |9 H - $data = [];+ A L) a; c$ j) t
- foreach($cursor as $doc) {
' a0 `' i. K+ ]. L/ w* \/ ~9 | - $data[] = $doc;( t z, d p H# _$ @- w! K
- }
' o) P& K. L$ S. N! e& T: n - echo '<pre>';
' S$ u9 l+ z/ i8 e - print_r($data);
复制代码 数据修改: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
. _7 F& u% @. \0 m7 v9 G - $bulk = new MongoDB\Driver\BulkWrite;$ E' s9 E! G# _% |/ G3 J' y. L
- $bulk->update(
! D6 k) k% H ?5 {2 r2 ] - ['name' => 'JetWu5'],
; t( \9 p' t( U1 K$ D' f - ['$set' => ['age' => 30, 'promise' => 'always smile!']]) d6 w# F7 G: ~( }9 s" W
- );+ \/ W1 c% y: |3 U3 X
- $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认4 }- }- [ Q: [
- $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);" ]% l8 K/ N( x& N
- echo '<pre>';6 |9 i) H0 H+ I! H& e0 w
- print_r($res);
复制代码 数据删除: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
4 q8 T* z& i& _: R+ K! { - $bulk = new MongoDB\Driver\BulkWrite;+ N% [: k0 X+ R. A" z
- $bulk->delete(['name' => 'JetWu3']);
o! ?+ E8 @7 K2 A: z: d. X8 ? - $bulk->delete(['name' => 'JetWu4']);
, t8 }, @, y! h- M* |% H2 H- h% j2 c - $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
5 f. z8 z- `0 b( `3 z) S - $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
, Q+ \6 \" Y% K - echo '<pre>';! Y; z) g6 q8 q; U
- print_r($res);
复制代码 7 s7 p/ G6 U( S8 Q' z
( P* k/ Z5 J) X- u
8 y l1 p8 @# `1 I; P* C2 k/ B# v' l, Y4 ^+ ^. w3 j+ G [* h
( g6 f6 H3 O4 B |