升级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
   5 h3 b/ C! b" Y' A
2. 
   " K3 P8 J  ]: p) q- C( o. V
3. use MongoDB\Driver\Manager;
   
4. use MongoDB\Driver\BulkWrite;
   2 h; h/ L" j% H$ K+ ~" s
5. use MongoDB\Driver\WriteConcern;
   7 c/ F. L9 Q$ a& G! ?2 r
6. use MongoDB\Driver\Query;
   8 G! j2 s- `* C. b  p/ Z; r
7. use MongoDB\Driver\Command;
   
8. 
   ; X2 U- L$ S: \% w) N' U! P  K
9. class MongoDb {
   
10. 
    
11.     protected $mongodb;
    6 p4 D. E$ R% p
12.     protected $database;
    
13.     protected $collection;
    
14.     protected $bulk;
    4 \& v% l( H$ @1 v
15.     protected $writeConcern;
    
16.     protected $defaultConfig
    
17.         = [
    
18.             'hostname' => 'localhost',
    
19.             'port' => '27017',
    
20.             'username' => '',
    ! Y# u6 v: s' F: i4 C6 c- }
21.             'password' => '',
    ! d) d4 O/ @' u" }1 L+ h* b8 A
22.             'database' => 'test'
    
23.         ];
    + n/ y! l( |3 y5 a# `% j
24. 
    8 T5 V9 C7 y. [1 p! a' @) `$ I
25.     public function __construct($config) {
    
26.         $config = array_merge($this->defaultConfig, $config);
    
27.         $mongoServer = "mongodb://";
    
28.         if ($config['username']) {
    
29.             $mongoServer .= $config['username'] . ':' . $config['password'] . '@';
    
30.         }
    " d5 u) }- }9 u- [5 K; E$ n
31.         $mongoServer .= $config['hostname'];
    
32.         if ($config['port']) {
    / ]+ ]7 @- c# k' k7 N! Q8 x
33.             $mongoServer .= ':' . $config['port'];
    
34.         }
    : w/ b' w; f8 W% D: M
35.         $mongoServer .= '/' . $config['database'];
    : a. M% g' q+ G. I
36. 
    0 _& c1 l: a' y& X# {
37.         $this->mongodb = new Manager($mongoServer);
    + s4 A# m6 P; o5 [4 `9 p
38.         $this->database = $config['database'];
    / I5 l( S, e2 {' P
39.         $this->collection = $config['collection'];
    
40.         $this->bulk = new BulkWrite();
    * y9 x3 A, U3 Y+ T2 _9 z2 h1 @% P
41.         $this->writeConcern = new WriteConcern(WriteConcern::MAJORITY, 100);
    
42.     }
    2 b% h+ }$ p: T# N  d  W
