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

; \3 C7 ?( K/ K. z& F/ \7 ?下面用PHP7新的API总结一下：

1 F1 A+ ?& h' v/ T, f一：CURD

1：链接

1. <?php
   6 d) V: Z  x' X7 U: v6 T
2. //链接mongodb
   / G. r) V" H' g) o
3. $manager = new MongoDB\Driver\Manager('mongodb://root:123@10.10.10.104:27017');
   
4. root 用户；123：密码；如果没有密码则不写

复制代码

0 O$ w: Q1 w& l0 I2：查询

5 t' w; x' p% N. R1 E; i& h

1. <?php
   6 ]4 O& \+ a, l. }5 f; ]
2. 
   
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   4 h# R6 U8 D4 V
5. 
   
6. //查询
   
7. $filter =  ['user_id'=>['$gt'=>0]]; //查询条件 user_id大于0
   
8. $options = [
   / g. ]& g' g9 L) O3 J
9.    'projection' => ['_id' => 0], //不输出_id字段
   8 S% G: n; t' r+ D, H9 ~, M) O
10.    'sort' => ['user_id'=>-1] //根据user_id字段排序 1是升序，-1是降序
    1 s2 O6 n  F" D3 a" G( J7 x
11. ];
    1 t6 R, o6 T4 [; g" h
12. $query = new MongoDB\Driver\Query($filter, $options); //查询请求
    
13. $list = $manager->executeQuery('location.box',$query); // 执行查询 location数据库下的box集合
    
14. 
    % E/ @/ d$ n' R8 c  B
15. 
    " u5 R, H: T8 ?& M
16. foreach ($list as $document) {
    
17.     print_r($document);
    0 E( Z/ V3 a5 G, I( [. B( `2 |
18. }

复制代码

查询更多条件使用方法，参考第二节mongodb基本命令，查询

7 w3 q# Y' q9 V0 g3：添加
" c% d! |5 i$ z; V
% T7 I4 L7 b  C

1. <?php
   
2. 
   
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   
5. 
   ' j$ k- i$ g$ W
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   - E+ r0 j/ d8 {: M; s0 J+ {( `
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'=>'中国人',]);
   
10. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

4：修改
' I* H; ]8 X" d

1. <?php
   
2. 
   
3. //链接mongodb
   
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 x8 i5 [# l* I" \! k
8. $bulk->update(
   1 m; P, ]: F, p( d4 Y& x, D( Z( M
9.         ['user_id' => 2],
   9 i+ a3 _. Y  x8 U& q
10.         ['$set'=>['real_name'=>'中国国']
    ; m1 D: A+ K5 j- j7 f. B
11. ]);
    + J! l, u0 {, i' |
12. //$set相当于mysql的 set，这里和mysql有两个不同的地方，
    
13. //1：字段不存在会添加一个字段;
    $ v+ G& d' o- D% f9 L
14. //2：mongodb默认如果条件不成立，新增加数据，相当于insert
    
15. 
    $ u" M# P) M- o5 E+ X
16. 
    
17. //如果条件不存在不新增加，可以通过设置upsert
    * r& C: ~5 l6 I3 J; e; t# K. d" D
18. //db.collectionName.update(query, obj, upsert, multi);
    . b9 w# T& p% d. b5 G5 O; j
19. 
    
20. $bulk->update(
    ( c# A( s# K1 A5 ~
21.         ['user_id' => 5],
    $ @7 s$ n% M; v. A' `
22.         [
    
23.                 '$set'=>['fff'=>'中国国']
    5 _" j9 [$ v/ o. k- H4 @, m
24.         ],
    5 y8 j- c/ r4 f$ j$ R# T5 M0 U
25.         ['multi' => true, 'upsert' => false]
    
26.         //multi为true,则满足条件的全部修改,默认为true，如果改为false，则只修改满足条件的第一条
    ) {9 R( F5 h" N  u+ E$ x  L
27.         //upsert为 treu：表示不存在就新增
    
28. );
      p. R- a, u6 x  u6 w$ D/ O0 }! h
29. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

* W4 C  p9 _7 D8 _& a* m1 K+ d
9 H: ?. U) m& x# v* f$ Kordered 设置
+ H  k. j3 F. V- }" c8 L
1：默认是ture，按照顺序执行插入更新数据，如果出错，停止执行后面的，mongo官方叫串行。
2：如果是false，mongo并发的方式插入更新数据，中间出现错误，不影响后续操作无影响，mongo官方叫并行

( @7 r9 Y' B- N6 p2 U3 w5：删除
. f4 X& C6 Y) Q6 I

1. <?php
   
2. 
   7 [( e8 x" u& A% ^' y
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   , @" M  D( T1 b& S
5. 
   
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   3 f! J" G3 R) K
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   % ?: s/ X3 V2 L3 W
8. $bulk->delete(['user_id'=>5]);//删除user_id为5的字段
   
9. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合
   
10. delete还可以通过limit设置不同删除方式
    
11. 
    ! P- o, ^# n  I' C! U+ d4 M
12. $bulk->delete(['user_id' => 1], ['limit' => 1]);   // limit 为 1 时，删除第一条匹配数据
    5 j/ u* ?8 ]- E$ O2 @
13. $bulk->delete(['user_id' => 2], ['limit' => 0]);   // limit 为 0 时，删除所有匹配数据，默认删除所有

复制代码

" B7 v+ y  M2 }' t* ?& F( y. r6：捕获异常

1. MongoDB\Driver\Exception\AuthenticationException
   / Z, j- ^( L! G+ K% V7 W4 K; c: F
2. MongoDB\Driver\Exception\BulkWriteException
   
3. MongoDB\Driver\Exception\ConnectionException
     [7 r3 J  W2 M# K, c$ c- V
4. MongoDB\Driver\Exception\ConnectionTimeoutException
   
5. MongoDB\Driver\Exception\Exception //所有驱动程序异常的公共接口
   ( N( E4 x5 B/ Y  r% \
6. MongoDB\Driver\Exception\ExecutionTimeoutException
   
7. MongoDB\Driver\Exception\InvalidArgumentException
   
8. MongoDB\Driver\Exception\LogicException
   
9. MongoDB\Driver\Exception\RuntimeException
   * E. K7 g5 x6 r# g; K% f8 S, i1 E. R) S
10. MongoDB\Driver\Exception\SSLConnectionException
    
11. MongoDB\Driver\Exception\UnexpectedValueException
    
12. MongoDB\Driver\Exception\WriteException

复制代码

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

点击查看全部
2 Z+ E; }7 s$ ~6 _( I; {+ d
0 r: t( K  M( G2 F0 y( b3 q