升级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
   0 e+ a. t3 {) P. h  u* U9 U7 N; {1 N; q, E
2. 
   
3. use MongoDB\Driver\Manager;
   
4. use MongoDB\Driver\BulkWrite;
   
5. use MongoDB\Driver\WriteConcern;
   
6. use MongoDB\Driver\Query;
   
7. use MongoDB\Driver\Command;
   
8. 
   : `# C% G, c# F  G
9. class MongoDb {
   1 [+ M4 E5 {5 w( J' `9 i1 l( u
10. 
    : w4 ~" \8 b, Z
11.     protected $mongodb;
    
12.     protected $database;
    
13.     protected $collection;
    
14.     protected $bulk;
    ( Q6 U+ t9 g; I+ }. t
15.     protected $writeConcern;
    ; o. r, ~# Z+ O# P7 q
16.     protected $defaultConfig
    
17.         = [
    
18.             'hostname' => 'localhost',
    
19.             'port' => '27017',
    
20.             'username' => '',
    
21.             'password' => '',
    5 o1 e1 i5 \# I- @7 z$ }
22.             'database' => 'test'
    
23.         ];
    " F. ^% ]3 S' M+ f
24. 
    : K6 ^% }- L2 p6 d' h
25.     public function __construct($config) {
    
26.         $config = array_merge($this->defaultConfig, $config);
    7 p" D* h+ Y+ G3 y% N# y; u7 T
27.         $mongoServer = "mongodb://";
    7 K9 ~: ]! x+ \0 U& @
28.         if ($config['username']) {
    8 }& [; ]% e$ m% b! x
29.             $mongoServer .= $config['username'] . ':' . $config['password'] . '@';
    
30.         }
    
31.         $mongoServer .= $config['hostname'];
    , x. T( f2 a7 X; e& u2 v& L
32.         if ($config['port']) {
    
33.             $mongoServer .= ':' . $config['port'];
    
34.         }
    
35.         $mongoServer .= '/' . $config['database'];
    
36. 
    ! Z4 \; b/ p2 o% V+ b: H! z! _" e& j* y
37.         $this->mongodb = new Manager($mongoServer);
    
38.         $this->database = $config['database'];
    + B4 |2 C+ P' X8 ^# w) ~7 e8 r, N7 L; ^% y
39.         $this->collection = $config['collection'];
    
40.         $this->bulk = new BulkWrite();
    ( S/ J& v1 U( ^, j6 b2 I5 l0 D+ S
41.         $this->writeConcern = new WriteConcern(WriteConcern::MAJORITY, 100);
    1 A* B; z( u. E* T/ k" B: G
42.     }
    
43. 
    
44.     public function query($where = [], $option = []) {
    
45.         $query = new Query($where, $option);
    
46.         $result = $this->mongodb->executeQuery("$this->database.$this->collection", $query);
    
47. 
    ; K3 x) ?+ O. _
48.         return json_encode($result);
    
49.     }
    
50. 
    # W* i* U' p6 @/ `5 U
51.     public function count($where = []) {
    , A9 }+ s! y4 G5 h9 a
52.         $command = new Command(['count' => $this->collection, 'query' => $where]);
    6 I# \" E' L! m7 N) Y- z0 o% G
53.         $result = $this->mongodb->executeCommand($this->database, $command);
    
54.         $res = $result->toArray();
    
55.         $count = 0;
    
56.         if ($res) {
    " t7 e" m% ?  t, |4 P8 {
57.             $count = $res[0]->n;
    
58.         }
    2 U2 N; x5 S: j8 P2 R) k
59. 
    
60.         return $count;
    ' c' y) ]+ k# `# D5 v
61.     }
    6 M' i0 g+ @6 g; T
62. 
    
63.     public function update($where = [], $update = [], $upsert = false) {
    # n3 I  n$ c* p2 s2 [
64.         $this->bulk->update($where, ['$set' => $update], ['multi' => true, 'upsert' => $upsert]);
    
65.         $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
    4 K8 Y5 l' u2 f- f* P. c
66. 
    * P; ?. l, h8 |3 s- w/ v
67.         return $result->getModifiedCount();
    9 t% U! R0 h& w  N! J" ]( @0 L
68.     }
    