43. 
    8 T! `1 d' l1 p
44.     public function query($where = [], $option = []) {
    4 z# l' I2 J. v. Z
45.         $query = new Query($where, $option);
    
46.         $result = $this->mongodb->executeQuery("$this->database.$this->collection", $query);
    
47. 
    
48.         return json_encode($result);
    * T* a. d7 C( m; i# k
49.     }
    ; G! ^* z" w$ f+ O7 q
50. 
    5 Q6 B3 N; E. M" L7 B* L
51.     public function count($where = []) {
    
52.         $command = new Command(['count' => $this->collection, 'query' => $where]);
    9 o! Y% r) L/ r* I  Q1 N6 F
53.         $result = $this->mongodb->executeCommand($this->database, $command);
    
54.         $res = $result->toArray();
    
55.         $count = 0;
    
56.         if ($res) {
    
57.             $count = $res[0]->n;
    
58.         }
    7 M7 o9 q2 W; B" B
59. 
    
60.         return $count;
    - S2 \: N3 R2 T9 }
61.     }
    
62. 
    3 ^7 G* t0 a- S0 B
63.     public function update($where = [], $update = [], $upsert = false) {
    & B" h$ b) Y2 h: o8 Y4 L) S2 Q
64.         $this->bulk->update($where, ['$set' => $update], ['multi' => true, 'upsert' => $upsert]);
    4 X4 b$ a* \" W" Q6 d6 d
65.         $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
    $ F$ i- N% B. g( j
66. 
    
67.         return $result->getModifiedCount();
    6 D  n$ U/ B. E& M2 g! I+ H9 Z
68.     }
    
69. 
    ) W$ C/ ~) J) K3 v6 m1 B
70.     public function insert($data = []) {
    
71.         $this->bulk->insert($data);
    
72.         $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
    
73. 
    ) m& @; J- C/ i: S  J- u+ t
74.         return $result->getInsertedCount();
    
75.     }
    " c, v% t) \/ U( @5 b
76. 
    
77.     public function delete($where = [], $limit = 1) {
    , r! F+ d9 D# F6 y( _- J2 W# m
78.         $this->bulk->delete($where, ['limit' => $limit]);
    
79.         $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
    # O! n7 ^. r5 {6 r, O( I1 \4 J
80. 
    , r* w* w/ H7 n# B. j7 V, a
81.         return $result->getDeletedCount();
    1 W1 a' |# Y% ?5 y8 w/ B
82.     }
    2 t9 `8 G2 `, u6 t4 \
83. }

复制代码

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

MongoDB 库1.连接

• 原
  

1. new MongoClient();

复制代码

• 新
  

1. new MongoDB\Client();

复制代码

2.新增

• 原
  

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

复制代码

• 新
  . ]; B( h5 z6 Q: m+ M

1. $resultOne = $collention->insertOne($array, $options);//单
   : ]4 a5 Q. x& w4 R( C
2. $lastId = $resultOne->getInsertedId();
   
3. $resultMany = $collention->insertMany($array, $options);//多
   ' k' y' t6 \, X4 F# Q) k- q
4. $count = $resultMany->getInsertedCount();

复制代码

3.修改

• 原
  

1. $collention->update($condition, [
   
2.     '$set' => $values
   
3. ,[
   : {( i, [' h; D" u& ~
4.     'multiple' => true//多条，单条false
   
5. ]);

复制代码

• 新
  

1. $collection->updateOne(
   2 x9 o# W3 W/ h- F7 C* c
2.     ['state' => 'ny'],
   * x- P8 k0 L  s% s8 x
3.     ['$set' => ['country' => 'us']]
   0 K1 S  i0 ~# s3 w/ w1 R  D& V; C6 r
4. );
   ! ]' R& p, Z$ @8 e
5. $updateResult = $collection->updateMany(
   ( T7 V" B; ]' M5 E/ |  j8 C
6.     ['state' => 'ny'],
   # ~* e# ]/ w$ \. e$ U% y6 ]
7.     ['$set' => ['country' => 'us']]
   
8. );
   
9. $count = $updateResult->getModifiedCount();

复制代码

4.查询

• 原
  4 P9 Z% z6 z$ K" O* Y% v

1. $cursor = $collection->find($condition, [
   . _( h! b. x4 G
2.     'name' => true//指定字段
   
3. ]);
   
4. $cursor->skip(5);
   
5. $cursor->limit(5);
   6 R* _% @1 F- L1 P1 @- b2 `
6. $cursor->sort([
   
7.     'time' => -1
   
8. ]);

复制代码

• 新
  

1. $cursor = $collection->find($condition, [
   
2.     'skip' => 5,
   
3.     'limit' => 5,
   3 n, l4 H/ `0 V9 t4 y) i2 d) H1 `
4.     'sort' => [
   1 k0 j1 X; u( o4 A  h
5.         'time' => -1
   
6.     ],//排序
   % R7 L7 l. _7 r& O) }+ N- I
7.     'projection' => [
   
8.         'name' => 1//指定字段
   % K1 q( N3 l2 x) A5 n0 S
9.     ]
   8 o" D1 y! @  _2 @* c6 J
10. ]);

复制代码

5.删除

• 原
  

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

复制代码

• 新
  % o4 L: [; q/ ^

1. $result = $collention->deleteOne($condition, $options);
   
2. $collention->deleteMany($condition, $options);
   
3. 
   5 u+ O: e, z* e( [& I0 J$ n8 O
4. $result->getDeletedCount();

复制代码

补充

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

1. $collention->findAndModify([
   " G$ v, Z7 [6 J$ i
2.     '_id' => $tableName//我在自增表中用其它的表名作主键
   
3. ], [
   7 f. u' X9 `3 m2 V2 ?9 `
4.     '$inc' => ['id' => 1]//自增
   : w: ]- L4 S9 ~, ^+ n4 s% B
5. ], [
   
6.     '_id' => 0
   
7. ], [
   
8.     'new' => 1//返回修改后的结果，默认是修改前的
   2 w* x/ a( G& V% T, w7 {
9. ]);

复制代码

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

1. $collention->findOneAndUpdate([
   
2.     '_id' => $tableName
   0 |# r1 L5 w% r9 @' M( }' e3 |9 U# e
3. ], [
   ! z" b, j1 o! N7 S& R9 b
4.     '$inc' => ['id' => 1]
   
5. ], [
   0 J, s" c  I3 g! A1 c* P/ U
6.     'projection' => ['id' => 1],
   $ C) E" X3 A7 V$ v+ k+ M
7.     'returnDocument' => MongoDB\Operation\FindOneAndUpdate::RETURN_DOCUMENT_AFTER
   / ^% t/ X( c/ g+ a; H/ H/ B& I
8. ]);

复制代码

& N( {- f+ z3 W