升级PHP7操作MongoDB

admin

使用 PHP+MongoDB 的用户很多，因为 MongoDB 对非结构化数据的存储很方便。在 PHP5 及以前，官方提供了两个扩展，Mongo 和 MongoDB，其中 Mongo 是对以 MongoClient 等几个核心类为基础的类群进行操作，封装得很方便，所以基本上都会选择 Mongo 扩展。

详情请见官方手册：http://php.net/manual/zh/book...

但是随着 PHP5 升级到 PHP7，官方不再支持 Mongo 扩展，只支持 MongoDB，而 PHP7 的性能提升巨大，让人无法割舍，所以怎么把 Mongo 替换成 MongoDB 成为了一个亟待解决的问题。MongoDB 引入了命名空间，但是功能封装非常差，如果非要用原生的扩展，几乎意味着写原生的 Mongo 语句。这种想法很违背 ORM 简化 DB IO 操作带来的语法问题而专注逻辑优化的思路。

详情也可参见官方手册：http://php.net/manual/zh/set....

在这种情况之下，MongoDB 官方忍不住了，为了方便使用，增加市场占有率，推出了基于MongoDB 扩展的库：https://github.com/mongodb/mo...

该库的详细文档见：https://docs.mongodb.com/php-...

MongoDB 驱动

如果使用原驱动的话，大致语法如下：

1. <?php
   
2. 
   4 W6 m2 Q! }( Y
3. use MongoDB\Driver\Manager;
   
4. use MongoDB\Driver\BulkWrite;
   $ L* \. t  J, X; Q- N8 G- Z. D# _* m
5. use MongoDB\Driver\WriteConcern;
   : C6 o6 ^% M/ R7 f2 l/ n+ n% W
6. use MongoDB\Driver\Query;
   9 u1 J  O  s9 O; j
7. use MongoDB\Driver\Command;
     I) K4 J2 V* `# ]$ Q4 [
8. 
   
9. class MongoDb {
   . K+ {1 Z2 R0 B$ N
10. 
    
11.     protected $mongodb;
    
12.     protected $database;
    
13.     protected $collection;
    7 c. I4 o0 a9 E0 W
14.     protected $bulk;
    0 h; O# W2 m9 z: O0 R5 n( ^
15.     protected $writeConcern;
    ! K) _$ z0 Z! \! e* Q& ?$ ^
16.     protected $defaultConfig
    
17.         = [
    / X4 u' I9 S0 ]# I
18.             'hostname' => 'localhost',
    
19.             'port' => '27017',
    
20.             'username' => '',
    
21.             'password' => '',
    
22.             'database' => 'test'
    
23.         ];
    
24. 
    8 L, i' g- q4 H: t1 A. [& U& o
25.     public function __construct($config) {
    5 L' U! a% @3 f8 y% o. D, Z) x1 V3 b
26.         $config = array_merge($this->defaultConfig, $config);
    
27.         $mongoServer = "mongodb://";
    
28.         if ($config['username']) {
    6 ?+ j# G: B9 {+ B$ R
29.             $mongoServer .= $config['username'] . ':' . $config['password'] . '@';
    # ?. S  o* _9 H! Z0 l! @6 M
30.         }
    - ~/ _; O' l0 f+ s5 U
31.         $mongoServer .= $config['hostname'];
    ) E2 \4 v0 y) I+ N9 i
32.         if ($config['port']) {
    
33.             $mongoServer .= ':' . $config['port'];
    4 Y' y5 w" v: L* f* ]$ m& r
34.         }
    
35.         $mongoServer .= '/' . $config['database'];
    
36. 
    * r+ o8 A+ m9 u; F+ {4 k
37.         $this->mongodb = new Manager($mongoServer);
    / ~! ?* f# i5 N7 N, ]. k5 ^
38.         $this->database = $config['database'];
    
39.         $this->collection = $config['collection'];
    $ R: [1 ^9 ^* g4 ]1 u& h
40.         $this->bulk = new BulkWrite();
    
41.         $this->writeConcern = new WriteConcern(WriteConcern::MAJORITY, 100);
    
42.     }
    
43. 
    7 J1 L2 E% f3 C( s0 e1 m( q. I
44.     public function query($where = [], $option = []) {
    6 l$ e2 P7 @% e, f
45.         $query = new Query($where, $option);
    6 k7 `, `( r4 \
46.         $result = $this->mongodb->executeQuery("$this->database.$this->collection", $query);
    5 Z; d0 m- }: x$ E4 y3 q, G
47. 
    
48.         return json_encode($result);
    
49.     }
    
50. 
    3 q: T# {5 Z3 |8 Q! j% Z  w# ^3 m
51.     public function count($where = []) {
    
52.         $command = new Command(['count' => $this->collection, 'query' => $where]);
    
53.         $result = $this->mongodb->executeCommand($this->database, $command);
      c' r0 v2 B/ t% }9 v
54.         $res = $result->toArray();
    " b) z/ E2 U3 I% u3 M
55.         $count = 0;
    * e, @/ c( M# r" H6 `0 \/ u
56.         if ($res) {
    
57.             $count = $res[0]->n;
    . _( Y2 Q' C5 t$ w$ \! y
58.         }
    
59. 
    3 a: w7 S8 K, n0 _) G
60.         return $count;
    
61.     }
    5 b) z- ?$ d0 e9 v* I5 t- S) u$ P