69. 
    ( P6 y" x! q+ @! N, F- _
70.     public function insert($data = []) {
    4 |) }( e- Q) {6 |' G
71.         $this->bulk->insert($data);
    9 y& m3 H: t4 I0 `
72.         $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
    6 Y+ M- j! Y& Q1 f: }7 D& R/ i$ L
73. 
    
74.         return $result->getInsertedCount();
    ( W! z! ~  ]$ x" V5 D
75.     }
    
76. 
    
77.     public function delete($where = [], $limit = 1) {
    
78.         $this->bulk->delete($where, ['limit' => $limit]);
    
79.         $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
    
80. 
    
81.         return $result->getDeletedCount();
    9 n. v" N% g* v" \4 p! |- c
82.     }
    
83. }

复制代码

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

MongoDB 库1.连接

• 原
  * D( o. ^% X3 _% S

1. new MongoClient();

复制代码

• 新
  

1. new MongoDB\Client();

复制代码

2.新增

• 原
  

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

复制代码

• 新
  

1. $resultOne = $collention->insertOne($array, $options);//单
   
2. $lastId = $resultOne->getInsertedId();
   + D6 q) y- x/ b2 \4 L/ U
3. $resultMany = $collention->insertMany($array, $options);//多
   9 b' U1 \2 ?; X
4. $count = $resultMany->getInsertedCount();

复制代码

3.修改

• 原
  4 U. c7 v+ N3 o' N* d( G+ n+ U

1. $collention->update($condition, [
   4 Q7 y. F% C2 U& v# `; [; J/ @2 Q
2.     '$set' => $values
   
3. ,[
   1 I. I. M9 l$ Z" c
4.     'multiple' => true//多条，单条false
   # K! Y" y$ w( D" b7 g/ d
5. ]);

复制代码

• 新
  5 H3 [2 c# p  S: \6 c; }: l4 K$ `

1. $collection->updateOne(
   4 _: K  L) r+ o2 y1 Y
2.     ['state' => 'ny'],
   1 }) R% N( P( d
3.     ['$set' => ['country' => 'us']]
   & x) c  H0 J* ^0 m$ ?/ U# T+ x) b
4. );
   4 q% Y+ x5 v! }9 Y
5. $updateResult = $collection->updateMany(
   
6.     ['state' => 'ny'],
   ' c8 `3 `7 u: D2 ?0 |% i# _
7.     ['$set' => ['country' => 'us']]
   
8. );
   ! ^) V& o+ n$ \" K4 w
9. $count = $updateResult->getModifiedCount();

复制代码

4.查询

• 原
  0 C: E) M: S# X) M6 y

1. $cursor = $collection->find($condition, [
   6 \/ P: W$ h1 S+ N; |/ k" z
2.     'name' => true//指定字段
   0 r- t5 G, j1 I+ `& Z) w7 W
3. ]);
   & c/ v- I& o6 {) ^, B4 ]! }
4. $cursor->skip(5);
   
5. $cursor->limit(5);
   : s+ q) H8 X) e7 q
6. $cursor->sort([
   
7.     'time' => -1
   7 g: D! L3 _/ K  d4 W
8. ]);

复制代码

• 新
  ) T/ V* N* V; X0 ~; z! x6 P9 Z

1. $cursor = $collection->find($condition, [
   
2.     'skip' => 5,
   ! e/ F9 A5 s/ t9 s( U3 Q
3.     'limit' => 5,
   
4.     'sort' => [
   * C8 y9 O) F9 k& \2 i- w0 ~4 A
5.         'time' => -1
   
6.     ],//排序
   ) ~  Z5 a, ?6 k& I7 q
7.     'projection' => [
   8 w$ V3 C& j4 W
8.         'name' => 1//指定字段
   
9.     ]
   ' s+ O5 M! g! ~) @/ H1 C9 B3 j
10. ]);

复制代码

5.删除

• 原
  

1. $collention->remove($condition, [
   * U* z$ ?7 K3 J. B: H
2.     'justOne' => false//删单条
   
3. ]);
     g/ Q  A( y/ S
4. $collention->remove([]);//删所有

复制代码

• 新
  , M5 w( P' w0 q0 h

1. $result = $collention->deleteOne($condition, $options);
   
2. $collention->deleteMany($condition, $options);
   
3. 
   - z/ }! {% H/ S7 L9 r5 P6 \3 B
4. $result->getDeletedCount();

复制代码

补充

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

1. $collention->findAndModify([
   
2.     '_id' => $tableName//我在自增表中用其它的表名作主键
   
3. ], [
   
4.     '$inc' => ['id' => 1]//自增
   
5. ], [
   6 I7 P5 {  ~4 M
6.     '_id' => 0
   " F/ P* {6 _% r% _: V( W
7. ], [
   4 N; d& e# a/ [! Z; O8 _/ y
8.     'new' => 1//返回修改后的结果，默认是修改前的
   0 g" L2 m! J% [
9. ]);

复制代码

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

1. $collention->findOneAndUpdate([
   " G3 u! I! B5 I: [$ w% [
2.     '_id' => $tableName
   
3. ], [
   
4.     '$inc' => ['id' => 1]
   
5. ], [
   2 Y; H+ a4 h+ r. L$ t
6.     'projection' => ['id' => 1],
   8 }7 J7 A5 o/ b) x0 f" m  ?
7.     'returnDocument' => MongoDB\Operation\FindOneAndUpdate::RETURN_DOCUMENT_AFTER
   " i; d* h/ T) z1 ?
8. ]);

复制代码

; Q; M( F2 J, q( \8 @4 O# r/ P