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

# j. d3 d& t" w+ M下面用PHP7新的API总结一下：

) \* b9 W; I6 V. P一：CURD

" X9 b. u3 _- @" F" C$ |& p1：链接

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

复制代码

2：查询

1. <?php
   % `& [% v+ v, b1 W4 E
2. 
   ) U6 z8 U1 k% r. m' n/ T0 r
3. //链接mongodb
   5 q) D. W9 h5 @* c6 h3 K
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   , M. ]" U& z- [- n: ~3 s# |
5. 
   # m6 Z- u4 p, ]; B3 C4 m6 e
6. //查询
   4 i( l9 ]1 F1 D% g* ^  |( D* F
7. $filter =  ['user_id'=>['$gt'=>0]]; //查询条件 user_id大于0
   
8. $options = [
   : y( m/ ~- M6 M
9.    'projection' => ['_id' => 0], //不输出_id字段
   
10.    'sort' => ['user_id'=>-1] //根据user_id字段排序 1是升序，-1是降序
    
11. ];
    * k& ~7 _8 i3 J) ]; x6 e8 p
12. $query = new MongoDB\Driver\Query($filter, $options); //查询请求
    6 K* _2 j: Z. V! h) Y. K: d
13. $list = $manager->executeQuery('location.box',$query); // 执行查询 location数据库下的box集合
    
14. 
    8 C: A! h' G6 Z8 N5 q  H2 u
15. 
    
16. foreach ($list as $document) {
    1 @4 h: {6 \  _: ~/ M, f
17.     print_r($document);
    
18. }

复制代码

查询更多条件使用方法，参考第二节mongodb基本命令，查询
( z  h2 ]! ~, W$ U! N5 x( q: |7 f
3：添加
2 n9 z7 n- x) N: M8 r

1. <?php
   ! w) [" o* b' R. Z0 z. F
2. 
   
3. //链接mongodb
     L% y2 t. C7 d& N" \# b6 c
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   
5. 
   0 _0 Y! n0 U4 f- W8 j
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   
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'=>'中国人',]);
     ?5 S2 p( s  I9 B! u3 `
10. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

( D- l' e) F7 `4：修改

1. <?php
   
2. 
     ]! Z, R' d8 R* Q0 I) C4 J2 L9 Q
3. //链接mongodb
   1 w/ r* }: \/ b  n) K
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   
5. 
   
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   " V& ?9 ^8 q- k& z  N" Z
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   
8. $bulk->update(
   
9.         ['user_id' => 2],
   1 n2 u* D! S. V3 w0 f; {  g# `
10.         ['$set'=>['real_name'=>'中国国']
    0 @, h% h0 L; [
11. ]);
    8 w0 f( b  z# H. I5 C
12. //$set相当于mysql的 set，这里和mysql有两个不同的地方，
    3 J* G+ L* w0 C- h. D5 x: ~
13. //1：字段不存在会添加一个字段;
    
14. //2：mongodb默认如果条件不成立，新增加数据，相当于insert
    
15. 
    
16. 
    
17. //如果条件不存在不新增加，可以通过设置upsert
    % V0 R! w! Z, q9 V8 a
18. //db.collectionName.update(query, obj, upsert, multi);
    & L" g$ b: o9 D, k" L
19. 
    . {; T! E% h" I
20. $bulk->update(
    
21.         ['user_id' => 5],
    
22.         [
    5 y7 Z3 m4 I" l" J) @( f( w
23.                 '$set'=>['fff'=>'中国国']
    0 ~1 |% c/ K5 |! ?9 M0 ]. @9 P, W
24.         ],
    
25.         ['multi' => true, 'upsert' => false]
    8 u5 `0 P* H: s& [, I: [$ y* F% z. Y
26.         //multi为true,则满足条件的全部修改,默认为true，如果改为false，则只修改满足条件的第一条
    
27.         //upsert为 treu：表示不存在就新增
    6 T- V" c) G. A$ i( \0 [; b3 n3 o$ [
28. );
    
29. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

* v$ R% q3 c; D3 dordered 设置
# w4 Z9 m; W/ E9 n7 T4 M
1：默认是ture，按照顺序执行插入更新数据，如果出错，停止执行后面的，mongo官方叫串行。
2：如果是false，mongo并发的方式插入更新数据，中间出现错误，不影响后续操作无影响，mongo官方叫并行
3 P2 U/ |+ g/ m
5：删除
- `$ W  q7 @! M
2 ?1 ]) N; t% E3 u: b

1. <?php
   
2. 
   
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   4 e- }/ E, U$ N% o! V( b8 I
5. 
   , K) e  y: X, c  S3 _
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   , h/ U: o8 W6 ~3 H- S0 r
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   7 _, L8 y& m# o, T' R0 h$ G0 c
8. $bulk->delete(['user_id'=>5]);//删除user_id为5的字段
   & P# x3 L& |( g- p# U" n  ?
9. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合
   
10. delete还可以通过limit设置不同删除方式
    7 {$ u) X3 m( y( c6 h
11. 
    * \, H4 X' g" T3 x% }; Y7 [3 o
12. $bulk->delete(['user_id' => 1], ['limit' => 1]);   // limit 为 1 时，删除第一条匹配数据
    
13. $bulk->delete(['user_id' => 2], ['limit' => 0]);   // limit 为 0 时，删除所有匹配数据，默认删除所有

复制代码

' u  D+ g! P4 w8 L; O1 y& F6：捕获异常

. c8 C5 E- T& t* P3 v

1. MongoDB\Driver\Exception\AuthenticationException
   
2. MongoDB\Driver\Exception\BulkWriteException
   
3. MongoDB\Driver\Exception\ConnectionException
   . m6 J5 r8 r. L* x+ S) a% n  K1 @9 n
4. MongoDB\Driver\Exception\ConnectionTimeoutException
   , V, d& {3 U. _2 l
5. MongoDB\Driver\Exception\Exception //所有驱动程序异常的公共接口
   
6. MongoDB\Driver\Exception\ExecutionTimeoutException
   5 D! q; p5 {7 l; \
7. MongoDB\Driver\Exception\InvalidArgumentException
   + v% m$ v( b- R# B( b
8. MongoDB\Driver\Exception\LogicException
   
9. MongoDB\Driver\Exception\RuntimeException
   
10. MongoDB\Driver\Exception\SSLConnectionException
    
11. MongoDB\Driver\Exception\UnexpectedValueException
    " ?: P- l. ]: T% {7 r" O
12. MongoDB\Driver\Exception\WriteException

复制代码

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

4 |1 e) v  k0 Z1 u点击查看全部
- Z- O1 p" v" }7 N* m0 R* b

: o9 Y5 J" k# [8 q" ?# @2 {$ K