62. 
    : [! d7 k: ~2 i
63.     public function update($where = [], $update = [], $upsert = false) {
    ) {- H- v/ Z" ^& g$ |! S
64.         $this->bulk->update($where, ['$set' => $update], ['multi' => true, 'upsert' => $upsert]);
    
65.         $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
    
66. 
    ; W4 k! s+ O( G" b2 Y& [
67.         return $result->getModifiedCount();
    . [% T7 q/ I- Z4 Y
68.     }
    
69. 
    % X& I( D* Q- ], Y
70.     public function insert($data = []) {
    1 Q& A1 g3 m, V
71.         $this->bulk->insert($data);
    
72.         $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
    
73. 
    
74.         return $result->getInsertedCount();
    
75.     }
    & d" T- j, q3 k. y, ?* r- G. m
76. 
    3 G! P3 Z+ M! d0 l
77.     public function delete($where = [], $limit = 1) {
    
78.         $this->bulk->delete($where, ['limit' => $limit]);
    * v& B! r: b8 R, @, u
79.         $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
    
80. 
    $ }' @% B! m3 i% @1 M
81.         return $result->getDeletedCount();
    ! }0 ^  ^1 Y+ A$ S
82.     }
    
83. }

复制代码

这样的语法和之前差异太大，改动不方便，换 PHP MongoDB 库

MongoDB 库1.连接

• 原
  

1. new MongoClient();

复制代码

• 新
  , b* K' l' E/ a

1. new MongoDB\Client();

复制代码

2.新增

• 原
  

1. $collention->insert($array, $options);

复制代码

• 新
  8 }" c$ a2 I+ s) S% _) `+ D8 V; V

1. $resultOne = $collention->insertOne($array, $options);//单
   
2. $lastId = $resultOne->getInsertedId();
   / F9 m# Y2 ^' G* W( |
3. $resultMany = $collention->insertMany($array, $options);//多
   ! E4 y/ H/ t- ^# G9 u1 |
4. $count = $resultMany->getInsertedCount();

复制代码

3.修改

• 原
  

1. $collention->update($condition, [
   ) v: _+ M  v  G, c. H2 {. O+ j
2.     '$set' => $values
   
3. ,[
   
4.     'multiple' => true//多条，单条false
   # G) G* q0 B/ i8 U9 i7 Z
5. ]);

复制代码

• 新
  + @  h" V) I5 K- z( p

1. $collection->updateOne(
   % d  X- |' N$ o  ~* H2 e
2.     ['state' => 'ny'],
   
3.     ['$set' => ['country' => 'us']]
   
4. );
   
5. $updateResult = $collection->updateMany(
   : }6 P* y7 k3 w$ Q
6.     ['state' => 'ny'],
   $ J5 }6 ]& ~2 ]7 C: j5 i$ b: Z) f
7.     ['$set' => ['country' => 'us']]
   
8. );
   4 D4 z/ B! C. r+ T% l3 Y' e+ i7 T
9. $count = $updateResult->getModifiedCount();

复制代码

4.查询

• 原
  

1. $cursor = $collection->find($condition, [
   
2.     'name' => true//指定字段
   
3. ]);
   
4. $cursor->skip(5);
   - P& a! p6 ?) K7 l8 c4 A' L
5. $cursor->limit(5);
   
6. $cursor->sort([
   ! e% G0 j0 N9 q- K; c
7.     'time' => -1
   
8. ]);

复制代码

• 新
  6 i5 l# M7 v2 \: u

1. $cursor = $collection->find($condition, [
   8 _$ G4 t: Q% L+ g
2.     'skip' => 5,
   
3.     'limit' => 5,
   
4.     'sort' => [
   
5.         'time' => -1
   
6.     ],//排序
   " C9 ?/ S- T( A# `3 c. ~
7.     'projection' => [
   9 W- @9 D9 ?* k6 M  X: }! D4 G* s
8.         'name' => 1//指定字段
   
9.     ]
   
10. ]);

复制代码

5.删除

• 原
  " p- q) Y, F# M$ B; J1 c6 [1 @

1. $collention->remove($condition, [
   
2.     'justOne' => false//删单条
   
3. ]);
   
4. $collention->remove([]);//删所有

复制代码

• 新
  & [6 A+ ~$ C1 l& W8 [

1. $result = $collention->deleteOne($condition, $options);
   3 o4 w% x1 p& T6 L0 f
2. $collention->deleteMany($condition, $options);
   : p' ~" J# G' X, O( [2 I
3. 
   
4. $result->getDeletedCount();

复制代码

补充

有些人可能习惯以类似 MySQL 的自增 ID 来处理数据，以前可能使用 findAndModify() 方法来查询并修改：

1. $collention->findAndModify([
   " i; y3 T' U- Q! ]/ z0 b8 Y
2.     '_id' => $tableName//我在自增表中用其它的表名作主键
   6 q) N  y" I2 |) L6 O6 Y% J' n
3. ], [
   3 ~9 _  p4 e' H& @/ R: y
4.     '$inc' => ['id' => 1]//自增
   
5. ], [
   
6.     '_id' => 0
   8 @. _; M) |) N* F; ^  t9 r0 k& I5 q8 N
7. ], [
   " C6 l, L1 d! F) J( E7 ]( X' j* J5 s
8.     'new' => 1//返回修改后的结果，默认是修改前的
   8 F' P, I8 G: ^  y0 Z
9. ]);

复制代码

现在使用 MongoDB 库的话需要修改为：

1. $collention->findOneAndUpdate([
   8 W, [9 g% {  }% r- \6 Y4 Z4 @
2.     '_id' => $tableName
   0 X  n3 C! Y# l7 j6 X
3. ], [
   2 T4 L) n" P8 ^' r5 W' v
4.     '$inc' => ['id' => 1]
   : _" y! J$ @' x
5. ], [
   
6.     'projection' => ['id' => 1],
   % G, v8 Z0 V; k. u! S
7.     'returnDocument' => MongoDB\Operation\FindOneAndUpdate::RETURN_DOCUMENT_AFTER
   
8. ]);

复制代码