cncml手绘网

标题: 升级PHP7操作MongoDB [打印本页]

---

作者: admin    时间: 2019-3-19 14:24
标题: 升级PHP7操作MongoDB

使用 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
   . U, [& E" m. L. S
2. 
   * F& M0 y2 }0 B, _
3. use MongoDB\Driver\Manager;
   
4. use MongoDB\Driver\BulkWrite;
   7 o8 Y' Y( R! x7 D/ G1 T# {; }
5. use MongoDB\Driver\WriteConcern;
   
6. use MongoDB\Driver\Query;
   ' w2 ^# I. A( B$ j" o% |
7. use MongoDB\Driver\Command;
   
8. 
   
9. class MongoDb {
   - a4 |  P5 w. W, B4 r( D
10. 
    8 R, N# t3 V% X  N7 \. I" u
11.     protected $mongodb;
    
12.     protected $database;
    
13.     protected $collection;
      E" W" A# O2 M% `7 a. b
14.     protected $bulk;
    5 M: E  G1 \  ], f3 j5 W4 [8 f0 W
15.     protected $writeConcern;
    / r8 ?0 i! l0 C4 n* |
16.     protected $defaultConfig
    $ r2 T+ G! I$ t
17.         = [
    . e- A1 T$ o$ `
18.             'hostname' => 'localhost',
      [  _% f  c( @8 O: b1 Y
19.             'port' => '27017',
    
20.             'username' => '',
      t* A0 K- _, {% o
21.             'password' => '',
    
22.             'database' => 'test'
    2 \* K0 }9 ~6 p2 @8 ]* Z
23.         ];
    ) y+ @9 a7 T9 ], F) u
24. 
    
25.     public function __construct($config) {
    & W& \4 ~4 @3 }6 v: D8 I
26.         $config = array_merge($this->defaultConfig, $config);
    % D- ^' W6 L; w( n& Z
27.         $mongoServer = "mongodb://";
    
28.         if ($config['username']) {
    " n0 |1 u$ |: M$ b% b
29.             $mongoServer .= $config['username'] . ':' . $config['password'] . '@';
    
30.         }
    & j* b( \9 u0 z  z
31.         $mongoServer .= $config['hostname'];
    
32.         if ($config['port']) {
    5 j, q8 ^2 @% E
33.             $mongoServer .= ':' . $config['port'];
    
34.         }
    $ u2 @9 ^6 L- l; v  x0 B% \1 B: k$ O
35.         $mongoServer .= '/' . $config['database'];
    
36. 
    + R5 `  w! \" f2 R& M2 Y
37.         $this->mongodb = new Manager($mongoServer);
    3 e5 D0 b$ z$ i$ \: v3 C
38.         $this->database = $config['database'];
    
39.         $this->collection = $config['collection'];
    2 z: J+ M, D0 f9 C( z% G
40.         $this->bulk = new BulkWrite();
    1 S+ D0 i' e1 p% \3 I# p5 p
41.         $this->writeConcern = new WriteConcern(WriteConcern::MAJORITY, 100);
    6 F: U- j3 N! D
42.     }
    6 i8 a1 j, i' K  R+ F% r
43. 
    + V  G; j) G. @
44.     public function query($where = [], $option = []) {
    , \/ s9 Y1 U, T. z9 z: _
45.         $query = new Query($where, $option);
    
46.         $result = $this->mongodb->executeQuery("$this->database.$this->collection", $query);
    
47. 
    
48.         return json_encode($result);
    
49.     }
    3 \+ T! }- C% |- f% D6 s' |
50. 
    
51.     public function count($where = []) {
    
52.         $command = new Command(['count' => $this->collection, 'query' => $where]);
    + j! K0 B9 h2 |4 [. Z& o+ Q
53.         $result = $this->mongodb->executeCommand($this->database, $command);
    
54.         $res = $result->toArray();
    
55.         $count = 0;
    - b( S  N2 x4 b8 C5 f- T1 n
56.         if ($res) {
    6 P. g) [% i  T1 p* W1 n
57.             $count = $res[0]->n;
    : D0 q9 E) R! r/ K: ~) b& X
58.         }
    & S& c& \6 I6 f% l
59. 
    + v5 r+ w6 `( k& K
60.         return $count;
    
61.     }
    : |# `3 Y$ s' A7 N5 n# c/ Q) C
62. 
    % i: o- v6 E! P$ u& x% o( K
63.     public function update($where = [], $update = [], $upsert = false) {
    $ g1 I- R: Y; a+ A
64.         $this->bulk->update($where, ['$set' => $update], ['multi' => true, 'upsert' => $upsert]);
    
65.         $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
    / y: D. Y: y3 U5 H# A/ g
66. 
    
67.         return $result->getModifiedCount();
    # h! f+ V0 ~% L0 {) E$ k
68.     }
    
69. 
    
70.     public function insert($data = []) {
    
71.         $this->bulk->insert($data);
    * n5 m) \3 ?! t# ?  A
72.         $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
      P- C9 M3 t" {9 y
73. 
    
74.         return $result->getInsertedCount();
    2 f! Q! B1 U. X3 R- }
75.     }
    
76. 
    
77.     public function delete($where = [], $limit = 1) {
    ! W# O9 m0 r3 i; z3 K  W- O  r
78.         $this->bulk->delete($where, ['limit' => $limit]);
    
79.         $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
    % R. y  V' N8 M) a8 v
80. 
    : ~( w! f) Q9 r( l# W# }1 r0 G% h
81.         return $result->getDeletedCount();
    " \+ k$ N; W  h/ @; Z$ G
82.     }
    7 O4 h$ c9 R6 r9 j. B5 V
83. }

复制代码

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

MongoDB 库1.连接

• 原
  * y+ r' w# f0 J1 X4 v5 H

1. new MongoClient();

复制代码

• 新
  

1. new MongoDB\Client();

复制代码

2.新增

• 原
  

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

复制代码

• 新
  " Z; w+ W& v+ I3 u  ~

1. $resultOne = $collention->insertOne($array, $options);//单
   
2. $lastId = $resultOne->getInsertedId();
   
3. $resultMany = $collention->insertMany($array, $options);//多
   ! g1 r  w6 |5 o+ w
4. $count = $resultMany->getInsertedCount();

复制代码

3.修改

• 原
  0 J9 e% w# v$ r/ M6 m+ w0 t5 F

1. $collention->update($condition, [
   " o& D+ @1 @" P( ~' i" y& i
2.     '$set' => $values
   
3. ,[
   
4.     'multiple' => true//多条，单条false
   
5. ]);

复制代码

• 新
  

1. $collection->updateOne(
   
2.     ['state' => 'ny'],
   
3.     ['$set' => ['country' => 'us']]
   3 l! ^4 g4 z$ R1 d! W& b1 K
4. );
   + Z1 h" [0 V& U+ w' p7 e
5. $updateResult = $collection->updateMany(
   
6.     ['state' => 'ny'],
     b0 |' W, W7 \# [& @' V- N5 b
7.     ['$set' => ['country' => 'us']]
   
8. );
   6 c) U) B6 F* p: l/ a
9. $count = $updateResult->getModifiedCount();

复制代码

4.查询

• 原
  

1. $cursor = $collection->find($condition, [
   / \+ @, b  q. X- C" ?# W3 O- }4 }$ q
2.     'name' => true//指定字段
   
3. ]);
   6 S3 i- q+ q& c" ?
4. $cursor->skip(5);
   6 [9 T9 X! r% q: `5 v9 Q4 [
5. $cursor->limit(5);
   . S& R- P. h7 |
6. $cursor->sort([
   : W1 R3 S( v" m2 D% Y* ~! R
7.     'time' => -1
   # x* Q( [# W. [) X
8. ]);

复制代码

• 新
  

1. $cursor = $collection->find($condition, [
   
2.     'skip' => 5,
   
3.     'limit' => 5,
   
4.     'sort' => [
   
5.         'time' => -1
   
6.     ],//排序
   
7.     'projection' => [
   ) P) r6 o$ ]4 u2 M5 m
8.         'name' => 1//指定字段
   
9.     ]
   
10. ]);

复制代码

5.删除

• 原
  2 O. ~+ j% W$ A* h9 f

1. $collention->remove($condition, [
   8 }3 Y* I; P8 i/ l! j8 Y
2.     'justOne' => false//删单条
   
3. ]);
   
4. $collention->remove([]);//删所有

复制代码

• 新
  

1. $result = $collention->deleteOne($condition, $options);
   
2. $collention->deleteMany($condition, $options);
   6 z  q& g% J* f
3. 
   3 |- w. ]1 U4 T+ l3 Q6 \. V6 k* e
4. $result->getDeletedCount();

复制代码

补充

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

1. $collention->findAndModify([
   # F4 c: v: t6 L0 b" m
2.     '_id' => $tableName//我在自增表中用其它的表名作主键
   
3. ], [
   
4.     '$inc' => ['id' => 1]//自增
   
5. ], [
   
6.     '_id' => 0
   5 i2 V+ `8 F# q) u
7. ], [
   
8.     'new' => 1//返回修改后的结果，默认是修改前的
   
9. ]);

复制代码

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

1. $collention->findOneAndUpdate([
   % g( h3 X0 Q/ A+ K1 Z8 ^
2.     '_id' => $tableName
   : J& g! x5 b9 S& V
3. ], [
   - U- B6 @/ }3 j# n2 y7 o0 ~
4.     '$inc' => ['id' => 1]
   
5. ], [
   . Z3 l( J/ M0 x
6.     'projection' => ['id' => 1],
   
7.     'returnDocument' => MongoDB\Operation\FindOneAndUpdate::RETURN_DOCUMENT_AFTER
   
8. ]);

复制代码

% \& s  c. o4 C

---

欢迎光临 cncml手绘网 (http://bbs.cncml.com/)

Powered by Discuz! X3.2