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总结一下：
, `; H3 o  |* V, }
一：CURD
3 z& m( u! e( \
1：链接
2 P$ @" ^2 M5 T/ f* D% \

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

复制代码

& C$ g5 D$ C6 d
2：查询
! }( |- |; g7 ?2 W/ v
. r1 ~4 c; t( D' [2 R

1. <?php
   ) s; j6 a) a: |" c; g  y4 j: z0 D
2. 
   
3. //链接mongodb
     K, v& a- l/ R7 q
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   
5. 
   
6. //查询
   # n3 F+ z3 d; E$ ~1 _( n( r( i! p
7. $filter =  ['user_id'=>['$gt'=>0]]; //查询条件 user_id大于0
   $ K# [, Y& M+ S5 C# F) R. Z1 B& i
8. $options = [
   4 O( p) D# `# N6 D
9.    'projection' => ['_id' => 0], //不输出_id字段
     T( ~. j) n* A* @, f
10.    'sort' => ['user_id'=>-1] //根据user_id字段排序 1是升序，-1是降序
    6 A4 R9 p6 U/ E1 ^3 c8 L) U
11. ];
    $ a* L3 r4 ^2 Q: F
12. $query = new MongoDB\Driver\Query($filter, $options); //查询请求
    ! x7 V% G& D  p3 r5 G
13. $list = $manager->executeQuery('location.box',$query); // 执行查询 location数据库下的box集合
    # F/ x/ N# v9 V$ ]6 L
14. 
    ; c" E, a( j0 m1 \6 n6 D3 P1 D
15. 
    
16. foreach ($list as $document) {
    
17.     print_r($document);
    
18. }

复制代码

. g9 V/ L  J9 K9 V查询更多条件使用方法，参考第二节mongodb基本命令，查询

0 }. v6 T; {2 T3：添加

) |  k8 F, _) h, x# A% \

1. <?php
   
2. 
   
3. //链接mongodb
   ( i6 t* P# R/ ?3 a: \  W/ B
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   
5. 
   % @" W  _+ W' W2 J1 V
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   ( @- w% M; j$ ?0 X& \
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   9 Q  Z' [; J1 `7 H% a5 t
8. $bulk->insert(['user_id' => 2, 'real_name'=>'中国',]);
   ) q! m: u5 l% e( h1 d
9. $bulk->insert(['user_id' => 3, 'real_name'=>'中国人',]);
   
10. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

4：修改
) m# y$ w" u3 @1 T" q4 u; X
& r  h- R0 b5 g" r; r

1. <?php
   
2. 
   % B2 T2 W4 n2 K- K
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   
5. 
   + P7 _* n, L8 ~  n# C! ]. z# i" {$ U
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   , o% o0 q4 i# p
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   2 x  H) H7 |+ A! ?3 r* K' p! g
8. $bulk->update(
   " N7 C4 K* U1 \0 e1 {
9.         ['user_id' => 2],
   
10.         ['$set'=>['real_name'=>'中国国']
    / q  o7 y+ J* C  d2 I
11. ]);
    ) ~) q+ n. X. X6 a! @) |
12. //$set相当于mysql的 set，这里和mysql有两个不同的地方，
    4 R+ Q' R7 G+ O% \9 a
13. //1：字段不存在会添加一个字段;
    , X- Z* x" }" Y5 r" x9 j7 b1 a. x
14. //2：mongodb默认如果条件不成立，新增加数据，相当于insert
    ; {; q5 u8 f- J! l# L
15. 
    
16. 
    ' C6 o% j* ~, ^% _# U
17. //如果条件不存在不新增加，可以通过设置upsert
    
18. //db.collectionName.update(query, obj, upsert, multi);
    
19. 
    - R& f* K5 u" I) y1 |6 w: L
20. $bulk->update(
    
21.         ['user_id' => 5],
    9 V. A. h# _" X$ [& P  w
22.         [
    
23.                 '$set'=>['fff'=>'中国国']
    # z) b% e6 V" W3 T; i1 K! `
24.         ],
    
25.         ['multi' => true, 'upsert' => false]
    # q6 P1 P# w6 @, R, W  P
26.         //multi为true,则满足条件的全部修改,默认为true，如果改为false，则只修改满足条件的第一条
    3 S( o0 q7 l) o
27.         //upsert为 treu：表示不存在就新增
    
28. );
    
29. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

0 \3 V4 D, k# k$ o3 aordered 设置
! ]1 l4 j: [1 W" J
1：默认是ture，按照顺序执行插入更新数据，如果出错，停止执行后面的，mongo官方叫串行。
  _* R" T1 Q7 h8 b. `2：如果是false，mongo并发的方式插入更新数据，中间出现错误，不影响后续操作无影响，mongo官方叫并行
' ]4 D7 e5 T1 i' b8 i
7 M7 O2 X2 E- N' u& |5：删除

1. <?php
   
2. 
   
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   
5. 
   9 g5 y* \- @- ~
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   % B- y0 N8 _, ]' Y3 y! j$ }' a
8. $bulk->delete(['user_id'=>5]);//删除user_id为5的字段
   % c5 m8 t- Z; \3 M) }1 k
9. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合
   % v( K& P2 q" q  f) i; a5 K
10. delete还可以通过limit设置不同删除方式
    ( Y7 d3 c3 t# O7 `, x# p- `! a4 J
11. 
    ) n( ?7 F; q3 D$ w0 ?
12. $bulk->delete(['user_id' => 1], ['limit' => 1]);   // limit 为 1 时，删除第一条匹配数据
    # z$ ~2 j% S) g3 \
13. $bulk->delete(['user_id' => 2], ['limit' => 0]);   // limit 为 0 时，删除所有匹配数据，默认删除所有

复制代码

8 k# R# O. b! N5 u9 q6：捕获异常
0 g4 q+ P) r  C9 n
8 W- Q/ Q7 h# q/ C8 O

1. MongoDB\Driver\Exception\AuthenticationException
   ) z9 N: A1 T) b6 i; V* d
2. MongoDB\Driver\Exception\BulkWriteException
   7 D6 p6 I) B" M6 D, d( }
3. MongoDB\Driver\Exception\ConnectionException
   & Y3 d# i, F( N; u, q2 e" J
4. MongoDB\Driver\Exception\ConnectionTimeoutException
   
5. MongoDB\Driver\Exception\Exception //所有驱动程序异常的公共接口
   ' s* B) e6 y) }" Y& W' V
6. MongoDB\Driver\Exception\ExecutionTimeoutException
   
7. MongoDB\Driver\Exception\InvalidArgumentException
   
8. MongoDB\Driver\Exception\LogicException
   , n1 p6 w& y" q( t6 f' x6 E4 ]9 R
9. MongoDB\Driver\Exception\RuntimeException
   + w& I  |; e( e! j$ Y
10. MongoDB\Driver\Exception\SSLConnectionException
    " N+ P6 N4 Z% L+ v  d0 \: L
11. MongoDB\Driver\Exception\UnexpectedValueException
    
12. MongoDB\Driver\Exception\WriteException

复制代码

5 M2 @* N! s% v3 ~0 J- Z
: h5 V2 m. O0 D( z" _7 V: [1 A

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

点击查看全部
9 c6 [5 \5 y: {3 _
3 C2 c' Y: ~! x' l# i