升级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
   # v% x  D% a: U* P
2. 
   
3. use MongoDB\Driver\Manager;
   
4. use MongoDB\Driver\BulkWrite;
   
5. use MongoDB\Driver\WriteConcern;
   3 U& e5 ]$ F# i1 s4 ?
6. use MongoDB\Driver\Query;
   ; c9 y/ p6 b2 P$ Y# ^
7. use MongoDB\Driver\Command;
   & E$ l6 K/ l! i- G! o; U
8. 
   
9. class MongoDb {
   
10. 
    
11.     protected $mongodb;
    1 V! [* R* P* s3 A3 C, U
12.     protected $database;
    ' Q9 z. n0 ]/ v
13.     protected $collection;
    
14.     protected $bulk;
    + o; u# Y6 Z7 ?$ ^
15.     protected $writeConcern;
    
16.     protected $defaultConfig
    
17.         = [
    
18.             'hostname' => 'localhost',
    
19.             'port' => '27017',
    ' H" [+ t2 Q$ {8 D+ u
20.             'username' => '',
    ' o) A% x  k5 O% w1 m
21.             'password' => '',
    
22.             'database' => 'test'
    1 w' D0 {& M) N
23.         ];
    
24. 
    
25.     public function __construct($config) {
    ' T- {' ]8 Z/ F8 c/ n1 v& L
26.         $config = array_merge($this->defaultConfig, $config);
    
27.         $mongoServer = "mongodb://";
    ! T8 F. d2 a  t7 e6 K2 q% B: J
28.         if ($config['username']) {
    
29.             $mongoServer .= $config['username'] . ':' . $config['password'] . '@';
    
30.         }
    
31.         $mongoServer .= $config['hostname'];
    ' I. `9 _4 @- X  {" p8 I4 G
32.         if ($config['port']) {
    8 j8 g+ ]0 k  }. b$ M
33.             $mongoServer .= ':' . $config['port'];
    9 Z( D  [5 M- n4 J1 G
34.         }
    " Q4 |' }) g; }4 ^1 P
35.         $mongoServer .= '/' . $config['database'];
      a1 W/ ~# Q5 p0 m! T
36. 
    ; Z! S5 J6 D' F
37.         $this->mongodb = new Manager($mongoServer);
    
38.         $this->database = $config['database'];
    
39.         $this->collection = $config['collection'];
    
40.         $this->bulk = new BulkWrite();
    
41.         $this->writeConcern = new WriteConcern(WriteConcern::MAJORITY, 100);
    & u! H% P, `3 e$ r- P9 H& T! d
42.     }
    8 k1 r+ P+ y0 O% D' E* Q
43. 
    7 D. d6 _4 f. ?: j, C
44.     public function query($where = [], $option = []) {
    & Q6 o& n$ P" l! A( _& o6 d
45.         $query = new Query($where, $option);
    9 d4 q6 R" n$ m& S
46.         $result = $this->mongodb->executeQuery("$this->database.$this->collection", $query);
    ! i2 H  ]2 z/ T2 U7 R6 ^# t& H0 _# m6 p7 f
47. 
    1 {1 Z6 T* C( L% L8 v
48.         return json_encode($result);
    2 S6 j2 i% b! ^. q
49.     }
    
50. 
    1 _. d. z) B: l) l* w. w9 V4 \
51.     public function count($where = []) {
    6 `, T1 o, i+ @" C# y2 j
52.         $command = new Command(['count' => $this->collection, 'query' => $where]);
    . i8 G( a, K; {4 Q4 K" r" K; t
53.         $result = $this->mongodb->executeCommand($this->database, $command);
    ; N' {( i9 B; j4 q! ]
54.         $res = $result->toArray();
    1 A- s, ]' }- Z( u
55.         $count = 0;
    
56.         if ($res) {
    $ P' R: I0 M1 D1 \. r
57.             $count = $res[0]->n;
    
58.         }
    
59. 
    $ V3 Z; ~/ x0 d3 F+ ~$ o: H
60.         return $count;
    # J" \2 d$ ~5 J! @6 B
61.     }
    5 p8 h$ w* r1 d7 h) s' c
62. 
    
63.     public function update($where = [], $update = [], $upsert = false) {
    
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. 
    
67.         return $result->getModifiedCount();
    8 s  }4 r) Z/ S: {6 L7 i, Z
68.     }
    6 Q; `. e9 z2 @: `/ f: I; O: M- v
69. 
    ) l; K; N; p# s/ C( l, T
