MongoDB的PHP驱动提供了一些核心类来操作MongoDB,总的来说MongoDB命令行中有的功能,它都可以实现,而且参数的格式基本相似。PHP7以前的版本和PHP7之后的版本对MongoDB的操作有所不同,本文主要以PHP7以前版本为例讲解PHP对MongoDB的各种操作,最后再简单说明一下PHP7以后版本对MongoDB的操作。 一、数据插入 - //insert()( u, }- i% s' _
- //参数1:一个数组或对象
- k, q% ]# W, } - //参数2:扩展选项
$ Q, J7 `' S n. { - // fsync:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入硬盘& `+ D2 o0 n. t2 o, |
- // j:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入日志
. h+ F# ` l# ~! D4 h4 u - // w:默认为1,写操作会被(主)服务器确认,若为0则将不会得到确认,使用复制集时设置为n用于确保主服务器将数据修改成功复制到n个节点后再确认
3 i1 C* \8 o( P3 V( \6 ]8 J - // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
$ W+ r3 C9 `3 L) p - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)3 {& s" B& D- Z. q' d- A$ X+ ~7 q2 u- X' I
- $mongo = new MongoClient('mongodb://localhost:27017');+ N( Y( j- E: Y, ^
- $db = $mongo->mf;//选择数据库
: G( q4 l; I9 B/ \. c; Y& e - $collection = $db->friend;//选择文档集合: s$ ^* p- T* O/ M
- $doc = [//定义一个文档,即一个数组
% a4 y& d+ B# R7 f4 S) @ - 'First Name' => 'Jet',9 p, S! A* a1 w% l4 Z9 _
- 'Last Name' => 'Wu',
2 g+ m" u4 s$ a4 Y' J& R - 'Age' => 26,! v& T+ W* R2 I/ c$ q8 R8 D' Z1 x, R
- 'Phone' => '110',
* ]; G7 o# ?9 {8 I. B - 'Address' => [
, a! P. {5 T9 b/ v+ ]) D, d - 'Country' => 'China',
' g" p3 @+ {5 Z5 C- ^9 d - 'City' => 'Shen Zhen': b" o' J1 p9 m
- ],0 P8 `# [# n/ {$ a* g# z2 Q0 g
- 'E-Mail' => [3 F/ b6 \/ ~2 q# E
- '123456@qq.com',
9 k( x9 D. K {! A3 g- Y" z+ F - '666666@sina.com',4 I J: O* e; r: ~0 S- a6 F
- '8888888@qq.com',8 N+ ^) G/ k# \' g1 a
- '77887788@qq.com'& p8 x5 N* b: h' z$ L
- ]$ J8 |: B4 ~& F$ f7 ^: R# L
- ];4 J6 {/ y4 ~+ h/ V& f+ k& l
- $res = $collection->insert($doc);//向集合中插入一个文档8 Z7 [% a7 K# U; O
- echo '<pre>';! y; D( m" Q0 d y4 b- ^
- print_r($res);//$res['ok']=1表示插入成功
复制代码二、数据查询 1. 查询单个文档: - //findOne()
$ p0 d! {- [0 c- k! s2 J - //参数1:搜索条件
# a: P2 r" X: L! Y6 Z. ?; X' N4 n - //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非在第二个参数显式加入'_id'=>false。不设置则返回所有字段+ ^6 c4 m& K4 N: d
- $mongo = new MongoClient('mongodb://localhost:27017');0 o* P+ P0 E* K" z2 x! e% K/ c0 h
- $db = $mongo->mf;
9 p+ n$ m3 J- S* M - $collection = $db->friend;
; v$ h- ?" x$ A6 q5 l+ z - $one = $collection->findOne(['First Name' => 'Jet']);
U. W V) x6 K - echo '<pre>';
" S& Y; C0 V4 K; U8 D1 W - print_r($one);//返回一个数组,查不到数据则返回NULL
复制代码2. 查询多个文档: - //find()$ `0 G7 ]7 { G) T, G' \: L1 N
- //参数1:搜索条件" T4 C8 M& f# P7 F/ u3 l$ h- H
- //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非显式设置为false不返回。不设置则返回所有字段6 Q/ D& R% C" f5 j
- $mongo = new MongoClient('mongodb://localhost:27017');' ]7 V) O' S. M4 {& `
- $db = $mongo->mf;
( [) ]! Z6 H( I" a t - $collection = $db->friend;
/ c* B# L2 F6 _) F. a. J - $cursor = $collection->find(['Address.Country' => 'China']);//使用点操作符查找数组元素
& N8 Z( K I- x - echo '<pre>';. t! H0 f; R% u* D2 b _% w- N. T
- while($doc = $cursor->getNext()) {//循环读取每个匹配的文档
8 T" H$ }/ s- F3 N0 Z - print_r($doc);
4 j0 y& `+ C' K2 O* d - }
复制代码使用各种条件操作符定义查询: - //mongodb分别使用$lt(小于)、$lte(下雨等于)、$eq(等于)、$gte(大于等于)、$gt(大于)、$ne(不等于)表示<、<=、=、>=、>、<>,用于整数字段查询
& I+ \& I' ~3 M0 Q - $mongo = new MongoClient('mongodb://localhost:27017');- y( o& x9 E8 C% A: @5 o
- $db = $mongo->mf;$ s0 [1 Q' q# V* W* {/ _6 \
- $collection = $db->friend;+ o( q0 \5 K- q
- $cursor = $collection->find(['Age' => ['$gt' => 30]]);
) U% j% {2 t$ G6 z/ p1 @1 K5 d" A - echo '<pre>';
+ w0 H( J5 J; Q9 ?" P2 _5 _% {8 |3 t4 Q - while($doc = $cursor->getNext()) {8 w D# |* m5 }* h/ V, D) Y# R! j
- print_r($doc);
+ z) J* v" t$ A$ n6 R - }
复制代码 //查询某个字段的所有不重复的值
W) c4 g+ c1 B0 v8 v $res = $collection->distinct('Age'); - //$in:匹配多个值中任意一个
; n3 r; r" A* H7 E+ T+ q4 \ - $cursor = $collection->find(['Address.Country' => ['$in' => ['China', 'USA']]]);
/ h9 W) V8 o( H0 B3 i; \6 w - ' L" N; V/ U- k% n
- //$all:匹配多个值中所有值(用于数组字段查询)
3 R3 `" u' Z: F- a - $cursor = $collection->find(['E-Mail' => ['$all' => ['123456@qq.com', '77887788@qq.com']]]);; w/ U% {" }$ y8 _' e+ v
- 8 V% v# A0 b* L F$ X# S) l
- //$or:或查询1 Z5 G9 Q% r9 z& H5 ~
- $cursor = $collection->find(['$or' => [['First Name' => 'Jet'], ['Address.Country' => 'USA']]]); E( X9 Q% X0 C! k8 y
-
: \' V. \) U: j8 o$ L - //$slice:获取数组字段中指定数目的元素,位于find()函数第二个参数中
; r4 [- S' [4 F - $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => 2]]);//只返回前两个email- S! `2 Z& ]2 [% R e
- $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => -2]]);//只返回最后两个email
% }0 Z* e; V' T& D* k$ K' N3 p - $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => [1, 2]]]);//忽略第一个,返回接下来两个5 b: S W" A3 _* g
- 7 d, i5 z9 }$ I+ @
- //$exists:根据某个字段是否有设置值进行查询
: n% Q# X) \; Z. e; |, z - $cursor = $collection->find(['Hobby' => ['$exists' => false]]);//查找Hobby字段未设置值的文档! w/ G: b) E: b
-
1 e+ i% N9 [: v4 j) q: [9 r/ m - //正则表达式查询
1 B1 x; @ U5 O: E: Q+ U/ U - $cursor = $collection->find(['First Name' => new MongoRegex('/^Je/i')]);//查找First Name字段以Je开头的文档,忽略大小写差异
复制代码使用MongoCursor类提供的其他函数: - //排序:1升序,-1降序
+ L: d& i# O. p$ J2 s) k. \- H - $cursor->sort(['Age' => 1]);
: k( ^$ p; T, D8 p& I -
9 r& a. O. k/ ?7 Q, _: x. J: r; k! ? - //忽略前n个匹配的文档
4 j1 n: A7 g* I - $cursor->skip(1);
+ i$ ^' F( b# L' Z* z1 f$ p) w -
3 P# z0 x: m& p4 g6 g. \2 | i - //只返回前n个匹配的文档(limit()与skip()结合使用可实现数据分页功能)" |, A' h/ O7 G: i% S! Z( v3 M
- $cursor->limit(1);
0 s2 @- g: b$ m* ^) w4 S( p - 6 {( t5 Z% I; X- B. h1 v
- //匹配文档的总数, t: U8 f+ G8 i* o- ^/ |, r
- $cursor->count();$ ? D3 L" ^- n. W6 u
-
# F" f! n8 C& s4 y) j& F* P! S4 s& m. ] - //指定查询索引; L/ ], ^( }) V3 r/ c" U
- $cursor->hint(['Last Name' => -1]);//若索引不存在则会报错
复制代码聚集查询:对数据进行分组统计 - //聚合查询:对数据进行分组统计1 O8 w- f, g' H& ]0 }) K# d
- $mongo = new MongoClient('mongodb://localhost:27017');" G$ _ O. u# s9 q3 |; W* T4 g
- $db = $mongo->mf;
6 h; v/ A. ~# ~$ O; O - $collection = $db->friend;# o: M$ z- N" U. p7 g
- $res = $collection->aggregate([
4 n3 c( J$ E1 O/ e5 u+ H$ @% L - '$group' => [
. X6 s+ Y- z9 v- T- g1 |' t6 z - '_id' => '$Address.Country',//分组字段,注意要加上“$”,这里是根据数组字段某个元素值进行分组
0 X: ?( }* T9 n4 ^ - 'total' => ['$sum' => 1],//求总和,表示每匹配一个文档总和就加1
( h; p2 r4 y( ?. M; B2 F" t$ | - 'maxAge' => ['$max' => '$Age'],//分组中Age字段最大值9 p2 q3 R+ f+ l9 H$ J- L
- 'minAge' => ['$min' => '$Age']//分组中Age字段最小值
( c3 f& y7 o4 r& L9 C - ]1 T. n/ J& y0 m2 P* E5 o
- ]);
1 S4 c% u8 `. x" W7 Z - echo '<pre>';
3 ^" Q/ G) m& \2 \2 a, y - print_r($res);//返回一个数组,$ret['result']为数组,存放统计结果0 Y7 f' u% U: v7 V+ ?8 N5 f; L; J
-
% P! M* C% C; l# s0 z6 t! l - 8 n3 b* C7 U! n
- //存在其它操作的聚合查询:多个操作之间执行先后顺序取决于它们位置的先后顺序! |8 `7 D+ P: t/ Q
- //聚合查询中的所有操作,包括'$group'在内,都是可选的。$ Q# r9 K2 u. b9 q) L
- $mongo = new MongoClient('mongodb://localhost:27017');
* c& z$ d/ T5 x - $db = $mongo->mf;, a; U4 x( ~9 Y1 y" t- _+ J% i
- $collection = $db->friend;8 \" Z$ Q9 c; M0 m2 B
- $res = $collection->aggregate([$ M" L( i; k. n( S. z$ A
- [//过滤条件:只对符合条件的原始文档进行聚合运算,若是放在'$group'之后则是只返回符合条件的结果文档
. O! i1 r8 N4 k - '$match' => ['Age' => ['$gt' => 30]]
9 g' c# b/ P1 K7 d3 H8 e7 v - ]," [1 r8 A6 f7 ^8 s0 z
- [//指定分组字段、统计字段
4 y, P* N$ V) B4 V! U& j/ h$ E - '$group' => [
5 h+ `& ~, h {7 B4 @9 M! \6 w - '_id' => '$Address.Country',; |7 u+ I0 R, ?* U- ^6 @! [
- 'totalAge' => ['$sum' => '$Age']//计算各个分组Age字段总和
( h. V+ g7 ?; I( U( v/ m* L4 s1 W - ]9 Y' V: I6 ?+ q, g2 {% Q2 Z- X
- ],: M* k6 N0 f2 ` V. o: ]
- //以下操作若是放在'$group'之前则在聚合前作用于原始文档,若放在'$group'之后则在聚合后作用于结果文档, Q5 N. _: @8 k5 m4 G5 @
- ['$unwind' => '$E-Mail'],//将包含有某个数组类型字段的文档拆分成多个文档,每个文档的同名字段的值为数组中的一个值。& e( }- ~% g. g7 J
- ['$project' => ['myAge' => '$Age', 'First Name' => '$First Name']],//指定返回字段,可以对字段进行重命名,格式:返回字段名 => $原来字段名* ^: G2 C) }- J0 [ V; q( Q) [: M
- ['$skip' => 2],//跳过指定数量的文档' b& e* S$ k8 ?. Y; A) G7 J: I) F
- ['$limit' => 2],//只返回指定数量的文档
3 P) ~+ N" T) }" `3 W4 d/ O - ['$sort' => ['totalAge' => 1]]//排序" t- p& I% w" K
- ]);1 F, {4 Y0 s0 B! i* X& o k: z- r
- echo '<pre>';3 }7 y. A A6 X4 A
- print_r($res);
复制代码
2 ]$ B3 f8 H! m5 m5 f3 y3 C三、数据修改 - //update(); l* {; X$ [5 y, _9 f, z
- //参数1:更新条件,指定更新的目标对象。- T: z5 X5 u6 w" s
- //参数2:指定用于更新匹配记录的对象。8 y/ \* L4 J2 \$ r6 y
- //参数3:扩展选项组。 m7 d* a: M8 r" C6 ?
- // upsert:若设置为true,当没有匹配文档的时候会创建一个新的文档。( P# u2 D7 a+ ~! Q
- // multiple:默认为false,若设置为true,匹配文档将全部被更新。" N- O0 ~, w, H; f, F
- // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。' f3 D9 l) V. u5 {& U
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作. G1 |. G, A% p' F0 a7 w
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。& F1 l/ _# u3 j( e5 s# v/ C
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
+ i" @3 ~# n0 z0 R- K - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
. {4 s0 b7 E: l( i - //注意:若不使用任何修改操作符,则匹配文档将直接被整个替换为参数2指定的对象。+ Z/ Z9 b* ~& \# \" t
- , H% f' y0 l# ~: K8 ~
- //$inc:增加特定键的值,若字段不存在则新建字段并赋值# `; M' d5 a' b! |- J N. a6 H8 w
- $mongo = new MongoClient('mongodb://localhost:27017');9 P' ?. p4 B8 {" H' [3 }: z* J- n
- $db = $mongo->mf;3 W V# C' K4 {0 ]
- $collection = $db->friend;, }$ ?. X% w7 Z9 U% O3 i) l
- $res = $collection->update(['First Name' => 'Jet'], ['$inc' => ['Age' => 2]]);
8 [# H4 X* M2 Q1 J4 J$ Z/ m2 f" e - echo '<pre>';
. s8 S& h0 n' [& a' y - print_r($res);//$res['ok']=1表示修改成功,$res['nModified']表示修改的文档数量
3 C. E" m, V% ~9 q - ) Z6 R. t+ f/ v- r
- //$set:重置特定键的值,若字段不存在则新建字段并赋值1 S: o! p. B9 N8 M; y1 ^
- $res = $collection->update(['First Name' => 'Jet'], ['$set' => ['Hobby' => 'pingpong']]);' p l) w8 D, y# S) A+ u
-
4 u! S6 s ^( b. p8 P4 x8 W# n - //$unset:删除字段
& S& b8 h6 H5 x' N! d y - $res = $collection->update(['First Name' => 'Jet'], ['$unset' => ['Hobby' => 1]]);# d k/ y# } Q/ H$ T" g G! T" `3 [
-
; k& x: w7 j: |; o3 p9 N - //$rename:重命名字段,若字段不存在则不进行任何操作
; v, O" J$ c5 J, H: S+ g - $res = $collection->update(['First Name' => 'Jet'], ['$rename' => ['Hobby' => 'hobby', 'Age' => 'age']]);
8 `: H* f2 w$ z7 H! u) X - //注意:如果文档中已经使用了指定名称的字段,则该字段将会被删除,然后再进行重命名操作。" R2 g, j: \4 R6 b
-
4 S/ H/ \8 l9 u: B1 o - //$setOnInsert:设置了upsert为true,并且发生了插入操作的时候,将某个字段设置为特定的+ `+ @% N5 x0 l# K1 }+ l
- $res = $collection->update(['First Name' => 'jet'], ['$setOnInsert' => ['lang' => 'English']], ['upsert' => true]);
4 O* s) i9 n* f - . s- R3 E4 R& K5 c8 S% T/ j
- //$push:向指定字段添加一个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错
8 D4 U- A1 W. y+ M - $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '123123@qq.com']]);1 y4 y) |& B+ s+ ^0 m8 }
- " h: B/ d5 _! w0 ~9 R! y7 Z
- //$push:向指定字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错
# |; \. E( T* a5 Q) [/ V+ V& r - $res = $collection->update(['First Name' => 'Jet'], ['$pushAll' => ['E-Mail' => ['666@qq.com', '8888888@qq.com']]]);- o* U3 M1 T2 x5 I4 u
-
! z$ Z9 _' I2 I" V, a3 v7 V - //使用$push和$each向某个字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错4 }5 ?! V7 y4 W" F8 w9 o2 A
- $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);
/ n/ n; Q: ~. D' Q+ R; g0 l$ M7 V - . d$ h4 H7 ]0 ?! e4 E
- //$addToSet:将数据添加到数组中(只在目标数组没有该数据的时候才将数据添加到数组中)
' W- e( E6 G- b- |1 i7 c - $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => '123123@qq.com']]);
- B' `) ~7 f6 u) m% H+ E! O - $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);0 `1 `9 k6 v" Z6 ~6 U7 \* k: T
-
% F: _- q/ Q- X& P6 v* Z6 z0 L$ [5 A - //$pop:从数组中删除一个元素,-1表示删除第一个元素,1表示删除最后一个元素(其实负数都删除第一个元素,0或正数都删除最后一个元素)
9 d$ n' l' ~4 }$ r. L - $res = $collection->update(['First Name' => 'Jet'], ['$pop' => ['E-Mail' => 1]]);. @; ?1 @9 }$ T" O+ _, X9 x1 _
-
+ c/ I3 {: h! w- i - //$pull:删除数组中所有指定值: U% S' D, i: g- g. f4 b
- $res = $collection->update(['First Name' => 'Jet'], ['$pull' => ['E-Mail' => '123123@qq.com']]);
: x8 n+ P8 G! [/ j; F) u - 0 P6 m8 ]* @( Z. E$ X% @; P# i
- //$pullAll:删除数组中多个元素的所有值
$ C) W @0 w# [: x" ? - $res = $collection->update(['First Name' => 'Jet'], ['$pullAll' => ['E-Mail' => ['123123@qq.com', '666@qq.com']]]);
复制代码- //save()
, X# ^( Q; D: t j1 e - //参数1:希望保存的信息数组1 U$ V6 g( b. `" C9 v' P
- //参数2:扩展选项) o- G( ]5 {( x0 ? H7 u- v
- // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。+ D7 i( o8 J; C8 M2 ~* F
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作' ~" k) z9 b5 q+ k+ l
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。
! Q* }" q/ H5 n, k - // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间1 n2 C9 V5 X1 g( D5 q
- // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
* e2 O! n+ t0 X3 ?1 r! ]( W - //注意:若已存在则更新,若不存在则插入;更新时使用参数1指定的信息数组替换整个文档。
' Z, M% t* h3 V% D - //若想更新则应该在参数1中指定_id键的值。) ?) ?- G0 r( m
- $mongo = new MongoClient('mongodb://localhost:27017');7 y: p1 ~4 D- V* c# O/ d
- $db = $mongo->mf;
0 K z$ y& `/ N( a( Q: p% ? - $collection = $db->friend;( t% f. X& M* p# _# x
- $doc = [//定义一个文档,即一个数组 v/ C% m, E1 U8 m6 J
- 'First Name' => 'Jet',% d4 |2 G) w- R- H1 C
- 'Last Name' => 'Wu',
+ o& @' F3 h0 h2 ]* j8 b4 Y. `6 r6 Y - 'Age' => 26,
8 y0 ?6 j5 ?5 e3 p1 {6 J' ] - 'Phone' => '110',
# g8 W1 J4 P, b6 B1 i - 'Address' => [
! X+ @% {8 u2 e; [4 n. D - 'Country' => 'China',
$ l: i- L0 Z% @, M) r. b - 'City' => 'Shen Zhen'
3 x+ l3 N4 w4 f m H - ],
3 y" j2 {& ?' q - 'E-Mail' => [
! |& z% D {: h4 D5 i4 H% S7 s0 c - '123456@qq.com',9 h( u4 B7 l M" ~7 A# K* \" _
- '666666@sina.com',
( n5 C0 l9 `9 d4 d- ]/ U0 { - '8888888@qq.com',) v! g$ G4 X4 |/ S
- '77887788@qq.com'
/ t1 o, \2 W/ P+ n9 @6 C- H - ]5 P; n. B8 L6 Z6 _2 z# {, |4 Y6 J
- ];! }* s% x! `6 H' P, h- I
- $res = $collection->save($doc);5 c, W; H4 ^: J! K. P( K
- echo '<pre>';& b- ~5 y% l Z
- print_r($res);//$res['ok']=1表示操作成功,$res['updatedExisting']=1表示更新,$res['upserted']=1表示插入8 g0 a/ Q8 T. F# v5 `( K
3 N( C( v7 x7 I, ?8 E( S/ t7 h1 i
复制代码- //findAndModify()
3 f$ I9 V- B9 O1 A3 K' X1 O5 r7 @ - //参数1:指定查询条件
0 Z3 n- f( Q' q - //参数2:指定用于更新文档的信息 L1 d. W; ~! R* t1 S* n
- //参数3:可选,指定希望返回的字段5 K8 I0 ~3 j4 Y! n
- //参数4:扩展选项$ ?0 y. z$ B7 h" u/ w
- // sort:以特定顺序对匹配文档进行排序6 @" j4 t: d" s( ~. C
- // remove:若设置为true,第一个匹配文档将被删除
0 d; \- o Z+ l! a, J$ O - // update:若设置为true,将在被选择的文档上执行更新操作- `& O% @6 E+ s# m3 P
- // new:默认为false,若设置为true则返回更新后的文档,否则返回更新前的文档# ^" h/ e8 a* Z) v9 e. V; r2 \0 u
- // upsert:若设置为true,没有找到匹配文档的时候将插入一个新的文档
, B' R4 W& v& l7 N- I& q - $mongo = new MongoClient('mongodb://localhost:27017');$ P1 @- L8 @- O9 e4 p/ \3 d
- $db = $mongo->mf;- U( Z2 g8 g0 B2 R* f$ t' J
- $collection = $db->friend;4 b; a$ W4 e2 n4 m2 u% d8 ?
- $res = $collection->findAndModify(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '111@qq.com']]);
( z ?/ S6 E6 z1 l% p0 ] - echo '<pre>';
5 Z; W+ k3 G% x. F/ z# F7 R6 K - print_r($res);
复制代码 四、数据删除 - //remove(): F' w' d- _: P; G( p* q
- //参数1:查询条件- O3 r ?4 U: d
- //参数2:扩展选项% l X! E8 |1 I. B3 ]; m
- // justOne:若设置为true,则最多只有一个匹配的文档将被删除3 @3 q8 X5 ? s" e! @1 w1 a
- // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。5 A4 N6 p3 t8 j* w3 M7 s4 w8 U
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作4 m9 x' }. g$ M8 ?3 B+ S
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。
$ H7 j. L5 d- ^: N: ^; K - // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
$ Y/ }1 {3 P: {3 p - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
, P. E3 T4 R/ r - $mongo = new MongoClient('mongodb://localhost:27017');
* D" r( u! }4 M ?, L7 ` - $db = $mongo->mf;2 S" Z( M' F: H. g, A
- $collection = $db->friend;5 w% m5 X5 e1 b6 ~& o
- $res = $collection->remove(['First Name' => 'jet']);
& \+ A- ?9 q' h3 | - echo '<pre>';
5 d# k* k+ L& g - print_r($res);//$res['n']表示删除了几个文档
复制代码
( T( ]$ j* a& }4 m+ z1 q以上是PHP7以前版本的MongoDB操作,下面简单介绍PHP7以后版本的操作。 " W) |5 D( Y& L y7 d! r5 {7 f
-----------------------------------------------PHP7分隔线---------------------------------------------------------------------
6 Z. q& G) X3 F- U6 C0 i" Q- E; P数据插入: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');: m9 Q- S k+ ]1 } u( N3 k7 |
- $bulk = new MongoDB\Driver\BulkWrite;
1 J: [( n) Z, K0 t- P- f - $bulk->insert(['name' => 'JetWu5', 'age' => 26]);
3 M2 e& i5 U7 j; Y6 z - $bulk->insert(['name' => 'JetWu6', 'age' => 26]);
- C C- E( e/ H; T# a8 L -
* B, G5 F+ j1 }: y7 f* z6 ?5 b - $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认2 ^3 ^" N) c1 a' f' T
- $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
2 q$ N/ l, {; x7 y6 l7 ` - echo '<pre>';3 \% U, X' |( W7 [) g
- print_r($res);
复制代码
3 Y! _9 H: U: @数据查询: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');1 c2 U9 h$ L/ \# s
- $query = new MongoDB\Driver\Query(['age' => 24], ['sort' => ['age' => 1]]);) E8 h) |8 y# w
- $cursor = $manager->executeQuery('wjt.friend', $query);! c9 o6 r. f5 P9 c" R
- 6 R1 @4 g! B/ n! _# V: a- [# A# |/ z
- $data = [];
0 P( m, |7 a% G - foreach($cursor as $doc) {, c' w$ {/ c8 n
- $data[] = $doc; E; e7 I/ E6 o9 T- C
- }5 ^4 V6 a V7 Q/ T' K* N
- echo '<pre>';# h* v9 `& w) B; O6 o: w& e
- print_r($data);
复制代码 数据修改: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');0 E$ Q$ c6 O6 T
- $bulk = new MongoDB\Driver\BulkWrite;6 R! j- V: j/ }5 s
- $bulk->update(' _3 A& i, f+ ]# l3 F
- ['name' => 'JetWu5'],
! v: M4 s% \9 W% X4 a& C0 M( }! R& x - ['$set' => ['age' => 30, 'promise' => 'always smile!']]" f& S" W! Z6 h8 U, B
- ); L2 @( u* U# y
- $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认8 [8 T7 C' l9 ~# t6 E0 M
- $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);" @+ u! m' \3 f6 \, V# a8 z
- echo '<pre>';" C, A$ \( h; Q
- print_r($res);
复制代码 数据删除: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
; i! { h$ j) H% n0 k4 ~ - $bulk = new MongoDB\Driver\BulkWrite;
% \9 [3 {% M1 m8 H' Z7 J - $bulk->delete(['name' => 'JetWu3']);
5 z( v+ b( D+ j- j5 s& K. Z - $bulk->delete(['name' => 'JetWu4']);
# g% A& _5 c8 F# n9 f - $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
% {/ w o8 e0 }# n6 I - $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
( Q0 Q h3 J6 j' H$ t/ x - echo '<pre>';
8 E7 j& M# t+ K' f; ^6 q! `% U - print_r($res);
复制代码
, V ~9 d- E& w! k$ \4 A( s2 B/ n$ U( [: r
8 S& a' u8 f& m" G" b3 |. ~/ R& f8 U# I$ X
" o1 b7 P5 j. w } |