MongoDB的PHP驱动提供了一些核心类来操作MongoDB,总的来说MongoDB命令行中有的功能,它都可以实现,而且参数的格式基本相似。PHP7以前的版本和PHP7之后的版本对MongoDB的操作有所不同,本文主要以PHP7以前版本为例讲解PHP对MongoDB的各种操作,最后再简单说明一下PHP7以后版本对MongoDB的操作。 一、数据插入 - //insert()! @# ~! Q. `* ~0 T$ _+ T
- //参数1:一个数组或对象/ k/ c( a3 j; T
- //参数2:扩展选项
' h1 d; R$ ?. P/ @ - // fsync:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入硬盘8 b- v' n0 `4 ?+ ] U# w: c; b6 X
- // j:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入日志
- R. a- o1 \2 w2 K4 L" v( p - // w:默认为1,写操作会被(主)服务器确认,若为0则将不会得到确认,使用复制集时设置为n用于确保主服务器将数据修改成功复制到n个节点后再确认4 e: h9 ?: I! z! t5 a7 d6 Y( c
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间- s6 {" w5 ?2 e
- // timeout:指定客户端需要等待服务器响应的超时时间(毫秒), m* b6 D R/ |2 |" R d6 J
- $mongo = new MongoClient('mongodb://localhost:27017');
3 u" s8 a' Y+ e7 l7 m - $db = $mongo->mf;//选择数据库) `) s4 g6 K1 m+ K& f+ N0 u5 D
- $collection = $db->friend;//选择文档集合; s" U- q! X7 U, Z: O* y
- $doc = [//定义一个文档,即一个数组
, z3 `1 V( V- U% u - 'First Name' => 'Jet',
( [# f# Q. L" e5 ]7 M7 P+ |: w8 p - 'Last Name' => 'Wu',
' G! k; s: v0 H' j9 Z. l - 'Age' => 26,
$ h" W; \. [+ v* X& J2 S: V& m - 'Phone' => '110',& ?6 F2 o/ N v7 P
- 'Address' => [
+ O: Y7 U$ q; \! H! A5 y j) I - 'Country' => 'China',
$ G( I1 z0 A p8 _ - 'City' => 'Shen Zhen'
4 \, O2 q# X3 C7 y, R8 @6 f: R% C - ],/ ]4 m! V/ F1 S/ s4 H3 y1 O; M
- 'E-Mail' => [( D2 H3 ~1 F/ e6 g' C
- '123456@qq.com',; a* ~* u* B& F& V* g
- '666666@sina.com',
3 f7 I' h5 k6 w3 {; `! M - '8888888@qq.com',2 r: ]: G# C2 C" I+ ]& x2 |' X
- '77887788@qq.com'
/ I+ j* ?% [; S6 v$ \4 K - ]
9 B5 u* K, e1 ?9 }3 U, Y - ];
1 t$ T2 l( M7 ^4 o - $res = $collection->insert($doc);//向集合中插入一个文档
; ? C; E, M2 Q2 G6 p4 ]) g, z - echo '<pre>';
w2 ?9 e a* O }# G r( w! R - print_r($res);//$res['ok']=1表示插入成功
复制代码二、数据查询 1. 查询单个文档: - //findOne()+ D0 d! Y$ c+ R5 S
- //参数1:搜索条件
( k; [, \4 j# W6 a- e, A - //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非在第二个参数显式加入'_id'=>false。不设置则返回所有字段# Z* j) u. z0 h* k& o
- $mongo = new MongoClient('mongodb://localhost:27017');' j- n9 [; }5 o- @/ ?1 @' H' P
- $db = $mongo->mf;
, l3 j1 c, @( I$ l0 ]5 V2 B - $collection = $db->friend;
: d. ]3 G+ Y7 Y+ u7 v - $one = $collection->findOne(['First Name' => 'Jet']);) Y' H9 W2 c* ?+ c/ b2 e
- echo '<pre>';5 C7 S: _* R" U1 R+ W" |
- print_r($one);//返回一个数组,查不到数据则返回NULL
复制代码2. 查询多个文档: - //find()
- ]% g- R" J( ~' T/ Z, t - //参数1:搜索条件
% ~; a7 B/ y! X; F - //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非显式设置为false不返回。不设置则返回所有字段4 p( f2 R1 l! J' J. G$ J
- $mongo = new MongoClient('mongodb://localhost:27017');
: l/ [" {6 _* d - $db = $mongo->mf;/ V' l- y2 O$ X, b O' P$ I) V: W9 q9 n
- $collection = $db->friend;9 }$ H- J! p2 n! e% \
- $cursor = $collection->find(['Address.Country' => 'China']);//使用点操作符查找数组元素6 h2 r6 c3 ?0 i0 |
- echo '<pre>';8 W( r% x! n" F" ~- T) R0 L
- while($doc = $cursor->getNext()) {//循环读取每个匹配的文档
m' A+ N/ s6 \+ M; u - print_r($doc);
6 B- r5 C/ L( b3 j0 V/ n - }
复制代码使用各种条件操作符定义查询: - //mongodb分别使用$lt(小于)、$lte(下雨等于)、$eq(等于)、$gte(大于等于)、$gt(大于)、$ne(不等于)表示<、<=、=、>=、>、<>,用于整数字段查询
$ z6 y1 _% V+ L. v - $mongo = new MongoClient('mongodb://localhost:27017');
8 q# O1 {7 ?2 c) t8 `: y% h: { - $db = $mongo->mf;
4 h5 p2 D/ ^3 P2 J - $collection = $db->friend;0 ~) A4 j8 i6 U1 u
- $cursor = $collection->find(['Age' => ['$gt' => 30]]);% T- @! e3 O. h& C; _( A: `
- echo '<pre>';( S7 s4 o, ?; L$ H- k
- while($doc = $cursor->getNext()) {
( M' ]! s4 v0 }/ y. i. V" ^3 M - print_r($doc);* I6 d. R$ F& T# L' l' h
- }
复制代码 //查询某个字段的所有不重复的值5 @! q, y% U9 e
$res = $collection->distinct('Age'); - //$in:匹配多个值中任意一个
/ t) k8 Q- \% {7 @; W! p - $cursor = $collection->find(['Address.Country' => ['$in' => ['China', 'USA']]]);
& F$ W' r. U; t) \" X% B; \, x( c# d -
/ N X" O* |" N2 n( @ - //$all:匹配多个值中所有值(用于数组字段查询)6 l: D5 t3 {7 {, V. {: o
- $cursor = $collection->find(['E-Mail' => ['$all' => ['123456@qq.com', '77887788@qq.com']]]);
8 d) X2 x' n1 o$ I V' a -
7 B; \2 ^2 n$ L: v - //$or:或查询2 n1 I o0 ?7 k; B: ] u0 z9 h' {8 K
- $cursor = $collection->find(['$or' => [['First Name' => 'Jet'], ['Address.Country' => 'USA']]]);+ _3 M0 S9 F2 K, I. S0 |
-
% `5 o8 D. r5 q/ q! s4 t - //$slice:获取数组字段中指定数目的元素,位于find()函数第二个参数中
: S1 d% S ~+ W \+ n - $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => 2]]);//只返回前两个email; K" {$ u- e+ r! l
- $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => -2]]);//只返回最后两个email& k$ e: C8 [, j
- $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => [1, 2]]]);//忽略第一个,返回接下来两个3 t! p* ~# B+ W; H6 k
-
; F9 ~! Y$ l, w' c2 ]0 w - //$exists:根据某个字段是否有设置值进行查询
; O! G& q; n3 l* E - $cursor = $collection->find(['Hobby' => ['$exists' => false]]);//查找Hobby字段未设置值的文档
$ k2 o* g( @! B -
* G& }% _! p+ h: K* h6 z" m8 a - //正则表达式查询
8 A7 G2 ~3 w! D - $cursor = $collection->find(['First Name' => new MongoRegex('/^Je/i')]);//查找First Name字段以Je开头的文档,忽略大小写差异
复制代码使用MongoCursor类提供的其他函数: - //排序:1升序,-1降序
& T F7 L* z6 z, D - $cursor->sort(['Age' => 1]);& D* v Z+ E* I/ a5 _
-
% w5 E& Z# e0 J - //忽略前n个匹配的文档
! E) V$ b" o& G" L7 h0 T - $cursor->skip(1);
4 i) H- X3 C1 H* c+ R. b -
# I% }' {& Q9 m/ W; C - //只返回前n个匹配的文档(limit()与skip()结合使用可实现数据分页功能)
2 D+ z* F( {' T F% I - $cursor->limit(1);$ Y9 [4 k# w V* [$ C t2 t
-
g3 ^5 m0 X* G% E( o/ E - //匹配文档的总数
6 t# F4 Q/ i' [ - $cursor->count();
) V+ ~: z1 P( q" S* ]+ \ -
& H% g0 Z5 h" I G9 P- | B - //指定查询索引
5 L* i- b& ^! e5 P& }% o, i - $cursor->hint(['Last Name' => -1]);//若索引不存在则会报错
复制代码聚集查询:对数据进行分组统计 - //聚合查询:对数据进行分组统计
) f: c# Q$ l9 E/ _0 N8 B - $mongo = new MongoClient('mongodb://localhost:27017');7 Z1 ]9 Y( X5 W1 L9 g
- $db = $mongo->mf;; K2 z) V; C+ i i7 a
- $collection = $db->friend;# j; T% w) ~% z7 c/ b- s. Y- i! i
- $res = $collection->aggregate([6 o+ ?8 O* G% M9 Y% d4 k- b& V) }' ^8 \
- '$group' => [
# w) y* @8 T4 }7 e _' e - '_id' => '$Address.Country',//分组字段,注意要加上“$”,这里是根据数组字段某个元素值进行分组 C4 G" @, y7 t, F# y
- 'total' => ['$sum' => 1],//求总和,表示每匹配一个文档总和就加1
9 q( G1 `$ @4 A- n6 N5 [ - 'maxAge' => ['$max' => '$Age'],//分组中Age字段最大值
- T7 m: U8 @. q& A h& S - 'minAge' => ['$min' => '$Age']//分组中Age字段最小值6 N% Z- l! l6 v6 s
- ]
+ Q) A7 r/ p8 x$ r - ]);
" q% }& M3 T/ M - echo '<pre>';9 ~1 U* S6 h# k B0 b% X
- print_r($res);//返回一个数组,$ret['result']为数组,存放统计结果
4 b$ c+ ~8 P6 b% Q& i - % b; k) o+ E: q0 ?- k# \0 W6 S, x/ W
- 9 }. o* \) a! w9 f$ S8 y" U
- //存在其它操作的聚合查询:多个操作之间执行先后顺序取决于它们位置的先后顺序
6 T5 w1 Y' ~# [; z% g2 G1 X/ E - //聚合查询中的所有操作,包括'$group'在内,都是可选的。# R! j& ^! `; ^; O' J2 d2 J) l( s9 m7 p
- $mongo = new MongoClient('mongodb://localhost:27017');
" @4 b ^4 h/ t. p - $db = $mongo->mf;! Q; u, P+ o. P6 I. a
- $collection = $db->friend;
6 k4 W. e( I& H: s) f; z - $res = $collection->aggregate([
0 `3 S! n' l3 r) { - [//过滤条件:只对符合条件的原始文档进行聚合运算,若是放在'$group'之后则是只返回符合条件的结果文档
. Y: d# F0 q; G& I8 y - '$match' => ['Age' => ['$gt' => 30]]
9 _# q- p" p' l% x - ],
0 p* W/ [3 \' a9 H - [//指定分组字段、统计字段/ v m) S* X" [! b8 m( R# I, } O( I
- '$group' => [
, K/ R6 _ J: m. I) s! d# }0 W( | - '_id' => '$Address.Country',
2 J1 P5 k/ m2 }1 p6 e) K) X - 'totalAge' => ['$sum' => '$Age']//计算各个分组Age字段总和
( W6 N. L. K4 o" I$ J - ]% e3 V4 E9 f: p- z$ u: q
- ],
: H5 H1 P2 u* l6 W$ _2 H6 P* l% x% z - //以下操作若是放在'$group'之前则在聚合前作用于原始文档,若放在'$group'之后则在聚合后作用于结果文档: u1 z/ G: q7 n1 G
- ['$unwind' => '$E-Mail'],//将包含有某个数组类型字段的文档拆分成多个文档,每个文档的同名字段的值为数组中的一个值。
' V6 V% Y4 i. J" L' X. N - ['$project' => ['myAge' => '$Age', 'First Name' => '$First Name']],//指定返回字段,可以对字段进行重命名,格式:返回字段名 => $原来字段名
& R7 z& _6 y" p5 s; F - ['$skip' => 2],//跳过指定数量的文档
3 @ s7 A$ C& l2 D& D - ['$limit' => 2],//只返回指定数量的文档
- e5 u* p Q& x" ^/ i a/ e - ['$sort' => ['totalAge' => 1]]//排序
7 _ K/ l8 D! b, {0 M. W - ]);3 o0 r- ^8 R9 b& m. N$ D3 Y- Y* T
- echo '<pre>';1 P, j; z. C2 m5 r6 o% [
- print_r($res);
复制代码 # G# [7 ]$ F* O) f6 X
三、数据修改 - //update()
# {* e4 Y* G# P4 o - //参数1:更新条件,指定更新的目标对象。% s) Z4 w7 ]" ^+ I2 @! J
- //参数2:指定用于更新匹配记录的对象。" H3 k3 u4 Q; [1 t) z
- //参数3:扩展选项组。
/ y, q' B2 ^5 v: u9 I - // upsert:若设置为true,当没有匹配文档的时候会创建一个新的文档。
9 [8 }+ f. n& J) o B. q. ~ - // multiple:默认为false,若设置为true,匹配文档将全部被更新。' r3 k8 L& v- e/ v9 V5 P$ W0 {! @
- // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。* i1 B5 @) s& h. f0 o+ u
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作4 g8 h& T% c- T1 {, |
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。* y4 P9 ]2 l/ A7 q
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间3 y$ a( R1 n! s9 {
- // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
5 }" t' z3 ]6 i0 ~) X; ]4 ` - //注意:若不使用任何修改操作符,则匹配文档将直接被整个替换为参数2指定的对象。& G. c% i( K' @- ]$ o
-
) |! V6 l) ?9 o* @' B: v - //$inc:增加特定键的值,若字段不存在则新建字段并赋值
4 i7 g. g# O# p# A7 ~# c$ C1 \- r8 S - $mongo = new MongoClient('mongodb://localhost:27017');
, q5 j) z2 z9 H - $db = $mongo->mf;
* J) W/ ~: \: T# z - $collection = $db->friend;
9 Z$ H6 Y" M7 \; r) ` - $res = $collection->update(['First Name' => 'Jet'], ['$inc' => ['Age' => 2]]);
; e% b" m* a. y5 ~+ R& v - echo '<pre>';
0 o! D+ d) z2 ~. b - print_r($res);//$res['ok']=1表示修改成功,$res['nModified']表示修改的文档数量
0 w/ b% ^5 B _6 k: m9 S+ x -
: H: R9 t3 Y( Q- o6 u( Z4 | - //$set:重置特定键的值,若字段不存在则新建字段并赋值 I' r+ b/ z& I; Z& w0 z! x) o
- $res = $collection->update(['First Name' => 'Jet'], ['$set' => ['Hobby' => 'pingpong']]);
' ~, G' D. H! x, C ^& N - ; i2 }$ T# v5 J0 [6 Q# \
- //$unset:删除字段' r0 {( F3 k+ |+ C" E
- $res = $collection->update(['First Name' => 'Jet'], ['$unset' => ['Hobby' => 1]]);/ ?% L% I* ^/ v7 }
- . c* U0 M# X! {* ]- |
- //$rename:重命名字段,若字段不存在则不进行任何操作7 p9 h0 S& k0 a2 |0 W( E
- $res = $collection->update(['First Name' => 'Jet'], ['$rename' => ['Hobby' => 'hobby', 'Age' => 'age']]);
, x# M2 {# l+ J5 Y. M - //注意:如果文档中已经使用了指定名称的字段,则该字段将会被删除,然后再进行重命名操作。
0 e) b3 s& G3 D; ? - & [9 k# \! p T+ Z
- //$setOnInsert:设置了upsert为true,并且发生了插入操作的时候,将某个字段设置为特定的
- @' O# Y5 x5 g2 g2 L* X* U, D - $res = $collection->update(['First Name' => 'jet'], ['$setOnInsert' => ['lang' => 'English']], ['upsert' => true]);1 Z2 ~+ a0 f# T; D- L+ i) E* _
- 6 I7 V, l2 L. G
- //$push:向指定字段添加一个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错
8 @" U" j" X5 B7 ^, K5 s, K9 q - $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '123123@qq.com']]);% J8 b, K5 o3 f& ]
-
8 D6 B j* {1 ~+ _, V+ V - //$push:向指定字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错 c$ @4 t1 d0 B v9 k/ F; p
- $res = $collection->update(['First Name' => 'Jet'], ['$pushAll' => ['E-Mail' => ['666@qq.com', '8888888@qq.com']]]);& j" y" N# h. n" i3 g
- & w- L" n+ r/ M( Y& h8 J- ^6 c
- //使用$push和$each向某个字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错 J2 i, q- _3 c7 [* B
- $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);: X8 |, M8 x# d. c
- 4 L$ C: C& |' N5 A0 q& h# ?: L/ u
- //$addToSet:将数据添加到数组中(只在目标数组没有该数据的时候才将数据添加到数组中)
9 ~- k% }0 M `! E! X - $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => '123123@qq.com']]);
6 `$ ?6 M0 M& K" A( _0 k5 N$ V8 U - $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);9 Z: N$ g. J2 J+ o% H+ @
- - j; k/ Y: S& o. o
- //$pop:从数组中删除一个元素,-1表示删除第一个元素,1表示删除最后一个元素(其实负数都删除第一个元素,0或正数都删除最后一个元素)
. H9 ^3 v. A. M9 l+ s! b- K - $res = $collection->update(['First Name' => 'Jet'], ['$pop' => ['E-Mail' => 1]]);
% g/ p/ V e% L' w3 x -
2 U0 x9 o: A/ A: ^ - //$pull:删除数组中所有指定值
. _) i" P9 Z% ~4 G& U% q - $res = $collection->update(['First Name' => 'Jet'], ['$pull' => ['E-Mail' => '123123@qq.com']]); F. O) f4 L) K
-
- Z( V* A5 q% C; q6 \ - //$pullAll:删除数组中多个元素的所有值2 k8 T. ]6 N9 U6 }$ x
- $res = $collection->update(['First Name' => 'Jet'], ['$pullAll' => ['E-Mail' => ['123123@qq.com', '666@qq.com']]]);
复制代码- //save()" G2 I1 W0 T) N% L3 F
- //参数1:希望保存的信息数组/ h- z) V9 e+ Q4 I# n
- //参数2:扩展选项9 H( D u6 j8 V" z- R
- // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。3 o0 m8 |" C0 I# w0 ?, N
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作+ i: D- ^( d( W& z- E
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。
* A. I; H) r( R5 O9 G* W - // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
3 R% }1 E4 B9 m& @' y. _ - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
0 r; c2 V+ P9 ~3 D7 O' {% W - //注意:若已存在则更新,若不存在则插入;更新时使用参数1指定的信息数组替换整个文档。% X+ Q2 Y9 z" I7 o e
- //若想更新则应该在参数1中指定_id键的值。
# Y% u9 i: T$ P- y; t- H - $mongo = new MongoClient('mongodb://localhost:27017');& K) G6 x/ w2 ], K
- $db = $mongo->mf;
4 R F3 F) i4 _! e+ K" ` - $collection = $db->friend;
; j2 H( q% f/ M9 y' T7 D - $doc = [//定义一个文档,即一个数组
7 T. `" g5 t3 [! g; L - 'First Name' => 'Jet',% g. u* f$ z* ?( G" \2 ]! m& O5 Z
- 'Last Name' => 'Wu',& s( h q7 ]! q1 S! t
- 'Age' => 26,1 |" E( C# H6 t# V! s& }
- 'Phone' => '110',
; _% B7 d% i3 A5 c6 T4 B& y1 V - 'Address' => [6 p2 `! E N1 O W
- 'Country' => 'China',
5 f+ H8 {6 L& w$ S& J - 'City' => 'Shen Zhen'
% A( J3 d; w6 R, x - ],/ \! x' U' `9 ?6 y
- 'E-Mail' => [
! L: _; K& x1 @5 U - '123456@qq.com',
0 H( ]' m* G6 U! _7 Y* R - '666666@sina.com',
2 T; ?6 u0 S/ p9 g4 T% a0 v - '8888888@qq.com',
8 m" i1 t' p5 t) `; Q! H - '77887788@qq.com'
2 B; Q2 H8 M* G- w8 g) b7 E - ]( U, G4 o4 R' q% R9 u
- ];
5 r, D1 j+ D& \( F - $res = $collection->save($doc);
0 ^8 `- m( F7 E9 @+ D5 | - echo '<pre>';
9 q- L, J$ `. y* H8 T( m& T; _& Q - print_r($res);//$res['ok']=1表示操作成功,$res['updatedExisting']=1表示更新,$res['upserted']=1表示插入8 i- L6 u2 }' R# x7 t9 Q4 d* W
- 4 {- O( b6 P6 m7 z; m
复制代码- //findAndModify(), D Y' |! ]- U
- //参数1:指定查询条件
' O& h Q% V8 q7 ^7 `& O6 i% [: E - //参数2:指定用于更新文档的信息# u. u3 U' `3 _8 n1 G
- //参数3:可选,指定希望返回的字段
& D2 j4 w4 s! N5 ]) ^5 q - //参数4:扩展选项
" ~( G2 [+ P8 e1 d6 [ z$ N" X - // sort:以特定顺序对匹配文档进行排序
5 \1 v6 G- u$ X5 O2 b$ Q& [: @ - // remove:若设置为true,第一个匹配文档将被删除
. o; L' |6 x0 \ k1 U - // update:若设置为true,将在被选择的文档上执行更新操作
7 g# |( j2 k- V" n6 a - // new:默认为false,若设置为true则返回更新后的文档,否则返回更新前的文档) x6 [9 L$ o& D0 H- B: ?* v# R
- // upsert:若设置为true,没有找到匹配文档的时候将插入一个新的文档2 k! u8 n$ G3 ]1 {$ j8 Y. @. l: h6 n
- $mongo = new MongoClient('mongodb://localhost:27017');; Q# m* d- R# S/ K- g. T4 f; N
- $db = $mongo->mf;& I5 U0 I, K" v- s6 E+ D8 w
- $collection = $db->friend;' a4 d" m4 X0 [
- $res = $collection->findAndModify(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '111@qq.com']]);
, E. [* m9 y! T9 U( a - echo '<pre>';
: m" a0 q' z6 e5 f - print_r($res);
复制代码 四、数据删除 - //remove()
" n8 w2 L) u. D: j" ~ - //参数1:查询条件. Q! h! X1 c1 M8 m6 F/ U! Z
- //参数2:扩展选项- [5 Z( L; t8 ^
- // justOne:若设置为true,则最多只有一个匹配的文档将被删除/ S7 k( U) X# C: B
- // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。3 s* L# ]6 J# Q+ s& G
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作
, b a8 ~& z/ V/ t9 g - // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。
; d0 a2 t" G1 D( t8 r! l2 x6 W - // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
( h! ?. b# p) L1 \& M - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)9 w% K+ H% F# w6 E. {, A _
- $mongo = new MongoClient('mongodb://localhost:27017');
) _* E, i5 A, a, l1 ~5 W - $db = $mongo->mf;
0 n- B+ K" D; h0 D: i2 {3 J* h - $collection = $db->friend;. S) R$ ]. I& s3 h
- $res = $collection->remove(['First Name' => 'jet']);, s% _8 |) |; U7 H6 a9 q$ k3 C
- echo '<pre>';, e+ w9 E/ k7 N2 B" \: x4 n
- print_r($res);//$res['n']表示删除了几个文档
复制代码
9 _. C: y0 \, u/ Q! R k以上是PHP7以前版本的MongoDB操作,下面简单介绍PHP7以后版本的操作。 0 ]/ g3 ~; n! Z% D
-----------------------------------------------PHP7分隔线--------------------------------------------------------------------- ; V. ~, v' B; G: _; y% \, f2 A3 c
数据插入: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');1 w9 f% M' v. ^8 p. b- }
- $bulk = new MongoDB\Driver\BulkWrite;) o! a+ H. A# o$ f, x2 z/ `) }
- $bulk->insert(['name' => 'JetWu5', 'age' => 26]);, V. H# u: X! j( r9 Z
- $bulk->insert(['name' => 'JetWu6', 'age' => 26]);0 }/ p, E' F% h* z, [
-
' A7 N. d3 k2 E+ X$ a$ L* U1 S( m; @ - $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
9 y9 E+ O- \. e* }2 Z4 E - $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);# E+ S& H0 X6 g! i+ ~* Y
- echo '<pre>';
2 z/ S; s& X" g! M1 ?& O - print_r($res);
复制代码
- s$ J; O2 |0 e数据查询: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');9 g- B7 A3 O% f& ]& b
- $query = new MongoDB\Driver\Query(['age' => 24], ['sort' => ['age' => 1]]);
1 P9 S. K8 C' K5 z N8 n" \ - $cursor = $manager->executeQuery('wjt.friend', $query);
& U6 @- s6 E9 R2 ^# O - , f/ T! y$ W7 p1 ^9 _( m0 l4 b; \7 J
- $data = [];9 a2 u& R5 y0 H! i$ h. F
- foreach($cursor as $doc) {( S# X* U V- ?* f8 u1 b
- $data[] = $doc;6 `3 A; p; D0 C1 @9 J
- }. R4 w& p( u W1 R" u0 G
- echo '<pre>';1 k2 M" w" w7 ?4 h' r0 L
- print_r($data);
复制代码 数据修改: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
( `' w5 v& B+ E' V# @8 x - $bulk = new MongoDB\Driver\BulkWrite;
e j# E* c2 F1 Q - $bulk->update() q% M& P8 ?4 M6 L- q; f# y/ r6 a
- ['name' => 'JetWu5'],4 V* p3 J& s5 R9 w
- ['$set' => ['age' => 30, 'promise' => 'always smile!']]
8 |, u" Y( j2 R - );
) ^2 f5 z$ C \9 A% e9 J- S i T. t! P - $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
. q8 |& U! d, f& J V& F/ F+ K - $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
5 K/ e8 G. }3 [; v - echo '<pre>';/ S7 j; ~) U1 c7 w$ u7 X
- print_r($res);
复制代码 数据删除: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
# E" |" | \# G - $bulk = new MongoDB\Driver\BulkWrite;
, L6 [# U1 e3 V% a- A# N - $bulk->delete(['name' => 'JetWu3']);
1 v- d; M1 ]$ E1 X( Z( ~ - $bulk->delete(['name' => 'JetWu4']);. B. [ x. s$ f6 ~/ T X
- $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
3 L& G: u$ F* r. k9 k - $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
- E2 l/ {' T: ~7 O4 ^ - echo '<pre>';
3 w! [$ N# A3 J* V - print_r($res);
复制代码
9 p. @9 x- s; G. a6 Z# F, `2 u8 {: B
: Q1 S2 q) O0 D
3 B4 Y$ s( v$ p' v& N+ G
; m9 f% h# p6 X |