cncml手绘网

标题: php7的mongodb基本用法 [打印本页]

---

作者: admin    时间: 2019-6-24 20:58
标题: php7的mongodb基本用法
提示：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不支持以前的写法。

4 `9 e3 X; c2 h8 M下面用PHP7新的API总结一下：
* ~" I1 {1 s8 ^8 ]7 n
( A  J, Q6 h& c一：CURD
: B& D( z6 [. Z6 d
& S9 P9 u; X/ z8 W3 H1：链接

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

复制代码

0 M& N3 t" Q8 I% o) _: M2：查询
, w. m; p4 F9 y% p

1. <?php
   ) X. k3 `2 {' r+ O0 z  i9 w
2. 
   5 f8 a, f, q( G7 ~2 w& G4 [% X' g2 H
3. //链接mongodb
   
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   4 [9 a. {1 m& P# X# W; c9 G4 ]0 u' a( G
5. 
   ) O! x7 `% @: p% v0 _$ W. Q: U* a9 ~
6. //查询
   5 p4 j6 ~* j- w' W7 K  X4 N+ }
7. $filter =  ['user_id'=>['$gt'=>0]]; //查询条件 user_id大于0
   : P" A* f4 w8 y8 E
8. $options = [
   
9.    'projection' => ['_id' => 0], //不输出_id字段
   2 }! Y& C- E5 b! ~
10.    'sort' => ['user_id'=>-1] //根据user_id字段排序 1是升序，-1是降序
    
11. ];
    
12. $query = new MongoDB\Driver\Query($filter, $options); //查询请求
    ' [7 |8 Y( b) X: q2 j
13. $list = $manager->executeQuery('location.box',$query); // 执行查询 location数据库下的box集合
    2 y! F) R$ }, A: T4 U1 b
14. 
    * s- q6 R# g  q# a8 X0 U
15. 
    
16. foreach ($list as $document) {
    " c+ B( {/ ~# X+ Q0 b) s) Y# b) W/ y
17.     print_r($document);
    
18. }

复制代码

查询更多条件使用方法，参考第二节mongodb基本命令，查询
3 v! [% S3 K1 l  Y2 c0 t
) g. R2 _! S! `! `. M% }3：添加
4 O2 j, e. X2 Q) {! }8 j
2 |: q( r4 c- `2 _( x! M

1. <?php
   
2. 
   9 a( w9 K4 I9 c$ u% d0 L
3. //链接mongodb
   : a; n* K) Y# C3 u. f
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   
5. 
   7 J+ ?# R: V( T) }* |. S
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'=>'中国人',]);
   6 _1 E; ~; I# S8 A8 D
10. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

9 q! o. o! j+ D+ o+ z& e4：修改

9 x0 k: `; V/ g% j$ }+ T

1. <?php
   
2. 
   
3. //链接mongodb
   ! s# }. v/ r/ L' }7 y5 m
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   
5. 
   
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   + Z7 [7 E8 W7 K# H, W. n0 |
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   6 e, f/ D* K( s) k
8. $bulk->update(
   
9.         ['user_id' => 2],
   / y0 x& Y! L1 H$ T0 Q
10.         ['$set'=>['real_name'=>'中国国']
    
11. ]);
    
12. //$set相当于mysql的 set，这里和mysql有两个不同的地方，
    
13. //1：字段不存在会添加一个字段;
    5 d& S1 f3 \$ E% J$ }
14. //2：mongodb默认如果条件不成立，新增加数据，相当于insert
    + Q5 h8 e0 ^/ y4 S( ^1 x
15. 
      f$ r- ]! Y$ ]. X' B
16. 
    
17. //如果条件不存在不新增加，可以通过设置upsert
    ; |4 L/ M+ d. o* n4 ]3 `% a
18. //db.collectionName.update(query, obj, upsert, multi);
    5 o! G% T" p1 L7 H3 h  _) W; B, u
19. 
    % h! B  _3 q" O2 g3 X8 O* L0 J* ^
20. $bulk->update(
    
21.         ['user_id' => 5],
    . `$ _% i- k, n* t/ Z: w
22.         [
    4 I8 b% i  Z3 h. }2 ?
23.                 '$set'=>['fff'=>'中国国']
    
24.         ],
    
25.         ['multi' => true, 'upsert' => false]
    
26.         //multi为true,则满足条件的全部修改,默认为true，如果改为false，则只修改满足条件的第一条
    
27.         //upsert为 treu：表示不存在就新增
    . I# O3 u& p2 T- F
28. );
    
29. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合

复制代码

ordered 设置
/ F3 E7 G) h" \9 f. S/ v
. c1 Z& D. |7 j- Q9 g* _1：默认是ture，按照顺序执行插入更新数据，如果出错，停止执行后面的，mongo官方叫串行。
2：如果是false，mongo并发的方式插入更新数据，中间出现错误，不影响后续操作无影响，mongo官方叫并行

5：删除

1. <?php
   
2. 
   
3. //链接mongodb
   8 c7 ~: b  `2 U: q1 i
4. $manager = new MongoDB\Driver\Manager('mongodb://root:sjhc168@10.10.10.104:27017');
   ' i9 m4 o" N2 T
5. 
   
6. $bulk = new MongoDB\Driver\BulkWrite; //默认是有序的，串行执行
   , ]6 a' ?+ }/ n! v. \- j
7. //$bulk = new MongoDB\Driver\BulkWrite(['ordered' => flase]);//如果要改成无序操作则加flase，并行执行
   & t4 \+ D% d' _( s4 k$ a
8. $bulk->delete(['user_id'=>5]);//删除user_id为5的字段
   
9. $manager->executeBulkWrite('location.box', $bulk); //执行写入 location数据库下的box集合
   
10. delete还可以通过limit设置不同删除方式
    ! f' ]! G' e  N( i( D- j, i
11. 
    
12. $bulk->delete(['user_id' => 1], ['limit' => 1]);   // limit 为 1 时，删除第一条匹配数据
    
13. $bulk->delete(['user_id' => 2], ['limit' => 0]);   // limit 为 0 时，删除所有匹配数据，默认删除所有

复制代码

" ]: B1 ?2 t, ^$ {' c$ k' E9 A% l
, T! V! [2 S6 o0 _, E6：捕获异常

1. MongoDB\Driver\Exception\AuthenticationException
   
2. MongoDB\Driver\Exception\BulkWriteException
   
3. MongoDB\Driver\Exception\ConnectionException
   : j1 \+ v2 S/ H3 `
4. MongoDB\Driver\Exception\ConnectionTimeoutException
   2 t! `# v; ]4 {& j
5. MongoDB\Driver\Exception\Exception //所有驱动程序异常的公共接口
   - S- r# G. a7 b! d
6. MongoDB\Driver\Exception\ExecutionTimeoutException
   
7. MongoDB\Driver\Exception\InvalidArgumentException
   
8. MongoDB\Driver\Exception\LogicException
   2 n8 w2 X$ B0 _
9. MongoDB\Driver\Exception\RuntimeException
   6 Y3 w5 \9 r. e2 K5 C0 A
10. MongoDB\Driver\Exception\SSLConnectionException
    " Y1 @, i4 \* @$ I) R" |* n. D2 w
11. MongoDB\Driver\Exception\UnexpectedValueException
    - y. z7 I' W( F  m# o
12. MongoDB\Driver\Exception\WriteException

复制代码

8 d( ~  z% k3 m! B6 T点击查看全部

' ^5 h6 L& U* l' V: G8 c

---

欢迎光临 cncml手绘网 (http://cncml.com/)

Powered by Discuz! X3.2