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

( X' T3 q! G# j! |下面用PHP7新的API总结一下：
+ b$ ~# I/ b! Q1 b/ n6 |% l
. j" I, y0 o8 _6 d4 M2 X一：CURD
9 k" F4 h; O2 Y  Z7 @' b2 b) r
% F; y0 N0 @2 _2 u# |( g' l+ `1：链接

3 ^# C  h; A6 x4 g

1. <?php
   # ?( Z3 K  S8 B& {/ W6 f
2. //链接mongodb
   / L! f6 F$ y) K
3. $manager = new MongoDB\Driver\Manager('mongodb://root:123@10.10.10.104:27017');
   
4. root 用户；123：密码；如果没有密码则不写

复制代码

: A; G! o7 w8 J* w1 w* q4 ?1 U
, U" H1 ^: x3 F* h8 u/ l/ E2：查询
6 A$ L# W0 t3 [2 \7 L4 C" ]- h

1. <?php
   
2. 
   " l3 R# X7 s* }! s2 w* b
3. //链接mongodb
     C# x% F, N# o! z
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   2 J8 P" ]- I1 k2 `. X  K4 i9 h+ C; s
5. 
   
6. //查询
   ' N, m( Y! K; G7 ?4 A/ s% z8 r
7. $filter =  ['user_id'=>['$gt'=>0]]; //查询条件 user_id大于0
   
8. $options = [
   9 Z: F$ a+ J6 v) @8 ?
9.    'projection' => ['_id' => 0], //不输出_id字段
   0 M, Z) K+ x$ k! D
10.    'sort' => ['user_id'=>-1] //根据user_id字段排序 1是升序，-1是降序
    
11. ];
    : r) j: Z% ]) _, D" e0 R0 `5 m# i
12. $query = new MongoDB\Driver\Query($filter, $options); //查询请求
    - ~+ w+ f% Y' }' L& W$ A
13. $list = $manager->executeQuery('location.box',$query); // 执行查询 location数据库下的box集合
    
14. 
      M' P$ \* b. P2 N6 P5 L
15. 
    & o7 S. L7 @. D5 W0 V6 F
16. foreach ($list as $document) {
    
17.     print_r($document);
    $ A8 c3 x4 d, c" t" f- x
18. }

复制代码

" D2 u- ^8 v6 z% Z6 H% h" W查询更多条件使用方法，参考第二节mongodb基本命令，查询

3：添加
$ W2 @2 t( J" K0 z) R( s

1. <?php
   
2. 
   
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   + \+ h0 T2 [, J6 t; R5 P: A
5. 
   
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   ' [: Y' D. m' @9 D% ]& _
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   
8. $bulk->insert(['user_id' => 2, 'real_name'=>'中国',]);
   
9. $bulk->insert(['user_id' => 3, 'real_name'=>'中国人',]);
   " z- L9 S- j0 w) X
10. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

4：修改
  b2 q. K% u3 q; O" D, p0 o8 n
! k- b( A3 ^5 x9 I/ ?5 D& |6 e

1. <?php
   , V  ]+ L8 |/ g
2. 
   
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   
5. 
   ( A6 C, V  O! H$ X9 E+ E
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
     [+ t( d) p4 t  ]) ]3 ]& K: v4 [
8. $bulk->update(
   & C, `5 S- D* O2 F8 R. R7 a1 F
9.         ['user_id' => 2],
   . P; S2 |! S: k1 n7 Q/ k
10.         ['$set'=>['real_name'=>'中国国']
    
11. ]);
    
12. //$set相当于mysql的 set，这里和mysql有两个不同的地方，
    % g1 V8 N$ Y% M  a1 S/ \
13. //1：字段不存在会添加一个字段;
    
14. //2：mongodb默认如果条件不成立，新增加数据，相当于insert
    + C( _, t3 O$ [- z; y( z9 B
15. 
    
16. 
    , k8 a# {1 g( x# G* T5 z
17. //如果条件不存在不新增加，可以通过设置upsert
    
18. //db.collectionName.update(query, obj, upsert, multi);
    
19. 
    
20. $bulk->update(
    
21.         ['user_id' => 5],
    * m; D$ f6 }4 ?2 C/ @- Q6 R
22.         [
    $ u# G  `" E6 U) |
23.                 '$set'=>['fff'=>'中国国']
    " m' u2 ?3 f) c; M! t4 W
24.         ],
    0 T, q: P4 A& p; \( n+ M5 m/ X
25.         ['multi' => true, 'upsert' => false]
    7 ?9 A2 g" @* V, S- D
26.         //multi为true,则满足条件的全部修改,默认为true，如果改为false，则只修改满足条件的第一条
    7 i& h  `# G# Z# }+ R4 V: @
27.         //upsert为 treu：表示不存在就新增
    ) C5 V, c/ R+ w5 O8 I
28. );
    
29. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

. w- y- C: V1 f! N6 p0 |; i
! B4 n' G/ C0 X/ x8 a# Y  gordered 设置

- Y; k6 a9 P* _' Q3 z2 j7 A8 |2 ~1：默认是ture，按照顺序执行插入更新数据，如果出错，停止执行后面的，mongo官方叫串行。
2：如果是false，mongo并发的方式插入更新数据，中间出现错误，不影响后续操作无影响，mongo官方叫并行

5：删除

1. <?php
   3 p& ~; i# x7 m1 ]. t! U; d. r) j
2. 
   
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   
5. 
   0 T( m+ C' r1 R0 f/ S
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   7 R! A% T& s% J+ K0 b2 v# A
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   
8. $bulk->delete(['user_id'=>5]);//删除user_id为5的字段
   0 N6 e0 B5 j: i4 U; K* P
9. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合
   
10. delete还可以通过limit设置不同删除方式
    2 d4 S, b! w( ~/ u; |8 q/ f" X) E
11. 
    
12. $bulk->delete(['user_id' => 1], ['limit' => 1]);   // limit 为 1 时，删除第一条匹配数据
    ' h* N) A* M! O
13. $bulk->delete(['user_id' => 2], ['limit' => 0]);   // limit 为 0 时，删除所有匹配数据，默认删除所有

复制代码

( W2 w; G* B* X' L: C  [
7 ]7 O8 S( q! A, e4 A. i7 G6：捕获异常

1. MongoDB\Driver\Exception\AuthenticationException
   & G( K( `5 h/ }( F7 b3 K/ W
2. MongoDB\Driver\Exception\BulkWriteException
   
3. MongoDB\Driver\Exception\ConnectionException
   
4. MongoDB\Driver\Exception\ConnectionTimeoutException
   
5. MongoDB\Driver\Exception\Exception //所有驱动程序异常的公共接口
   
6. MongoDB\Driver\Exception\ExecutionTimeoutException
   
7. MongoDB\Driver\Exception\InvalidArgumentException
   ; t  g0 @8 A" S+ z/ a" o; o: a: j
8. MongoDB\Driver\Exception\LogicException
   + i( E( N  G+ n' N0 r4 n/ c3 P
9. MongoDB\Driver\Exception\RuntimeException
   ( A  ~4 a5 y8 s
10. MongoDB\Driver\Exception\SSLConnectionException
    / V8 q( r$ [$ G  \# K
11. MongoDB\Driver\Exception\UnexpectedValueException
    0 y5 x  a" @  R- {
12. MongoDB\Driver\Exception\WriteException

复制代码

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

& J$ O7 s" v- w+ I点击查看全部