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不支持以前的写法。
# _' m+ @6 H# ^: y4 M  P+ Y
下面用PHP7新的API总结一下：

一：CURD

0 R- c4 I0 _5 Z0 O1：链接

9 f' M( S  _' H6 }1 E+ a

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

复制代码

2：查询
" t8 D! F* Y+ V! q/ V; e1 v

1. <?php
   
2. 
   ) Q* W9 ?  X' ~
3. //链接mongodb
   ( V" i- k- K: ?4 H
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   ' h, p$ T! r  p4 T
5. 
   
6. //查询
   ( [5 g5 z; m. |! C
7. $filter =  ['user_id'=>['$gt'=>0]]; //查询条件 user_id大于0
   9 i6 b+ J$ X2 _; O
8. $options = [
   
9.    'projection' => ['_id' => 0], //不输出_id字段
   8 W9 f3 H* G" m1 M$ [, m
10.    'sort' => ['user_id'=>-1] //根据user_id字段排序 1是升序，-1是降序
    0 z' |4 B0 T( R  Y/ \
11. ];
    
12. $query = new MongoDB\Driver\Query($filter, $options); //查询请求
    % T  f4 u9 w, ^7 z; _0 Y: Y9 w7 ]9 _
13. $list = $manager->executeQuery('location.box',$query); // 执行查询 location数据库下的box集合
    : R7 ~* t7 K7 S) t0 \  Y
14. 
      A/ ?& c$ o& q' A% F7 _& K
15. 
    
16. foreach ($list as $document) {
    9 d+ y# w. Q+ X8 D1 O% G* s# \0 K
17.     print_r($document);
    ' I; M6 e' p! Y& e, o/ C
18. }

复制代码

% Y0 e& [' H/ a. O2 m0 u查询更多条件使用方法，参考第二节mongodb基本命令，查询
6 q& p  Z- w9 g0 h2 i
7 y' ]$ J1 J0 ~% U1 g% E3：添加

0 q) J  k6 ^) ^: r6 X: H/ a8 o( y

1. <?php
   
2. 
   ! b: c; R! d/ Q0 ^% F* [8 [; }* T
3. //链接mongodb
   : A% C! T8 A' V" f( Q, `2 b
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   1 |# |! R% j( _: T
5. 
   0 ^: Q& g! W  g* z" J
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   5 ~# Z" i/ U( M, _& K6 m7 s
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集合

复制代码

+ b( V9 n" S$ ^( O6 `# E4 J4：修改

2 P+ j; `5 N# c# Q- `

1. <?php
   
2. 
   2 l. @; M" I8 R6 _5 V9 d0 ?6 w/ i, w' P9 ~
3. //链接mongodb
   9 _0 W$ X9 N0 j# e# u
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   1 J. T  f4 p' o# I7 w5 r
5. 
   # ^+ d' J& x8 m7 H  {
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   ; ?4 o1 f" w2 B6 b' B$ a/ S1 N
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   ) Y, S5 D% e# Q# D, K5 Z. R# W
8. $bulk->update(
   
9.         ['user_id' => 2],
     U) c% e! ^7 @7 W+ h1 g/ N
10.         ['$set'=>['real_name'=>'中国国']
    
11. ]);
    6 c& J- s- N: v. B3 Z
12. //$set相当于mysql的 set，这里和mysql有两个不同的地方，
    $ x' Q% x: w7 Q7 j& w
13. //1：字段不存在会添加一个字段;
    
14. //2：mongodb默认如果条件不成立，新增加数据，相当于insert
      H9 _# m, X# j" p+ r
15. 
    1 z& `9 o& R1 T! K6 E% u
16. 
    ' w7 K6 m" m: Z0 x, Z& K. T
17. //如果条件不存在不新增加，可以通过设置upsert
    
18. //db.collectionName.update(query, obj, upsert, multi);
    
19. 
    4 G4 _5 W/ \/ D6 ]2 v
20. $bulk->update(
    
21.         ['user_id' => 5],
    0 d4 ^6 f; K; G- l1 {
22.         [
    
23.                 '$set'=>['fff'=>'中国国']
    
24.         ],
    
25.         ['multi' => true, 'upsert' => false]
    7 M# j" ~; d- y% v  U
26.         //multi为true,则满足条件的全部修改,默认为true，如果改为false，则只修改满足条件的第一条
    
27.         //upsert为 treu：表示不存在就新增
    $ r' D/ F- G2 ]% q* p2 h
28. );
    $ [" n5 p' C' l5 d. z
29. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

ordered 设置

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

- x$ d3 o" c' M: l7 @2 T5：删除
; v. y; t, |) ], g) `- q  y- \0 _3 b7 f

1. <?php
   ; L2 j7 Q- r) W# j8 s0 ?
2. 
   
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   8 Y( S" a, ]! H* j3 f
5. 
   
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   ' P7 Z& F" }1 a, y* M- S4 Z
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   , Q: m9 ?7 O* _2 A4 _/ ~
8. $bulk->delete(['user_id'=>5]);//删除user_id为5的字段
   8 O  `5 M) w! I
9. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合
   
10. delete还可以通过limit设置不同删除方式
    
11. 
    
12. $bulk->delete(['user_id' => 1], ['limit' => 1]);   // limit 为 1 时，删除第一条匹配数据
    
13. $bulk->delete(['user_id' => 2], ['limit' => 0]);   // limit 为 0 时，删除所有匹配数据，默认删除所有

复制代码

. a/ _. X4 {, W9 {0 Y5 u6：捕获异常
  N; R# m( ]1 _" W/ }, t/ Z

1. MongoDB\Driver\Exception\AuthenticationException
   ! Z" c7 i2 y* k& x9 C, ]
2. MongoDB\Driver\Exception\BulkWriteException
   
3. MongoDB\Driver\Exception\ConnectionException
   & t$ C+ G& D  _: L/ [! l' {* n) J
4. MongoDB\Driver\Exception\ConnectionTimeoutException
   9 Z  X. p! s; O% O7 j
5. MongoDB\Driver\Exception\Exception //所有驱动程序异常的公共接口
   3 K8 ~! a' n! L0 W
6. MongoDB\Driver\Exception\ExecutionTimeoutException
   
7. MongoDB\Driver\Exception\InvalidArgumentException
   
8. MongoDB\Driver\Exception\LogicException
   
9. MongoDB\Driver\Exception\RuntimeException
   , w- _' Y# E$ h
10. MongoDB\Driver\Exception\SSLConnectionException
    ( E/ {8 U; t; D! ?7 z
11. MongoDB\Driver\Exception\UnexpectedValueException
    
12. MongoDB\Driver\Exception\WriteException

复制代码

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

点击查看全部
% F) g" g) U  L( I, |) q9 I
+ J* L# M$ Y+ y# C1 Q
* h# B$ u  X1 N8 @8 u$ E