管理员
论坛积分
分
威望 点
贡献值 个
金币 枚
|
提示:PHP的mongodb扩展,从5.6开始已经废弃了原来的mongo扩展,php7的pecl下载地址:https://pecl.php.net/package/mongodb,或者选择mongodb官方开发:https://github.com/mongodb/mongo-php-library,git上的这个支持以前mongo写法,pecl上的mongodb不支持以前的写法。
- q8 w1 j2 m( v0 {( g6 ~
2 W5 ]9 i! U; Z, o下面用PHP7新的API总结一下:/ {; ] ^* g: ?5 y+ m0 p l9 b
% E7 h! _8 j; u8 B" x" K一:CURD
: X5 F& q' z3 Y: b1 A9 e+ }
# I1 e. q0 W- v }4 P6 F# r4 i/ |8 ~1:链接( }" z, m9 u2 a' D( Y2 [6 ?: b, |/ t7 q
5 N& I$ N6 N5 ~
- <?php
; P: b* l2 A3 F" `1 k& V# X2 E - //链接mongodb
% ~9 W$ ?( |" H( T - $manager = new MongoDB\Driver\Manager('mongodb://root:123@10.10.10.104:27017'); x/ l; U0 ]( x4 f% J( k1 l6 G
- root 用户;123:密码;如果没有密码则不写
复制代码 + c+ }" p6 ~- m" V
. l- I. M3 Q! a3 J' ?) i2:查询
( M( {6 ]# k- e# p8 L' c4 W0 Q0 v7 ]7 |. a! A4 C, R
- <?php
8 r3 F. Z! k6 G) Q - 9 k/ P- E m/ V5 F. y1 H9 R
- //链接mongodb
; ~ ?2 w' b% g) O* S - $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
/ e, P1 V: u: o: } - 7 d+ h& L; W! z. z: } K! D" _6 p- \
- //查询: \) W2 ]9 \1 o; d; D& I
- $filter = ['user_id'=>['$gt'=>0]]; //查询条件 user_id大于0
2 y% I1 U* B) W' `8 w( w" _ - $options = [( Y" Q" H, D& n/ H- J. ^4 B
- 'projection' => ['_id' => 0], //不输出_id字段
0 V2 O7 a$ Q; \; O' G8 `8 `: F# Y$ q - 'sort' => ['user_id'=>-1] //根据user_id字段排序 1是升序,-1是降序
* k8 r8 k" |. n* _* k - ];; F+ b( c$ I" i; z
- $query = new MongoDB\Driver\Query($filter, $options); //查询请求
! }. @" a/ E: z: f - $list = $manager->executeQuery('location.box',$query); // 执行查询 location数据库下的box集合; S$ {1 X: ]: m0 G
- * b5 z. m* S! m1 ~- @
I; n0 c' F/ p$ u% }& A- foreach ($list as $document) {
9 T5 E* c- i6 b - print_r($document);
" V+ H+ k0 T; P7 h3 \ - }
复制代码
( H/ W; E5 C2 W6 w+ Q查询更多条件使用方法,参考第二节mongodb基本命令,查询
: I' |% D* w% I8 Q; X# I' X+ a' d+ D3 g( b, Q9 A( m
3:添加! }1 h8 S) |& U( J: ?9 u" ]
" D* T. ^# {1 P% I: |6 [5 d$ w- <?php7 L! q# J4 U- o% R; B# [. E" W0 m
P" l$ c6 [& v5 z- //链接mongodb$ e, ]! U8 N8 ~
- $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
0 X, ]9 D2 W! A3 g8 ]: b - ! W, K! K7 u e4 ^1 }, y8 f' C
- $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的,串行执行! ?( x0 O( J% l( k5 [
- //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase,并行执行
1 F3 i1 H0 `9 X, J6 o3 k8 G# j% G, | - $bulk->insert(['user_id' => 2, 'real_name'=>'中国',]);
l" ^3 I' U6 d& f4 s - $bulk->insert(['user_id' => 3, 'real_name'=>'中国人',]);! ~9 J# [' G( Y, i; T9 B
- $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合
复制代码
+ p7 r( x- g; \" ?4 Q: R0 Z. D4:修改0 `6 r [- a# u4 |9 Q, {. g
2 R1 ?0 Z- F- A7 D# f
- <?php* @1 Y' O3 @2 ` g
- # k" R% |4 L) c
- //链接mongodb
9 N# ?) w+ A( u+ ^3 d8 I" {) C: y - $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');* j: \0 g1 k) t- H/ k {+ w- W$ Q. a! h
- : O' f- y# Q7 ]
- $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的,串行执行/ x' i; r/ ~6 o, `
- //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase,并行执行! Z7 ~ p8 Q1 B
- $bulk->update(
; a8 u! c- e1 m. x" n; p, K - ['user_id' => 2],
& D/ @: P' f8 Q8 M - ['$set'=>['real_name'=>'中国国']. w% q V- l5 v( j
- ]); 6 i. J; P. q3 L3 F1 z2 I
- //$set相当于mysql的 set,这里和mysql有两个不同的地方,
: \/ W% a) B* m- j - //1:字段不存在会添加一个字段;" l0 y# V' Y9 B5 n6 J' _! F
- //2:mongodb默认如果条件不成立,新增加数据,相当于insert
8 B7 _% x% u% T) F" e+ s+ j
/ I5 ?& E$ U6 S! a x+ v5 ~/ U- 5 e, x: r- _9 Z. M" D
- //如果条件不存在不新增加,可以通过设置upsert0 N9 ]9 ?' e$ l+ G
- //db.collectionName.update(query, obj, upsert, multi);) H, V& U7 w1 [2 E* A* }$ o
/ W0 V) L( p) M. b8 R8 ~1 K+ ?- $bulk->update(
+ ^- L. v# H& \ - ['user_id' => 5],) D2 n: g% j, }4 f `
- [
. ?% Q/ q* Q7 q$ n2 B" _! q - '$set'=>['fff'=>'中国国']
0 b: S; |% q* ^. |% v0 p' P - ],
# s3 P$ Z7 h s0 T - ['multi' => true, 'upsert' => false] $ s) B3 R# Q' e2 i: C/ v+ n8 d
- //multi为true,则满足条件的全部修改,默认为true,如果改为false,则只修改满足条件的第一条; p; I4 P3 R9 V; ]- e6 K0 W
- //upsert为 treu:表示不存在就新增8 i% k% U+ K) Z
- );, M* P, V) t J, D
- $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合
复制代码
. u7 r* E: I- |
8 g2 j: y8 P1 I% Bordered 设置4 G% y# M5 i9 @( |4 t& M* w/ Y1 p
) B( o% ?7 S8 @5 W
1:默认是ture,按照顺序执行插入更新数据,如果出错,停止执行后面的,mongo官方叫串行。; }" ?# z% B. Z$ ], h
2:如果是false,mongo并发的方式插入更新数据,中间出现错误,不影响后续操作无影响,mongo官方叫并行
3 X' y* M' ]! J+ i$ T& j
' u9 |2 }$ y6 a3 \; w2 ]5:删除# w, j9 B" l, t8 S8 H
! H8 w& T! t- {1 U& X6 P- <?php% M; f. u7 D3 ~% j' P
4 g3 {$ i9 T0 N- //链接mongodb& e9 r' Z+ A) S% s3 M) n* Z
- $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');' S; m% j# x. S5 [5 r
- 4 b# Z0 N+ B' E" l1 o- a# H) e* e
- $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的,串行执行
) Q) ]: s* k ] - //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase,并行执行
# ?4 v+ z0 W6 h# E1 l' p - $bulk->delete(['user_id'=>5]);//删除user_id为5的字段! d4 }# m2 m4 m+ C2 l3 Q7 E
- $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合0 q4 h5 V2 D+ s0 y2 U2 h' v0 u
- delete还可以通过limit设置不同删除方式
7 v) c$ r4 T M F/ L - 5 O2 f7 e# F) @" I8 e
- $bulk->delete(['user_id' => 1], ['limit' => 1]); // limit 为 1 时,删除第一条匹配数据 j) m9 I) c) ?
- $bulk->delete(['user_id' => 2], ['limit' => 0]); // limit 为 0 时,删除所有匹配数据,默认删除所有
复制代码 ; P' e$ a8 U( l& O
, q2 w0 u0 ?# u8 _: ] D8 q: m$ l5 Q6:捕获异常
1 W$ |$ t% Y: b- f/ U s
. b9 K* S5 P. [3 T4 y. I: m3 y+ M9 |1 K- MongoDB\Driver\Exception\AuthenticationException5 A7 n- M' R5 [5 T# q+ F! R
- MongoDB\Driver\Exception\BulkWriteException6 p( T, ^$ ~. j) s, P! i% u* y8 V0 P
- MongoDB\Driver\Exception\ConnectionException
( y, d i) O) o& z' o - MongoDB\Driver\Exception\ConnectionTimeoutException+ p; X" |( y5 s4 {1 W6 i
- MongoDB\Driver\Exception\Exception //所有驱动程序异常的公共接口
2 `6 |" Y" g& Q7 O# y - MongoDB\Driver\Exception\ExecutionTimeoutException( H! `8 l1 |$ b: g5 [: C
- MongoDB\Driver\Exception\InvalidArgumentException
) Y7 A+ [& u( b1 d7 J. @) N- i - MongoDB\Driver\Exception\LogicException1 S3 B: p- P& E0 y% Q, A% D
- MongoDB\Driver\Exception\RuntimeException
5 J7 I6 V0 W8 U$ l" L( N" n! F - MongoDB\Driver\Exception\SSLConnectionException
6 H- n$ R6 A- o* L8 `: P: d4 p" N. L! J - MongoDB\Driver\Exception\UnexpectedValueException$ b( Q% _5 b! ]: W9 q7 s
- MongoDB\Driver\Exception\WriteException
复制代码
/ P! b7 h! I3 {5 U7 J" C8 M/ C2 M0 e8 I! D: G* g4 K
w @5 g! n1 n/ Q
点击查看全部
+ Q: X0 y$ Y; i3 c% W* q& J
; P/ B& |1 c3 N% m" p; ^9 K$ s6 g! r( L! ^+ Z
|
|