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

4 ^! t1 i& M  G% \8 `- t! s/ ?下面用PHP7新的API总结一下：

一：CURD

/ Z% }( i" y- y5 T3 i1 m1：链接
5 Z' i* {6 g3 }/ Q' A
4 F$ j: O% X7 \, `

1. <?php
   ) T( Y% ]- S% S# C$ E
2. //链接mongodb
     v+ X2 G) W7 `; I; Q* h: l' C
3. $manager = new MongoDB\Driver\Manager('mongodb://root:123@10.10.10.104:27017');
   
4. root 用户；123：密码；如果没有密码则不写

复制代码

! ~, O# }' T+ ]( r& K
2：查询
  h9 Q+ \: r! t) z& A

1. <?php
   
2. 
   
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   
5. 
   ' C7 C5 a2 q4 Y# R7 g
6. //查询
   
7. $filter =  ['user_id'=>['$gt'=>0]]; //查询条件 user_id大于0
   
8. $options = [
   . B( l" n! _# Y" a' W: y
9.    'projection' => ['_id' => 0], //不输出_id字段
   4 U5 [0 c4 `, {8 [
10.    'sort' => ['user_id'=>-1] //根据user_id字段排序 1是升序，-1是降序
    
11. ];
    ) R! p! x- F8 M4 ^, t! X
12. $query = new MongoDB\Driver\Query($filter, $options); //查询请求
    8 K* H% @7 H5 I4 z; L6 G$ U
13. $list = $manager->executeQuery('location.box',$query); // 执行查询 location数据库下的box集合
    
14. 
    2 [, W8 t; q/ R' Y8 _
15. 
    $ N" b& Z; _3 @6 z( \1 p
16. foreach ($list as $document) {
    
17.     print_r($document);
    ! G. p  q) w  M3 s
18. }

复制代码

1 x3 U+ P' a6 q: j; O* `查询更多条件使用方法，参考第二节mongodb基本命令，查询

$ v3 D- _5 n# s. g$ z5 ~: p3：添加
0 y# ~: }' A# }9 ?# V
7 I2 m! r8 j1 N9 j0 x- n

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，并行执行
   
8. $bulk->insert(['user_id' => 2, 'real_name'=>'中国',]);
   ; Y: P+ x, ^2 I5 Q3 A4 d
9. $bulk->insert(['user_id' => 3, 'real_name'=>'中国人',]);
   
10. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

0 I1 v: v/ i0 N4：修改
) K' A0 V+ o# u- P8 h0 K9 ^

1. <?php
   6 y8 @6 A  c0 z) W% G# R9 O8 u
2. 
   # O' |/ e5 i5 |7 b) N
3. //链接mongodb
   ! E. W6 j" }3 a" a$ U, ?/ G* p
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
     [8 x- r6 \3 c4 B
5. 
   : ~8 U8 ~$ z4 s! l9 ]# B# z
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   1 ~* F: m# \; c. n& ?" G
8. $bulk->update(
   * e4 L. |. V+ ~4 V: P5 W
9.         ['user_id' => 2],
   
10.         ['$set'=>['real_name'=>'中国国']
    
11. ]);
    9 Q# l% ?, X/ N
12. //$set相当于mysql的 set，这里和mysql有两个不同的地方，
    7 t- W+ N6 E) V+ b8 P+ v! a1 `
13. //1：字段不存在会添加一个字段;
    
14. //2：mongodb默认如果条件不成立，新增加数据，相当于insert
    
15. 
    ) E+ G  l" g% f' [$ }0 U9 R
16. 
    
17. //如果条件不存在不新增加，可以通过设置upsert
    
18. //db.collectionName.update(query, obj, upsert, multi);
    3 w& \" {0 y/ q; A4 }2 G
19. 
    ; Y$ l1 g8 z9 I$ A6 I9 ?; `9 y5 u
20. $bulk->update(
    
21.         ['user_id' => 5],
    
22.         [
    
23.                 '$set'=>['fff'=>'中国国']
    
24.         ],
    ) `6 E9 m5 M: u/ v% `
25.         ['multi' => true, 'upsert' => false]
    
26.         //multi为true,则满足条件的全部修改,默认为true，如果改为false，则只修改满足条件的第一条
    . n+ S" a4 d5 P; b; M. [2 v
27.         //upsert为 treu：表示不存在就新增
    1 r6 _: S! {5 y; {/ e
28. );
    
29. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

* c* ?! h) n. {) }
) s# {7 u! b7 }ordered 设置

1：默认是ture，按照顺序执行插入更新数据，如果出错，停止执行后面的，mongo官方叫串行。
2：如果是false，mongo并发的方式插入更新数据，中间出现错误，不影响后续操作无影响，mongo官方叫并行

5：删除
& S( Q" T0 U  w5 J( ?7 {( y, M8 j+ a
' y5 h# H" `0 d

1. <?php
   
2. 
   + g! S, A" ]+ V& c: L( K
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   * y: E7 I! k. @1 P
5. 
   ) }# y, P: p3 z7 l4 h1 t2 r
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   
8. $bulk->delete(['user_id'=>5]);//删除user_id为5的字段
   ) ^( K" U; h6 ^" X' j1 X
9. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合
   / _, O- i; \: c( C3 J
10. delete还可以通过limit设置不同删除方式
    % \: s' A) G8 }; _1 Z
11. 
    
12. $bulk->delete(['user_id' => 1], ['limit' => 1]);   // limit 为 1 时，删除第一条匹配数据
    
13. $bulk->delete(['user_id' => 2], ['limit' => 0]);   // limit 为 0 时，删除所有匹配数据，默认删除所有

复制代码

: {9 l9 x3 B# \  }1 D' C; n
6：捕获异常

5 K2 j+ P. W3 g' W6 H

1. MongoDB\Driver\Exception\AuthenticationException
   0 f1 ^1 o% y% V2 }5 P4 p' r
2. MongoDB\Driver\Exception\BulkWriteException
   ! q; p% ~8 `3 A- M; \
3. MongoDB\Driver\Exception\ConnectionException
   
4. MongoDB\Driver\Exception\ConnectionTimeoutException
   
5. MongoDB\Driver\Exception\Exception //所有驱动程序异常的公共接口
   % u' A2 _# c2 }- C$ r+ o5 S& w/ `) a
6. MongoDB\Driver\Exception\ExecutionTimeoutException
   6 k! \8 l1 F. W5 C
7. MongoDB\Driver\Exception\InvalidArgumentException
   
8. MongoDB\Driver\Exception\LogicException
     _- N6 C, T+ R, C
9. MongoDB\Driver\Exception\RuntimeException
   
10. MongoDB\Driver\Exception\SSLConnectionException
    , {5 p$ o7 v  Q' Q  \  d+ H
11. MongoDB\Driver\Exception\UnexpectedValueException
    
12. MongoDB\Driver\Exception\WriteException

复制代码

& H0 q, m7 \$ m9 d

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

点击查看全部
+ X3 @2 ]# h! @. f
; t7 X5 R0 L9 h' |* M- ], G6 l& }
/ c; W6 h5 G9 @  H