升级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
   : `; `. h/ t; j2 N7 s! ?) @0 @
2. 
   
3. use MongoDB\Driver\Manager;
   ' z/ |5 E; H+ @/ T9 j5 i1 w+ S
4. use MongoDB\Driver\BulkWrite;
   
5. use MongoDB\Driver\WriteConcern;
   $ I+ r% o7 J, Q$ M, u) `& x
6. use MongoDB\Driver\Query;
   4 D& J3 {) M+ }% `# Q- U
7. use MongoDB\Driver\Command;
   
8. 
   
9. class MongoDb {
   
10. 
    
11.     protected $mongodb;
    
12.     protected $database;
    2 R- _7 D4 p( f8 R7 o) {- E4 J
13.     protected $collection;
    : h; X* ^" `) |5 q
14.     protected $bulk;
    
15.     protected $writeConcern;
    / e8 O( X! Y1 d3 W* U, J, E
16.     protected $defaultConfig
    % y: I; i9 p: t( o7 `
17.         = [
    
18.             'hostname' => 'localhost',
      V; P4 I  M0 f* A" y: T
19.             'port' => '27017',
    
20.             'username' => '',
    
21.             'password' => '',
    - c4 \# r8 a% Q
22.             'database' => 'test'
    
23.         ];
    
24. 
    
25.     public function __construct($config) {
    ; w/ [. }, r9 [/ I4 K  f
26.         $config = array_merge($this->defaultConfig, $config);
    
27.         $mongoServer = "mongodb://";
    $ W& _. B* }3 m- w: q: P7 D' R
28.         if ($config['username']) {
      {; i! ~3 n- W. o/ X, ?" Y
29.             $mongoServer .= $config['username'] . ':' . $config['password'] . '@';
    ) [* ~, z/ Y) i% H4 c$ D
30.         }
    
31.         $mongoServer .= $config['hostname'];
    
32.         if ($config['port']) {
    
33.             $mongoServer .= ':' . $config['port'];
    6 D6 @! Z, m$ \8 y& C+ `5 V# c
34.         }
    
35.         $mongoServer .= '/' . $config['database'];
    * x; P* \- e8 G. R* I
36. 
    
37.         $this->mongodb = new Manager($mongoServer);
    6 z* a) ]) \  h! y; G, n- E
38.         $this->database = $config['database'];
    - f5 H5 R  V+ E' z0 V
39.         $this->collection = $config['collection'];
    
40.         $this->bulk = new BulkWrite();
    : A0 ~) V* X; M4 V" G- Z/ {
41.         $this->writeConcern = new WriteConcern(WriteConcern::MAJORITY, 100);
    & b1 B( V' t8 L; X4 L
42.     }
    
43. 
    
44.     public function query($where = [], $option = []) {
    : j) u3 i$ K- [: R
45.         $query = new Query($where, $option);
    , a2 b+ @* w$ w8 J, d; P
46.         $result = $this->mongodb->executeQuery("$this->database.$this->collection", $query);
    
47. 
    
48.         return json_encode($result);
    " ~. s0 z( t7 c2 B: `
49.     }
    
50. 
      U$ |5 v* l/ d# g
51.     public function count($where = []) {
    
52.         $command = new Command(['count' => $this->collection, 'query' => $where]);
    
53.         $result = $this->mongodb->executeCommand($this->database, $command);
    
54.         $res = $result->toArray();
    
55.         $count = 0;
    + n$ j: a7 I( m& _
56.         if ($res) {
    & F, x9 V# z* D! q1 E0 I1 `
57.             $count = $res[0]->n;
    % b; E" Y/ k! j- L$ r
58.         }
    
59. 
    
60.         return $count;
    
61.     }
    : p& |6 B* G7 Y/ V
62. 
    $ Y% a" B6 {9 j& ~( ?
63.     public function update($where = [], $update = [], $upsert = false) {
    ( m9 j$ z  r; i
64.         $this->bulk->update($where, ['$set' => $update], ['multi' => true, 'upsert' => $upsert]);
    1 C$ Q3 l& q: x
65.         $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
    - k- M3 K% e' h- L% ^: g
66. 
    
67.         return $result->getModifiedCount();
    
68.     }
    8 ]- F  S# K  x! N& u/ }: I1 o
69. 
    
70.     public function insert($data = []) {
    6 Z6 J' d1 C0 ]* N' r) i4 I/ E
71.         $this->bulk->insert($data);
    
72.         $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
    5 }% u$ V) j& Z; I5 F# d9 c; l
73. 
    
74.         return $result->getInsertedCount();
    
75.     }
    ' L1 n' ~0 ?3 }  s
