cncml手绘网
标题: PHP操作MongoDB(增删改查)php7.0以下 [打印本页]
作者: admin 时间: 2019-3-5 13:50
标题: PHP操作MongoDB(增删改查)php7.0以下
MongoDB的PHP驱动提供了一些核心类来操作MongoDB,总的来说MongoDB命令行中有的功能,它都可以实现,而且参数的格式基本相似。PHP7以前的版本和PHP7之后的版本对MongoDB的操作有所不同,本文主要以PHP7以前版本为例讲解PHP对MongoDB的各种操作,最后再简单说明一下PHP7以后版本对MongoDB的操作。
一、数据插入
- //insert()
0 z1 e) [- u# S8 ?# M+ ~ - //参数1:一个数组或对象# k; t8 s8 b& S9 Z* M- g
- //参数2:扩展选项9 A0 s8 Y1 a4 h) l y: c, h' X3 \
- // fsync:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入硬盘
$ b$ A! W* d( [8 x! @: L - // j:默认为false,若为true则mongo在确认数据插入成功之前将会强制把数据写入日志3 ~8 X! Z8 X: L* i8 U6 E
- // w:默认为1,写操作会被(主)服务器确认,若为0则将不会得到确认,使用复制集时设置为n用于确保主服务器将数据修改成功复制到n个节点后再确认+ {* G0 g' g! E% A3 L
- // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
( ?' `8 { \$ r" | - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
8 F' D; [! u( e5 n% G9 j - $mongo = new MongoClient('mongodb://localhost:27017');4 ^0 M! Q9 M! d6 ~
- $db = $mongo->mf;//选择数据库6 R/ P. J$ [: b$ G6 ?0 m9 I) e( s' B$ T
- $collection = $db->friend;//选择文档集合
6 v y" U9 v4 n- s - $doc = [//定义一个文档,即一个数组
: s+ U. a, Z6 F5 L- h2 l - 'First Name' => 'Jet',% t2 B+ T9 Y, b) {. Z# @
- 'Last Name' => 'Wu',
" j1 c8 v) v+ x4 u - 'Age' => 26,
8 s4 X2 v) ` _" K2 K/ d y - 'Phone' => '110',
; n2 ^1 b" I. d I- V( \3 f/ t: v - 'Address' => [
9 j/ b! V6 \! R$ r6 M4 h! J- A: U - 'Country' => 'China',
! d' P2 t& J g6 C - 'City' => 'Shen Zhen'4 x" i4 G" P/ \! `) j6 K
- ],
. R6 j6 w: ^6 T* b8 x - 'E-Mail' => [
0 {6 d4 W+ y. e5 n5 e: H - '123456@qq.com',6 `% |7 ]' i/ n, V6 ~
- '666666@sina.com',
9 M: w8 R! C3 X+ |0 c9 \ \# t8 ` - '8888888@qq.com',3 L! O: m) P. E" J. c' K
- '77887788@qq.com'2 r; H7 c& \7 f
- ]
5 R% \: l/ |1 a3 s+ X w - ];
" i' }; j$ g# Z* B6 n3 M% K - $res = $collection->insert($doc);//向集合中插入一个文档
- X. K. Y2 ]! o, E3 r5 Y/ \4 s - echo '<pre>';
; E0 W' }6 ` C$ C - print_r($res);//$res['ok']=1表示插入成功
复制代码二、数据查询
1. 查询单个文档:
- //findOne()
9 w4 E( y2 Y! p3 H5 i - //参数1:搜索条件3 h; @) l7 e8 ?
- //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非在第二个参数显式加入'_id'=>false。不设置则返回所有字段
6 a. k1 u4 f9 H1 ^. F( J - $mongo = new MongoClient('mongodb://localhost:27017');
* l u) k; ^; [& }. q - $db = $mongo->mf;( l$ M4 }+ p3 o* j% [7 ~# R' l
- $collection = $db->friend;' ]7 r8 I6 U% j. C; X
- $one = $collection->findOne(['First Name' => 'Jet']);% B" l9 _ U$ A
- echo '<pre>';
4 r' E7 D5 O" j, I \# } - print_r($one);//返回一个数组,查不到数据则返回NULL
复制代码2. 查询多个文档:
- //find()
+ e; Y% a: o- R6 |, M+ v; I - //参数1:搜索条件' e- w" H& j: S" }) h' C
- //参数2:指定返回字段,array('fieldname' => true, 'fieldname2' => true)。_id字段总会返回,除非显式设置为false不返回。不设置则返回所有字段
5 x- S! G* ?8 h; P D - $mongo = new MongoClient('mongodb://localhost:27017');
8 P; V! Z4 C! \$ q; s2 @ - $db = $mongo->mf;4 p; r# q& K, r9 v. z
- $collection = $db->friend;. Q1 P' F2 R+ y, N# {+ I; G% q
- $cursor = $collection->find(['Address.Country' => 'China']);//使用点操作符查找数组元素
$ h+ B8 z+ e7 Z7 S - echo '<pre>';& S# H' O- U, |0 e8 t
- while($doc = $cursor->getNext()) {//循环读取每个匹配的文档7 N$ k" J) L. z0 l( A2 ~
- print_r($doc);) W. U1 ~7 T3 W
- }
复制代码使用各种条件操作符定义查询:
- //mongodb分别使用$lt(小于)、$lte(下雨等于)、$eq(等于)、$gte(大于等于)、$gt(大于)、$ne(不等于)表示<、<=、=、>=、>、<>,用于整数字段查询
; f1 a: P+ a. Z7 g - $mongo = new MongoClient('mongodb://localhost:27017');
& e! o2 L; R* I0 A; \; u- j - $db = $mongo->mf;( I7 U; t# A- Z+ j
- $collection = $db->friend;
# I$ S. n( c1 V - $cursor = $collection->find(['Age' => ['$gt' => 30]]);* h, N; H' X) j9 ^& g6 z4 j- C
- echo '<pre>';3 x# }* V& C, q4 V- s% Z: ?! U
- while($doc = $cursor->getNext()) {- \$ E& M+ x2 N# O6 Y- N
- print_r($doc);( b5 d F: \- T" R$ t7 R
- }
复制代码 //查询某个字段的所有不重复的值
* n# Z; X/ S/ E. N( p3 B/ h4 R $res = $collection->distinct('Age');
- //$in:匹配多个值中任意一个: S# X c* C: k0 M# c- c
- $cursor = $collection->find(['Address.Country' => ['$in' => ['China', 'USA']]]);
" ]7 ] _% c2 m. u2 m! |. D - 2 O8 ~4 h, W+ v6 V
- //$all:匹配多个值中所有值(用于数组字段查询)
5 k2 I( H+ ^, l/ U7 _3 W# Y - $cursor = $collection->find(['E-Mail' => ['$all' => ['123456@qq.com', '77887788@qq.com']]]);
) Y, k8 W2 {. E) j9 b0 | - : A6 f7 g( y7 F4 T; g: @+ X
- //$or:或查询
! A b3 ~- N+ }4 @9 c7 e - $cursor = $collection->find(['$or' => [['First Name' => 'Jet'], ['Address.Country' => 'USA']]]);% Z( W0 Q- o% S, g0 Z
-
# Z) L) o+ v7 t1 @6 q* o1 t W - //$slice:获取数组字段中指定数目的元素,位于find()函数第二个参数中
: X; Y- q6 O* O l- j - $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => 2]]);//只返回前两个email
* G" D# @5 r7 {) }! @ - $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => -2]]);//只返回最后两个email
: W* R9 h( w* u) }4 h - $cursor = $collection->find(['First Name' => 'Jet'], ['E-Mail' => ['$slice' => [1, 2]]]);//忽略第一个,返回接下来两个
2 v, ]6 G" ^& q - ! q: v. y+ [, p
- //$exists:根据某个字段是否有设置值进行查询
. ^5 ]( K8 t' F- O$ ~% G - $cursor = $collection->find(['Hobby' => ['$exists' => false]]);//查找Hobby字段未设置值的文档" H! w4 s0 w; k) q$ C1 r
-
- H' ]4 R6 K& F5 W) y% i" S - //正则表达式查询+ C" U0 I# n7 Z3 _6 k/ ^" @8 F
- $cursor = $collection->find(['First Name' => new MongoRegex('/^Je/i')]);//查找First Name字段以Je开头的文档,忽略大小写差异
复制代码使用MongoCursor类提供的其他函数:
- //排序:1升序,-1降序
: j2 t3 `& c3 R R$ t8 q0 M# q - $cursor->sort(['Age' => 1]);- Z1 L- ?& }8 k. z; t( A$ D1 X( |
- ! Y+ F8 }" [1 z5 t3 J+ N5 j
- //忽略前n个匹配的文档9 } T& _% C: B" N6 Y2 |
- $cursor->skip(1);
9 }3 I- Y5 \% }; x( ~8 l -
x$ ^5 ~! x0 d5 Q - //只返回前n个匹配的文档(limit()与skip()结合使用可实现数据分页功能)
0 N/ A* Z! v5 ~3 L - $cursor->limit(1);
, `- @% W8 Z( ?; Y7 a - % G$ X% G! M" a' o# T) X& j' C
- //匹配文档的总数8 v) e* l' z! P* n4 @
- $cursor->count();- ]# c1 J$ b$ |4 D/ ?# L, T% P z; C' K
- 4 E* [. c) k! L# ^- D' x
- //指定查询索引* ~3 k0 k8 z; Q: h. \1 |' Z3 s
- $cursor->hint(['Last Name' => -1]);//若索引不存在则会报错
复制代码聚集查询:对数据进行分组统计
- //聚合查询:对数据进行分组统计0 n! ?( i/ @8 ]
- $mongo = new MongoClient('mongodb://localhost:27017');! Q) b: Q o. l3 p! k
- $db = $mongo->mf;' [3 x/ V9 t- B: J, h2 f/ R$ e
- $collection = $db->friend;
% E1 T3 G( q* X& s6 b - $res = $collection->aggregate([
3 K6 v; L3 Q3 T/ k' A9 T' E4 U - '$group' => [. o; [& L! M. s+ Z+ Y% w/ m
- '_id' => '$Address.Country',//分组字段,注意要加上“$”,这里是根据数组字段某个元素值进行分组# I c( T9 O- f
- 'total' => ['$sum' => 1],//求总和,表示每匹配一个文档总和就加1
. F- r, c) l7 H8 T - 'maxAge' => ['$max' => '$Age'],//分组中Age字段最大值( Q2 G$ X& u* ^, ]
- 'minAge' => ['$min' => '$Age']//分组中Age字段最小值5 N0 D( q# y. d* k/ F
- ]
5 @0 U6 t2 I. R4 D: Z7 U - ]);3 D+ ~: P+ u4 }
- echo '<pre>';- g$ Z" e9 c ?
- print_r($res);//返回一个数组,$ret['result']为数组,存放统计结果4 e; j( r# i% H, q
-
: D2 F/ e7 g; G2 r# h - 7 _" [) p+ U6 P, T, b2 s( i
- //存在其它操作的聚合查询:多个操作之间执行先后顺序取决于它们位置的先后顺序
9 [/ j3 f( A, z! N - //聚合查询中的所有操作,包括'$group'在内,都是可选的。
& W4 \1 R4 a8 M3 i - $mongo = new MongoClient('mongodb://localhost:27017');
8 X$ V5 P: ~% b3 F: B - $db = $mongo->mf;
& }4 W7 u; \4 ]1 @ - $collection = $db->friend;9 i* [8 c! |. k! C9 W& d* G1 H. a+ {
- $res = $collection->aggregate([7 J: O7 }! y/ W
- [//过滤条件:只对符合条件的原始文档进行聚合运算,若是放在'$group'之后则是只返回符合条件的结果文档, }% i; _# m) i" e5 z
- '$match' => ['Age' => ['$gt' => 30]]$ B: }7 j; `! P3 y4 G! w
- ],
3 \6 i( S& e6 ~0 N* a - [//指定分组字段、统计字段
7 Y8 j( u: t5 O6 d: N4 k - '$group' => [3 Y7 M7 z, r+ d2 l6 q& T1 A# M
- '_id' => '$Address.Country',
1 F& d" ~, Y& j6 U' J - 'totalAge' => ['$sum' => '$Age']//计算各个分组Age字段总和/ z3 m7 f6 l; k: r. r
- ]
7 \7 g: s1 \8 W' F) p* P - ],
: Q2 t. d" e" [ - //以下操作若是放在'$group'之前则在聚合前作用于原始文档,若放在'$group'之后则在聚合后作用于结果文档
5 \( ]7 m; z& v3 V" Z - ['$unwind' => '$E-Mail'],//将包含有某个数组类型字段的文档拆分成多个文档,每个文档的同名字段的值为数组中的一个值。/ I& R1 U& i/ }) K9 m6 D
- ['$project' => ['myAge' => '$Age', 'First Name' => '$First Name']],//指定返回字段,可以对字段进行重命名,格式:返回字段名 => $原来字段名
5 W2 [( |* O' ?5 {" n* \6 r - ['$skip' => 2],//跳过指定数量的文档
+ R/ {, |' P! K$ B- z - ['$limit' => 2],//只返回指定数量的文档6 z0 Z9 n R1 g) l
- ['$sort' => ['totalAge' => 1]]//排序
( K! o, S: n o - ]);
) J3 w0 _5 U- F. J/ W! b& i; C, { - echo '<pre>';
& s" X( Q+ L. i$ B. H3 X - print_r($res);
复制代码 C3 V9 J8 N! P' ~" Y5 M a. H8 X8 K
三、数据修改
- //update()' i/ Z* U) S& c1 `( N: _
- //参数1:更新条件,指定更新的目标对象。5 S" {! i2 i# e( j
- //参数2:指定用于更新匹配记录的对象。% g H$ r+ w1 v6 G8 N+ F
- //参数3:扩展选项组。8 X2 r% j* b$ q) j& C% i
- // upsert:若设置为true,当没有匹配文档的时候会创建一个新的文档。6 p, q( h# X4 H, Z5 H8 f* {& ^ t
- // multiple:默认为false,若设置为true,匹配文档将全部被更新。
( I \* K3 d+ n/ a, s - // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。8 s' ?! Y& b* h, Q
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作& e) H9 q# W; r1 B
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。
! b; p; e$ T! k( l/ R) C$ T: u8 [ ^ - // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
& _6 J# [; _1 V8 t9 W! k3 U - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
. E% ]2 O' V0 p9 M" o - //注意:若不使用任何修改操作符,则匹配文档将直接被整个替换为参数2指定的对象。
) o) l3 O0 E( S7 x; v) F. ~ c2 j -
$ J6 u% w2 ^5 ?: n/ k7 p0 ? - //$inc:增加特定键的值,若字段不存在则新建字段并赋值! Q/ Z2 c1 ?' U1 g3 l, x& M
- $mongo = new MongoClient('mongodb://localhost:27017');
, \$ _ e. Y, v) S* J) n - $db = $mongo->mf;4 |+ o$ q" E% \ z# `! r
- $collection = $db->friend;# S" a# M& j8 ], r) _3 J8 @
- $res = $collection->update(['First Name' => 'Jet'], ['$inc' => ['Age' => 2]]); S" @6 `0 W3 Z. r6 l
- echo '<pre>';
$ @5 I4 z4 P( S - print_r($res);//$res['ok']=1表示修改成功,$res['nModified']表示修改的文档数量
8 e+ R0 J/ W) T9 R - $ Y4 r( p9 X* M- x+ V- m
- //$set:重置特定键的值,若字段不存在则新建字段并赋值6 }4 y& R# d& H# W0 c
- $res = $collection->update(['First Name' => 'Jet'], ['$set' => ['Hobby' => 'pingpong']]);
+ e2 ^/ h8 V4 F -
4 d$ G8 ~( V! ]& ?: K" J* d' w - //$unset:删除字段
' `/ ]' I* J+ r0 `! Q# h ?/ d - $res = $collection->update(['First Name' => 'Jet'], ['$unset' => ['Hobby' => 1]]);4 v2 Q( e+ `6 v1 R' V6 M7 I4 X
-
" c, Z8 j6 R9 Q1 x/ m$ d; L - //$rename:重命名字段,若字段不存在则不进行任何操作( C q- ~& N' K
- $res = $collection->update(['First Name' => 'Jet'], ['$rename' => ['Hobby' => 'hobby', 'Age' => 'age']]);
% I$ I2 u; T. N1 n - //注意:如果文档中已经使用了指定名称的字段,则该字段将会被删除,然后再进行重命名操作。
2 h( B1 k( N' Y6 m( A. t -
. U, B% _4 r4 |, _+ n) j9 ?$ K, P - //$setOnInsert:设置了upsert为true,并且发生了插入操作的时候,将某个字段设置为特定的
+ B& g$ K9 i2 t+ i* t, y+ F* j4 R% B - $res = $collection->update(['First Name' => 'jet'], ['$setOnInsert' => ['lang' => 'English']], ['upsert' => true]);6 o; V" N8 B: `) j* q N( a
- 4 |* ?/ z# A# K5 O5 t: J
- //$push:向指定字段添加一个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错
4 Z+ u# R9 Z9 E0 R - $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '123123@qq.com']]);
, F( Z+ ?# A3 Q3 n" Q -
5 r- \! D2 [2 b - //$push:向指定字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错7 j& ~ G0 A' m3 e2 N3 W
- $res = $collection->update(['First Name' => 'Jet'], ['$pushAll' => ['E-Mail' => ['666@qq.com', '8888888@qq.com']]]);4 u0 o& B: ]8 w/ K. Y# q( N1 W( m
- ; T$ q- |# g3 J
- //使用$push和$each向某个字段添加多个值(作用于数组字段),若字段不存在会先创建字段,若字段值不是数组会报错
* b' \0 e$ ?1 J( P - $res = $collection->update(['First Name' => 'Jet'], ['$push' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);0 i1 [- Q! T) y
- 9 K7 k: S: y0 }& P, b
- //$addToSet:将数据添加到数组中(只在目标数组没有该数据的时候才将数据添加到数组中)- [/ o* O6 D; f5 J7 [' E# ?
- $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => '123123@qq.com']]);1 ` N2 b* O3 X8 H! n* A
- $res = $collection->update(['First Name' => 'Jet'], ['$addToSet' => ['E-Mail' => ['$each' => ['123123@qq.com', '666@qq.com']]]]);
" r6 E0 a: W- Z9 u; W5 [ -
V' b- h* q$ n/ Q1 a, \ - //$pop:从数组中删除一个元素,-1表示删除第一个元素,1表示删除最后一个元素(其实负数都删除第一个元素,0或正数都删除最后一个元素)
7 q5 D% n8 h6 B0 H X+ R - $res = $collection->update(['First Name' => 'Jet'], ['$pop' => ['E-Mail' => 1]]);
& o1 j; \/ c, s ]2 h! w6 A7 |4 U - 1 x5 p# g- _0 d( k+ y% x
- //$pull:删除数组中所有指定值0 x! v) h+ r+ }8 G# @7 o, c3 M
- $res = $collection->update(['First Name' => 'Jet'], ['$pull' => ['E-Mail' => '123123@qq.com']]);
+ I- j+ G) P: x! {# _7 ~" A0 I - - E$ Q7 n/ {+ v I0 ^9 q- i2 U
- //$pullAll:删除数组中多个元素的所有值
9 u* d$ H' m+ n5 e: K8 l - $res = $collection->update(['First Name' => 'Jet'], ['$pullAll' => ['E-Mail' => ['123123@qq.com', '666@qq.com']]]);
复制代码- //save()7 y: {( s8 U+ T0 W1 o! j" P
- //参数1:希望保存的信息数组
( w, i& R2 N2 G: z! K# R1 [ - //参数2:扩展选项7 y' s. @* |3 C2 U7 q5 n$ m0 J
- // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。/ ]0 R' G3 u' A- W' `" e/ t* n
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作5 N+ j2 L2 o) z- H5 t2 Q2 u" S$ f
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。
7 K1 a4 ?, J, p) C- D) O6 \ - // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间3 W0 E' j1 y, `' [0 B6 d6 Q* c- x0 ]
- // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)* C$ f! X' U/ E6 u3 w# P! X
- //注意:若已存在则更新,若不存在则插入;更新时使用参数1指定的信息数组替换整个文档。
* ?1 B3 U5 j9 }7 A/ T9 F$ N# F - //若想更新则应该在参数1中指定_id键的值。7 a# {6 j5 m# |, d9 X
- $mongo = new MongoClient('mongodb://localhost:27017');
1 V9 u ~' N- d. P - $db = $mongo->mf;; _, D1 [% o( `: K% w
- $collection = $db->friend;
( C+ C% _! J7 q0 u* T8 C& I3 D - $doc = [//定义一个文档,即一个数组, q/ i3 _4 F( O1 N: R' {8 P+ }, s
- 'First Name' => 'Jet',5 E6 O2 D+ p" |) F9 I) t
- 'Last Name' => 'Wu',6 u2 Z( L5 R! \
- 'Age' => 26,: M$ T/ j. a8 B/ x( {' I1 z2 @
- 'Phone' => '110',
- Y. e! N- n" E4 R. M( [ - 'Address' => [
6 h6 V2 c# t' l - 'Country' => 'China',* D9 P" L) v( @2 S9 X
- 'City' => 'Shen Zhen'( U D1 C- w8 G) Q! C! x! l& }1 V
- ],
, L( E& b' W7 a; G8 u+ s# E - 'E-Mail' => [
" J; s. z0 }# u) ?' r - '123456@qq.com',2 i3 O" x4 z4 B2 J8 p
- '666666@sina.com',
' i/ ~- l$ L6 w0 h$ B5 C - '8888888@qq.com',
& s- Z( E1 L* f6 z% \ - '77887788@qq.com'
: F3 t: b+ ]8 F3 T8 i( u - ]
9 R) |( ?! n. i7 Y, @: b* q2 |8 n" ] - ];: B7 x- O% {8 U8 b/ G. j, ]) B9 X' r
- $res = $collection->save($doc);. d/ J, A, C; S2 g. V$ X
- echo '<pre>';( w; d% _; E% X3 s
- print_r($res);//$res['ok']=1表示操作成功,$res['updatedExisting']=1表示更新,$res['upserted']=1表示插入
* _6 ^ j8 P7 j, [' a - # u7 N8 q! r/ X. @# Y# a8 e
复制代码- //findAndModify()2 u" O( V& p6 ^- O
- //参数1:指定查询条件; V" |6 l% J( N. z4 P9 u V
- //参数2:指定用于更新文档的信息
# F) s/ a+ c' _$ r( v - //参数3:可选,指定希望返回的字段7 x7 U$ m' M" [
- //参数4:扩展选项
( I2 F9 s8 h2 h8 j - // sort:以特定顺序对匹配文档进行排序0 l% P+ Z! ^& u- c
- // remove:若设置为true,第一个匹配文档将被删除2 B" V2 _& t# ?9 f! K9 b
- // update:若设置为true,将在被选择的文档上执行更新操作
6 L0 @6 M0 m7 I) I: S7 a1 s - // new:默认为false,若设置为true则返回更新后的文档,否则返回更新前的文档4 e, n/ l0 ]7 Z8 O& Y
- // upsert:若设置为true,没有找到匹配文档的时候将插入一个新的文档
8 V! J9 f" J+ B% j) ]7 [ - $mongo = new MongoClient('mongodb://localhost:27017');
; b5 d0 s1 @5 f' Y$ E" d - $db = $mongo->mf;
1 X; @/ R' u3 D# q4 T - $collection = $db->friend;
+ Y, ]2 ?0 p+ m( T5 Y/ l - $res = $collection->findAndModify(['First Name' => 'Jet'], ['$push' => ['E-Mail' => '111@qq.com']]);6 H4 C% q N' Y0 \" \
- echo '<pre>';3 K/ I8 C) E8 E: G6 f" s, f
- print_r($res);
复制代码
四、数据删除
- //remove()
8 | i' q! k0 }4 ] - //参数1:查询条件
& |7 c7 G- k- x, g3 F% }' k( I e - //参数2:扩展选项
* H3 O6 f# E1 F T" H - // justOne:若设置为true,则最多只有一个匹配的文档将被删除
" u* l: a0 A6 K/ B! T - // fsync:若设置为true,w参数将被覆盖为0,数据将在更新结果返回前同步到磁盘。7 k3 u3 s/ b4 T$ X) G
- // w:默认为1;若设置为0,更新操作将不会得到确认;使用复制集时可设置为n,确保主服务器在将修改复制到n个节点后才确认该更新操作0 d8 t3 C% u# m' i" r1 {
- // j:默认为false,若设置为true,数据将在更新结果返回之前写入到日志中。
" E& @. g; S- u - // wtimeout:默认为10000(毫秒),用于指定服务器等待接收确认的时间
1 ^$ R9 d# t* A/ E. o - // timeout:指定客户端需要等待服务器响应的超时时间(毫秒)
; h! S) a( H# J* L - $mongo = new MongoClient('mongodb://localhost:27017');
) H6 w% _' B8 n! u& I' R1 A" Z5 z( d - $db = $mongo->mf;4 x5 V8 ^ E6 q) K D
- $collection = $db->friend;/ D( H- b8 V" [& `6 \
- $res = $collection->remove(['First Name' => 'jet']);7 M; O% p. G" K* {" m( W- e
- echo '<pre>';' {4 p( ?) {4 n2 k; F
- print_r($res);//$res['n']表示删除了几个文档
复制代码 0 ^1 {" p1 d+ b$ H
以上是PHP7以前版本的MongoDB操作,下面简单介绍PHP7以后版本的操作。
% j$ K' \. f# Z0 t-----------------------------------------------PHP7分隔线---------------------------------------------------------------------
8 S6 g7 M7 A- s' ?1 C1 [! c
数据插入:
- $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');! I) D0 _- ^6 w7 U$ o
- $bulk = new MongoDB\Driver\BulkWrite;- I/ z1 t) y4 s0 x# B% ]. l
- $bulk->insert(['name' => 'JetWu5', 'age' => 26]);
$ d! O6 `$ F& L/ }, z1 p - $bulk->insert(['name' => 'JetWu6', 'age' => 26]);
1 O: E! Z* X: x* }5 L -
8 j6 |) a' j; B/ H! d) O - $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
$ `, u# `3 Z6 d# X$ U - $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);8 U T% j3 x' t: G) D3 H* c% F
- echo '<pre>';
, u( [+ l( w1 k% o. b) A: Y) |% H - print_r($res);
复制代码 p2 X6 w/ e$ ~
数据查询:
- $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
3 c: v+ j D6 X! [9 x0 b0 z4 ~" z - $query = new MongoDB\Driver\Query(['age' => 24], ['sort' => ['age' => 1]]);3 P: Y3 G$ B& M% n# I; e
- $cursor = $manager->executeQuery('wjt.friend', $query);
8 ]. O: l. k3 L -
3 g! Q G5 q! G/ K7 k! p - $data = [];$ a* e3 L9 n6 `+ L4 d
- foreach($cursor as $doc) {
$ n: n8 p7 p$ G# [$ f - $data[] = $doc;
6 L3 c- @% J& M8 t. B p5 w - }
; M# ?6 H; i' `3 r, Q w7 G$ [ - echo '<pre>';
0 A. p2 h+ q3 v V) h - print_r($data);
复制代码
数据修改:
- $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');
7 n n; r: C5 `, o - $bulk = new MongoDB\Driver\BulkWrite;
4 f! w+ B8 g# ~) y$ p j. Z! H - $bulk->update(; Q9 O8 h# B& _/ |/ p1 o
- ['name' => 'JetWu5'],
2 y: ~% V: r' m D# O - ['$set' => ['age' => 30, 'promise' => 'always smile!']]
5 Z3 E0 T' _$ A/ @3 w8 l - );+ s: x5 B) \9 k
- $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认
# r+ U F: a) Z2 c - $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);
! r$ S) R# Y% G1 S - echo '<pre>';
- T/ r; M+ |+ L - print_r($res);
复制代码
数据删除:
- $manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');5 D5 n+ z5 S; l+ q$ ]! r; A. h8 ?
- $bulk = new MongoDB\Driver\BulkWrite;* A8 O+ ]. n) k
- $bulk->delete(['name' => 'JetWu3']);
/ J9 c7 X1 G# S - $bulk->delete(['name' => 'JetWu4']);: u* X2 Z* d v
- $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);//可选,修改确认( Y& W6 x" e" | l
- $res = $manager->executeBulkWrite('wjt.friend', $bulk, $writeConcern);6 P5 ?4 J4 A r1 Z2 g' R
- echo '<pre>';! W/ h/ |$ h1 P, [+ A
- print_r($res);
复制代码
$ Y+ U4 K( h' w% Q' ~7 W3 r3 \" g3 d) J, c4 o4 @5 Z# U# u6 c( z
* g6 n1 q5 G6 u2 Q: j2 s# o4 G
2 _4 P2 J8 t( m3 @# z7 Q+ O4 a# j$ E1 O9 X7 i/ g- u# O$ o
欢迎光临 cncml手绘网 (http://www.cncml.com/) |
Powered by Discuz! X3.2 |