php7的mongodb基本用法

admin

提示：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不支持以前的写法。

下面用PHP7新的API总结一下：
3 ]& F" O7 w4 C2 E% S
一：CURD

1：链接
2 n) @, N; X8 _( P% O
9 O" `, X% s, K0 B1 ^* [6 F% j

1. <?php
   
2. //链接mongodb
   
3. $manager = new MongoDB\Driver\Manager('mongodb://root:123@10.10.10.104:27017');
   ; e0 l; X# E# v# N
4. root 用户；123：密码；如果没有密码则不写

复制代码

2：查询
( T( v* {& f- X9 G6 O4 w$ h* |

1. <?php
   1 F. Z$ ?, f- i( h$ ?% N
2. 
   
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   ! p1 [) Y, ?  S: V8 O+ G
5. 
   0 H9 f. }. Z. z: n( U7 P# t
6. //查询
   
7. $filter =  ['user_id'=>['$gt'=>0]]; //查询条件 user_id大于0
   
8. $options = [
   4 w. z+ {' r* O: h$ Z+ Y. B3 Y4 {
9.    'projection' => ['_id' => 0], //不输出_id字段
   . |1 V' V0 a3 z0 z# H
10.    'sort' => ['user_id'=>-1] //根据user_id字段排序 1是升序，-1是降序
    
11. ];
    
12. $query = new MongoDB\Driver\Query($filter, $options); //查询请求
    % ~; g' d7 O' T/ m7 Q
13. $list = $manager->executeQuery('location.box',$query); // 执行查询 location数据库下的box集合
    
14. 
    $ l& v+ E- W9 X7 H
15. 
    
16. foreach ($list as $document) {
    
17.     print_r($document);
    9 R! b7 q0 t2 y( Y  I
18. }

复制代码

1 O0 l) {& h; p查询更多条件使用方法，参考第二节mongodb基本命令，查询

" G( R4 l4 e3 k' @3：添加

" {4 X) s* ]6 V  N: n5 n) n

1. <?php
   3 W2 z: X+ A3 l0 B4 m: b
2. 
   $ A# D5 v# W- W5 ?. f( ~) r  A
3. //链接mongodb
   & V' B5 n) V9 a$ {7 S" n
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   
5. 
   
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   6 t: v% `# b3 f& ]) H
8. $bulk->insert(['user_id' => 2, 'real_name'=>'中国',]);
   
9. $bulk->insert(['user_id' => 3, 'real_name'=>'中国人',]);
   
10. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

# V2 u! }3 j# x2 T: c, c( @: |% P& j4：修改
# b  P% r. ]7 u: V  _/ z# @

1. <?php
   
2. 
   7 s; Z% d- N, b3 {3 T
3. //链接mongodb
   0 c" q& U8 A( y8 p& [
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   ! G" U& [) Y& q: Z! V8 _! X
5. 
   5 f: ~2 }: A) S+ C8 _! V
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   , L$ g8 l: ~/ J4 W
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   7 W7 H) D/ L, T$ H  v% O- Y  p
8. $bulk->update(
   
9.         ['user_id' => 2],
   7 V5 k# O  d) f
10.         ['$set'=>['real_name'=>'中国国']
    & @/ O% x' U/ Q) `
11. ]);
    - v5 d7 K, D& o: A* H1 S
12. //$set相当于mysql的 set，这里和mysql有两个不同的地方，
    - ^; |! P" r- g2 j3 [: q; z! A
13. //1：字段不存在会添加一个字段;
    1 |$ Z( Q# k! E; M
14. //2：mongodb默认如果条件不成立，新增加数据，相当于insert
    2 N) C* _5 |' `
15. 
    
16. 
    
17. //如果条件不存在不新增加，可以通过设置upsert
    ( C- t3 b4 f, c6 Q/ ?
18. //db.collectionName.update(query, obj, upsert, multi);
    ; M& F  Z; p6 l5 q
19. 
    
20. $bulk->update(
    : j% h% z8 k+ N
21.         ['user_id' => 5],
    
22.         [
    ; D* g. B( G: p' h6 _1 z
23.                 '$set'=>['fff'=>'中国国']
    ; M( o8 \; K2 h4 ~
24.         ],
    * f8 S9 W  \* d) L, U* I: U
25.         ['multi' => true, 'upsert' => false]
    3 M2 s: F2 J/ a) }9 `2 ~; v( x
26.         //multi为true,则满足条件的全部修改,默认为true，如果改为false，则只修改满足条件的第一条
    
27.         //upsert为 treu：表示不存在就新增
    
28. );
    ' r3 p* t6 M8 ^2 r
29. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

6 e0 p- M0 ~+ ~! s0 {* q  H2 aordered 设置
/ |; R3 Z& z" F, g' t
, x- O2 |% _$ a8 V1：默认是ture，按照顺序执行插入更新数据，如果出错，停止执行后面的，mongo官方叫串行。
2：如果是false，mongo并发的方式插入更新数据，中间出现错误，不影响后续操作无影响，mongo官方叫并行
8 o. _0 R4 }+ @6 N* q2 ]# y
5：删除

1. <?php
   
2. 
   8 g9 W5 _# |/ G. y1 D) D
3. //链接mongodb
   . _% ^# w5 l/ @3 P. q( C
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   3 L, l' R* b8 x" y+ m
5. 
   ) g9 J/ ^5 y4 z2 F
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   # ^' Z0 J2 M8 S4 J8 w  g. I5 E
8. $bulk->delete(['user_id'=>5]);//删除user_id为5的字段
   % n: d5 v/ O) v2 \2 o- z2 Z. g
9. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合
   
10. delete还可以通过limit设置不同删除方式
    , _: s, A5 y7 u" O* Y& |, {3 p* F
11. 
    
12. $bulk->delete(['user_id' => 1], ['limit' => 1]);   // limit 为 1 时，删除第一条匹配数据
    
13. $bulk->delete(['user_id' => 2], ['limit' => 0]);   // limit 为 0 时，删除所有匹配数据，默认删除所有

复制代码

* A( o" E: v) l. ], [$ Q
9 X7 @" c- M% C2 w9 N6 R3 A6：捕获异常

1. MongoDB\Driver\Exception\AuthenticationException
   ( E5 n7 r; \9 E
2. MongoDB\Driver\Exception\BulkWriteException
   - x5 f: c2 _# [9 h: u- m
3. MongoDB\Driver\Exception\ConnectionException
   
4. MongoDB\Driver\Exception\ConnectionTimeoutException
   " q  D9 N) [# e( k$ F, R9 T4 z
5. MongoDB\Driver\Exception\Exception //所有驱动程序异常的公共接口
   
6. MongoDB\Driver\Exception\ExecutionTimeoutException
   ' M# j. d: y! }, c% A! A
7. MongoDB\Driver\Exception\InvalidArgumentException
   
8. MongoDB\Driver\Exception\LogicException
   - U& I6 @& P4 Q$ d, Z: V
9. MongoDB\Driver\Exception\RuntimeException
   
10. MongoDB\Driver\Exception\SSLConnectionException
    / S, ^3 ], R9 z4 K+ v
11. MongoDB\Driver\Exception\UnexpectedValueException
    - e. D3 O: g: l6 W: `
12. MongoDB\Driver\Exception\WriteException

复制代码

7 Z/ l- A. C. S# Q- Q
% w0 {9 }1 A5 n8 a- F( O

游客，如果您要查看本帖隐藏内容请回复

, t; t% D: ~5 n* W! K/ N+ ^' B点击查看全部
- I( O9 \- m* s5 k/ x) ?$ d
4 u) M. |7 N! l  U