MongoDB的PHP驱动提供了一些核心类来操作MongoDB,总的来说MongoDB命令行中有的功能,它都可以实现,而且参数的格式基本相似。PHP7以前的版本和PHP7之后的版本对MongoDB的操作有所不同,本文主要以PHP7以前版本为例讲解PHP对MongoDB的各种操作,最后再简单说明一下PHP7以后版本对MongoDB的操作。 一、数据插入 - //insert()3 H8 f" y8 L- B5 a- E
- //参数1:一个数组或对象/ c2 O- X' n% o% E9 p
- //参数2:扩展选项6 {: Y' h' B G# x9 |6 B/ g
- // fsync:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入硬盘! F5 A; ^. G2 b/ L& T9 E, c
- // j:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入日志5 c/ {6 e+ u s3 H$ Q0 W7 j
- // w:默认为1,写操作会被(主)服务器确认,若为0则将不会得到确认,使用复制集时设置为n用于确保主服务器将数据修改成功复制到n个节点后再确认
; v X, D7 s* n - // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间! r" _( P& q/ a, d9 g
- // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
/ |7 L( w0 o# n - $mongo = new MongoClient('mongodb://localhost:27017');- @. A) S) ?" O1 }& K
- $db = $mongo->mf;//选择数据库+ w+ `5 Y$ \# H! x. o. k
- $collection = $db->friend;//选择文档集合
, t0 m/ \9 V% s! c ^6 H - $doc = [//定义一个文档,即一个数组
/ H$ h' \8 I, Q8 R2 Y) h - 'First Name' => 'Jet',
7 H. u$ O' N" o - 'Last Name' => 'Wu',
5 `: |1 c Z W* I - 'Age' => 26,) r" a6 `3 {1 E/ W' z! Z; `
- 'Phone' => '110',
/ d3 q' g8 y* Y9 d2 ?1 L: ` - 'Address' => [
. T1 Q" H2 X* i& F3 v' ~ - 'Country' => 'China',
# D0 U6 y$ b9 ~, {8 m - 'City' => 'Shen Zhen'9 n. L; |8 r5 g$ P R
- ],% A# E: R! d/ G v+ k
- 'E-Mail' => [' u, V4 c8 Z. C- R. \
- '123456@qq.com',# H- F& ~$ w9 [
- '666666@sina.com',
6 n% M( D, m1 b, z; z8 c- g8 R' w - '8888888@qq.com',8 R4 W. N4 y/ J7 y, R1 h( ]' p
- '77887788@qq.com'6 n$ X/ G4 ~+ m: E% A" V4 `. R
- ]. T2 ^& ^" u$ b8 V$ Z% B( U
- ];- t# L' F1 ]3 K8 I
- $res = $collection->insert($doc);//向集合中插入一个文档. t3 K& t/ h; d5 J5 Y$ N9 g8 e
- echo '<pre>';1 p" d6 |4 e8 r1 x8 y8 o5 S8 N
- print_r($res);//$res['ok']=1表示插入成功
复制代码二、数据查询 1. 查询单个文档: - //findOne()$ O% c* C; P4 c2 a
- //参数1:搜索条件
( O1 w o; d$ q/ B! p - //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非在第二个参数显式加入'_id'=>false。不设置则返回所有字段1 d( J( |, p$ d2 ?2 I7 Q# [. J
- $mongo = new MongoClient('mongodb://localhost:27017');6 P9 k2 H7 R- h0 u7 x5 b
- $db = $mongo->mf;* W0 m/ J) Y# D3 R" E, h6 N" j
- $collection = $db->friend;7 j3 k4 I& }" s8 F1 {& R- m7 C
- $one = $collection->findOne(['First Name' => 'Jet']);
1 Z& X, K7 Q, j! G0 G6 }4 ^6 R - echo '<pre>';' {0 f4 G# A+ D" Y% P8 z
- print_r($one);//返回一个数组,查不到数据则返回NULL
复制代码2. 查询多个文档: - //find()
$ @2 q5 b0 t1 n8 ]3 g7 J, p! U - //参数1:搜索条件# x3 _: c- P- |7 R D0 {
- //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非显式设置为false不返回。不设置则返回所有字段, k/ f, s. E$ c, ^2 ~8 D) c4 b
- $mongo = new MongoClient('mongodb://localhost:27017');* P2 D1 [0 S( W# Y
- $db = $mongo->mf;. _9 B \1 g |% I2 P
- $collection = $db->friend;5 L+ F6 }0 s% w3 V! o, a" ~/ u
- $cursor = $collection->find(['Address.Country' => 'China']);//使用点操作符查找数组元素/ V7 C, o' E- y' u9 q2 T
- echo '<pre>';
) \0 Q- @5 H" O# i; h - while($doc = $cursor->getNext()) {//循环读取每个匹配的文档' |& K0 J3 w+ l! S- c
- print_r($doc);
' K. [* D" {8 v4 v2 A: G; ? - }
复制代码使用各种条件操作符定义查询: - //mongodb分别使用$lt(小于)、$lte(下雨等于)、$eq(等于)、$gte(大于等于)、$gt(大于)、$ne(不等于)表示<、<=、=、>=、>、<>,用于整数字段查询
' x+ [% E1 Q& C3 N% s% y4 K - $mongo = new MongoClient('mongodb://localhost:27017');
$ L9 Q) A* d2 ?% p2 g4 z8 d; ?* s0 K - $db = $mongo->mf;% Y7 Q1 G+ o5 v- z& w/ o. ~- A
- $collection = $db->friend;
7 K, ^! z8 R/ w3 P - $cursor = $collection->find(['Age' => ['$gt' => 30]]);" m# x' `$ R' q, N9 X
- echo '<pre>';
0 x- ~6 B, j# Y& M% C, ]8 h - while($doc = $cursor->getNext()) {
/ P. n% u3 P+ m0 ?& H1 }, J$ {6 ? A - print_r($doc);( D7 k9 e6 V. Z/ r: ~/ a
- }
复制代码 //查询某个字段的所有不重复的值' `; N% q! P% y
$res = $collection->distinct('Age'); - //$in:匹配多个值中任意一个 J1 k; e5 \. z6 }. S
- $cursor = $collection->find(['Address.Country' => ['$in' => ['China', 'USA']]]);
2 x0 L" D% _9 y, } -
) C/ ?, d E& F* o2 e( b j! I* i - //$all:匹配多个值中所有值(用于数组字段查询): e7 u+ C1 B4 h
- $cursor = $collection->find(['E-Mail' => ['$all' => ['123456@qq.com', '77887788@qq.com']]]);
6 W' R6 l! Q) {3 g7 Y - 7 ^# J9 c4 c) b7 k, w. D
- //$or:或查询8 i1 a9 D: s8 z. Z* Y
- $cursor = $collection->find(['$or' => [['First Name' => 'Jet'], ['Address.Country' => 'USA']]]);
, ^% J4 Z2 V4 ~/ b- C -
( h# }/ r; H* f0 W' o - //$slice:获取数组字段中指定数目的元素,位于find()函数第二个参数中# {: t8 F, d! y, _
- $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => 2]]);//只返回前两个email
* g- q) F3 W; [# {, h7 J/ J - $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => -2]]);//只返回最后两个email! y8 h8 K1 ~3 g
- $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => [1, 2]]]);//忽略第一个,返回接下来两个
$ `4 R! Z! H* |) r$ d Q, ^! Y -
' b" ?2 d! {, r4 R$ W7 N - //$exists:根据某个字段是否有设置值进行查询
6 H$ N0 M z: h( B - $cursor = $collection->find(['Hobby' => ['$exists' => false]]);//查找Hobby字段未设置值的文档
, [) T' u/ }9 j" y' C' p -
6 K6 I; m# m2 A- T9 C, A - //正则表达式查询
! B0 m* p- ^; M9 E* E7 l' ? - $cursor = $collection->find(['First Name' => new MongoRegex('/^Je/i')]);//查找First Name字段以Je开头的文档,忽略大小写差异
复制代码使用MongoCursor类提供的其他函数: - //排序:1升序,-1降序
5 G) [: h. ^! D' Z - $cursor->sort(['Age' => 1]);+ H( K1 i' h4 N, i2 T& O9 S; @
-
' r1 U$ w/ Y; `) Y9 q( L - //忽略前n个匹配的文档
+ @! ~, U3 y1 l - $cursor->skip(1);
' a( ]; Z! Z- ?8 E* Y+ C - C- x* U/ a- W8 f
- //只返回前n个匹配的文档(limit()与skip()结合使用可实现数据分页功能): e1 r: f9 @8 Y* o
- $cursor->limit(1);
; F+ \# s) v# _ - 2 X% Q7 B2 [9 X! a
- //匹配文档的总数
2 {% k* S/ t( J - $cursor->count();
# x L5 Z0 c" z! S -
. n* G; ~0 c$ V' y v% g - //指定查询索引0 w% |5 Z2 O" O# Z/ W, @
- $cursor->hint(['Last Name' => -1]);//若索引不存在则会报错
复制代码聚集查询:对数据进行分组统计 - //聚合查询:对数据进行分组统计4 {+ ?4 U: ^3 @* f* k2 s
- $mongo = new MongoClient('mongodb://localhost:27017');9 B/ q+ B/ W. @! w! i. i
- $db = $mongo->mf;3 m3 q0 M+ g! f% r0 u F
- $collection = $db->friend;8 m8 P, S2 c6 d: j5 Q# `
- $res = $collection->aggregate([( {8 P1 Q0 L8 ]- [. `
- '$group' => [
9 |% i3 U6 F4 p7 J8 ~& x, R - '_id' => '$Address.Country',//分组字段,注意要加上“$”,这里是根据数组字段某个元素值进行分组2 a# T7 B8 S3 J) ~
- 'total' => ['$sum' => 1],//求总和,表示每匹配一个文档总和就加1. Y" D( B: o: b% y) m* c2 \
- 'maxAge' => ['$max' => '$Age'],//分组中Age字段最大值# d( ^0 I q) j+ d/ n# `
- 'minAge' => ['$min' => '$Age']//分组中Age字段最小值
0 p6 P! P9 b! D - ]5 @ P" _7 ~& e, E* ?' O8 a
- ]);
; Q- Z$ m4 q2 s( G - echo '<pre>';/ H/ E3 B @& F
- print_r($res);//返回一个数组,$ret['result']为数组,存放统计结果
# `% ?8 C& s* {$ W6 Y( o) @4 }8 u6 R -
' ?/ x9 d; K" S# [5 X - * y, w N- K6 U- f9 b
- //存在其它操作的聚合查询:多个操作之间执行先后顺序取决于它们位置的先后顺序# h: t/ c0 D# @5 ~; O$ R v5 F5 W/ M
- //聚合查询中的所有操作,包括'$group'在内,都是可选的。
# _! P2 y4 ^ ?+ K' t; s. f - $mongo = new MongoClient('mongodb://localhost:27017');6 Z R0 l: ?2 l5 j
- $db = $mongo->mf;8 E; L2 A- {2 G$ O: r3 j+ T
- $collection = $db->friend;
0 `1 v% |* _) m - $res = $collection->aggregate([6 a* y r4 X* [5 m( I
- [//过滤条件:只对符合条件的原始文档进行聚合运算,若是放在'$group'之后则是只返回符合条件的结果文档
9 p3 }' ^7 K/ h& f' e A# u - '$match' => ['Age' => ['$gt' => 30]]
" c5 G. {( G0 o! K- x8 M - ],7 E+ d5 b& {0 n( M. ~
- [//指定分组字段、统计字段
2 g- ^7 l7 q' J8 Z - '$group' => [/ d' \: k0 t" ^5 E: q! ~' Z
- '_id' => '$Address.Country',1 Y) P; N7 d8 R5 r
- 'totalAge' => ['$sum' => '$Age']//计算各个分组Age字段总和& c1 @$ q0 g, G3 _$ b
- ]4 y3 `' k d+ r, f1 A
- ],7 W" m& r1 Q) G3 ^4 @0 \
- //以下操作若是放在'$group'之前则在聚合前作用于原始文档,若放在'$group'之后则在聚合后作用于结果文档
5 @3 m% [4 B( a - ['$unwind' => '$E-Mail'],//将包含有某个数组类型字段的文档拆分成多个文档,每个文档的同名字段的值为数组中的一个值。! _3 U6 i& \; E4 N1 ^' O
- ['$project' => ['myAge' => '$Age', 'First Name' => '$First Name']],//指定返回字段,可以对字段进行重命名,格式:返回字段名 => $原来字段名
5 Y7 H6 b" `: O# {- o4 r |7 ]% _ - ['$skip' => 2],//跳过指定数量的文档+ B5 b G$ C1 B
- ['$limit' => 2],//只返回指定数量的文档; Y# S$ U6 }; `
- ['$sort' => ['totalAge' => 1]]//排序
0 J0 Q2 B8 U" v+ J7 X* C - ]);
9 j4 `8 I7 j3 F! ]- Z - echo '<pre>';2 j" ?$ \! Q$ U" A: f% _( F
- print_r($res);
复制代码
# k0 H0 Q$ O4 B& j; P5 D1 V! g三、数据修改 - //update()( d, b! R! r- g
- //参数1:更新条件,指定更新的目标对象。1 N4 V! K& c- p8 s
- //参数2:指定用于更新匹配记录的对象。' m7 I) q3 B0 R( c& t2 L4 p! S$ X
- //参数3:扩展选项组。
$ r9 |. |! y& l$ g0 {0 P - // upsert:若设置为true,当没有匹配文档的时候会创建一个新的文档。9 E& q1 ^# }7 ]1 z! C2 [
- // multiple:默认为false,若设置为true,匹配文档将全部被更新。6 H0 F" ]9 Z. ~( @2 L6 X; A. n* X
- // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。
6 ^. L6 }2 u" [5 W3 \ - // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作
& Y+ x8 A2 d# |% f' ^. q& f - // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。
) b6 \. H$ ]& b( N; r6 |( [ - // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间* d' T8 S$ z! z+ o
- // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
) k+ U2 B/ s, d# O - //注意:若不使用任何修改操作符,则匹配文档将直接被整个替换为参数2指定的对象。
! s/ M! ?: S0 D" R - 4 q0 w5 v6 t3 r; w5 |( Y N5 ^' p A% d
- //$inc:增加特定键的值,若字段不存在则新建字段并赋值
7 w5 r. S$ l4 `4 B3 R& X - $mongo = new MongoClient('mongodb://localhost:27017');
: K) h( h9 q/ t: t6 c" Y4 j - $db = $mongo->mf;
: g& ]6 c8 d R0 Y! j$ u- B3 ?6 @ - $collection = $db->friend;
3 i5 M" p: A9 d* K4 F! J( E - $res = $collection->update(['First Name' => 'Jet'], ['$inc' => ['Age' => 2]]);' l3 }$ z$ t1 ^' t
- echo '<pre>';. ?1 M7 m' M+ n+ j+ Y- `
- print_r($res);//$res['ok']=1表示修改成功,$res['nModified']表示修改的文档数量0 o7 H; M8 ?: G S- O% g+ N
- 1 i2 g. h- G/ c
- //$set:重置特定键的值,若字段不存在则新建字段并赋值3 ?7 S& T9 t9 C @/ o% E. _
- $res = $collection->update(['First Name' => 'Jet'], ['$set' => ['Hobby' => 'pingpong']]);6 O4 P* k0 _1 |6 }. _
-
: [! {0 E- W5 R$ V - //$unset:删除字段7 ?6 S" s* b* H! y& ~
- $res = $collection->update(['First Name' => 'Jet'], ['$unset' => ['Hobby' => 1]]);
: Y# c- e8 g K+ G$ a$ L/ d -
6 n: b, X- d# a9 c; [6 O - //$rename:重命名字段,若字段不存在则不进行任何操作
% h9 @% g5 F! a6 [4 H. u# m! y, \' O - $res = $collection->update(['First Name' => 'Jet'], ['$rename' => ['Hobby' => 'hobby', 'Age' => 'age']]);* B4 t* I' v. v/ r; c
- //注意:如果文档中已经使用了指定名称的字段,则该字段将会被删除,然后再进行重命名操作。
# V+ k: Y* N0 w* S8 b* C# W% x0 j1 s -
% w6 K1 Q2 W0 z' ^% W! \* [. `0 u - //$setOnInsert:设置了upsert为true,并且发生了插入操作的时候,将某个字段设置为特定的
7 @) d4 J9 C1 d% p& M$ {. | - $res = $collection->update(['First Name' => 'jet'], ['$setOnInsert' => ['lang' => 'English']], ['upsert' => true]);
1 ~+ A0 K% v; i% _* G, l) w -
0 W3 W/ C) B6 \" h2 p - //$push:向指定字段添加一个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错; X T; F: J- ?3 M3 @
- $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '123123@qq.com']]);
- @ M* w3 O8 w6 x3 X# ? - 4 v$ E H" U$ Q. a6 N) r
- //$push:向指定字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错& f3 H+ n/ B. g" [
- $res = $collection->update(['First Name' => 'Jet'], ['$pushAll' => ['E-Mail' => ['666@qq.com', '8888888@qq.com']]]);
& n( N0 C% N; p9 S6 N, v+ F$ O) Q -
8 H: E1 I% v8 N9 K - //使用$push和$each向某个字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错
: c1 Q* o0 v3 S7 f4 x - $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);. W2 L6 a0 A. J) P& I
-
) n* h' @6 A5 M+ h. N3 E) r! Q3 h- V - //$addToSet:将数据添加到数组中(只在目标数组没有该数据的时候才将数据添加到数组中)3 e) X" X! q) l% ~5 w2 j% g
- $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => '123123@qq.com']]);
6 E3 ~% h) U4 J& }* i7 y; y - $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);
- ?" \% \$ h0 K -
+ j! x- h2 t6 f - //$pop:从数组中删除一个元素,-1表示删除第一个元素,1表示删除最后一个元素(其实负数都删除第一个元素,0或正数都删除最后一个元素)9 C9 T$ L. F, v9 g. w4 i( t6 _- S) V" X
- $res = $collection->update(['First Name' => 'Jet'], ['$pop' => ['E-Mail' => 1]]); u6 l$ W' l) ^1 \
-
" V' U- a6 p/ `' p8 v$ @ - //$pull:删除数组中所有指定值
9 |2 U/ n$ d' T8 s7 _( o- c - $res = $collection->update(['First Name' => 'Jet'], ['$pull' => ['E-Mail' => '123123@qq.com']]);. @ `9 z& h" C9 k+ k. m* y
- 1 i4 x1 m9 W9 o8 h
- //$pullAll:删除数组中多个元素的所有值
0 c$ @( X4 g3 A3 m# U8 E - $res = $collection->update(['First Name' => 'Jet'], ['$pullAll' => ['E-Mail' => ['123123@qq.com', '666@qq.com']]]);
复制代码- //save()# ~3 K; g2 k% c1 a- O5 v& I2 S/ B9 [
- //参数1:希望保存的信息数组
% ?+ @" n I) P/ l: ~ - //参数2:扩展选项
. a: {( n6 z9 H2 r# @( L2 C: a - // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。; ~( b# l$ l A8 R) I, j# ~7 q7 O3 i
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作: b9 r' u( M% E+ [$ j
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。3 \: s/ j6 Y6 P, \! j& y9 U% p0 y
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
2 `) p# I! S" h/ ^- S' W - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒). Q& G4 ]# v; x* X6 E+ S
- //注意:若已存在则更新,若不存在则插入;更新时使用参数1指定的信息数组替换整个文档。" Z' V6 ~0 {1 v
- //若想更新则应该在参数1中指定_id键的值。8 S- j& h& Q$ W
- $mongo = new MongoClient('mongodb://localhost:27017');% W2 k$ L6 [6 P$ m* L! e
- $db = $mongo->mf;7 a8 i5 L/ x: `
- $collection = $db->friend;
* \$ K8 c. y, P9 [0 h) z8 Y' S - $doc = [//定义一个文档,即一个数组" h; t9 b! p5 u
- 'First Name' => 'Jet',
5 H8 f. o9 C t2 ~ - 'Last Name' => 'Wu',6 S1 x) p. Y" Z) e: j- {" R3 s' ~6 A
- 'Age' => 26,; l- I, _ e9 J$ {: @& f
- 'Phone' => '110',
- V, R& {9 e: K% U - 'Address' => [
, l3 C. g$ O4 O - 'Country' => 'China',
& n! T5 N: Y. R# U. n - 'City' => 'Shen Zhen'
; `- J5 ? q6 d. I# ?8 C! y3 e - ],
" r" D) [% E) }2 u# q: s - 'E-Mail' => [
5 }1 A' P7 |( n& t - '123456@qq.com',
% r# i) a6 M) @* f5 b2 H/ Q5 @ Y - '666666@sina.com',* d% R# G/ y; U
- '8888888@qq.com',1 P# H0 u9 ? C- x1 D/ W. t
- '77887788@qq.com'
# F6 Y$ X9 d- O9 n8 }# a( h! P - ]
5 M0 X3 k' Z0 H$ K - ];
) H: K! ~: ~* N& [( o2 x - $res = $collection->save($doc);0 m5 L) |+ k' ^5 r% _* I2 [" J4 G
- echo '<pre>';
" w) D0 }1 Z/ L" C - print_r($res);//$res['ok']=1表示操作成功,$res['updatedExisting']=1表示更新,$res['upserted']=1表示插入
+ v* A* G. p/ H# v+ T" k# i
3 d+ o) p1 f0 f! D0 \# ^
复制代码- //findAndModify()' `2 W% H& t* [; I; m& R3 a
- //参数1:指定查询条件7 N, d0 d$ }& P3 E( W0 y9 v- n
- //参数2:指定用于更新文档的信息/ N7 X1 w/ Z( u5 x2 p
- //参数3:可选,指定希望返回的字段, o1 L1 d/ C1 \- u
- //参数4:扩展选项3 Z+ J$ [- J* W0 ?
- // sort:以特定顺序对匹配文档进行排序) G: r E) T5 O L. p0 b
- // remove:若设置为true,第一个匹配文档将被删除, A& k- z, x T% a
- // update:若设置为true,将在被选择的文档上执行更新操作. R$ ~ c+ L/ S& g" p. T
- // new:默认为false,若设置为true则返回更新后的文档,否则返回更新前的文档! [6 i& P$ y: P
- // upsert:若设置为true,没有找到匹配文档的时候将插入一个新的文档: P! g& C2 w7 Z9 M, O. T
- $mongo = new MongoClient('mongodb://localhost:27017');7 G4 v9 c+ t0 L4 S: A1 Q8 ]' g, t
- $db = $mongo->mf;' r5 a2 X8 ?+ O8 C2 B5 C
- $collection = $db->friend;; u0 }5 [- `7 ~, h
- $res = $collection->findAndModify(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '111@qq.com']]);6 h0 V; t* S7 {# {* Z1 z6 G
- echo '<pre>';
' E5 i7 Y: D) Y/ s! X - print_r($res);
复制代码 四、数据删除 - //remove()
- |- P3 m5 y( e* N6 y - //参数1:查询条件8 x. M, u' F9 J. h
- //参数2:扩展选项4 g& w" D6 `, @9 R0 w" L
- // justOne:若设置为true,则最多只有一个匹配的文档将被删除* B9 Z4 b2 Z6 R0 S$ ^, }
- // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。! d3 ^. p& c0 ` w Y
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作
; j7 b/ J9 x. y3 u+ V a - // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。( S9 @3 H. R! x( M& l# P9 ^: k
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间2 X0 K* X" q6 E
- // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
0 f6 ?1 t( y; f C0 m$ N, N H - $mongo = new MongoClient('mongodb://localhost:27017');) u" u* ?# Q' ^6 u, w+ R
- $db = $mongo->mf; t v9 K* w7 i9 O: ]0 C" {
- $collection = $db->friend;
6 e9 l# C8 q8 i3 Q - $res = $collection->remove(['First Name' => 'jet']);
! y8 }* j s; q, e' n - echo '<pre>';- H1 d+ r+ M; P, f; }. \
- print_r($res);//$res['n']表示删除了几个文档
复制代码
` R) u' o! W5 J+ q+ b! `% q3 d以上是PHP7以前版本的MongoDB操作,下面简单介绍PHP7以后版本的操作。
) z8 x( k: i% v2 I9 H. O-----------------------------------------------PHP7分隔线--------------------------------------------------------------------- 3 h* U# h3 t/ t: w' s
数据插入: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');8 f7 }4 g0 o2 ?2 v H
- $bulk = new MongoDB\Driver\BulkWrite;% j l: f. h2 ?) `. h
- $bulk->insert(['name' => 'JetWu5', 'age' => 26]);
& e1 [, ~# R0 i+ \9 c6 {) Z - $bulk->insert(['name' => 'JetWu6', 'age' => 26]);. t9 W+ P6 w7 a; Q& Q
- " b2 E( w' ~& _" i7 `
- $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认4 S4 w+ _& [0 c! ?* I2 ^7 F! i" |
- $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
9 Y6 T) ^' F4 y S - echo '<pre>';
$ `( `6 U* y2 ~$ V, b - print_r($res);
复制代码 4 g8 F' ]% y0 x7 \$ e: g
数据查询: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
' s& K% |. C: {; A- r+ N( g- l - $query = new MongoDB\Driver\Query(['age' => 24], ['sort' => ['age' => 1]]);
3 J1 j, r. H9 ?. m& C7 r2 H6 j - $cursor = $manager->executeQuery('wjt.friend', $query);: v6 Z7 n6 C7 s. N
- 3 `# G) H/ l; @
- $data = [];$ Z- q* `& U) U9 V* f
- foreach($cursor as $doc) {2 z0 J, R `7 a; E" a
- $data[] = $doc; p6 Q% d# s% r4 M, g" t1 B9 I, ^7 e
- }3 H% Y8 ], |& Q9 I8 ?' j
- echo '<pre>';9 C% `) M }# @, j1 h( x' }9 g0 [
- print_r($data);
复制代码 数据修改: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');% d5 J0 N: _' f# U
- $bulk = new MongoDB\Driver\BulkWrite;
# p3 x- [8 }+ [7 E - $bulk->update(
6 |5 n3 \0 a3 R - ['name' => 'JetWu5'],, x# J: B* d4 h$ V% P9 F( j
- ['$set' => ['age' => 30, 'promise' => 'always smile!']]' f+ s4 \; [! L: x3 W4 K
- );
2 U6 _% V" [ o; c2 Q; A - $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认5 _) H8 o* R2 O/ d. F4 {2 l3 d
- $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);' j/ q( _6 |5 W0 x. `4 A% z
- echo '<pre>';1 g3 w4 ~: r1 I |0 s( x. j8 e* L
- print_r($res);
复制代码 数据删除: - $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
4 ]; u- S- f$ L/ I* } - $bulk = new MongoDB\Driver\BulkWrite;
\0 t$ |; O- ]5 h8 m - $bulk->delete(['name' => 'JetWu3']);
7 h- s+ ?5 Y/ x( W' G+ m - $bulk->delete(['name' => 'JetWu4']);
4 N; u/ @2 O, }$ f+ U: m& `3 i. U% | - $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认# T4 x5 V: ~) u4 d( `* X! _/ S
- $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);4 g: r5 ]) M q. [' Z& ]/ J
- echo '<pre>';
4 Y' {2 q& s4 ~& _: J - print_r($res);
复制代码
' I; S0 H4 |1 r/ P5 ]; K2 j
4 ]1 \4 t* ^' K" k2 v9 a. h; ~& x: O# K! O( p4 P
4 ]! ^! k( g3 h+ i/ E k4 f
) ^$ l b B# U1 y) F" c6 ]
|