70.     public function insert($data = []) {
    
71.         $this->bulk->insert($data);
    
72.         $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
    0 W+ f2 y' {+ F
73. 
    " [( I0 o6 x. H4 y$ q3 G' y" C
74.         return $result->getInsertedCount();
    
75.     }
    ! B/ {* O( R1 ?$ l4 o) [
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);
    1 L) K, c7 _; o
80. 
    / e" P6 F" v, j0 q$ U: P
81.         return $result->getDeletedCount();
    4 o) b3 n, i4 V& U8 G- z
82.     }
    ' W; K) X/ z$ z0 n2 J
83. }

复制代码

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

MongoDB 库1.连接

• 原
  

1. new MongoClient();

复制代码

• 新
  * y" H) l9 g+ }0 o5 K2 x( J

1. new MongoDB\Client();

复制代码

2.新增

• 原
  

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

复制代码

• 新
  / i7 ~  Y7 X6 n0 B/ H

1. $resultOne = $collention->insertOne($array, $options);//单
   
2. $lastId = $resultOne->getInsertedId();
   ; Q3 G9 x( {! N9 ~0 ?
3. $resultMany = $collention->insertMany($array, $options);//多
   , ^3 s5 }& Z9 G; }
4. $count = $resultMany->getInsertedCount();

复制代码

3.修改

• 原
  9 \6 Z& I3 B+ Z! p

1. $collention->update($condition, [
   
2.     '$set' => $values
   $ |+ x7 y7 G" T( d* q" C' i& Z) U
3. ,[
   
4.     'multiple' => true//多条，单条false
   
5. ]);

复制代码

• 新
  ) }, e' x0 F' F8 L' Y

1. $collection->updateOne(
   
2.     ['state' => 'ny'],
   
3.     ['$set' => ['country' => 'us']]
   8 E! W- @- j- o
4. );
   
5. $updateResult = $collection->updateMany(
   5 T0 @; f4 Z+ q) P
6.     ['state' => 'ny'],
   
7.     ['$set' => ['country' => 'us']]
   
8. );
   
9. $count = $updateResult->getModifiedCount();

复制代码

4.查询

• 原
  " \  h$ I- |0 G

1. $cursor = $collection->find($condition, [
   
2.     'name' => true//指定字段
   
3. ]);
   , U' Y) V. S; e6 y- [6 J3 c
4. $cursor->skip(5);
   
5. $cursor->limit(5);
   
6. $cursor->sort([
     g. q5 a, P0 v$ I
7.     'time' => -1
   
8. ]);

复制代码

• 新
  

1. $cursor = $collection->find($condition, [
   
2.     'skip' => 5,
   
3.     'limit' => 5,
   
4.     'sort' => [
   
5.         'time' => -1
   / K5 @8 ?' s% m6 S  G& ?# A! V
6.     ],//排序
   ' ^! o) [4 b3 a! {
7.     'projection' => [
   6 |' s, I  ]+ g
8.         'name' => 1//指定字段
   
9.     ]
   $ V$ a: E1 ~$ y: D; ]
10. ]);

复制代码

5.删除

• 原
  

1. $collention->remove($condition, [
   9 q1 d1 K- k+ {$ a4 g1 I+ D3 s1 q
2.     'justOne' => false//删单条
   
3. ]);
   
4. $collention->remove([]);//删所有

复制代码

• 新
  

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

复制代码

补充

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

1. $collention->findAndModify([
   - J' @; k$ p% T, I8 _
2.     '_id' => $tableName//我在自增表中用其它的表名作主键
   
3. ], [
   
4.     '$inc' => ['id' => 1]//自增
   3 }( V$ r1 _" `$ D7 r' r
5. ], [
   
6.     '_id' => 0
   
7. ], [
   
8.     'new' => 1//返回修改后的结果，默认是修改前的
   
9. ]);

复制代码

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

1. $collention->findOneAndUpdate([
   ; P% M% N4 z) R8 c9 N/ ^' N
2.     '_id' => $tableName
   
3. ], [
   8 N( N! M# s* _' l  \; S# ]9 c
4.     '$inc' => ['id' => 1]
   ( V3 j" s6 R& G, k( E" ?
5. ], [
   
6.     'projection' => ['id' => 1],
   
7.     'returnDocument' => MongoDB\Operation\FindOneAndUpdate::RETURN_DOCUMENT_AFTER
   
8. ]);

复制代码

! C5 L% n, F& k( P9 ]7 J  w4 P/ C% _