MongoDB的PHP驱动提供了一些核心类来操作MongoDB,总的来说MongoDB命令行中有的功能,它都可以实现,而且参数的格式基本相似。PHP7以前的版本和PHP7之后的版本对MongoDB的操作有所不同,本文主要以PHP7以前版本为例讲解PHP对MongoDB的各种操作,最后再简单说明一下PHP7以后版本对MongoDB的操作。 一、数据插入 - //insert()# h- {5 @" F7 ?+ g. c" M
- //参数1:一个数组或对象
7 ~8 f# a$ u8 x! I& b) W# ^ - //参数2:扩展选项
/ z) Y1 }, ?4 V" j - // fsync:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入硬盘
/ d9 |! ?9 m( `( a/ F- F - // j:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入日志( _# b0 k; A5 E+ j# L
- // w:默认为1,写操作会被(主)服务器确认,若为0则将不会得到确认,使用复制集时设置为n用于确保主服务器将数据修改成功复制到n个节点后再确认& {, @7 S' k/ ~! e. |$ P1 R9 a$ n8 T' H
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
5 e; o6 H7 d4 D# M# i/ b$ D% ? - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)& i l6 }4 ^. U# K+ J% [0 X" O
- $mongo = new MongoClient('mongodb://localhost:27017');
$ o3 B# ]# R, L Y7 m. N M7 B - $db = $mongo->mf;//选择数据库
' ]3 t' a! I6 Q1 D' p% o - $collection = $db->friend;//选择文档集合 X, m1 e7 n& r' \
- $doc = [//定义一个文档,即一个数组4 W ]9 J2 b2 c3 v5 {4 N
- 'First Name' => 'Jet',
0 w$ |$ m: z) K- Z+ ]* @ - 'Last Name' => 'Wu',
' C! g& V5 |! }3 x0 \' ~ - 'Age' => 26,
4 i2 @' C: K/ Y0 U+ ^ - 'Phone' => '110',- b9 a# O! X1 d5 c5 `3 Z
- 'Address' => [- s& z% H9 n7 A2 p* M9 ?- t
- 'Country' => 'China',0 F* h5 O! f2 ^
- 'City' => 'Shen Zhen'9 C6 W- F; K2 a0 ?
- ],
% ^: F1 y% A* O3 @$ _' |) g/ _ - 'E-Mail' => [
- C# J" D& { v% n( t - '123456@qq.com',
6 o% o& m( r! i! s - '666666@sina.com'," Y* S1 L, M* s. M8 d- t0 @* Q
- '8888888@qq.com',
3 z/ X0 K$ g: V7 Z( q0 a - '77887788@qq.com'
$ H2 E1 h5 w8 N. `/ x - ]. y5 z, p! J0 p B& c# G0 |
- ];
; a7 H" [8 J" p - $res = $collection->insert($doc);//向集合中插入一个文档( |+ `9 Y0 P: O' R
- echo '<pre>';/ X5 A! u3 ]5 j2 V5 c, Q# B
- print_r($res);//$res['ok']=1表示插入成功
复制代码二、数据查询 1. 查询单个文档: - //findOne()
0 Z* ^5 T2 k$ V: u* n+ U - //参数1:搜索条件
3 j, D2 V6 l$ s8 S# k - //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非在第二个参数显式加入'_id'=>false。不设置则返回所有字段, T3 }! E' d. V: z2 w: ~
- $mongo = new MongoClient('mongodb://localhost:27017');
4 a: a9 n- s3 Q - $db = $mongo->mf;3 z/ D' C3 C, }8 Q! ]+ [
- $collection = $db->friend;
' Y6 B( q- X! b - $one = $collection->findOne(['First Name' => 'Jet']);
4 V% I$ N* C# A5 N2 ^ - echo '<pre>';
2 t0 r+ T, J% q0 T) U - print_r($one);//返回一个数组,查不到数据则返回NULL
复制代码2. 查询多个文档: - //find()0 e( E( c8 e. ^( ]. O2 ]
- //参数1:搜索条件
: w o4 q( P: H' y" A. x/ M& a3 U - //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非显式设置为false不返回。不设置则返回所有字段
6 x: }4 k+ N) j. m% c, K/ o2 g$ f9 E - $mongo = new MongoClient('mongodb://localhost:27017');
7 t* e9 n0 Z# e) x - $db = $mongo->mf;9 W- q I9 `: Z% C
- $collection = $db->friend;
7 l) O; c; U; R/ u: N1 F - $cursor = $collection->find(['Address.Country' => 'China']);//使用点操作符查找数组元素
; r2 E9 n& b' U. b7 }7 v& U! U1 x - echo '<pre>';; H" b0 m& X* P: w7 J
- while($doc = $cursor->getNext()) {//循环读取每个匹配的文档) n" w" T6 [" F5 M
- print_r($doc);
* E9 I1 V" ~0 d( ?" y - }
复制代码使用各种条件操作符定义查询: - //mongodb分别使用$lt(小于)、$lte(下雨等于)、$eq(等于)、$gte(大于等于)、$gt(大于)、$ne(不等于)表示<、<=、=、>=、>、<>,用于整数字段查询
3 Z+ Z, N4 N+ x7 ?3 O4 y3 u6 P9 t - $mongo = new MongoClient('mongodb://localhost:27017');
2 c2 g9 v; U$ p3 f- \+ ~) C - $db = $mongo->mf;
! E+ q1 d+ t$ G" _! z - $collection = $db->friend;+ ?1 ~4 q; [9 e+ l4 U
- $cursor = $collection->find(['Age' => ['$gt' => 30]]);) z0 T% X4 `* e/ ~
- echo '<pre>'; o d% v# f# f% g5 w
- while($doc = $cursor->getNext()) {
$ j1 Z/ r- u$ C: c$ o% A - print_r($doc);7 w; G9 F! m- o: }
- }
复制代码 //查询某个字段的所有不重复的值
! }; a: W0 F6 s$ p" R. M3 O $res = $collection->distinct('Age'); - //$in:匹配多个值中任意一个- a0 ~/ g2 ^0 A- U$ k* O
- $cursor = $collection->find(['Address.Country' => ['$in' => ['China', 'USA']]]);" p/ K$ q7 |9 a$ B: I
- 6 z5 X7 s' O0 Q5 T
- //$all:匹配多个值中所有值(用于数组字段查询)
+ I3 x# j. j& L( X - $cursor = $collection->find(['E-Mail' => ['$all' => ['123456@qq.com', '77887788@qq.com']]]);
. p- X& u; B3 N* _* P - 6 J8 j0 C4 f$ A2 L5 n
- //$or:或查询
) l |1 K* `! m, C/ Z - $cursor = $collection->find(['$or' => [['First Name' => 'Jet'], ['Address.Country' => 'USA']]]);3 V6 `1 @3 ] L/ f+ K" U
-
/ [# `$ ?) f. x: S4 C/ ]+ m, o - //$slice:获取数组字段中指定数目的元素,位于find()函数第二个参数中. x e; _* y( I; J8 [7 l
- $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => 2]]);//只返回前两个email7 U3 g K, x0 D* K5 t8 |
- $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => -2]]);//只返回最后两个email! L. [/ E: G1 q2 O# Y1 h& P
- $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => [1, 2]]]);//忽略第一个,返回接下来两个
1 W. c! ] u( |( _" Y2 A -
4 I/ P N3 g0 C% `. l% R - //$exists:根据某个字段是否有设置值进行查询0 i$ W& ]7 E0 A5 a8 V& m
- $cursor = $collection->find(['Hobby' => ['$exists' => false]]);//查找Hobby字段未设置值的文档
* O7 V/ `$ b/ e -
% T0 Q. e1 R8 q7 G2 b% t; o9 H5 F - //正则表达式查询
6 Q6 K8 o k& w; Y+ D - $cursor = $collection->find(['First Name' => new MongoRegex('/^Je/i')]);//查找First Name字段以Je开头的文档,忽略大小写差异
复制代码使用MongoCursor类提供的其他函数: - //排序:1升序,-1降序
2 D. G1 n# {% i/ |% H* d - $cursor->sort(['Age' => 1]);0 T7 d! y- M) R6 m" G. t2 ^/ ^
-
" E; J: I7 |& o/ T/ Q- F: z* k" I - //忽略前n个匹配的文档( h1 D1 ~- Z7 t/ h( Y; [
- $cursor->skip(1);" F9 L, }: x3 o4 u" m
-
3 _& L% m; }7 V) v' o - //只返回前n个匹配的文档(limit()与skip()结合使用可实现数据分页功能)! s# U9 r* [% q8 J& t
- $cursor->limit(1);
2 C) E7 b# O5 U4 c9 V, @8 M - ; J: F5 R: {: k; I/ Z/ z
- //匹配文档的总数+ D: M4 l$ m/ ^7 J$ j
- $cursor->count();
' M$ b2 \# [. Z6 c -
4 z1 q6 e! f9 X- @ - //指定查询索引
6 U) n7 F0 S. U7 k7 _2 j - $cursor->hint(['Last Name' => -1]);//若索引不存在则会报错
复制代码聚集查询:对数据进行分组统计 - //聚合查询:对数据进行分组统计
" n9 z0 Z2 `. X - $mongo = new MongoClient('mongodb://localhost:27017');
' ]9 X9 }/ o' G# S4 D - $db = $mongo->mf;
i/ z4 ?) T' q w+ q" o3 v - $collection = $db->friend;& \$ C: Y, B8 x8 [0 t4 g8 P
- $res = $collection->aggregate([
: a/ w4 C1 ^# c5 `# I7 B0 q r - '$group' => [
2 @ ^/ M! L4 z; J. ^1 @" b - '_id' => '$Address.Country',//分组字段,注意要加上“$”,这里是根据数组字段某个元素值进行分组
l1 h+ P. k6 x2 q" r$ F - 'total' => ['$sum' => 1],//求总和,表示每匹配一个文档总和就加1$ J$ T1 @5 M, O
- 'maxAge' => ['$max' => '$Age'],//分组中Age字段最大值" k; T7 G6 M- Y% |/ w0 g0 r+ Z
- 'minAge' => ['$min' => '$Age']//分组中Age字段最小值7 x& {. B% E% Z8 T7 Q- H5 k
- ]" n4 u0 x/ e3 B: Q
- ]);
; e w8 Y4 D1 e+ f: }8 z3 x - echo '<pre>';
4 g1 F. A8 m3 p5 {) p. [& J - print_r($res);//返回一个数组,$ret['result']为数组,存放统计结果' a8 f9 a7 c/ N" h( b' t( H# ]
-
2 c! _, A' s5 {- _ - ' I6 |; M9 Q+ X8 Q: C
- //存在其它操作的聚合查询:多个操作之间执行先后顺序取决于它们位置的先后顺序
4 X* m* Z% r1 I6 v - //聚合查询中的所有操作,包括'$group'在内,都是可选的。8 K& A' X) H5 G" o1 ^
- $mongo = new MongoClient('mongodb://localhost:27017');
/ [, _5 e+ `5 F1 A1 c/ a - $db = $mongo->mf;' T* q0 m' ?* ?" `
- $collection = $db->friend;! E* a& r" n0 L6 N4 E& S9 {1 @: W
- $res = $collection->aggregate([
( T, r6 c( g# Z9 P - [//过滤条件:只对符合条件的原始文档进行聚合运算,若是放在'$group'之后则是只返回符合条件的结果文档
& Q# u, J( m3 q0 L9 i; c - '$match' => ['Age' => ['$gt' => 30]]
: f) L7 I3 E" p1 c( g9 I - ],
( v9 m% t& |, l - [//指定分组字段、统计字段& ^0 {7 F5 B/ r/ S3 R5 [
- '$group' => [
0 K: g* b& x" b w! ~; s - '_id' => '$Address.Country',- T3 D( C. ^6 E. z: d% t
- 'totalAge' => ['$sum' => '$Age']//计算各个分组Age字段总和
! r- g' [" G( j& ] - ]
% v5 r$ n0 u( I* r - ],
+ d4 n2 r( f, V( A - //以下操作若是放在'$group'之前则在聚合前作用于原始文档,若放在'$group'之后则在聚合后作用于结果文档
- Z( x4 H4 p; u9 F' u. \ - ['$unwind' => '$E-Mail'],//将包含有某个数组类型字段的文档拆分成多个文档,每个文档的同名字段的值为数组中的一个值。4 X, r! a* r( I7 Z: a: i9 l/ }
- ['$project' => ['myAge' => '$Age', 'First Name' => '$First Name']],//指定返回字段,可以对字段进行重命名,格式:返回字段名 => $原来字段名+ k7 M0 h7 m5 C+ e
- ['$skip' => 2],//跳过指定数量的文档1 K& O2 N: g$ a' |
- ['$limit' => 2],//只返回指定数量的文档" r) M& C* O F) ~8 z7 s
- ['$sort' => ['totalAge' => 1]]//排序- M% o: }: E0 j/ @. {' X; b* U
- ]);
6 {% C9 ?, E! Z- S - echo '<pre>';
4 L! W2 u' u0 p. u4 i3 Q# n" k& `* I1 a4 e - print_r($res);
复制代码
% f: t+ K" K" W% z4 g三、数据修改 - //update()0 ~2 E( S' E+ B) }( a
- //参数1:更新条件,指定更新的目标对象。 g* Z5 c: q$ w
- //参数2:指定用于更新匹配记录的对象。
) ]% S5 i, d9 y9 |3 W" ~ - //参数3:扩展选项组。+ [4 b) ~( e- c2 A
- // upsert:若设置为true,当没有匹配文档的时候会创建一个新的文档。% g: K* I, N! |8 L
- // multiple:默认为false,若设置为true,匹配文档将全部被更新。" ^2 i+ y% N" }7 g
- // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。2 @- O- B d2 U1 J* K8 N: d0 ?
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作0 e% m9 s9 ^3 e: R
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。
. G8 U- ~# A- b( g - // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
: C; W( Z) m( x2 I8 n) A - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
, q0 {% J% X+ s; @. i - //注意:若不使用任何修改操作符,则匹配文档将直接被整个替换为参数2指定的对象。
4 r1 s6 z* A& P5 a4 r - 3 T3 c z; M( j! ~$ B+ ~2 N. C P
- //$inc:增加特定键的值,若字段不存在则新建字段并赋值
5 S$ W" `+ D( z+ y - $mongo = new MongoClient('mongodb://localhost:27017');! ^" p$ P; N* D& O
- $db = $mongo->mf;
+ k" a" C) ~4 j3 H - $collection = $db->friend;
7 F* d: C2 j# m/ t" t- a - $res = $collection->update(['First Name' => 'Jet'], ['$inc' => ['Age' => 2]]);1 f1 P8 b r5 j6 ?; t( x
- echo '<pre>';
o$ f) o' f2 `) y, }1 f- w0 M - print_r($res);//$res['ok']=1表示修改成功,$res['nModified']表示修改的文档数量" M+ L2 o9 ]5 }7 ~: o
- . M% S4 z: _1 ^& ^ ^
- //$set:重置特定键的值,若字段不存在则新建字段并赋值
2 ~8 p. [6 B! M% N - $res = $collection->update(['First Name' => 'Jet'], ['$set' => ['Hobby' => 'pingpong']]);# j' b0 f8 z( s
- ! _( z. y3 q& W/ ? j0 k. E
- //$unset:删除字段
5 S$ X8 a& z9 [ - $res = $collection->update(['First Name' => 'Jet'], ['$unset' => ['Hobby' => 1]]);* G9 ^3 y4 ?. v( U4 D
- . y, d6 ^7 i( g. R
- //$rename:重命名字段,若字段不存在则不进行任何操作/ d1 y3 N1 F! c% r7 M
- $res = $collection->update(['First Name' => 'Jet'], ['$rename' => ['Hobby' => 'hobby', 'Age' => 'age']]);
4 k0 B9 a9 C6 Z8 y" N - //注意:如果文档中已经使用了指定名称的字段,则该字段将会被删除,然后再进行重命名操作。
6 q) b4 L3 e1 Q6 U6 w" z L - 9 p! m, o' y$ B. L, c8 O& C% v9 O
- //$setOnInsert:设置了upsert为true,并且发生了插入操作的时候,将某个字段设置为特定的
. I% v ^6 H3 i3 Z% K9 H$ e - $res = $collection->update(['First Name' => 'jet'], ['$setOnInsert' => ['lang' => 'English']], ['upsert' => true]);
1 ^* t$ p8 w) c* l - ) t/ ~# v) g+ y4 e
- //$push:向指定字段添加一个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错# ^$ e% a5 l2 n/ ~( Q( {
- $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '123123@qq.com']]);
5 E( t0 z! S4 O" |9 M -
' ?7 Y" u$ v# T" c3 V- a - //$push:向指定字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错
) _) j+ K- h- s& ~" Z- Y - $res = $collection->update(['First Name' => 'Jet'], ['$pushAll' => ['E-Mail' => ['666@qq.com', '8888888@qq.com']]]);, Z9 A: R; x3 p( _8 ]( T, u
- 8 W7 W9 W6 B: |! S6 R) p
- //使用$push和$each向某个字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错( e5 q# z1 L7 J" Q* U
- $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);6 L# S) ~6 S: y$ L' @! S
-
s% D1 E1 @) e t6 m9 E3 ` - //$addToSet:将数据添加到数组中(只在目标数组没有该数据的时候才将数据添加到数组中)' I" p N, k4 ]* z3 G
- $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => '123123@qq.com']]);5 o; Q. _6 n; T, k) F5 O$ R( m
- $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);
5 i4 \# H5 d. [- k3 k" g/ y5 z -
: a% ?2 j; }, k5 | - //$pop:从数组中删除一个元素,-1表示删除第一个元素,1表示删除最后一个元素(其实负数都删除第一个元素,0或正数都删除最后一个元素)% v$ {8 l3 F, x& U
- $res = $collection->update(['First Name' => 'Jet'], ['$pop' => ['E-Mail' => 1]]);& f8 h( h# Z& v/ u. Q: P$ C/ y3 M
- 0 Z8 Y# W& y% x& A% E; W, R- a
- //$pull:删除数组中所有指定值
5 _- L+ t. K! n0 e - $res = $collection->update(['First Name' => 'Jet'], ['$pull' => ['E-Mail' => '123123@qq.com']]);
+ C3 \/ @8 m1 m8 K, Y1 r& r - " B' {' W( G" k1 I# e6 \/ B+ E
- //$pullAll:删除数组中多个元素的所有值
% U) m" P, M# T - $res = $collection->update(['First Name' => 'Jet'], ['$pullAll' => ['E-Mail' => ['123123@qq.com', '666@qq.com']]]);
复制代码- //save()
+ i! d! T l: Y5 N- g - //参数1:希望保存的信息数组
% ^8 H2 }; F7 p0 K" s - //参数2:扩展选项
3 A- K" o6 G" ?6 [1 H - // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。
9 S/ Q A* L; o2 J7 T+ c0 v# Z3 [8 \ - // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作: g g( C. \8 S) Z
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。; W1 d' J* X7 }7 g: u7 `9 N
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间* ~! d M9 U8 \$ @: s1 X. J. q4 S
- // timeout:指定客户端需要等待服务器响应的超时时间(毫秒), [. b6 Q# t- @! n# T6 [
- //注意:若已存在则更新,若不存在则插入;更新时使用参数1指定的信息数组替换整个文档。5 a) w) d; l- b1 s" z/ I9 P
- //若想更新则应该在参数1中指定_id键的值。
- n* Q. i9 j) @7 A, k, U - $mongo = new MongoClient('mongodb://localhost:27017');/ D6 F9 x1 D1 o
- $db = $mongo->mf;
5 C, S$ H: O& `$ q - $collection = $db->friend;
* b3 z: i. i7 r5 h) |/ m - $doc = [//定义一个文档,即一个数组
% ?' [" M( p. J! b! V5 U4 e3 x& ] - 'First Name' => 'Jet',
. ]7 g- v. j1 v' i: `3 I - 'Last Name' => 'Wu',6 F9 a) k* V! Y3 v: Q2 x7 q
- 'Age' => 26,
( C) [! j! c) w% G. V - 'Phone' => '110'," K) C/ o( s. X
- 'Address' => [
3 ^1 b( s6 F9 J1 }. q' n- J - 'Country' => 'China',2 J; H- a6 d7 X7 H7 G. X
- 'City' => 'Shen Zhen'
2 p/ r5 `6 Y) R/ k0 S - ],. g6 T: e7 r( i( E9 v) @
- 'E-Mail' => [) X6 w h" \0 G+ D' L& D0 y
- '123456@qq.com',
3 l) [ [! f: m1 u x - '666666@sina.com',% v5 ?3 U/ L& U
- '8888888@qq.com',& @6 x; L+ I+ @- y
- '77887788@qq.com'/ \! H" R' g9 c2 o% u! K6 A6 V- V! E
- ]% [/ d4 E! G6 o& U* u1 a
- ];6 Y( P/ X0 s6 a+ R5 _- W1 i* C$ x
- $res = $collection->save($doc);$ l6 k1 `: E; P4 C" W0 `
- echo '<pre>';
. Z+ l z; c6 }6 e& ]* M - print_r($res);//$res['ok']=1表示操作成功,$res['updatedExisting']=1表示更新,$res['upserted']=1表示插入8 s% @, W$ F) e
+ o Z; O1 ^* O6 h; O% g0 M& `
复制代码- //findAndModify()
5 K4 z! U5 w+ u4 ^* Y X, i - //参数1:指定查询条件
6 n) R/ j$ x9 D5 C- E" @* w; i( { - //参数2:指定用于更新文档的信息
0 z) g) O& R' p* G( q - //参数3:可选,指定希望返回的字段; ^- P0 L% v# H. E
- //参数4:扩展选项/ M* ?0 U" D! O' t
- // sort:以特定顺序对匹配文档进行排序4 y) C8 t2 s t9 b8 \: |# k5 Y
- // remove:若设置为true,第一个匹配文档将被删除6 O9 K/ H6 k' Q# J+ x
- // update:若设置为true,将在被选择的文档上执行更新操作
6 r3 i# V q+ o( ] - // new:默认为false,若设置为true则返回更新后的文档,否则返回更新前的文档4 u) \/ r! \1 q- ~
- // upsert:若设置为true,没有找到匹配文档的时候将插入一个新的文档1 M, i* ~7 G0 [5 b" e
- $mongo = new MongoClient('mongodb://localhost:27017');6 u+ G2 S5 G& r* r" d' m
- $db = $mongo->mf;
( Y$ K; J5 L+ K - $collection = $db->friend;
. a4 o/ C# }. p1 `% O {* e4 } - $res = $collection->findAndModify(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '111@qq.com']]);$ S+ L3 k' P! G& W
- echo '<pre>';1 l* M5 d. Q& Q5 C) b( i9 B
- print_r($res);
复制代码 四、数据删除 - //remove()2 J4 Z& B6 G, ^$ G/ o' Q
- //参数1:查询条件
# H |6 U0 m% }6 m' h! h: n - //参数2:扩展选项/ J7 d' O. h, c6 o" T2 u
- // justOne:若设置为true,则最多只有一个匹配的文档将被删除1 \* n1 `. e: C- }
- // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。( ^$ c; S3 f# w# s4 o
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作
$ v( B/ r2 w3 a; J2 ?/ \ - // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。% N- C2 E: z! d
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
# l) J2 t. T4 ]( R, w - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
8 m6 O0 h: E% N - $mongo = new MongoClient('mongodb://localhost:27017');
0 }+ H3 i# R4 o - $db = $mongo->mf;
- h; W3 ?5 q4 v8 S; j - $collection = $db->friend;0 U1 X7 ~* u Q0 H. m
- $res = $collection->remove(['First Name' => 'jet']);( S/ u* Z3 ^/ t: K) I" b$ o
- echo '<pre>';' i+ @! ?* {( y5 s9 w
- print_r($res);//$res['n']表示删除了几个文档
复制代码
+ Y# b# _+ {0 g) H( K4 v/ Q' e, R以上是PHP7以前版本的MongoDB操作,下面简单介绍PHP7以后版本的操作。 : ~0 {7 ~) v4 _4 \3 q- l& S
-----------------------------------------------PHP7分隔线---------------------------------------------------------------------
! o8 J6 P& n5 Q. q a数据插入: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');( l# _% l* s6 O* N
- $bulk = new MongoDB\Driver\BulkWrite;
f- o# O6 @* N v @0 s - $bulk->insert(['name' => 'JetWu5', 'age' => 26]);& E9 u$ f* d; t6 B. j% z2 `
- $bulk->insert(['name' => 'JetWu6', 'age' => 26]);
1 [- N: K, G! c q2 f -
$ e1 D% q+ _# q$ r - $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
% m" F$ I1 X% b/ C. R/ s% R( E - $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);& _9 v- t7 x% V) [8 K. u- T$ S* E
- echo '<pre>';5 f1 ?9 A8 T9 R+ Y! r" d) N1 T
- print_r($res);
复制代码
0 W5 @$ Z5 t+ L9 _% K数据查询: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
4 J4 R' X) ]1 t; {7 Y8 \/ m/ A8 ]" x - $query = new MongoDB\Driver\Query(['age' => 24], ['sort' => ['age' => 1]]);
2 ~7 K9 @. K3 V- F0 ?3 Y - $cursor = $manager->executeQuery('wjt.friend', $query);
1 ~/ `1 W& ^& E" ? - ( S$ L2 ], U8 n: l" v
- $data = [];1 V8 \2 |7 ~- v5 {5 P/ @) H3 g
- foreach($cursor as $doc) {$ B( D4 E. ]7 z# o: _
- $data[] = $doc;/ a0 J2 n. M7 }& q5 ]+ b- U
- }" f, I* ]& b: Z
- echo '<pre>';
+ U1 @* h3 _. C; ~ - print_r($data);
复制代码 数据修改: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
. e1 Z! f0 I4 k( j9 c - $bulk = new MongoDB\Driver\BulkWrite;. b/ X# H3 L6 X; ^* h
- $bulk->update(, A1 }% M8 ?6 P# v' \1 I! |. g
- ['name' => 'JetWu5'],2 o0 _7 ?& z2 U
- ['$set' => ['age' => 30, 'promise' => 'always smile!']]
3 l- s8 R; G& P2 y/ l' H - );
( o* K3 F6 U6 I+ n* T: t0 z - $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
& o; X0 i7 v* r' C M2 R - $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
& V; }# S4 M5 ~/ \% P* d - echo '<pre>';1 w' e$ W5 h9 i
- print_r($res);
复制代码 数据删除: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');2 q8 v9 |. }; O* }, H1 \* I
- $bulk = new MongoDB\Driver\BulkWrite;$ `- J% l) a/ F8 r$ @0 A. I
- $bulk->delete(['name' => 'JetWu3']);( ~' I" N8 l/ g" l
- $bulk->delete(['name' => 'JetWu4']);% n% ~4 X- N2 ]" ~' K# t7 W
- $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
' k8 `$ f" ^4 Q9 j, P, l' @/ y4 U - $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
1 i6 V: [- [2 o; V1 R% V - echo '<pre>';
8 w( n% G0 `. a: q, x - print_r($res);
复制代码
: g4 M) R1 Q. [
0 m# H% f+ A( Y0 V/ M' \3 U9 k6 {( D1 T* `9 q$ w
" A4 n4 x/ \$ A( z! }' X0 ?
7 f0 I0 O; n: W7 j ^) L |