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
   
2. 
   
3. use MongoDB\Driver\Manager;
   ' y* z6 C; i! \
4. use MongoDB\Driver\BulkWrite;
   5 u: w1 ^  }* {" W  |& ?; @* F  M
5. use MongoDB\Driver\WriteConcern;
   
6. use MongoDB\Driver\Query;
   
7. use MongoDB\Driver\Command;
   + P* ]! @4 g- W$ E0 A: z& g
8. 
   " J; H( R6 h2 U* y! x/ k
9. class MongoDb {
   * l1 m, f0 @# s. ^. }6 e
10. 
    
11.     protected $mongodb;
    ; M& a2 ^8 `, Y8 ~- d2 V* g5 R1 ~4 ?8 E
12.     protected $database;
    
13.     protected $collection;
    , m2 Q1 e, ?$ Z# ~4 E/ K% |
14.     protected $bulk;
    
15.     protected $writeConcern;
    
16.     protected $defaultConfig
    0 D& [" A1 b  V2 G! _+ [( x5 u+ M
17.         = [
    " c* o  Q( H  Z9 E2 L& Z
18.             'hostname' => 'localhost',
    
19.             'port' => '27017',
    7 E4 z. C% ?" q3 P/ v" k
20.             'username' => '',
    
21.             'password' => '',
    7 p+ _3 L1 W, _  l+ h
22.             'database' => 'test'
    * q7 ?5 v* I6 p& D( U
23.         ];
    - ]; L5 f- x3 u2 ]" `2 X* S; x
24. 
    + T9 _  P+ J8 s% Q6 ?2 ]+ `5 w
25.     public function __construct($config) {
    1 O+ r4 z6 F! ~3 r4 C' L! ?+ |* p
26.         $config = array_merge($this->defaultConfig, $config);
    ! _- L) s+ |% \3 X& U
27.         $mongoServer = "mongodb://";
    
28.         if ($config['username']) {
    
29.             $mongoServer .= $config['username'] . ':' . $config['password'] . '@';
    3 @0 q  c7 O. k  }) J/ [
30.         }
    , L, {# m$ s' q( b/ }" L4 _: `
31.         $mongoServer .= $config['hostname'];
    1 C0 \2 {/ H  |0 O, P7 h
32.         if ($config['port']) {
    
33.             $mongoServer .= ':' . $config['port'];
    , ]- m* i+ {5 H* Z' F
34.         }
    
35.         $mongoServer .= '/' . $config['database'];
    , i. N) y& i; t9 z. V$ z6 k
36. 
    
37.         $this->mongodb = new Manager($mongoServer);
    7 o4 h% G, u& |& p5 C! l! {
38.         $this->database = $config['database'];
    % {) T) C; e7 ^7 @3 L$ x; f, q( h
39.         $this->collection = $config['collection'];
    2 H! r1 @1 i- V& W8 S; T# `% e
40.         $this->bulk = new BulkWrite();
    % s- m% s9 A, b' O% Q8 |, H
41.         $this->writeConcern = new WriteConcern(WriteConcern::MAJORITY, 100);
    2 f9 Y% L  s+ ?$ V' m
42.     }
    
43. 
    / @$ Q# d/ z9 m! N% b1 V# t: W- a: y
44.     public function query($where = [], $option = []) {
    1 f7 X* u9 G$ @6 v# ~$ A# x
45.         $query = new Query($where, $option);
    
46.         $result = $this->mongodb->executeQuery("$this->database.$this->collection", $query);
    
47. 
    ) b% E. h8 p7 l1 w
48.         return json_encode($result);
    
49.     }
      V3 g. `7 a( L% d$ C
50. 
    
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();
    0 t" f& P3 }$ S1 k
55.         $count = 0;
    4 z+ _; Y) I. r# e! |
56.         if ($res) {
    
57.             $count = $res[0]->n;
    " s7 ?% B8 k8 ?6 I! A4 K8 [
58.         }
    
59. 
      h; _0 K. r2 n" `/ X3 G1 B
60.         return $count;
    
61.     }
    & w. Q6 S7 _# [. @  z# G: l! q/ a
62. 
    9 R& i- h8 W. r) i
63.     public function update($where = [], $update = [], $upsert = false) {
    * j1 a1 p' p8 N* I+ j
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. 
    . {6 z/ }1 h6 W4 c# E- ^/ Z
67.         return $result->getModifiedCount();
    " M( I1 v% s9 }7 u2 @) `" |
68.     }
    
69. 
    1 ?5 e* t3 A; w0 L9 ^5 p$ `
70.     public function insert($data = []) {
    2 X0 |" q  c( E: m. b8 a5 B
71.         $this->bulk->insert($data);
      @; l# b, W6 z4 V" s  K& P
72.         $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
    
73. 
    5 J9 |% s, V0 t: k. k0 U+ I( p
74.         return $result->getInsertedCount();
    0 j* R+ _1 z: s8 y
75.     }
    7 e4 D: O" b! ^# \+ F( s
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);
    % f# O( F4 O0 \
80. 
    
81.         return $result->getDeletedCount();
    8 b$ {) `  h  T' B
