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不支持以前的写法。
% t9 [" x1 o( H
下面用PHP7新的API总结一下：
/ E. A3 r! a" _0 {; P# j
$ S/ y7 W  B$ s0 ~一：CURD
+ t2 V9 p: L# }6 {4 X5 {& Q
6 u: i1 \; a7 T- C1：链接
* E. d4 O! f8 N: V5 E9 `* T

1. <?php
   
2. //链接mongodb
   - V6 B1 }" i9 X
3. $manager = new MongoDB\Driver\Manager('mongodb://root:123@10.10.10.104:27017');
   
4. root 用户；123：密码；如果没有密码则不写

复制代码

0 F7 W. Z% u+ I3 Y4 q
2：查询

) I, G! V$ m- z+ k) [

1. <?php
   ; F9 D+ c. R. G6 a# v
2. 
   
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   & a5 o( K  M5 `8 l! q; `4 |
5. 
   & e. x1 J+ a9 \. U. R; T7 a
6. //查询
   
7. $filter =  ['user_id'=>['$gt'=>0]]; //查询条件 user_id大于0
   : c* {6 H# U  E0 O7 Q
8. $options = [
   2 s$ U" ~" G5 F6 p, Z* x3 ~
9.    'projection' => ['_id' => 0], //不输出_id字段
   * ~6 n. r1 e  M+ P+ q
10.    'sort' => ['user_id'=>-1] //根据user_id字段排序 1是升序，-1是降序
    
11. ];
    
12. $query = new MongoDB\Driver\Query($filter, $options); //查询请求
    
13. $list = $manager->executeQuery('location.box',$query); // 执行查询 location数据库下的box集合
    / \' b, t4 K) G4 ~7 Z+ t: [! Y0 t
14. 
    
15. 
    
16. foreach ($list as $document) {
    % J( p& Y% d0 _; s
17.     print_r($document);
    $ i8 ~- a7 S: l! \9 h
18. }

复制代码

) K% F; W& m% z- x% J查询更多条件使用方法，参考第二节mongodb基本命令，查询
7 U. k0 G/ f6 W9 n( T2 F" k- C0 X
" r8 C# k! t5 J1 q- O3：添加

) T* M: ]) Z8 d, G) u

1. <?php
   2 `  V) Q3 {3 A: t* J4 B
2. 
   * j( N; b0 ?, N) V* P0 J3 _7 s9 X
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   $ e# _/ a6 H4 y1 `$ S  I0 e$ `
5. 
   
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
     i! b6 `5 q" p+ I/ F7 F/ d( c0 L
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'=>'中国人',]);
   , A4 R2 [8 H% c) E
10. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

! f. Z7 b9 B0 j/ n4：修改

0 Y+ u5 b' }. S5 G1 e. U! C

1. <?php
   
2. 
   
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   % K+ T- A. q/ q, ?0 b
5. 
   
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   . A$ I5 F# D4 s2 G- Z- d9 }4 x
8. $bulk->update(
   9 G  `; u" e: i
9.         ['user_id' => 2],
   
10.         ['$set'=>['real_name'=>'中国国']
    6 x. [+ p+ R7 J& K2 G! X4 ]- P
11. ]);
    
12. //$set相当于mysql的 set，这里和mysql有两个不同的地方，
    
13. //1：字段不存在会添加一个字段;
    3 B, i6 W) ]0 q* ^8 h, ^7 `
14. //2：mongodb默认如果条件不成立，新增加数据，相当于insert
    ' ]8 T/ ^2 T, y% |( y# X. u/ S
15. 
      |# h# t8 b! z) c: X
16. 
    3 F" t) _) `& X4 u7 K% I
17. //如果条件不存在不新增加，可以通过设置upsert
    ) f7 Z& {8 d) a1 b' o; {
18. //db.collectionName.update(query, obj, upsert, multi);
    / j5 p$ f, Y  I
19. 
    
20. $bulk->update(
    
21.         ['user_id' => 5],
    ) S/ k( |' b/ J6 c+ e
22.         [
    
23.                 '$set'=>['fff'=>'中国国']
    # ]9 T. ^0 m) Q. j# h' u" m' N
24.         ],
    
25.         ['multi' => true, 'upsert' => false]
    ) o1 y1 @- o$ T
26.         //multi为true,则满足条件的全部修改,默认为true，如果改为false，则只修改满足条件的第一条
    ) Q7 O- Z$ \, e& @
27.         //upsert为 treu：表示不存在就新增
    
28. );
    9 ~* X5 [6 \3 x0 H5 c
29. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

1 j7 k' f% t9 r2 @ordered 设置
7 M2 S2 Z  R- R% {, d; z
1：默认是ture，按照顺序执行插入更新数据，如果出错，停止执行后面的，mongo官方叫串行。
2：如果是false，mongo并发的方式插入更新数据，中间出现错误，不影响后续操作无影响，mongo官方叫并行
$ G" b2 I0 E7 X4 ?+ b& l2 }
4 H; ~* z3 ^* S4 J- I( T5：删除

$ X3 W9 E* S3 f( Y' c

1. <?php
   
2. 
   
3. //链接mongodb
   7 ~1 r8 Q* s* J/ a1 p' c5 L# @
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   
5. 
   
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   0 w; T# v7 `* u8 x' |  p! A
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   
8. $bulk->delete(['user_id'=>5]);//删除user_id为5的字段
   " k# R( L6 H1 A: A! w
9. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合
   
10. delete还可以通过limit设置不同删除方式
    
11. 
    
12. $bulk->delete(['user_id' => 1], ['limit' => 1]);   // limit 为 1 时，删除第一条匹配数据
    : h  l( a  U6 D( K* T/ j
13. $bulk->delete(['user_id' => 2], ['limit' => 0]);   // limit 为 0 时，删除所有匹配数据，默认删除所有

复制代码

6：捕获异常

! J- G5 o! b% ~8 s& r/ |

1. MongoDB\Driver\Exception\AuthenticationException
   
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
   9 @8 {$ ?  Z, s  j, j$ c6 ~* {
7. MongoDB\Driver\Exception\InvalidArgumentException
   9 K1 L! z. i  q5 P
8. MongoDB\Driver\Exception\LogicException
   
9. MongoDB\Driver\Exception\RuntimeException
   
10. MongoDB\Driver\Exception\SSLConnectionException
    + i- N- X  g4 }" M
11. MongoDB\Driver\Exception\UnexpectedValueException
    ; I' C  @7 @7 M& w( _* O$ w/ Q
12. MongoDB\Driver\Exception\WriteException

复制代码

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

点击查看全部