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

3 [2 D: Q' A+ i. H; T下面用PHP7新的API总结一下：

一：CURD

1：链接
: P& ~7 z( |2 B8 L- h1 q/ ^

1. <?php
   / w" F* e3 e$ N4 M2 O
2. //链接mongodb
   ' L6 J$ c, d( s. o
3. $manager = new MongoDB\Driver\Manager('mongodb://root:123@10.10.10.104:27017');
   . g  s- d  ~! q# Q7 K' ^0 ]
4. root 用户；123：密码；如果没有密码则不写

复制代码

. G  ]) w3 a& i! ^+ C6 c0 `2：查询
3 Y/ J5 B( y  r9 |- L

1. <?php
   : C4 W, e$ U1 `6 ]& `0 R
2. 
   
3. //链接mongodb
   & j. z+ e& x1 z6 `/ n8 @
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   
5. 
   * |2 Y, m0 }" b6 D* c
6. //查询
   5 D' r/ h# z) @& a; t$ A' B" p
7. $filter =  ['user_id'=>['$gt'=>0]]; //查询条件 user_id大于0
   
8. $options = [
   
9.    'projection' => ['_id' => 0], //不输出_id字段
   : J& R2 s  Q6 |9 l
10.    'sort' => ['user_id'=>-1] //根据user_id字段排序 1是升序，-1是降序
    
11. ];
    7 o& B0 i& ~- B4 u5 l" E7 Z
12. $query = new MongoDB\Driver\Query($filter, $options); //查询请求
    0 r6 ^  y- Y; ~9 _$ M# E' o3 A
13. $list = $manager->executeQuery('location.box',$query); // 执行查询 location数据库下的box集合
    
14. 
    4 _4 H# D- G* N% W1 G
15. 
    
16. foreach ($list as $document) {
    
17.     print_r($document);
    
18. }

复制代码

查询更多条件使用方法，参考第二节mongodb基本命令，查询

3：添加
1 {9 T  n7 O9 }0 \% r; s# T
; K$ L, Z+ N) P. I* L5 H

1. <?php
   7 F6 v* k" @% K. S7 E# w- \  N- `/ [
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，并行执行
     {5 B; n  I/ r* U( E# d
8. $bulk->insert(['user_id' => 2, 'real_name'=>'中国',]);
   : O( H) x5 ?- i8 k
9. $bulk->insert(['user_id' => 3, 'real_name'=>'中国人',]);
   ! ~  g6 F! D6 I- c7 M3 ]) w
10. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

- [. {: d9 m! Y# R4：修改

1. <?php
   4 e* E) m2 G' c
2. 
   
3. //链接mongodb
   - E% s1 N* ~% ~1 _( L
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   : ?' _9 S9 p3 w7 ^  m( Q
5. 
   ) C2 h5 X8 H- M2 O; z; m
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   . @4 M2 r9 p: H6 t2 z  K
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   # R/ k3 H( o$ W0 x6 x
8. $bulk->update(
   1 v- k% T* W: H! [
9.         ['user_id' => 2],
   2 h+ B* D- `$ P" ^. S2 i
10.         ['$set'=>['real_name'=>'中国国']
    
11. ]);
    
12. //$set相当于mysql的 set，这里和mysql有两个不同的地方，
    9 X5 `# @4 t: X  ^1 v
13. //1：字段不存在会添加一个字段;
    
14. //2：mongodb默认如果条件不成立，新增加数据，相当于insert
    ' h+ q4 A# S6 d: O1 S
15. 
    
16. 
    4 g  T/ w2 B: S4 V
17. //如果条件不存在不新增加，可以通过设置upsert
    
18. //db.collectionName.update(query, obj, upsert, multi);
    
19. 
    : R7 l1 r! L& t( b9 s+ O
20. $bulk->update(
    
21.         ['user_id' => 5],
    % [7 @1 Z# b$ I1 t: C- j  u
22.         [
    $ T: ?) a2 p8 H1 u  [
23.                 '$set'=>['fff'=>'中国国']
    1 t4 o6 g- D9 H  v- U9 i0 G
24.         ],
    
25.         ['multi' => true, 'upsert' => false]
    , R+ e" }: U& p" N$ c% }
26.         //multi为true,则满足条件的全部修改,默认为true，如果改为false，则只修改满足条件的第一条
    
27.         //upsert为 treu：表示不存在就新增
    
28. );
    
29. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

/ E9 @! h% l9 @% i* X* U6 ?
ordered 设置

- t7 h$ C& y8 q" m4 S  F) n0 B: e5 B1：默认是ture，按照顺序执行插入更新数据，如果出错，停止执行后面的，mongo官方叫串行。
2：如果是false，mongo并发的方式插入更新数据，中间出现错误，不影响后续操作无影响，mongo官方叫并行

5：删除
! A- r7 p, K* t" s8 ?. b- C
3 E; x5 V5 M* n7 E

1. <?php
   9 Z  u! |5 P( m  L; [, F
2. 
   ( @. ^. w- a) r% ~6 d8 X/ G  O
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   # I# s& L" e7 t0 c, B" \# P
5. 
   9 W6 \; B7 E. e8 t9 P
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   - h) ~( g+ r; S$ M+ P7 \; u  X
8. $bulk->delete(['user_id'=>5]);//删除user_id为5的字段
   
9. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合
   
10. delete还可以通过limit设置不同删除方式
    % ]& ^  J+ z4 B6 \- X9 A" S
11. 
    % Q1 Z; J2 p6 f; Z7 v8 n" H: L
12. $bulk->delete(['user_id' => 1], ['limit' => 1]);   // limit 为 1 时，删除第一条匹配数据
    4 p4 y: |# l6 `" Q# ^9 b
13. $bulk->delete(['user_id' => 2], ['limit' => 0]);   // limit 为 0 时，删除所有匹配数据，默认删除所有

复制代码

4 r( m4 J7 Y, X' d1 c
6：捕获异常
. v& [( o* T- C# A

1. MongoDB\Driver\Exception\AuthenticationException
   / w( A! G- x3 v
2. MongoDB\Driver\Exception\BulkWriteException
   
3. MongoDB\Driver\Exception\ConnectionException
   7 c: Z- Z0 D  W8 e$ I
4. MongoDB\Driver\Exception\ConnectionTimeoutException
   
5. MongoDB\Driver\Exception\Exception //所有驱动程序异常的公共接口
   3 T- t, k7 a2 v
6. MongoDB\Driver\Exception\ExecutionTimeoutException
   
7. MongoDB\Driver\Exception\InvalidArgumentException
   
8. MongoDB\Driver\Exception\LogicException
   * s7 J1 P' A6 k( N) q
9. MongoDB\Driver\Exception\RuntimeException
   & P6 u( x* |' \$ d; k8 D
10. MongoDB\Driver\Exception\SSLConnectionException
    0 h% W/ s  |8 g/ F6 E; B5 l: a
11. MongoDB\Driver\Exception\UnexpectedValueException
    
12. MongoDB\Driver\Exception\WriteException

复制代码

% o' v* {9 A; F' W- K  b( q

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

; p2 g1 ?, b1 c/ c( _5 Y: F点击查看全部