82.     }
    9 U) G8 Y" U/ e4 t  u
83. }

复制代码

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

MongoDB 库1.连接

• 原
  

1. new MongoClient();

复制代码

• 新
  ! I; {% l3 y" j% _6 ~

1. new MongoDB\Client();

复制代码

2.新增

• 原
  1 s. [7 p5 I# j3 Y" ^; p/ m6 U

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

复制代码

• 新
  

1. $resultOne = $collention->insertOne($array, $options);//单
   $ [% ~/ ^  B/ L$ F9 T
2. $lastId = $resultOne->getInsertedId();
   2 h8 _1 }8 u8 P' Z0 @. V
3. $resultMany = $collention->insertMany($array, $options);//多
   
4. $count = $resultMany->getInsertedCount();

复制代码

3.修改

• 原
  

1. $collention->update($condition, [
   6 ]. g$ p. C4 {1 t' u. n1 e
2.     '$set' => $values
   ' M+ t4 B; p4 ?& n/ S
3. ,[
   
4.     'multiple' => true//多条，单条false
   
5. ]);

复制代码

• 新
  + K3 N, n, g) o

1. $collection->updateOne(
   9 p& p% e* D" H* D/ G. s6 U
2.     ['state' => 'ny'],
   
3.     ['$set' => ['country' => 'us']]
   
4. );
   7 I# w! [$ a3 ~: v! v+ i
5. $updateResult = $collection->updateMany(
   
6.     ['state' => 'ny'],
   
7.     ['$set' => ['country' => 'us']]
   1 M% _; J* u6 Z9 Q
8. );
   * J% A% _( C7 O) p8 B. t
9. $count = $updateResult->getModifiedCount();

复制代码

4.查询

• 原
  , }: k, Q$ P+ ]( l8 x

1. $cursor = $collection->find($condition, [
   " t9 {, z" x) k( P# Y+ N4 c
2.     'name' => true//指定字段
   
3. ]);
   , q% Y( u- P* m( }- r
4. $cursor->skip(5);
     d. \1 w, x# `8 Y  C5 s
5. $cursor->limit(5);
   . F$ A$ B0 q2 L2 P
6. $cursor->sort([
   . j& t$ Z8 D1 Z6 a5 c- Z
7.     'time' => -1
   " g' ?2 M* \* ]/ b/ Y+ w! g
8. ]);

复制代码

• 新
  

1. $cursor = $collection->find($condition, [
   $ i' [0 P( o" f. d0 Q! [9 K
2.     'skip' => 5,
   
3.     'limit' => 5,
   ( O5 y% d% M6 K* O3 R  C
4.     'sort' => [
   
5.         'time' => -1
   , a0 ]% X; R# `( R( r! k" d) U4 G
6.     ],//排序
   ; m$ ^9 ?. d9 _5 `) n2 N
7.     'projection' => [
   
8.         'name' => 1//指定字段
   . i4 n  a# C5 k! `5 k0 i- m  Q
9.     ]
   
10. ]);

复制代码

5.删除

• 原
  * J" n: L8 B3 W9 x6 i

1. $collention->remove($condition, [
   
2.     'justOne' => false//删单条
   " ?+ x: q6 Q9 g: U8 D
3. ]);
   
4. $collention->remove([]);//删所有

复制代码

• 新
  ; m# ^0 |, O7 J6 g( a

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

复制代码

补充

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

1. $collention->findAndModify([
   
2.     '_id' => $tableName//我在自增表中用其它的表名作主键
   
3. ], [
   
4.     '$inc' => ['id' => 1]//自增
   + |% X5 W- S( v% o
5. ], [
   ; \& D' P& {6 m
6.     '_id' => 0
   
7. ], [
   
8.     'new' => 1//返回修改后的结果，默认是修改前的
   $ W8 g, s2 u) F( q
9. ]);

复制代码

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

1. $collention->findOneAndUpdate([
   
2.     '_id' => $tableName
   
3. ], [
   
4.     '$inc' => ['id' => 1]
   
5. ], [
   . V, ~2 T; O8 `9 E  \1 n) m( u0 ^
6.     'projection' => ['id' => 1],
   ) q8 Q9 Z) d& R6 `
7.     'returnDocument' => MongoDB\Operation\FindOneAndUpdate::RETURN_DOCUMENT_AFTER
   ' L0 S( K5 u$ E0 }! z* t* w
8. ]);

复制代码

, X5 b, H3 z  c: z& J8 _
) v$ w' Z* v# o' j

---

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

Powered by Discuz! X3.2