MongoDB的PHP驱动提供了一些核心类来操作MongoDB,总的来说MongoDB命令行中有的功能,它都可以实现,而且参数的格式基本相似。PHP7以前的版本和PHP7之后的版本对MongoDB的操作有所不同,本文主要以PHP7以前版本为例讲解PHP对MongoDB的各种操作,最后再简单说明一下PHP7以后版本对MongoDB的操作。 一、数据插入 - //insert()) t! t# f8 \5 `; D3 Z
- //参数1:一个数组或对象
" d. L' O: u( U! ~- W* N' b5 h - //参数2:扩展选项
- p% _9 I- L8 Z7 D9 g5 U - // fsync:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入硬盘0 A2 i c5 P2 y3 L: u
- // j:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入日志
8 V% F. f0 Q3 ^7 w5 P0 z2 C5 S - // w:默认为1,写操作会被(主)服务器确认,若为0则将不会得到确认,使用复制集时设置为n用于确保主服务器将数据修改成功复制到n个节点后再确认
- z) D" L$ T* e2 t. J( v% Q; Q* P - // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
/ O6 K* g& m) f! e& ?! \ - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒) E8 m7 R: A; q- D# ?! \+ R: Z
- $mongo = new MongoClient('mongodb://localhost:27017');
2 f: |. E0 T0 A6 |3 g. @$ o - $db = $mongo->mf;//选择数据库
, i- W% U# K6 P0 A - $collection = $db->friend;//选择文档集合
, G4 l3 U0 ~* [ - $doc = [//定义一个文档,即一个数组
u8 |( Z+ n- E# J" H$ Y5 G - 'First Name' => 'Jet',& P: p) j& e( K
- 'Last Name' => 'Wu',
! z0 \; o. u7 ~" C' k( M - 'Age' => 26,
8 x* j" x. {8 z# C - 'Phone' => '110',
3 W! S3 ^& K$ e, b - 'Address' => [
. b% n, \2 R, e" {( _ - 'Country' => 'China',9 I* ?! j: G1 [: `( w
- 'City' => 'Shen Zhen'
' F: p2 F5 Q1 i3 W5 p5 c - ],/ Z D( p! o2 a9 A) C3 |
- 'E-Mail' => [
& B4 r- L9 y1 c - '123456@qq.com',
& N3 o- }3 A9 c4 S' S - '666666@sina.com',
: Y. g" \7 X4 c5 J' c - '8888888@qq.com',, f, i6 x5 Q5 H
- '77887788@qq.com'
3 c$ s. @4 v2 b8 C8 @$ ^ - ]/ |" Y! t. i: e- h& A
- ];
( \% `7 h, [8 W4 Y% V2 d r3 c - $res = $collection->insert($doc);//向集合中插入一个文档4 F8 o& L9 k. `6 \% o G
- echo '<pre>';5 z' L+ M! m7 Y/ A
- print_r($res);//$res['ok']=1表示插入成功
复制代码二、数据查询 1. 查询单个文档: - //findOne()
1 Z3 l* I% O5 s0 G( w - //参数1:搜索条件
) Y' e& u! b* I4 ~1 s5 I; A - //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非在第二个参数显式加入'_id'=>false。不设置则返回所有字段
! V: U2 [" e; d; }+ d" h/ [: [ - $mongo = new MongoClient('mongodb://localhost:27017');. q0 r( m/ \6 K8 I' B: y2 Z
- $db = $mongo->mf;1 S" l+ _* C" n% r+ X
- $collection = $db->friend;! U5 W3 D% j5 e' q
- $one = $collection->findOne(['First Name' => 'Jet']);
) B* V5 F0 b% _: {* [/ }" E- G - echo '<pre>';9 f% b& z! H0 s9 C* ^3 W* G% I
- print_r($one);//返回一个数组,查不到数据则返回NULL
复制代码2. 查询多个文档: - //find()
3 D7 ~9 z" i( q: b; s - //参数1:搜索条件
! `; p1 P8 S! t, O - //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非显式设置为false不返回。不设置则返回所有字段9 L2 R( f' b* ]9 z
- $mongo = new MongoClient('mongodb://localhost:27017');! c M$ V: |. W
- $db = $mongo->mf;9 M- u" Z2 t5 g& E* w
- $collection = $db->friend;
% ~9 ^) }' l; t" ?" D* W9 j - $cursor = $collection->find(['Address.Country' => 'China']);//使用点操作符查找数组元素, n9 r& |+ @& X0 I$ x7 H9 }9 h
- echo '<pre>';: L2 _2 ?0 c) X7 o, o* }# ^
- while($doc = $cursor->getNext()) {//循环读取每个匹配的文档
u* f# e/ T$ }# x - print_r($doc);3 H" V5 j2 V3 @2 |% ~3 `
- }
复制代码使用各种条件操作符定义查询: - //mongodb分别使用$lt(小于)、$lte(下雨等于)、$eq(等于)、$gte(大于等于)、$gt(大于)、$ne(不等于)表示<、<=、=、>=、>、<>,用于整数字段查询( m3 [- r% R- @) v
- $mongo = new MongoClient('mongodb://localhost:27017');3 Y8 l/ K( k) R9 p
- $db = $mongo->mf;& N5 j" P" H* _
- $collection = $db->friend;& [ A% U/ Z! d9 T' h
- $cursor = $collection->find(['Age' => ['$gt' => 30]]);
- e& p) T1 f5 o0 n& W - echo '<pre>';
1 i: @3 \% C. m+ s; |: ~8 y3 h, Y - while($doc = $cursor->getNext()) {! U2 |3 q, @: v1 o8 t) w% ?
- print_r($doc);2 Y4 z, [' E) m5 A8 H w2 n
- }
复制代码 //查询某个字段的所有不重复的值 A) {* ^0 q+ L. E6 Q
$res = $collection->distinct('Age'); - //$in:匹配多个值中任意一个
, s# Q7 r; v& L2 o1 M - $cursor = $collection->find(['Address.Country' => ['$in' => ['China', 'USA']]]);* Y- T5 { d4 I7 l* D
-
* R, Y0 f0 r! P' l* `! V) h; V - //$all:匹配多个值中所有值(用于数组字段查询)
+ G% \* D8 R+ \* c9 V$ V - $cursor = $collection->find(['E-Mail' => ['$all' => ['123456@qq.com', '77887788@qq.com']]]);
" v' K* l' h( r - : P' r4 q2 }" w0 Q! }( g
- //$or:或查询( S5 B" t" b3 d* }3 P
- $cursor = $collection->find(['$or' => [['First Name' => 'Jet'], ['Address.Country' => 'USA']]]);
/ h. g, ]2 f; M! W8 |; k2 L - + X) R% J- `6 y3 X
- //$slice:获取数组字段中指定数目的元素,位于find()函数第二个参数中: f+ g8 M: M$ t/ Q
- $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => 2]]);//只返回前两个email
6 r$ W* {1 `; z' X - $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => -2]]);//只返回最后两个email
/ i/ A" p% M% O. l, P( M% L - $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => [1, 2]]]);//忽略第一个,返回接下来两个( [" e, c. Z5 ]/ d; R( I0 ^
- 7 u0 x" V* U" ^/ X
- //$exists:根据某个字段是否有设置值进行查询
3 s- B! B2 r, m9 } - $cursor = $collection->find(['Hobby' => ['$exists' => false]]);//查找Hobby字段未设置值的文档
% F3 i* Q/ r( o8 _. C& ` -
" R. ]/ [ [6 @: F f( [ G" ?2 D7 _ - //正则表达式查询* O' x) n8 S X% m
- $cursor = $collection->find(['First Name' => new MongoRegex('/^Je/i')]);//查找First Name字段以Je开头的文档,忽略大小写差异
复制代码使用MongoCursor类提供的其他函数: - //排序:1升序,-1降序
$ Q. E4 K, F9 U) H3 d - $cursor->sort(['Age' => 1]); s( e, E8 ~* d
-
) s9 i+ q5 `5 L' ?" e+ D- ` - //忽略前n个匹配的文档
0 y' z4 v" i% V: t - $cursor->skip(1);
/ N6 Y+ _3 t9 K: y - * U. G& @8 j8 z1 [. k1 M3 b$ B6 K
- //只返回前n个匹配的文档(limit()与skip()结合使用可实现数据分页功能)
) h& g* a+ |# o& J# s. g - $cursor->limit(1);
8 i& {0 W: S' M -
, C5 d& r1 G0 S `: `0 p* K) e. d - //匹配文档的总数
/ \0 A! n, z8 d - $cursor->count();
" F( Q7 o) c6 M- U; F - % m! I/ E1 d$ N7 S7 y
- //指定查询索引- L3 l- s: f9 i7 Y
- $cursor->hint(['Last Name' => -1]);//若索引不存在则会报错
复制代码聚集查询:对数据进行分组统计 - //聚合查询:对数据进行分组统计7 n5 v2 ^, `# r3 s# B1 w
- $mongo = new MongoClient('mongodb://localhost:27017');
1 w; r) B( C1 g- T - $db = $mongo->mf;& t+ w) u% \; ~4 R( |) |
- $collection = $db->friend;
$ |% D6 \' Q0 r# u; G" m- ^ - $res = $collection->aggregate([
( ?3 G, v0 A+ C( f9 l" f: _ - '$group' => [
y4 n) o5 K' F4 e - '_id' => '$Address.Country',//分组字段,注意要加上“$”,这里是根据数组字段某个元素值进行分组) l7 J1 n0 x0 E2 u8 d* l
- 'total' => ['$sum' => 1],//求总和,表示每匹配一个文档总和就加1
3 L6 k+ f, ] t( Z6 [ - 'maxAge' => ['$max' => '$Age'],//分组中Age字段最大值
& N' E ^3 |- J) Y7 Q6 E - 'minAge' => ['$min' => '$Age']//分组中Age字段最小值$ }$ X6 V$ _8 t. o B2 {$ m
- ]3 ]9 t2 a+ f, F# t# X
- ]);
0 i& r; a/ p+ @3 x; T; n) V - echo '<pre>';
0 }5 l# X* D+ G1 s3 v1 D- J+ o - print_r($res);//返回一个数组,$ret['result']为数组,存放统计结果/ {/ X+ N$ Q: S, i8 E/ _
-
& |! L2 a6 ]4 h+ P -
8 f( B* L. C3 V. B8 H - //存在其它操作的聚合查询:多个操作之间执行先后顺序取决于它们位置的先后顺序
; {% c$ s* \' P! i. h/ ]6 Z - //聚合查询中的所有操作,包括'$group'在内,都是可选的。
* D) ~. k( l% p+ m# m - $mongo = new MongoClient('mongodb://localhost:27017');
6 a, l1 R$ X* o ~3 g* k# Z - $db = $mongo->mf;! W5 x% @' Y- t: b5 i7 P4 R
- $collection = $db->friend;2 Y3 t4 V+ Q% |# n7 H& L5 P$ N
- $res = $collection->aggregate([
. }; h7 @" u: t, k - [//过滤条件:只对符合条件的原始文档进行聚合运算,若是放在'$group'之后则是只返回符合条件的结果文档
' Q# _/ W' O/ T* a% { - '$match' => ['Age' => ['$gt' => 30]]8 Y1 R/ H8 m }- V& i
- ],
( n. x/ a- ?5 _9 X1 b - [//指定分组字段、统计字段
! C& V. ]2 g: I - '$group' => [1 O- X! d" i9 A/ s7 Q
- '_id' => '$Address.Country',/ q9 d- N: {- a( ]: {; B( ]& K
- 'totalAge' => ['$sum' => '$Age']//计算各个分组Age字段总和5 Z9 {: i7 x; A* ]! j4 H5 w
- ]' o6 _- ~' Y# ^1 j7 S, _8 x
- ],
/ a" K4 m4 }+ v! S1 ^ - //以下操作若是放在'$group'之前则在聚合前作用于原始文档,若放在'$group'之后则在聚合后作用于结果文档
* H1 E3 @- X/ c* q8 w - ['$unwind' => '$E-Mail'],//将包含有某个数组类型字段的文档拆分成多个文档,每个文档的同名字段的值为数组中的一个值。
9 R! q1 O1 T! V/ u% H - ['$project' => ['myAge' => '$Age', 'First Name' => '$First Name']],//指定返回字段,可以对字段进行重命名,格式:返回字段名 => $原来字段名: H+ b$ J: p7 u9 ]2 \/ A
- ['$skip' => 2],//跳过指定数量的文档& J% j9 V; M0 K7 }* ?) Y
- ['$limit' => 2],//只返回指定数量的文档
0 ~* G6 M U* A - ['$sort' => ['totalAge' => 1]]//排序
' I* E5 R2 S" \- ^* d8 e) H% @' O - ]);2 x9 d/ Y4 u6 \2 ^( {
- echo '<pre>';
+ D, S6 x9 [6 M: L5 n9 ` - print_r($res);
复制代码
# P" _0 a$ Q# C) G( F# D% y三、数据修改 - //update()- z' p2 K! N' K* H% z: ^; I
- //参数1:更新条件,指定更新的目标对象。
2 Y; W+ N7 C; B8 d - //参数2:指定用于更新匹配记录的对象。9 h( C+ z3 r9 Y
- //参数3:扩展选项组。
3 M v, `5 M. v7 T3 h - // upsert:若设置为true,当没有匹配文档的时候会创建一个新的文档。
; W3 ~2 @& t. H - // multiple:默认为false,若设置为true,匹配文档将全部被更新。: J s( d @ f9 Q
- // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。
8 Z* I' Q2 E" N7 g8 Z+ e- h: ]( Y1 D - // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作+ h' {/ A0 Q: O; |) z
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。+ n) x4 l v7 u2 Z( O
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间7 q4 S s- }! I: `
- // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)6 ?3 r/ L3 s* V& g0 n' h
- //注意:若不使用任何修改操作符,则匹配文档将直接被整个替换为参数2指定的对象。$ |( G0 W3 V5 A# A
-
. u" C4 c x p8 e - //$inc:增加特定键的值,若字段不存在则新建字段并赋值
; B, O u# T1 z6 u5 o" Y2 {8 X - $mongo = new MongoClient('mongodb://localhost:27017');- f0 H, b$ G; D0 |/ ]
- $db = $mongo->mf;- E: r: _" _7 t" x! B8 x8 W
- $collection = $db->friend;
! B2 Z/ H, B8 d7 }" M+ x/ p) X( l; e4 S - $res = $collection->update(['First Name' => 'Jet'], ['$inc' => ['Age' => 2]]);/ l; F8 }0 k, w! s( A1 {
- echo '<pre>';
3 b R s% {$ A: ~. S: f4 l) Y - print_r($res);//$res['ok']=1表示修改成功,$res['nModified']表示修改的文档数量1 E0 {$ i& M0 @; ~9 n9 F4 g$ C
-
* W: {( L+ E. C$ x, u- e - //$set:重置特定键的值,若字段不存在则新建字段并赋值
3 v( d3 o1 d( q/ z* i - $res = $collection->update(['First Name' => 'Jet'], ['$set' => ['Hobby' => 'pingpong']]);
6 D! Z' ^9 x. t# T7 e4 ]( r4 E& _ - 7 B% A- Z4 c* v+ c/ r
- //$unset:删除字段1 t$ y7 m3 T' r- s% Q( e) s
- $res = $collection->update(['First Name' => 'Jet'], ['$unset' => ['Hobby' => 1]]);
1 M4 E% @2 ^ z9 j) O - 3 R, r) Y k- ^2 v: g. u; Z
- //$rename:重命名字段,若字段不存在则不进行任何操作, }- `3 k1 b5 g% V% R
- $res = $collection->update(['First Name' => 'Jet'], ['$rename' => ['Hobby' => 'hobby', 'Age' => 'age']]);
# C, S* c2 U( z, C+ X* | - //注意:如果文档中已经使用了指定名称的字段,则该字段将会被删除,然后再进行重命名操作。
7 A: q" `; ?6 f/ i: Q -
* z {$ k( o1 {# z' e7 A# d: Q - //$setOnInsert:设置了upsert为true,并且发生了插入操作的时候,将某个字段设置为特定的
1 z1 n" F8 P. s+ ^7 d8 Y+ X - $res = $collection->update(['First Name' => 'jet'], ['$setOnInsert' => ['lang' => 'English']], ['upsert' => true]);
) c0 E3 Z% n8 u4 L# B1 u, B - 5 ]- l8 ~9 ^& {5 g
- //$push:向指定字段添加一个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错! H1 F$ t; H" s5 p$ }) x! q
- $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '123123@qq.com']]);
* G9 h7 @( U4 E0 D - $ T/ S u: s, a L4 D
- //$push:向指定字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错
3 n" N0 K" a2 Z: E) [ - $res = $collection->update(['First Name' => 'Jet'], ['$pushAll' => ['E-Mail' => ['666@qq.com', '8888888@qq.com']]]);
8 R8 R Y* E) y- {7 B$ j+ c - 1 e9 O7 W v8 K) \4 m
- //使用$push和$each向某个字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错1 A+ `" L# f% D
- $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);
6 B5 W* G& M: K9 h; L1 k1 l5 L -
/ ~. H" @ t# d! b* W - //$addToSet:将数据添加到数组中(只在目标数组没有该数据的时候才将数据添加到数组中) O$ l( m6 Q5 o+ P+ J
- $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => '123123@qq.com']]);
. a. j" u- l/ U* D - $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);
: y8 \3 H$ Y! n% ?% K L- ^5 a, I -
$ T6 d. T$ x8 x& c+ e" @ - //$pop:从数组中删除一个元素,-1表示删除第一个元素,1表示删除最后一个元素(其实负数都删除第一个元素,0或正数都删除最后一个元素)' Q( ?, v, U4 _# r
- $res = $collection->update(['First Name' => 'Jet'], ['$pop' => ['E-Mail' => 1]]);1 S( H, K) G+ n+ h; x
-
' M+ t9 D& O, C3 \! c# E7 c2 N$ V - //$pull:删除数组中所有指定值
|0 B# s( {% S1 Z& V - $res = $collection->update(['First Name' => 'Jet'], ['$pull' => ['E-Mail' => '123123@qq.com']]);
* w: Y2 y- f6 [% T6 i - 3 U4 ^6 Q4 f% R6 w" G/ Q
- //$pullAll:删除数组中多个元素的所有值
/ U5 a. X3 J; ?$ R8 ?% v" \ - $res = $collection->update(['First Name' => 'Jet'], ['$pullAll' => ['E-Mail' => ['123123@qq.com', '666@qq.com']]]);
复制代码- //save()- V. S' J( ^. ]+ }1 C* V
- //参数1:希望保存的信息数组
: ?' q! S) o3 }$ C2 z - //参数2:扩展选项- S% `. X2 x/ L7 T
- // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。! ]3 O+ ]* B3 A2 ~3 B+ V
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作
. v1 `- H& t4 G& {# ^" I0 x - // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。8 B+ r! H8 ~' R" j
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
- u' o1 P/ O) a) ]% ?3 R - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)& h% U% m- k0 O- \
- //注意:若已存在则更新,若不存在则插入;更新时使用参数1指定的信息数组替换整个文档。$ N5 e9 q+ A2 _, x; t
- //若想更新则应该在参数1中指定_id键的值。! V# U9 g/ W0 l* @+ E) y3 L
- $mongo = new MongoClient('mongodb://localhost:27017');
+ n: P/ d$ |4 m& J9 y - $db = $mongo->mf;
& Z- ^+ K6 v# a* Z - $collection = $db->friend;. s) c+ E8 P3 N
- $doc = [//定义一个文档,即一个数组
5 k1 e: g* m% P - 'First Name' => 'Jet',5 L8 {2 }1 C+ R1 g; n+ U
- 'Last Name' => 'Wu',
, A2 E: H9 n9 |% p - 'Age' => 26,
" [0 u; y" ?4 X6 e) p' P - 'Phone' => '110',+ Y1 z" M- U6 ^. R8 z( N7 A
- 'Address' => [6 [5 Z( r# [: O. ~
- 'Country' => 'China',
3 o: Z' L0 y9 s' @' s ] - 'City' => 'Shen Zhen'5 ^: U. m. m! C' ]% D/ j
- ],4 ^6 s7 r2 @2 n) h8 p; ]
- 'E-Mail' => [
7 F( G5 u, v- x - '123456@qq.com',$ |' ^+ w2 P! O
- '666666@sina.com',
2 P8 `; D) O$ J - '8888888@qq.com',
) u, j7 j$ y' [1 D( r8 s6 n - '77887788@qq.com'
$ E! `1 j. r9 g - ], S* z$ h! x, S2 c) {: A9 T
- ];6 b3 u# P; D" f6 }5 y7 z
- $res = $collection->save($doc);( C, J& ~' n, `) p& g8 M
- echo '<pre>'; V3 j3 y; F! u& K0 L# p9 Z
- print_r($res);//$res['ok']=1表示操作成功,$res['updatedExisting']=1表示更新,$res['upserted']=1表示插入
2 ~3 H- \$ ]- N
9 z R+ a% T% y; P
复制代码- //findAndModify()
$ g, F0 R# [, w. ~ - //参数1:指定查询条件
8 Y$ M7 o. D8 u- `4 a" W9 r7 z% G - //参数2:指定用于更新文档的信息
2 x4 s& A4 l2 Y q - //参数3:可选,指定希望返回的字段6 c+ Q$ U$ Y+ U0 {% X1 J6 @
- //参数4:扩展选项, a( U: `- L' F* q) F' u: O
- // sort:以特定顺序对匹配文档进行排序$ S' ~6 ~1 ~7 D; \* T/ h7 X/ {( F
- // remove:若设置为true,第一个匹配文档将被删除& m/ W0 g; B' s. _5 Y+ M8 y
- // update:若设置为true,将在被选择的文档上执行更新操作
0 k: f* u" ?5 D+ i - // new:默认为false,若设置为true则返回更新后的文档,否则返回更新前的文档
; ]/ P* s7 _' z/ X2 E - // upsert:若设置为true,没有找到匹配文档的时候将插入一个新的文档. W) L; O' B7 s5 q9 ~
- $mongo = new MongoClient('mongodb://localhost:27017');
# F* e. H' b2 N- z* B" x! a! K+ k* | - $db = $mongo->mf;
$ E6 s3 w+ m% \, ` - $collection = $db->friend;; W+ V& D( I9 m4 Y$ Q
- $res = $collection->findAndModify(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '111@qq.com']]);
/ ^) K) j5 }& k* E3 ]& ~$ T% M9 h& K - echo '<pre>'; T8 ~* Y- w s Z- ~
- print_r($res);
复制代码 四、数据删除 - //remove() g4 \1 W) s: \, G
- //参数1:查询条件
# ]" M) j. f: [$ I9 p9 _5 C - //参数2:扩展选项0 l: ^) g1 ~6 }0 m2 V. \
- // justOne:若设置为true,则最多只有一个匹配的文档将被删除& Q4 ?0 `, ?1 |) D6 m
- // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。
7 s% g- a6 d c - // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作
9 \ d2 b1 `" V - // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。, l; c( _, Y, G( ]. N
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间; y$ K2 Z7 s4 n6 e
- // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)" c$ t& q& u) P* y; |5 Z' e0 v( r& f( u
- $mongo = new MongoClient('mongodb://localhost:27017');( z5 L2 {+ i+ s3 e
- $db = $mongo->mf;9 R6 b, F# z1 x: p
- $collection = $db->friend;/ ]+ |- j# K* g: B1 B3 o! @
- $res = $collection->remove(['First Name' => 'jet']);$ M3 c+ I# c' c# q7 h
- echo '<pre>';
$ s M$ w. H; Q! t - print_r($res);//$res['n']表示删除了几个文档
复制代码
8 z$ F7 Q( ~8 x/ d以上是PHP7以前版本的MongoDB操作,下面简单介绍PHP7以后版本的操作。 ; O0 B' Q- b1 P* |) K8 }
-----------------------------------------------PHP7分隔线---------------------------------------------------------------------
7 p+ R- w" _& P+ l数据插入: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
J. w# |! _# X - $bulk = new MongoDB\Driver\BulkWrite;
$ M" A; d. }) }" d3 f - $bulk->insert(['name' => 'JetWu5', 'age' => 26]);2 r$ c" K% J% T5 G
- $bulk->insert(['name' => 'JetWu6', 'age' => 26]);# s6 _+ k8 g3 M" y7 b8 I
- / Y( n$ |! [; z4 k) }4 l
- $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
* v, ^3 ^: H7 w0 M' v+ Z2 Y$ m - $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
! H2 ^* H5 k8 Z - echo '<pre>';
6 m4 t) H* p. F7 X, e4 o5 C( K - print_r($res);
复制代码
+ z# l2 l m o9 W- ` u! w数据查询: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
& q( b' J5 [# N6 @* g - $query = new MongoDB\Driver\Query(['age' => 24], ['sort' => ['age' => 1]]);
' l) ^0 G' S# [4 w1 _ - $cursor = $manager->executeQuery('wjt.friend', $query);
* ^ r# w$ c9 ?$ o# e4 g; T- y( E -
, x7 X$ s" d5 Q6 e - $data = [];% i# M' s7 a5 o0 V
- foreach($cursor as $doc) { [0 H1 o D) M* B) i: l
- $data[] = $doc;
! c- F7 l2 ], R - }: W1 X$ }; t8 T9 M+ \, v: i
- echo '<pre>';
. r$ ^9 ]# x4 r$ [ - print_r($data);
复制代码 数据修改: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
; v2 v: y$ n. @. `" k" e - $bulk = new MongoDB\Driver\BulkWrite;
Y3 r) F3 x% [) t - $bulk->update(
/ T/ U- V1 o4 v b4 i: } - ['name' => 'JetWu5'],
4 b0 |0 R. I* ` - ['$set' => ['age' => 30, 'promise' => 'always smile!']]
( s9 X7 `" P7 Q6 l# I) ~" |1 C - );2 C2 S) a' E; Y- W& I
- $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
: }9 j; M. e- d0 V6 s- h Z' { - $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);$ a7 o) @5 R5 ^# K" {6 z: ?
- echo '<pre>';
# K2 q* ?5 V( e5 e9 o - print_r($res);
复制代码 数据删除: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
# p: B# _( u3 n$ x - $bulk = new MongoDB\Driver\BulkWrite;4 E3 V2 L+ s* X& E5 R* i$ a# e
- $bulk->delete(['name' => 'JetWu3']);. p2 R+ P/ b8 X& g! Z
- $bulk->delete(['name' => 'JetWu4']);6 y$ T2 \6 ^$ Q7 g
- $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认) L( |1 e3 k4 t0 Q8 ], D5 J
- $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
) ~5 I! P# v- `# W - echo '<pre>';& H- z! w& J* A( d$ y! u
- print_r($res);
复制代码
+ e% W6 }0 x1 t& @# @& E e* d, z. u+ H. ]4 A: {
3 ]- \& P" v! m$ `- ^. |
% Z& }' O1 K# Q9 X. E% S7 w# ]8 s. ~; C; {3 z. y4 D8 B
|