MongoDB的PHP驱动提供了一些核心类来操作MongoDB,总的来说MongoDB命令行中有的功能,它都可以实现,而且参数的格式基本相似。PHP7以前的版本和PHP7之后的版本对MongoDB的操作有所不同,本文主要以PHP7以前版本为例讲解PHP对MongoDB的各种操作,最后再简单说明一下PHP7以后版本对MongoDB的操作。 一、数据插入 - //insert()2 n4 l, p. [) }2 m6 {% t2 S6 L. m
- //参数1:一个数组或对象3 q8 ^' U) R% r. W2 G
- //参数2:扩展选项0 s" Q7 x1 r3 J% a2 n
- // fsync:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入硬盘
: e' I. r! E5 a& J - // j:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入日志
' X! V" y9 m1 q+ L- @0 E' u - // w:默认为1,写操作会被(主)服务器确认,若为0则将不会得到确认,使用复制集时设置为n用于确保主服务器将数据修改成功复制到n个节点后再确认8 l. t0 q% Q0 T1 \, w, h* R. Z2 J. H% y
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
; L- o, H4 ?7 |" Z - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
1 G( v+ E! I- t8 @; d - $mongo = new MongoClient('mongodb://localhost:27017');
! a8 E* t/ e* C1 q - $db = $mongo->mf;//选择数据库
( g; p6 h/ O& g - $collection = $db->friend;//选择文档集合
) F9 p8 l9 i* G$ X - $doc = [//定义一个文档,即一个数组
0 T5 i6 B# y/ B: Q; T; ?# p - 'First Name' => 'Jet',8 S. e( O+ E6 Y9 e. S
- 'Last Name' => 'Wu',0 u: [" x& t/ b2 k" \
- 'Age' => 26,
1 ?' ?. v3 X& q - 'Phone' => '110',
) u0 V* ]2 k' X# O* z4 d( A - 'Address' => [
/ h+ L1 d% ]) _, F2 U1 n7 P. _ - 'Country' => 'China',
* f7 ~5 y$ N) l7 X7 ]7 b - 'City' => 'Shen Zhen'" X" i3 q' T, T" `
- ],3 ]$ t1 O: v0 A% L; C
- 'E-Mail' => [$ x# B; `: r+ J3 W+ B& Y9 K9 t
- '123456@qq.com',
0 O" n; h, q: h - '666666@sina.com',
( {7 w. {$ j! E" Q7 E1 ?0 M - '8888888@qq.com',
$ s" G' G" ^. J3 X B+ { - '77887788@qq.com'
0 U9 l1 z" ^% h* }9 [* S - ]/ T+ R4 Z3 E; f" w
- ];
/ h0 D' ?: h, a0 m - $res = $collection->insert($doc);//向集合中插入一个文档. L _& r. l4 t. E- S
- echo '<pre>';3 L3 A+ A- d3 a. C0 z
- print_r($res);//$res['ok']=1表示插入成功
复制代码二、数据查询 1. 查询单个文档: - //findOne()9 F5 k8 D' T7 e' u
- //参数1:搜索条件
! q5 q2 x: F0 I - //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非在第二个参数显式加入'_id'=>false。不设置则返回所有字段
) n, Y; p% _, s- b8 k/ s, [% v - $mongo = new MongoClient('mongodb://localhost:27017');
+ e1 g) F9 a; y3 F - $db = $mongo->mf;
; k9 _# E @( u8 c4 c( Y - $collection = $db->friend;& y7 y3 A+ [& L/ s& H! m' N- [
- $one = $collection->findOne(['First Name' => 'Jet']);2 e. q6 v7 N* g# R; P
- echo '<pre>';! z/ |# A3 |5 o
- print_r($one);//返回一个数组,查不到数据则返回NULL
复制代码2. 查询多个文档: - //find()
7 S2 t: J+ a9 U3 F' X" m6 J - //参数1:搜索条件2 M _, }8 L7 t1 _& M. }# o4 x
- //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非显式设置为false不返回。不设置则返回所有字段1 k: \0 |% I$ c7 l: E) j/ j
- $mongo = new MongoClient('mongodb://localhost:27017');/ P3 A s& P! q' T$ o' W
- $db = $mongo->mf;
/ P" {# \: T# z1 B8 H - $collection = $db->friend;
7 W- {* i9 ?+ n7 V - $cursor = $collection->find(['Address.Country' => 'China']);//使用点操作符查找数组元素$ ]7 H0 c) j# C1 T: g7 \: _
- echo '<pre>';
- g4 L/ P4 H2 C% l - while($doc = $cursor->getNext()) {//循环读取每个匹配的文档
2 |) O: b: i8 y$ _ - print_r($doc);
4 k6 H( w0 E N( i7 c$ z0 j4 b - }
复制代码使用各种条件操作符定义查询: - //mongodb分别使用$lt(小于)、$lte(下雨等于)、$eq(等于)、$gte(大于等于)、$gt(大于)、$ne(不等于)表示<、<=、=、>=、>、<>,用于整数字段查询
* u/ a; E/ y6 D' |* N% x4 o - $mongo = new MongoClient('mongodb://localhost:27017'); z, t) v9 X1 ?- B! B2 v
- $db = $mongo->mf;
# g! ?2 h0 s; H8 }+ i g - $collection = $db->friend;
" l5 g4 U4 I5 M$ f" D: e - $cursor = $collection->find(['Age' => ['$gt' => 30]]);
0 |! h+ n3 T9 h) ^+ D - echo '<pre>';
& E6 W& B5 A0 u" [: b; t0 @ - while($doc = $cursor->getNext()) {
( k7 b0 ~# h& U - print_r($doc);& g( a& [6 Z% i i3 }0 Y# e
- }
复制代码 //查询某个字段的所有不重复的值
2 O2 G$ I2 Y: l3 x5 J $res = $collection->distinct('Age'); - //$in:匹配多个值中任意一个! r3 C6 X& i/ j- O
- $cursor = $collection->find(['Address.Country' => ['$in' => ['China', 'USA']]]);
/ O; j( O2 E( d* e% D - 6 @ S1 o w- Y h
- //$all:匹配多个值中所有值(用于数组字段查询)
$ \5 ^! h( O: Y/ ^ - $cursor = $collection->find(['E-Mail' => ['$all' => ['123456@qq.com', '77887788@qq.com']]]);
2 r @. `+ K( P -
/ }! z" V& Z+ I - //$or:或查询
! r5 J8 U2 i# _0 ?; L - $cursor = $collection->find(['$or' => [['First Name' => 'Jet'], ['Address.Country' => 'USA']]]);! o$ K6 X& k. c _. N/ R% s+ I
- 2 G8 J x5 B4 t) \) [& A3 i0 o. H
- //$slice:获取数组字段中指定数目的元素,位于find()函数第二个参数中
% }% o* w. O+ J4 D8 R - $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => 2]]);//只返回前两个email
% P+ z. c" }& r$ \- n( N - $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => -2]]);//只返回最后两个email9 w! W* D5 \* T9 _" B
- $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => [1, 2]]]);//忽略第一个,返回接下来两个) N; t+ z9 U! L. w
-
- U7 B7 M( c# M - //$exists:根据某个字段是否有设置值进行查询* Z0 Z4 ~) L7 W; Q3 ~( F8 i! Z" R2 T
- $cursor = $collection->find(['Hobby' => ['$exists' => false]]);//查找Hobby字段未设置值的文档$ P5 d5 _! R1 S' v3 {6 |" p- P
- 8 ]/ N5 U* M" |
- //正则表达式查询- V# n, Q; N& Z& n R
- $cursor = $collection->find(['First Name' => new MongoRegex('/^Je/i')]);//查找First Name字段以Je开头的文档,忽略大小写差异
复制代码使用MongoCursor类提供的其他函数: - //排序:1升序,-1降序) Z; U* U. ]2 M
- $cursor->sort(['Age' => 1]);
+ I$ {) w% ?9 r* S1 }' p - + B- Q( P4 Q7 G# l2 a7 O* |* X
- //忽略前n个匹配的文档1 D8 {4 X3 e; ]6 m
- $cursor->skip(1);1 Z! B1 B! g- d% `
-
$ D) t+ K# M9 N1 ~) x. N8 m2 M2 u$ @ - //只返回前n个匹配的文档(limit()与skip()结合使用可实现数据分页功能)
. F1 t+ e$ I& M# L2 { - $cursor->limit(1);
8 ]0 b9 A6 j6 k1 ?: E8 a/ _; o - : y* S4 S( O& e
- //匹配文档的总数
4 y; _$ \& O# l: i; w - $cursor->count();) H$ I6 Q* C6 Q& o( S# b
-
" y% j4 E3 d/ x - //指定查询索引
& B7 R3 P: L% U7 ~ - $cursor->hint(['Last Name' => -1]);//若索引不存在则会报错
复制代码聚集查询:对数据进行分组统计 - //聚合查询:对数据进行分组统计
: K; H5 G5 q# V' A) d0 Y - $mongo = new MongoClient('mongodb://localhost:27017');4 A+ ^) w$ N+ Z; |- z
- $db = $mongo->mf;
$ M* l" q6 y& d. q2 I0 |' f - $collection = $db->friend;
0 u" h2 V- U3 S5 b - $res = $collection->aggregate([
9 G `9 D6 t3 c - '$group' => [
3 y3 n5 o. a5 _4 \/ {. E& Z - '_id' => '$Address.Country',//分组字段,注意要加上“$”,这里是根据数组字段某个元素值进行分组
! T4 c2 S! A" K2 _ l - 'total' => ['$sum' => 1],//求总和,表示每匹配一个文档总和就加1
2 e' y/ _8 @) A2 O7 s7 G7 V0 r) o: a - 'maxAge' => ['$max' => '$Age'],//分组中Age字段最大值2 G; D9 t- g" \8 f$ K" R3 ~
- 'minAge' => ['$min' => '$Age']//分组中Age字段最小值5 S* h$ E3 ?) X' W8 h9 O
- ]) K8 P8 B6 L2 \- a( ^' w7 y& K
- ]);
$ Y; C: b4 m! ? {: Y - echo '<pre>';2 J& r! e1 w6 j7 g7 L# c8 v' s
- print_r($res);//返回一个数组,$ret['result']为数组,存放统计结果9 a6 d7 S" p( t$ ]$ G
- * _3 H0 g, e# d* M) J
- ) D: v! J K0 V- ?; P
- //存在其它操作的聚合查询:多个操作之间执行先后顺序取决于它们位置的先后顺序
! v: e( M g' M2 {4 I - //聚合查询中的所有操作,包括'$group'在内,都是可选的。
2 E' H# y. N/ I* c6 s - $mongo = new MongoClient('mongodb://localhost:27017');
, D+ ]. i6 C' A7 L! ?3 m& x - $db = $mongo->mf;2 U, a4 m* }8 U. z6 `
- $collection = $db->friend;
* n+ P, ]8 V q; t, W [ - $res = $collection->aggregate([+ D" N3 Y+ g) E9 b0 V
- [//过滤条件:只对符合条件的原始文档进行聚合运算,若是放在'$group'之后则是只返回符合条件的结果文档0 G3 g$ Z# E, Q2 N$ ^% @
- '$match' => ['Age' => ['$gt' => 30]]2 |; u+ b j# S I4 M
- ],+ J4 V, A, x2 d3 ^
- [//指定分组字段、统计字段8 g, D) z% h8 Y( g! I% |2 s
- '$group' => [' b, {* S7 ?6 q$ b' X R t1 ?
- '_id' => '$Address.Country',8 g V0 ? G; k3 b8 H. E" l3 i! o
- 'totalAge' => ['$sum' => '$Age']//计算各个分组Age字段总和
) @, k5 E1 w4 a - ]6 m8 x0 U0 b$ _
- ],
( d2 Y& P! ~: f; V - //以下操作若是放在'$group'之前则在聚合前作用于原始文档,若放在'$group'之后则在聚合后作用于结果文档 n/ y& h. M& F; M8 G
- ['$unwind' => '$E-Mail'],//将包含有某个数组类型字段的文档拆分成多个文档,每个文档的同名字段的值为数组中的一个值。
0 }& |2 a0 v# q7 P - ['$project' => ['myAge' => '$Age', 'First Name' => '$First Name']],//指定返回字段,可以对字段进行重命名,格式:返回字段名 => $原来字段名 H! A5 A7 C) r) D
- ['$skip' => 2],//跳过指定数量的文档
! e* `$ v0 G5 [: _- P - ['$limit' => 2],//只返回指定数量的文档: R! B& D! {: q7 E7 Z
- ['$sort' => ['totalAge' => 1]]//排序
& c/ `. ^" K% l. L( _" A - ]);
4 w) p- n/ E. p9 T8 P5 |% C7 @! R - echo '<pre>';# w& C" V1 S; K; R" }5 H1 e {
- print_r($res);
复制代码
! J. T/ L% D6 O8 M- W: M/ s三、数据修改 - //update()
( b/ ^* f+ ]% C) E$ e - //参数1:更新条件,指定更新的目标对象。8 H% n* m- ^ h( ]5 G, ^# w9 ^8 c
- //参数2:指定用于更新匹配记录的对象。: b; x% j' a3 ^: c% ~) T8 u2 Y
- //参数3:扩展选项组。5 N T: I! A5 G: b
- // upsert:若设置为true,当没有匹配文档的时候会创建一个新的文档。
. l* d$ N, v( s+ q# d- _0 A. g - // multiple:默认为false,若设置为true,匹配文档将全部被更新。
' g4 m& g' n+ m- Q7 M - // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。* W6 O* u, L2 S
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作6 t8 K' x. a( q% N6 \- c4 W
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。4 p1 X# P) u. Y6 T- D4 \+ h
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间6 C ]+ \8 j1 ]
- // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
# A2 k4 g( U1 q5 q0 m& | - //注意:若不使用任何修改操作符,则匹配文档将直接被整个替换为参数2指定的对象。5 Z# s* s% L4 C& Y/ A' F3 d9 p
-
) C4 B0 a9 O4 r" k. F3 L7 Y' r3 D - //$inc:增加特定键的值,若字段不存在则新建字段并赋值; B! Y& h4 G( Y: F; W) c f
- $mongo = new MongoClient('mongodb://localhost:27017');+ N: D0 j( [4 m! V/ t
- $db = $mongo->mf;4 |& v3 k' J$ S/ E& D! b
- $collection = $db->friend;9 m/ I z2 b! z
- $res = $collection->update(['First Name' => 'Jet'], ['$inc' => ['Age' => 2]]);
6 V7 F% E$ ]3 H+ T2 d" c - echo '<pre>';% i& P4 U$ X: r. _7 }2 k+ N# I7 i8 g3 V
- print_r($res);//$res['ok']=1表示修改成功,$res['nModified']表示修改的文档数量3 O4 h. L3 v* I4 u6 R
- ( \9 ?" k, c9 V4 R
- //$set:重置特定键的值,若字段不存在则新建字段并赋值6 ?+ t4 {- c% [- A
- $res = $collection->update(['First Name' => 'Jet'], ['$set' => ['Hobby' => 'pingpong']]);
8 Z2 g( _: X' n- s) A; k! d - # |/ R( c, Y4 ?
- //$unset:删除字段; U9 j. r, X) t$ c6 K! R
- $res = $collection->update(['First Name' => 'Jet'], ['$unset' => ['Hobby' => 1]]);
* u# r$ f. q6 a* K% M6 ?* x1 } -
. {- t2 k" w* {9 ]: y( H' E& r: T - //$rename:重命名字段,若字段不存在则不进行任何操作& E& V% q( v5 o7 v, q
- $res = $collection->update(['First Name' => 'Jet'], ['$rename' => ['Hobby' => 'hobby', 'Age' => 'age']]);: _5 {1 Y' k# I* ~) S& D
- //注意:如果文档中已经使用了指定名称的字段,则该字段将会被删除,然后再进行重命名操作。
% i) X; ?9 C5 a& f' B, _# Q -
0 j4 C8 |! Y# {1 y) T4 @ - //$setOnInsert:设置了upsert为true,并且发生了插入操作的时候,将某个字段设置为特定的: n4 l1 ^, [9 C+ ]
- $res = $collection->update(['First Name' => 'jet'], ['$setOnInsert' => ['lang' => 'English']], ['upsert' => true]);
' ?& C5 h# n, J, ]5 D - " `; W3 s a8 w$ r: F S
- //$push:向指定字段添加一个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错; t" u0 |3 M/ _$ x- C g, S# N
- $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '123123@qq.com']]);' n* g8 B8 A! S* I; g, j* n) Y2 v
-
6 c h& B9 y1 u) v& Q - //$push:向指定字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错
$ I5 F, |9 R4 Z `' ~4 J2 g, Q - $res = $collection->update(['First Name' => 'Jet'], ['$pushAll' => ['E-Mail' => ['666@qq.com', '8888888@qq.com']]]);
* B" v# h& b" ]# k, C8 x3 H) _& S - t- [4 D: M4 E8 G
- //使用$push和$each向某个字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错
+ r+ ~, C: w. z0 k/ {! l8 v) a - $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);' }! W& I6 I( x1 `
- , Y4 v0 F6 L9 E5 ~/ Q; M
- //$addToSet:将数据添加到数组中(只在目标数组没有该数据的时候才将数据添加到数组中)" ]4 L G" `6 s
- $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => '123123@qq.com']]);. U/ W1 D/ R' s& O+ N3 f; `0 X& |
- $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);
4 T& r" v# b. [% \ - # T9 l" _& ^, L+ [
- //$pop:从数组中删除一个元素,-1表示删除第一个元素,1表示删除最后一个元素(其实负数都删除第一个元素,0或正数都删除最后一个元素)
I8 T' x E6 T# Y# \/ q - $res = $collection->update(['First Name' => 'Jet'], ['$pop' => ['E-Mail' => 1]]);) O" r; a6 T. n2 o+ B* c
- % g' ]$ q4 y5 e) g! J# W
- //$pull:删除数组中所有指定值7 i D0 ?6 q6 X: b/ ~2 M* l
- $res = $collection->update(['First Name' => 'Jet'], ['$pull' => ['E-Mail' => '123123@qq.com']]);2 A: ?6 E7 H; @) @" Z
-
, J Y7 ]* F5 ]$ M+ F0 k J - //$pullAll:删除数组中多个元素的所有值, I7 z Z2 j! S& r0 x' w
- $res = $collection->update(['First Name' => 'Jet'], ['$pullAll' => ['E-Mail' => ['123123@qq.com', '666@qq.com']]]);
复制代码- //save()# p. r4 F) v/ i% m5 o8 z
- //参数1:希望保存的信息数组
) |1 n" h9 W+ E7 r' O& l - //参数2:扩展选项
7 `8 V. l' a) A1 ?$ ? - // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。
' G( c! w# A: j( U% n+ F - // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作, F& r; f( M$ S i3 k
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。2 ~2 a& t+ U' C! y
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
p: F( j. Y7 @" w- ` - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
$ V3 i% Y: D" a - //注意:若已存在则更新,若不存在则插入;更新时使用参数1指定的信息数组替换整个文档。/ y/ \& s4 u2 h
- //若想更新则应该在参数1中指定_id键的值。) e7 W/ t' C i' |2 I+ l& A
- $mongo = new MongoClient('mongodb://localhost:27017');
: D6 h/ C$ `( y+ @- P( m - $db = $mongo->mf;
0 Z- J5 v& K; ?: _0 A) ~+ G( @ - $collection = $db->friend;
9 X7 ~/ F, ]. i. U# r- J7 U - $doc = [//定义一个文档,即一个数组
% R+ O5 A3 f2 E6 g9 Z; ? - 'First Name' => 'Jet',
0 _4 s0 D3 i: F - 'Last Name' => 'Wu',
: x. ]7 {5 H- u* ^; m4 C - 'Age' => 26,; a+ S1 J4 c* b( C
- 'Phone' => '110',
: C* U4 z! |5 O. z# Y - 'Address' => [+ S; I! d1 \& @- D0 _
- 'Country' => 'China',
/ g, y- j+ K- u; V/ i2 m# E - 'City' => 'Shen Zhen'$ [& h9 T9 T, W' F7 j
- ],
% U0 m1 x7 c* ]8 u# S$ Y+ H# k - 'E-Mail' => [- X+ O+ o" i) I( w
- '123456@qq.com',, E2 m* T" w( R9 `9 V( D
- '666666@sina.com',8 o6 V; Y# ^, T" x9 p$ b1 \0 t
- '8888888@qq.com',
( a$ H; _5 n, V+ h - '77887788@qq.com'
* K; c& P* A% c - ]' v9 q* i: Z; c' N: Y1 U
- ];4 u0 K" _1 N8 z+ i9 ]
- $res = $collection->save($doc);4 u6 {3 L# P) m
- echo '<pre>';
+ s% M" d) n; o6 b' x, E: [. x; h - print_r($res);//$res['ok']=1表示操作成功,$res['updatedExisting']=1表示更新,$res['upserted']=1表示插入
9 P6 e/ Q E' g
/ S4 u1 @) U5 P: x: k+ s# v
复制代码- //findAndModify()
& M9 w% W9 ]) a2 S* x% [ Z - //参数1:指定查询条件& X7 Z' L- H: C3 B
- //参数2:指定用于更新文档的信息
2 ?( I. b2 W" Z m6 I3 v/ W - //参数3:可选,指定希望返回的字段. i: v9 g' M& p8 v1 B4 d0 `, L
- //参数4:扩展选项& J9 q7 g" i& Q: k% X8 S! I
- // sort:以特定顺序对匹配文档进行排序
6 ~4 i- Z6 L4 J% s/ R - // remove:若设置为true,第一个匹配文档将被删除- P1 k0 T0 f0 M7 K" q3 m) H
- // update:若设置为true,将在被选择的文档上执行更新操作
- n/ I C2 J4 p6 m2 ^ - // new:默认为false,若设置为true则返回更新后的文档,否则返回更新前的文档9 T+ W2 d9 C6 A6 T. E" N
- // upsert:若设置为true,没有找到匹配文档的时候将插入一个新的文档) j7 c+ g4 A0 I+ }7 M* R; e
- $mongo = new MongoClient('mongodb://localhost:27017');& X+ U. W `5 O; D! M2 Q. E
- $db = $mongo->mf;8 C) t6 p9 t/ Z$ K
- $collection = $db->friend;! x7 u9 \& {0 [" R: s" G$ `
- $res = $collection->findAndModify(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '111@qq.com']]);
) p0 s9 u7 k; ]2 W5 L9 b4 }* W - echo '<pre>';6 A' K R1 G9 Y; [7 t( O
- print_r($res);
复制代码 四、数据删除 - //remove()$ q' L. H( u1 V" a( A3 t
- //参数1:查询条件
5 Y9 {. y. {- l2 i& p9 h - //参数2:扩展选项8 _0 |# v3 h/ I% Z) ]% h
- // justOne:若设置为true,则最多只有一个匹配的文档将被删除
9 `5 V$ a/ C* P - // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。' S: c$ I7 b* l. [( }1 e, i6 c
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作
1 X5 V3 Q/ I" g2 R9 c! q - // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。
/ w1 x% D3 p1 ]+ j- [* n! F - // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间# U$ H$ [, m, G8 ^) |6 h
- // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)* X. H) s/ H! o9 j- Q# H
- $mongo = new MongoClient('mongodb://localhost:27017');
- v. C, N' K4 [1 s7 M - $db = $mongo->mf;( k7 h# `$ _3 ^7 r3 O
- $collection = $db->friend;
0 X1 z/ U0 `6 v% j/ f$ K) t) u - $res = $collection->remove(['First Name' => 'jet']);
& Y$ N# q' s3 G& F& f) _5 ^( `/ r - echo '<pre>';
) e. F* ~) ?/ `8 ^! K D$ { - print_r($res);//$res['n']表示删除了几个文档
复制代码
3 [, o, s; O4 I7 Q7 {以上是PHP7以前版本的MongoDB操作,下面简单介绍PHP7以后版本的操作。 0 @0 }% f) w" f+ K3 c
-----------------------------------------------PHP7分隔线---------------------------------------------------------------------
1 M2 ?, J* @& `# i* q3 _( t数据插入: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
$ G) W. L0 X& }# I - $bulk = new MongoDB\Driver\BulkWrite;: q; ?9 K) N7 m8 Z: Y
- $bulk->insert(['name' => 'JetWu5', 'age' => 26]);
) R* ` g5 \# W& q& O5 w - $bulk->insert(['name' => 'JetWu6', 'age' => 26]);1 Z0 E" ~ _' U d: M% c( o
- 0 _- p& I; a5 r& A/ \5 _6 ~
- $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
: M' L( [- c o/ c* N - $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
: a! J- K7 Z/ x, s - echo '<pre>';
+ |9 B) Q" T4 b9 j7 w+ t - print_r($res);
复制代码 6 E' G j U8 S4 a& f
数据查询: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
6 M5 C U F5 f9 { - $query = new MongoDB\Driver\Query(['age' => 24], ['sort' => ['age' => 1]]);
: ?* _- D( S. d8 Z5 m! X5 K - $cursor = $manager->executeQuery('wjt.friend', $query);
% ]# I, ~/ @8 A% c& f8 i r -
8 B; {0 k9 `( a6 j - $data = [];
. u% a" {2 g0 U/ V6 j/ ? - foreach($cursor as $doc) {
, \: @1 a, n( b$ c& A: V1 H% ~1 K - $data[] = $doc;1 q2 p ^" z, I
- }# f5 m! j% m1 e/ F7 P
- echo '<pre>';) j# f7 v9 Y) d$ c* {* }
- print_r($data);
复制代码 数据修改: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');, x4 e% D8 k) ?8 b' ~( s
- $bulk = new MongoDB\Driver\BulkWrite;. j$ S& ~1 r. ^5 d
- $bulk->update(; [7 h/ {* \/ h( j8 [
- ['name' => 'JetWu5'],
& ?+ ^" V. i, y - ['$set' => ['age' => 30, 'promise' => 'always smile!']]1 M O) F# o. x" V, N& }0 H: p# h
- );
, _/ j: I( m& Q4 ` - $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
3 H- H' a$ [6 s6 k - $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
2 r( P) |( c, w4 o& w% ^ u: g4 h - echo '<pre>';
6 K7 l, }+ j( p& V7 X# S- e! K - print_r($res);
复制代码 数据删除: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');: @( l7 K/ q* U3 ]2 O
- $bulk = new MongoDB\Driver\BulkWrite;2 S; Q( c6 N V2 J3 L# E: Y9 h
- $bulk->delete(['name' => 'JetWu3']);9 ]% Q: @3 N- H
- $bulk->delete(['name' => 'JetWu4']);9 y; M; `" Y8 d7 i1 B
- $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认8 h/ p& J5 X3 u* \7 E3 l3 m
- $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);# n p% M6 V' v8 e; X
- echo '<pre>';
8 m8 T' R; U- F6 @) E1 D - print_r($res);
复制代码 $ S" i8 \7 s) H% ?! x, [" e
) f0 k1 J) J: Y
+ A/ u; r" n% e# t/ F$ g
9 k' \* ?3 N7 E7 T6 n5 W; R5 T, d
" K o% w% v" h! W( V/ B, g5 w7 C |