MongoDB的PHP驱动提供了一些核心类来操作MongoDB,总的来说MongoDB命令行中有的功能,它都可以实现,而且参数的格式基本相似。PHP7以前的版本和PHP7之后的版本对MongoDB的操作有所不同,本文主要以PHP7以前版本为例讲解PHP对MongoDB的各种操作,最后再简单说明一下PHP7以后版本对MongoDB的操作。 一、数据插入 - //insert()8 z# V- f" i8 S1 t0 ]# q: y
- //参数1:一个数组或对象
0 Y \: q8 b$ m# x" U8 P - //参数2:扩展选项" s/ T& W7 |; f6 _
- // fsync:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入硬盘4 B% n/ x- }7 K# W& i
- // j:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入日志
7 @2 K, e3 f6 Z - // w:默认为1,写操作会被(主)服务器确认,若为0则将不会得到确认,使用复制集时设置为n用于确保主服务器将数据修改成功复制到n个节点后再确认# t W# Z7 a# U0 T4 ~7 u( h: {7 v/ ~
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
6 i! [6 E1 P: y6 T8 T" c0 Z - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)/ T, Z* M; t3 m, m2 }" l# _5 W
- $mongo = new MongoClient('mongodb://localhost:27017');" T7 ^* {4 [3 ^* a
- $db = $mongo->mf;//选择数据库4 C; T$ k) i- j) Y
- $collection = $db->friend;//选择文档集合3 R) Q+ e8 d4 C% j9 c
- $doc = [//定义一个文档,即一个数组
2 P# S/ J% l5 V) M8 J6 e - 'First Name' => 'Jet',
% ?2 B3 K! r9 q% g9 l! i F+ E - 'Last Name' => 'Wu',: p( x& N" u" s9 d6 V7 P$ a, a
- 'Age' => 26,1 W+ c W8 E/ n8 g8 q5 y
- 'Phone' => '110',
$ ]3 X& }7 ]; W2 C8 @, } - 'Address' => [1 r! ^/ R! w$ r* q! W
- 'Country' => 'China',
% h% @- ?- e+ W4 s, l. r6 J - 'City' => 'Shen Zhen'0 I# a1 m8 Y; f; k: D! P; D
- ],
, R8 G+ G# T. g - 'E-Mail' => [0 H+ H5 y3 }7 K: G& `
- '123456@qq.com',
( _; A5 U1 d' r2 l3 x - '666666@sina.com',
* b7 f4 a$ M4 m) G! y - '8888888@qq.com',5 f- G# q! |- i }& y5 g; J
- '77887788@qq.com'8 P3 g) Q" o$ z6 K4 j3 c3 c
- ]. X8 V2 q: d3 N/ s! z/ E
- ];
8 J0 m* u# d- ]# Z) @3 a! G o - $res = $collection->insert($doc);//向集合中插入一个文档
# X7 ^5 G5 p0 [: X - echo '<pre>';& s) Z3 r: d7 q& c
- print_r($res);//$res['ok']=1表示插入成功
复制代码二、数据查询 1. 查询单个文档: - //findOne()8 D+ L7 N" o( n" @
- //参数1:搜索条件
& z; ^' r3 x: ]! M - //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非在第二个参数显式加入'_id'=>false。不设置则返回所有字段1 x; l/ t+ Y7 t, C7 X% f
- $mongo = new MongoClient('mongodb://localhost:27017');
9 W7 o- f$ o5 V0 o4 } - $db = $mongo->mf;$ W& A, r4 ?, j: v- }
- $collection = $db->friend;# s. z: y! p/ X
- $one = $collection->findOne(['First Name' => 'Jet']);7 T l8 e& X* H1 ]2 M
- echo '<pre>';
" Q1 F; D1 C* ^' ~' Q; I - print_r($one);//返回一个数组,查不到数据则返回NULL
复制代码2. 查询多个文档: - //find()
) v5 O* ] K' o. Y8 ~' N5 _ - //参数1:搜索条件: R! G7 m( Y. m. W0 q S
- //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非显式设置为false不返回。不设置则返回所有字段
8 |0 n' i1 X- k0 V, w9 y - $mongo = new MongoClient('mongodb://localhost:27017');9 L" `; D- a3 k' a2 z/ T6 ~4 I; l. _
- $db = $mongo->mf;& C' n/ D) f9 Y( b$ N9 J+ G
- $collection = $db->friend;0 x# ]' \* t/ x) f3 B' N
- $cursor = $collection->find(['Address.Country' => 'China']);//使用点操作符查找数组元素
& t. c) O; }- W* g& r. u! L$ U - echo '<pre>';5 y7 o1 K. X. c
- while($doc = $cursor->getNext()) {//循环读取每个匹配的文档$ q# S6 |- }. q
- print_r($doc);
$ j; M( g6 t0 z( R) G- P; o - }
复制代码使用各种条件操作符定义查询: - //mongodb分别使用$lt(小于)、$lte(下雨等于)、$eq(等于)、$gte(大于等于)、$gt(大于)、$ne(不等于)表示<、<=、=、>=、>、<>,用于整数字段查询+ y6 j1 d) |4 ]# P7 R2 }- f
- $mongo = new MongoClient('mongodb://localhost:27017');( d8 }1 X6 J- k! t! T1 U
- $db = $mongo->mf;! x6 }9 i6 b4 ~$ r$ j
- $collection = $db->friend;
2 N; Q0 Q% b# ^( J- j2 [ - $cursor = $collection->find(['Age' => ['$gt' => 30]]);' K2 I% k( R# G0 Y
- echo '<pre>';
& g/ T1 e N$ j4 T9 _9 Y e7 U7 s - while($doc = $cursor->getNext()) {
0 j' i: [: b$ |. X4 d - print_r($doc);" @( T* g4 b" k7 Z3 B+ X& A+ w4 F
- }
复制代码 //查询某个字段的所有不重复的值. t. J. `1 e5 _2 [2 y5 \
$res = $collection->distinct('Age'); - //$in:匹配多个值中任意一个3 a9 V8 F. ~$ o1 D: E
- $cursor = $collection->find(['Address.Country' => ['$in' => ['China', 'USA']]]);5 N, e6 e. |8 X+ w \$ d/ R
- * W: t7 W0 G" u" ^* r' l3 u; n
- //$all:匹配多个值中所有值(用于数组字段查询)
/ B8 P0 H- F% _2 M4 Y9 |: z$ m, \ - $cursor = $collection->find(['E-Mail' => ['$all' => ['123456@qq.com', '77887788@qq.com']]]);/ C; I Z1 I w7 V- }# d2 l
- ( k8 e1 L% f0 T" L# y* Y
- //$or:或查询4 K3 O. m/ d8 G4 U6 H2 Y
- $cursor = $collection->find(['$or' => [['First Name' => 'Jet'], ['Address.Country' => 'USA']]]);" f4 J" _" v8 r8 ~) u' ]/ e
-
$ V; _5 ]5 O( { - //$slice:获取数组字段中指定数目的元素,位于find()函数第二个参数中
4 U7 K1 @: }, O) Z- w - $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => 2]]);//只返回前两个email, Z1 Y+ I" P0 g0 `
- $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => -2]]);//只返回最后两个email) z$ t. w D6 K
- $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => [1, 2]]]);//忽略第一个,返回接下来两个0 ]7 ~2 Q0 g. g0 g
-
( l# v. W5 }- L5 t; } - //$exists:根据某个字段是否有设置值进行查询
4 U: ?% {; e0 T& d3 N0 t$ _# Z - $cursor = $collection->find(['Hobby' => ['$exists' => false]]);//查找Hobby字段未设置值的文档6 a: B2 L k' T5 T
- 8 \' M' r {! M% X+ v2 A
- //正则表达式查询! ]6 }2 \# y1 |( J# Y" G: @# M( @
- $cursor = $collection->find(['First Name' => new MongoRegex('/^Je/i')]);//查找First Name字段以Je开头的文档,忽略大小写差异
复制代码使用MongoCursor类提供的其他函数: - //排序:1升序,-1降序
7 m7 X) n ]3 N - $cursor->sort(['Age' => 1]);, U% [3 U' Y m2 @; f
- - a* Z3 e" @; l# I _' c% ]
- //忽略前n个匹配的文档% g3 q. d( M1 U1 `
- $cursor->skip(1);- @7 n$ a0 y% A ^: c5 ^' W; e
- 7 _% [0 I7 E5 P: C9 P* R
- //只返回前n个匹配的文档(limit()与skip()结合使用可实现数据分页功能)
, x _: X: @& q - $cursor->limit(1);! Z" l/ F8 @0 r
-
* f) x! z& O7 W3 i - //匹配文档的总数 w9 K/ r# K% [9 _+ O" t0 _
- $cursor->count();
% d3 e" D0 M) I/ W' C- J" Y& F4 X -
9 n( Z! [* k1 ?/ |, Y5 d9 i# B' s - //指定查询索引3 T) P5 U& {2 ~$ l( r3 }
- $cursor->hint(['Last Name' => -1]);//若索引不存在则会报错
复制代码聚集查询:对数据进行分组统计 - //聚合查询:对数据进行分组统计
: L3 ~/ p2 k* b" h6 ~ - $mongo = new MongoClient('mongodb://localhost:27017');
& i- u! b. F3 B9 i7 p# C& }& { - $db = $mongo->mf;
' o/ N, Z9 G8 p9 O/ n% t( f - $collection = $db->friend; z$ t S: O6 @2 C) L
- $res = $collection->aggregate([6 H% u/ j7 }7 `9 _6 I! {
- '$group' => [
; K0 o2 W6 O# Y" s8 F - '_id' => '$Address.Country',//分组字段,注意要加上“$”,这里是根据数组字段某个元素值进行分组9 T+ G0 j' O' Q0 C. a
- 'total' => ['$sum' => 1],//求总和,表示每匹配一个文档总和就加14 X ?, M' _( R% d2 @
- 'maxAge' => ['$max' => '$Age'],//分组中Age字段最大值
% ~3 H, r3 ~. ] - 'minAge' => ['$min' => '$Age']//分组中Age字段最小值* h- g1 v' c, X4 T0 E
- ]9 z0 z2 ^" f* g D2 S
- ]); d$ c0 ]$ \: D1 F* R3 B% r U
- echo '<pre>';
9 l6 O; R& E; F4 I - print_r($res);//返回一个数组,$ret['result']为数组,存放统计结果! u. K6 N C9 B- O: I
- y( m9 ~( q4 Z; M
-
F3 w( \& m: ] - //存在其它操作的聚合查询:多个操作之间执行先后顺序取决于它们位置的先后顺序) }3 R5 a' D/ R2 f% `
- //聚合查询中的所有操作,包括'$group'在内,都是可选的。
; K, b9 V+ s, Q8 h/ d# A - $mongo = new MongoClient('mongodb://localhost:27017');/ k, h8 E$ G$ h. r5 G4 g
- $db = $mongo->mf;
* t. s" B# \( ?8 u( `0 {: z - $collection = $db->friend;" {& n+ K( q# l; w* W q* s* C
- $res = $collection->aggregate([
& L" W3 w4 i4 e - [//过滤条件:只对符合条件的原始文档进行聚合运算,若是放在'$group'之后则是只返回符合条件的结果文档1 Z, K: P+ O: U M6 D) X
- '$match' => ['Age' => ['$gt' => 30]]
7 W0 U0 L( S8 x- d - ],- I! ]) z2 u% P
- [//指定分组字段、统计字段
% u8 H8 u E9 r, b+ b$ W - '$group' => [
@. U1 [: V3 ^* B - '_id' => '$Address.Country',, N' H3 f" a8 ^# n; D
- 'totalAge' => ['$sum' => '$Age']//计算各个分组Age字段总和& r, S- c: H3 I6 X9 @$ W
- ]' j g. Q& `) \/ l/ Z
- ],+ V2 ?* C$ Z' n3 L
- //以下操作若是放在'$group'之前则在聚合前作用于原始文档,若放在'$group'之后则在聚合后作用于结果文档4 A: M8 H7 M6 q4 z! I
- ['$unwind' => '$E-Mail'],//将包含有某个数组类型字段的文档拆分成多个文档,每个文档的同名字段的值为数组中的一个值。
; R9 G+ W. `* w% @ - ['$project' => ['myAge' => '$Age', 'First Name' => '$First Name']],//指定返回字段,可以对字段进行重命名,格式:返回字段名 => $原来字段名; ^% D ^; r7 @& B6 v$ C: Y) _
- ['$skip' => 2],//跳过指定数量的文档# {( K! C* B. C5 t' }+ u$ C" E$ y
- ['$limit' => 2],//只返回指定数量的文档
+ c8 D }6 j; d; \$ Y9 s* g - ['$sort' => ['totalAge' => 1]]//排序
4 T! f S4 t( x( I - ]);
- G6 K" r0 g0 k - echo '<pre>';
4 e$ ^ z6 Q+ _# b# O; c - print_r($res);
复制代码 ! v m7 ]! S3 w$ `7 G
三、数据修改 - //update(); f2 ~' J( [& w& I5 s) I- p
- //参数1:更新条件,指定更新的目标对象。/ D8 `* I; T1 U6 e
- //参数2:指定用于更新匹配记录的对象。# K% E0 Z7 Z7 G L% k- N3 k& e
- //参数3:扩展选项组。
7 X' z5 D% h/ u - // upsert:若设置为true,当没有匹配文档的时候会创建一个新的文档。
& Z3 h- k& C7 a5 j1 S! X) W- s - // multiple:默认为false,若设置为true,匹配文档将全部被更新。6 c( e8 Q t9 _* h: m" r; k
- // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。
1 d6 ?; T- G" x - // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作# S& d7 j; K# {" j6 n& _
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。& z$ j5 _* w8 g+ A$ _4 n) a+ e# @
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间& m5 q6 a0 D/ Z- x, R
- // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
/ ~! s n+ c7 E) V X- o - //注意:若不使用任何修改操作符,则匹配文档将直接被整个替换为参数2指定的对象。
# }. ~3 ^% U) |/ D -
- Q# I7 l( A' O: D - //$inc:增加特定键的值,若字段不存在则新建字段并赋值
: o: H4 q! e- f$ {; U - $mongo = new MongoClient('mongodb://localhost:27017');
$ ^; v+ w, I V& v) D: E6 E; m - $db = $mongo->mf;
# R4 Z. Q7 W7 c X3 Z& z$ y - $collection = $db->friend;" H8 P" D+ b8 N- s! ?
- $res = $collection->update(['First Name' => 'Jet'], ['$inc' => ['Age' => 2]]);
* `% Z/ R' D. I; l - echo '<pre>';
\3 M: {5 q ~, ?- W. j - print_r($res);//$res['ok']=1表示修改成功,$res['nModified']表示修改的文档数量+ r1 R7 s" C2 ~: P
-
" J$ p2 D: w( V1 b1 f( V - //$set:重置特定键的值,若字段不存在则新建字段并赋值
8 V- R6 y1 x+ o( `& k# P& S - $res = $collection->update(['First Name' => 'Jet'], ['$set' => ['Hobby' => 'pingpong']]);
: h" n6 _" Z, @( ` - 0 z$ v: m9 F3 I8 ~3 o) R1 b8 R
- //$unset:删除字段4 v3 e8 H0 ?# T' i2 A$ r P
- $res = $collection->update(['First Name' => 'Jet'], ['$unset' => ['Hobby' => 1]]);
0 ]" n ~1 f0 e- B -
$ U7 Y9 ^0 ]4 U. p) E$ T# U8 Q4 X9 \ - //$rename:重命名字段,若字段不存在则不进行任何操作6 i" v, H5 v6 P2 Q2 ^2 X
- $res = $collection->update(['First Name' => 'Jet'], ['$rename' => ['Hobby' => 'hobby', 'Age' => 'age']]);! R9 k- | W% C
- //注意:如果文档中已经使用了指定名称的字段,则该字段将会被删除,然后再进行重命名操作。& H3 ^- a( r, x3 Z
-
! T, V# S1 o; {: ] - //$setOnInsert:设置了upsert为true,并且发生了插入操作的时候,将某个字段设置为特定的
+ X" F! n) ?+ H- p' v( p5 | - $res = $collection->update(['First Name' => 'jet'], ['$setOnInsert' => ['lang' => 'English']], ['upsert' => true]);& r% D6 J2 R& {
-
* A4 ~) p) Z# [$ O; B/ c& t - //$push:向指定字段添加一个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错& D1 W& q. {5 |; w+ }
- $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '123123@qq.com']]);
. I3 @% v- U9 K" k' i. o- X% a' B0 B7 e! p -
6 X% `! ?8 b& ]- F1 G - //$push:向指定字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错9 N0 L5 t; g6 d& L# v0 |6 n0 W/ e
- $res = $collection->update(['First Name' => 'Jet'], ['$pushAll' => ['E-Mail' => ['666@qq.com', '8888888@qq.com']]]);/ h5 A7 \( a2 L
- : t5 Y; _5 {2 ]
- //使用$push和$each向某个字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错
4 [0 x# |# o' K M - $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);) o1 J/ |& T# ?% Y# I* K+ L3 c
-
- _4 h, A. j( m& S( D1 ? - //$addToSet:将数据添加到数组中(只在目标数组没有该数据的时候才将数据添加到数组中)
% y0 X. x& t" Z- M* S - $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => '123123@qq.com']]);! q) o# k% A4 G: A5 N/ F! J
- $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);, d( X- H! a8 c- n" ?
-
, j; y, l k7 U0 f% j9 w - //$pop:从数组中删除一个元素,-1表示删除第一个元素,1表示删除最后一个元素(其实负数都删除第一个元素,0或正数都删除最后一个元素)1 E% w, _* v* I: K1 _, m, L
- $res = $collection->update(['First Name' => 'Jet'], ['$pop' => ['E-Mail' => 1]]);- A8 q. i7 k& S& q" h& |+ a
-
7 }0 W( Y# G5 M3 k- \ - //$pull:删除数组中所有指定值. |& o, I; i# }- z7 e* b) q& M
- $res = $collection->update(['First Name' => 'Jet'], ['$pull' => ['E-Mail' => '123123@qq.com']]);0 M {9 Q& F# d0 {. M" V
- & |7 I. q6 m2 L2 q9 S$ C$ i
- //$pullAll:删除数组中多个元素的所有值. Y' s9 b& E0 a( ?$ w- u9 g% [& k
- $res = $collection->update(['First Name' => 'Jet'], ['$pullAll' => ['E-Mail' => ['123123@qq.com', '666@qq.com']]]);
复制代码- //save()
% B3 B, v6 `% h% L1 c% J3 { n - //参数1:希望保存的信息数组: N* M4 _# r" A, J/ ^" c
- //参数2:扩展选项- I1 ?# \ P6 X& _( M% q
- // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。
' M7 l4 ?8 w |; o& P' a - // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作2 ?+ V/ X' L2 T1 y8 w
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。0 a% ^. f# L p* X7 q0 d4 d
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
/ @/ g+ Z T) N4 H# t! Q8 G+ R - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
7 m" b5 z3 u7 C - //注意:若已存在则更新,若不存在则插入;更新时使用参数1指定的信息数组替换整个文档。
' b( h* p1 D: F: u; N - //若想更新则应该在参数1中指定_id键的值。
" k- i0 i: Y; z - $mongo = new MongoClient('mongodb://localhost:27017');
& O: `5 J3 [- b. J3 i, E8 N - $db = $mongo->mf;
# M7 C9 s/ V# R - $collection = $db->friend;# ~1 J/ z( d9 q6 m! z4 `
- $doc = [//定义一个文档,即一个数组
2 `! V- R6 M( ], f- z9 q4 o, Y5 v# q8 d - 'First Name' => 'Jet',
/ t M& ~2 n/ [$ d/ s9 X0 m - 'Last Name' => 'Wu', Z! S6 N& |9 r
- 'Age' => 26,+ D" \& ~; z; k: n& V
- 'Phone' => '110',
" G4 o4 o9 J, v: |1 X - 'Address' => [
( z) c' [. w3 \% _9 Y# o - 'Country' => 'China',- A5 | q' K5 D
- 'City' => 'Shen Zhen'9 z8 Q- z9 N: M' ]8 b
- ],
* f0 L1 C2 r0 F* }4 \7 H - 'E-Mail' => [. W! ^. l# `. o
- '123456@qq.com',
: X q& ?: a. V, M8 K. o - '666666@sina.com',) t: O1 Q* d) b0 d$ U
- '8888888@qq.com',% Z+ z2 [4 o8 X+ A$ \, T5 o J
- '77887788@qq.com'" |0 E k6 t$ Z2 z
- ]
3 t! U3 z& A' @- N# E | - ];6 {1 k& P7 D! z" V% m) w
- $res = $collection->save($doc);
% B4 F+ l" p6 |9 ^2 u1 x - echo '<pre>';' [1 R( d0 X1 N2 c$ i* O
- print_r($res);//$res['ok']=1表示操作成功,$res['updatedExisting']=1表示更新,$res['upserted']=1表示插入
* R d: {4 K/ b O - 4 I7 R4 T3 G% u# B* e7 ?
复制代码- //findAndModify()
$ f& V- C$ G) g2 J: Q - //参数1:指定查询条件
0 |. M& t' ]$ q7 m2 S - //参数2:指定用于更新文档的信息
T4 l7 a/ h! x* W4 z$ K - //参数3:可选,指定希望返回的字段
+ v* S3 A& [) x( {/ o* J - //参数4:扩展选项, p( M/ f. J' M8 u
- // sort:以特定顺序对匹配文档进行排序
$ h4 C! ^/ r, Y, b$ W - // remove:若设置为true,第一个匹配文档将被删除( e+ V5 ~; g5 ^9 b) x
- // update:若设置为true,将在被选择的文档上执行更新操作' u1 R7 h7 p9 }- E# i& K
- // new:默认为false,若设置为true则返回更新后的文档,否则返回更新前的文档
7 z e% p$ b/ I; |' r( j6 N - // upsert:若设置为true,没有找到匹配文档的时候将插入一个新的文档
, f& y& S& l8 h/ J0 w1 \ - $mongo = new MongoClient('mongodb://localhost:27017');
* u0 r9 C- m; Y0 _( V" A3 z4 @: n - $db = $mongo->mf;
0 k: b2 l" j& F$ y/ G& H - $collection = $db->friend;
' }' @ Q3 s+ q! n* j$ u, w - $res = $collection->findAndModify(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '111@qq.com']]);5 A' f) ]1 u J4 t) O2 R N
- echo '<pre>';0 ?) E3 A- W3 d5 `
- print_r($res);
复制代码 四、数据删除 - //remove()
" ]$ E' p- }7 ]) c" | - //参数1:查询条件% M; v& J. q4 g
- //参数2:扩展选项) t2 a3 p; O5 b2 t" ]1 y% k
- // justOne:若设置为true,则最多只有一个匹配的文档将被删除
. \ W9 K" D) S8 x% `0 J+ p* g - // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。
( s, d. c% [% W; H# T - // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作' R8 p& k) e1 b6 n2 v3 E
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。% j& U# L* u% {" O
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
" J7 ~; Z+ c+ G$ v - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
# O9 X4 t- C, ~3 [! O - $mongo = new MongoClient('mongodb://localhost:27017');0 {/ f# @3 p- q6 ]) l
- $db = $mongo->mf;4 X* O: m& P( B( ^
- $collection = $db->friend;# w: B0 w& ~- g' |
- $res = $collection->remove(['First Name' => 'jet']);1 E+ @) s( d8 I5 F2 _( U
- echo '<pre>';
/ B3 Q! h/ @2 P. z; F - print_r($res);//$res['n']表示删除了几个文档
复制代码
8 j8 h5 a F3 Z以上是PHP7以前版本的MongoDB操作,下面简单介绍PHP7以后版本的操作。
5 a9 F3 J6 _( [' o+ b2 j-----------------------------------------------PHP7分隔线---------------------------------------------------------------------
* x r/ Z+ V8 M0 [2 G& w, {7 [数据插入: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
2 {; ]$ y7 E' z2 c, U% w" M - $bulk = new MongoDB\Driver\BulkWrite;+ }8 M6 G! B8 G$ r* \
- $bulk->insert(['name' => 'JetWu5', 'age' => 26]);
/ Z" [! X6 w4 G; ^ - $bulk->insert(['name' => 'JetWu6', 'age' => 26]);
9 M- Y7 [: ~. V5 Y6 J" z -
0 {$ k# s4 a/ g: F. a# J+ { - $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
8 n8 F* X4 M6 V8 C- B - $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);' M& Z) ~2 f8 {( n8 }4 K j6 \
- echo '<pre>';6 U4 ]2 a" D/ h$ M6 L" c7 u
- print_r($res);
复制代码 ! Q- A2 Z( w: F. V1 |6 S9 O
数据查询: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
+ i: l: m" n, v7 L U' l - $query = new MongoDB\Driver\Query(['age' => 24], ['sort' => ['age' => 1]]);3 ]0 H! f, R& m j# k
- $cursor = $manager->executeQuery('wjt.friend', $query);# s% Q: X# ]+ P5 f
- 9 g! y7 a, A' {# v' b* f9 l9 L! e
- $data = [];# M) y( L: }) Z$ f3 l* D. F) E
- foreach($cursor as $doc) {
/ D; Y( q* \; d: E$ u2 K- z - $data[] = $doc;" {( E, S6 ^- N; c3 n
- }
1 Y$ k0 w# I% G+ V( N - echo '<pre>';
* M' V0 f. F3 O/ G/ _ E! ~" m - print_r($data);
复制代码 数据修改: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
2 q' r- P- _$ C, q- T+ z - $bulk = new MongoDB\Driver\BulkWrite;
2 z4 B, F9 t& F - $bulk->update(& ?! |0 g% k/ [/ f3 L6 d- l
- ['name' => 'JetWu5'],& l3 U$ B3 L! ^) G! Z% P
- ['$set' => ['age' => 30, 'promise' => 'always smile!']]2 X( p/ s& [ @5 V4 M" c* n
- );# |2 C, y/ i; s" [+ |' C3 x3 C
- $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认6 Y: p2 H* `" n7 C
- $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
$ E2 |5 E0 y8 |; y& Q- Z, _6 p - echo '<pre>';
9 y) w( z p& ?2 \& R - print_r($res);
复制代码 数据删除: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
, q) C( g9 r( \4 [9 d1 [7 P - $bulk = new MongoDB\Driver\BulkWrite;& K% a' r) e4 p7 F( c" b8 D
- $bulk->delete(['name' => 'JetWu3']);3 Q+ U$ M& N- [: f# e
- $bulk->delete(['name' => 'JetWu4']);
8 Y; N9 @/ t" b5 ~8 a' r4 ]2 Q- ^ - $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认- v1 p6 c* m2 m/ M2 I
- $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);1 p- z! [+ X3 W* {" L; \* V4 i* [
- echo '<pre>';6 Q) r. l5 c; O
- print_r($res);
复制代码 ! l7 N8 J, j9 r8 c$ a! N
9 x/ _( d8 E7 j
6 h1 X2 b4 k ^$ N7 L8 C) v
/ O4 U: E1 j! g% k: e; j9 O) m0 @3 y+ W9 Y' ?5 k. R0 I6 u
|