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

9 G9 U5 ^! s. d9 S; {: b1 V* p  ^1 w下面用PHP7新的API总结一下：

一：CURD
, b* J; J& R) u" _' L# i" D2 w
1：链接
  s' }/ \7 z# e  d; v" _" @8 J

1. <?php
   - j$ L( S4 u) D4 }. M: ]
2. //链接mongodb
   3 E9 _+ k" G' |0 x: e$ G
3. $manager = new MongoDB\Driver\Manager('mongodb://root:123@10.10.10.104:27017');
   4 T* q5 a( v' M8 b' @: i
4. root 用户；123：密码；如果没有密码则不写

复制代码

) U9 a# h( s0 [/ M( R+ E$ T
* e' }) M' A% t. p9 k2：查询
! z' L3 s4 W$ L; [! [: P

1. <?php
   : ~5 g, K- E! ?1 A. y
2. 
   7 Q; ^0 D& J9 c4 O0 K
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   
5. 
   & O+ Q; ]8 b& b9 D8 f& f; I
6. //查询
   # s2 d; l! `- c
7. $filter =  ['user_id'=>['$gt'=>0]]; //查询条件 user_id大于0
   
8. $options = [
   
9.    'projection' => ['_id' => 0], //不输出_id字段
   
10.    'sort' => ['user_id'=>-1] //根据user_id字段排序 1是升序，-1是降序
    
11. ];
    ) O! o. W  J: ]4 M/ L! x. w: C8 _
12. $query = new MongoDB\Driver\Query($filter, $options); //查询请求
    : b' @3 |6 U$ L; x; b1 j; p
13. $list = $manager->executeQuery('location.box',$query); // 执行查询 location数据库下的box集合
    
14. 
    & l7 n7 b0 X) }  b5 b
15. 
    : C0 `" [( s1 V: R4 Q0 y
16. foreach ($list as $document) {
    
17.     print_r($document);
    # S3 W% X) c7 o5 E! N
18. }

复制代码

# @) n" o- A9 g* V: u查询更多条件使用方法，参考第二节mongodb基本命令，查询
( ]7 _& X+ r0 {8 ^# `: F+ n! V
) `, c! i4 z4 P2 K1 l- X3：添加

5 W9 v+ i# N+ E8 T8 k

1. <?php
   " }4 L$ c) U- v% `+ W3 _6 t
2. 
     o8 B, [# x5 |+ L0 k( W1 _  N+ T" B
3. //链接mongodb
   4 }. r, |; r1 \+ V
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   
5. 
   
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
     K; Y1 ^* b/ Y* L8 X  c  k
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   3 Q, e* L* D/ y0 T# v! t
8. $bulk->insert(['user_id' => 2, 'real_name'=>'中国',]);
   , n) z8 B" @' A. Z. \
9. $bulk->insert(['user_id' => 3, 'real_name'=>'中国人',]);
   
10. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

3 Z% t) U1 y( o) q+ w4：修改
" l$ O! M! T8 n8 Q4 @! o
& Z; H) B4 ]. I7 A

1. <?php
   
2. 
   
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   ' |, E) L+ k- V  \- ^
5. 
   + @; [0 G: M/ }0 i" g
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   9 l6 R! V2 [8 s) O
8. $bulk->update(
   
9.         ['user_id' => 2],
   5 z8 o6 l/ T0 @# |/ ?; q9 O& t
10.         ['$set'=>['real_name'=>'中国国']
    7 t. B1 ?5 ^9 l* q( Y1 Y8 `
11. ]);
    
12. //$set相当于mysql的 set，这里和mysql有两个不同的地方，
      M. D8 l, n9 M$ c& E% k
13. //1：字段不存在会添加一个字段;
    
14. //2：mongodb默认如果条件不成立，新增加数据，相当于insert
    
15. 
    . C, u3 Z- |+ [: s7 K, \
16. 
    
17. //如果条件不存在不新增加，可以通过设置upsert
    
18. //db.collectionName.update(query, obj, upsert, multi);
    
19. 
    - X% X( Y2 h2 L, [. Q% w
20. $bulk->update(
    4 E( p. A4 w/ l0 I, L& k
21.         ['user_id' => 5],
    / V- _" W' P, p$ k9 ~4 c
22.         [
    
23.                 '$set'=>['fff'=>'中国国']
    
24.         ],
    ) a" g! W0 _! P' N
25.         ['multi' => true, 'upsert' => false]
    % z' j2 ^1 \" G$ [9 s4 e
26.         //multi为true,则满足条件的全部修改,默认为true，如果改为false，则只修改满足条件的第一条
      d5 q. c% S+ P4 R! V6 x8 Y# d
27.         //upsert为 treu：表示不存在就新增
    $ ~) L' k$ j$ i6 o5 C8 A! f! f' |
28. );
    . s& d( N, r6 K  Z+ l) M8 O+ m- u
29. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

3 h9 A& }! t6 l1 z2 A
ordered 设置

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

5：删除

/ Y. G$ ~1 d7 }4 P2 c6 G$ S! p

1. <?php
   
2. 
   , c0 O6 u/ R7 T
3. //链接mongodb
   0 m9 K5 G% k" g) x9 m7 m- p  |4 x
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->delete(['user_id'=>5]);//删除user_id为5的字段
   8 s: r# y5 m! _9 Z  N+ i' ~" v4 N
9. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合
   : }4 a0 I, O. H/ R7 O
10. delete还可以通过limit设置不同删除方式
    
11. 
    & h8 W& |/ v) {" @5 \" z
12. $bulk->delete(['user_id' => 1], ['limit' => 1]);   // limit 为 1 时，删除第一条匹配数据
    
13. $bulk->delete(['user_id' => 2], ['limit' => 0]);   // limit 为 0 时，删除所有匹配数据，默认删除所有

复制代码

6：捕获异常
- t: k9 h. D2 ]& u6 T

1. MongoDB\Driver\Exception\AuthenticationException
   
2. MongoDB\Driver\Exception\BulkWriteException
   ! B! ?3 K7 B* }  Q1 E
3. MongoDB\Driver\Exception\ConnectionException
   
4. MongoDB\Driver\Exception\ConnectionTimeoutException
   ' o- e" \* D! A$ }
5. MongoDB\Driver\Exception\Exception //所有驱动程序异常的公共接口
   6 E1 I. Z7 i/ `
6. MongoDB\Driver\Exception\ExecutionTimeoutException
   
7. MongoDB\Driver\Exception\InvalidArgumentException
   1 v; ^+ K% W8 E2 K/ N0 ^5 O( j
8. MongoDB\Driver\Exception\LogicException
   % ^; R5 z& |0 \4 x8 C0 x# M
9. MongoDB\Driver\Exception\RuntimeException
   0 V4 P1 y* T. Q; |
10. MongoDB\Driver\Exception\SSLConnectionException
    
11. MongoDB\Driver\Exception\UnexpectedValueException
    
12. MongoDB\Driver\Exception\WriteException

复制代码

3 H) O3 I8 K5 x5 J

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

点击查看全部

( ^4 A* q& r* l4 L0 ]$ L5 V
, K8 t. ]7 D- I/ G9 ], D+ h8 B