76. 
    + u& q  q. ^( M6 s- a9 g
77.     public function delete($where = [], $limit = 1) {
    
78.         $this->bulk->delete($where, ['limit' => $limit]);
    + t! C5 ^4 Z, o+ l
79.         $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
    . J. ^  |% u# R- O
80. 
    
81.         return $result->getDeletedCount();
    
82.     }
    9 M) B+ A, S1 I8 `
83. }

复制代码

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

MongoDB 库1.连接

• 原
  * Y; ?7 G4 ~5 v7 i' {' u

1. new MongoClient();

复制代码

• 新
  : H  W* ]/ W0 p0 n0 m5 U- a; J

1. new MongoDB\Client();

复制代码

2.新增

• 原
  

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

复制代码

• 新
  3 Y$ k* a+ s" C- v! x

1. $resultOne = $collention->insertOne($array, $options);//单
   7 }% F1 e+ O% H; ~8 P' D( p
2. $lastId = $resultOne->getInsertedId();
   $ N6 `7 C$ X1 A, E8 k1 p/ i+ A# o
3. $resultMany = $collention->insertMany($array, $options);//多
   
4. $count = $resultMany->getInsertedCount();

复制代码

3.修改

• 原
  . h8 E( o; m7 n3 i5 L

1. $collention->update($condition, [
   % H4 L! S0 J$ T7 }
2.     '$set' => $values
   
3. ,[
   2 w. t7 H! Z2 e: a; Y$ Q
4.     'multiple' => true//多条，单条false
   
5. ]);

复制代码

• 新
  

1. $collection->updateOne(
   - L: I0 ^# s2 }  P5 F4 L
2.     ['state' => 'ny'],
   
3.     ['$set' => ['country' => 'us']]
   7 u6 r3 r1 c$ R4 ~- W
4. );
   
5. $updateResult = $collection->updateMany(
   . R4 {0 Y1 u. R# X  W/ e+ U
6.     ['state' => 'ny'],
   
7.     ['$set' => ['country' => 'us']]
   7 d5 w. Y" @% b8 |' p% B
8. );
   ) i/ d! ?( v. D( W! U
9. $count = $updateResult->getModifiedCount();

复制代码

4.查询

• 原
  

1. $cursor = $collection->find($condition, [
   
2.     'name' => true//指定字段
   
3. ]);
   3 u5 p# Z) [9 {  p" r5 |
4. $cursor->skip(5);
   " W0 f5 O" r) }
5. $cursor->limit(5);
   
6. $cursor->sort([
   
7.     'time' => -1
   
8. ]);

复制代码

• 新
  

1. $cursor = $collection->find($condition, [
   ' E1 \9 V1 v: R# r: {
2.     'skip' => 5,
     l, ?; C* Q+ R- K3 F7 T: H% o
3.     'limit' => 5,
   $ k4 u4 E" i0 V9 [9 P
4.     'sort' => [
   0 s2 e6 ^. ?6 C
5.         'time' => -1
   
6.     ],//排序
   
7.     'projection' => [
   
8.         'name' => 1//指定字段
   
9.     ]
   0 }. x* k$ q: f7 m" }0 Z  w) E
10. ]);

复制代码

5.删除

• 原
  

1. $collention->remove($condition, [
   
2.     'justOne' => false//删单条
   
3. ]);
   ' R! I5 V. W  E5 Q) I1 X. @
4. $collention->remove([]);//删所有

复制代码

• 新
  

1. $result = $collention->deleteOne($condition, $options);
   
2. $collention->deleteMany($condition, $options);
   
3. 
   
4. $result->getDeletedCount();

复制代码

补充

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

1. $collention->findAndModify([
   
2.     '_id' => $tableName//我在自增表中用其它的表名作主键
   5 Z; e# D. g7 b
3. ], [
   
4.     '$inc' => ['id' => 1]//自增
   ! k* S1 Y( Q, R. c3 D! g" y
5. ], [
   
6.     '_id' => 0
   - i' }4 M) n' y/ {! O+ ~5 O
7. ], [
   
8.     'new' => 1//返回修改后的结果，默认是修改前的
   
9. ]);

复制代码

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

1. $collention->findOneAndUpdate([
   
2.     '_id' => $tableName
   8 q) F! h  k/ V6 S) r
3. ], [
   
4.     '$inc' => ['id' => 1]
   
5. ], [
   ) n, T: ^* t& a, L1 s0 e
6.     'projection' => ['id' => 1],
   6 S8 V# n! T0 Z2 J
7.     'returnDocument' => MongoDB\Operation\FindOneAndUpdate::RETURN_DOCUMENT_AFTER
   & L5 h+ Y+ R. w7 C7 x, ]
8. ]);

复制代码

4 s  }% ]- T0 d2 K# C' k$ O