cncml手绘网

标题: PHP实现的mongoDB数据库操作类完整实例 [打印本页]

---

作者: admin    时间: 2019-3-9 02:49
标题: PHP实现的mongoDB数据库操作类完整实例

本文实例讲述了PHP实现的mongoDB数据库操作类。分享给大家供大家参考，具体如下：

最近的项目开发中使用的数据库是mongodb数据库，因为小编的公司也是刚刚使用mongodb数据库，所以之前没有封装好的mongodb数据库操作类拿来使用，所以小编在项目中自己封装了一个mongodb数据库操作类，特拿出来分享，不尽人意的地方希望大家勿喷。

众所周知，mongodb是典型的nosql数据库的代表，受到很多开发者的追捧，近几年尤为火热，mongodb的流行不是没有原因的，下边给大家简单介绍下MongoDB。

MongoDB是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。他支持的数据结构非常松散，是类似json的bjson格式，因此可以存储比较复杂的数据类型。Mongo最大的特点是他支持的查询语言非常强大，其语法有点类似于面向对象的查询语言，几乎可以实现类似关系数据库单表查询的绝大部分功能，而且还支持对数据建立索引。

它的特点是高性能、易部署、易使用，存储数据非常方便。主要功能特性有：

面向集合存储，易存储对象类型的数据。
模式自由。
8 L, T: [9 W; N* G0 ^$ {支持动态查询。
支持完全索引，包含内部对象。
支持查询。
; }6 D3 {3 P+ M! O, J, B支持复制和故障恢复。
2 x) O  i" o) I- X) x+ o& M* D使用高效的二进制数据存储，包括大型对象（如视频等）。
: D; B2 J. g3 K& U# h8 N3 q3 F自动处理碎片，以支持云计算层次的扩展性
支持RUBY，PYTHON，JAVA，C++，PHP等多种语言。
文件存储格式为BSON（一种JSON的扩展）
- O; d4 p; r  L+ m+ d5 \可通过网络访问

所谓“面向集合”（Collenction-Orented），意思是数据被分组存储在数据集中，被称为一个集合（Collenction)。每个 集合在数据库中都有一个唯一的标识名，并且可以包含无限数目的文档。集合的概念类似关系型数据库（RDBMS）里的表（table），不同的是它不需要定 义任何模式（schema)。

模式自由（schema-free)，意味着对于存储在mongodb数据库中的文件，我们不需要知道它的任何结构定义。如果需要的话，你完全可以把不同结构的文件存储在同一个数据库里。

存储在集合中的文档，被存储为键-值对的形式。键用于唯一标识一个文档，为字符串类型，而值则可以是各中复杂的文件类型。我们称这种存储形式为BSON（Binary Serialized dOcument Format）。

MongoDB服务端可运行在Linux、Windows或OS X平台，支持32位和64位应用，默认端口为27017。推荐运行在64位平台，因为MongoDB

在32位模式运行时支持的最大文件尺寸为2GB。

MongoDB把数据存储在文件中（默认路径为：/data/db），为提高效率使用内存映射文件进行管理。

小编自己封装的PHP操作MongoDB数据库的数据库操作类源码如下，仅供参考。

1. <?php
   * x# y4 |& K6 Z( c) E% v! X8 i6 K: f/ i
2. /**
   
3. * PHP操作mongodb数据库操作类
   
4. */
   
5. class Database {
   * p3 u% D2 J8 N8 P: t* \* I
6.   protected $database  = '';
   
7.   protected $mo;
   
8.   /**
   $ \  I1 U, G! k+ d" V
9.    * 构造方法
   
10.    */
    + {1 X, Y0 _" m# F3 h! |) T
11.   public function __construct() {
    
12.     $server = DBSERVER;
    
13.     $user = DBUSER;
    8 w# W6 |5 X) x; R; m  R
14.     $password = DBPASS;
    ! l7 v. B$ Y7 d2 w
15.     $port = DBPORT;
    
16.     $database = DBNAME;
    
17.     $mongo = $this->getInstance($server, $user, $password, $port);
    ) W' z& Z2 b* z
18.     $this->database = $mongo->$database;
    
19.   }
    
20.   /**
    $ P# k0 y8 c7 K/ L2 N
21.    * 数据库单例方法
    , X* ?' O% e, L8 B* u8 @
22.    * @param $server
    ; Q/ |  x6 |+ E) d* J
23.    * @param $user
      c" [4 F8 y! C; C) g
24.    * @param $password
    
25.    * @param $port
    - P2 s) d' z# ^# |3 L
26.    * @return Mongo
    $ j( h& ?6 B3 P
27.    */
    / O) {* p8 s- Z
28.   public function getInstance($server, $user, $password, $port) {
    ' u& |6 k' V$ `4 X2 T" j5 ~1 Q; h) f/ J
29.     if (isset($this->mo)) {
    5 k) n2 T5 c7 i6 K
30.       return $this->mo;
    $ @, U+ W+ V  s" B4 N& F
31.     } else {
    , g* I; y8 Z' r! `% A" d
32.       if (!empty($server)) {
    # F2 D  ]7 E+ `3 \9 j0 G
33.         if (!empty($port)) {
    
34.           if (!empty($user) && !empty($password)) {
    6 M& T1 B! p+ W/ n* j4 }
35.             $this->mo = new Mongo("mongodb://{$user}:{$password}@{$server}:{$port}");
    : o) X7 G4 I8 O1 L2 x# u1 i8 X
36.           } else {
    5 E- S0 B! @' i2 @1 z& y5 Q2 y
37.             $this->mo = new Mongo("mongodb://{$server}:{$port}");
    
38.           }
    " B+ H! S" T+ N7 C
39.         } else {
    
40.           $this->mo = new Mongo("mongodb://{$server}");
    
41.         }
    + ]& V! I( z7 N# H7 I7 w6 e
42.       } else {
    3 N+ ^3 e' j6 k, i
43.         $this->mo = new Mongo();
    7 K5 \; L" _9 Z1 O
44.       }
    
45.       return $this->mo;
    
46.     }
    
47.   }
    * g/ Q" R! }: d) ^: f4 }
48.   /**
    / ]2 y6 T1 O  [
49.    * 查询表中所有数据
    
50.    * @param $table
    9 D6 J5 U$ C& A, q0 Y
51.    * @param array $where
    
52.    * @param array $sort
    
53.    * @param string $limit
    ' V' I- {& A- @3 ]
54.    * @param string $skip
    ! K% Y; L3 `8 d$ k: y" K7 a; T. o* u
55.    * @return array|int
    . l1 o: ]' z) G7 E; _) I1 O
56.    */
    8 z# g3 B( C4 E+ r* `1 C
57.   public function getAll($table, $where = array(), $sort = array(), $limit = '', $skip = '') {
    
58.     if (!empty($where)) {
    
59.       $data = $this->database->$table->find($where);
    
60.     } else {
    $ j0 ~8 J* X' V: n: e& E
61.       $data = $this->database->$table->find();
    
62.     }
    4 y2 o9 u: i% w- q/ p+ f; Z
63.     if (!empty($sort)) {
    
64.       $data = $data->sort($sort);
    % O& C2 U; ^: Z: y
65.     }
    $ ^! E5 {) Y" o5 _
66.     if (!empty($limit)) {
    
67.       $data = $data->limit($limit);
    : E, h" z# f4 U8 s/ K
68.     }
    $ L) @8 z9 j$ K( e1 k0 h7 x
69.     if (!empty($skip)) {
    * G8 X) s- U6 W$ {4 Y6 q
70.       $data = $data->skip($skip);
    * z7 A% q+ d) J3 h% F, I8 A
71.     }
    4 @) w- G$ M" h& @
72.     $newData = array();
    
73.     while ($data->hasNext()) {
    0 z& g% ?, S0 X4 Z/ a4 O
74.       $newData[] = $data->getNext();
    + W+ `6 g& @" s4 w1 ]- k& C
75.     }
    
76.     if (count($newData) == 0) {
    
77.       return 0;
    : l; c, s( o8 F  N) }+ x
78.     }
    
79.     return $newData;
    - T3 X" |; l/ ~3 R3 ]- B/ m! A
80.   }
    
81.   /**
    
82.    * 查询指定一条数据
    3 ?9 o3 z6 k# F. Y( J
83.    * @param $table
    7 o  |4 r! `8 ^; q3 T* M. b
84.    * @param array $where
    
85.    * @return int
    , {; p) R* C: Z( _% v
86.    */
    % I/ a1 k: R1 V+ p% y
87.   public function getOne($table, $where = array()) {
    
88.     if (!empty($where)) {
    8 j6 f# f" Y9 u- D; N6 N$ ]
89.       $data = $this->database->$table->findOne($where);
    ( C. V: N) y- N2 t
90.     } else {
    
91.       $data = $this->database->$table->findOne();
    6 X( q0 K+ r- X1 n  U/ ^9 q
92.     }
    & t+ u* J. R+ `6 Y
93.     return $data;
    
94.   }
    
95.   /**
    ! X- U) @) P& E: b* X/ K
96.    * 统计个数
    
97.    * @param $table
    $ _6 d% ]7 J3 H4 B
98.    * @param array $where
    
99.    * @return mixed
    
100.    */
     
101.   public function getCount($table, $where = array()) {
     : L% g; ?, L, H* `* q; f
102.     if (!empty($where)) {
     1 q+ g9 O' t' O* {- W, t* @
103.       $data = $this->database->$table->find($where)->count();
     
104.     } else {
     
105.       $data = $this->database->$table->find()->count();
     
106.     }
     % L3 N# ]2 v* _1 O0 w
107.     return $data;
     1 P. Z* {: Z1 g3 K: W# W8 w4 M
108.   }
     
109.   /**
       r/ M4 P4 _* w1 s2 |, ?0 x
110.    * 直接执行mongo命令
     
111.    * @param $sql
     
112.    * @return array
     
113.    */
     
114.   public function toExcute($sql) {
     
115.     $result = $this->database->execute($sql);
     $ F6 S) d! Y& S* F" [! G+ W# y
116.     return $result;
     
117.   }
     ! X2 h. Z. b- r* c3 |
118.   /**
     
119.    * 分组统计个数
     0 |) s* X- Z* d; y; T, [
120.    * @param $table
     
121.    * @param $where
     
122.    * @param $field
     8 ^0 {6 n; l1 l4 B3 O9 z" _
123.    */
     
124.   public function groupCount($table, $where, $field) {
     
125.     $cond = array(
     ; `* J. K2 x; v  ?1 F  I
126.       array(
     
127.         '$match' => $where,
     
128.       ),
     
129.       array(
     5 g( c/ x' u) ?0 J, S4 W
130.         '$group' => array(
     : q- z! c3 m' X6 H2 g: _
131.           '_id' => '
     7 @& e) Q0 x0 e1 v
132. 
     % \  t+ ?; p- t6 K3 y  ?/ u3 k+ B1 _
133. . $field,
     ( f# k' f9 U* m' J
134.           'count' => array('$sum' => 1),
     ; Z5 o0 a, w  I* ~4 s" D3 l
135.         ),
     % e# |. f3 o* H) j6 z7 d" e
136.       ),
     8 k; h1 N' }# @$ g; V! {; t
137.       array(
     * P+ b4 m* N7 E9 n3 J/ P. g
138.         '$sort' => array("count" => -1),
     9 v) ~! x2 A  s& V
139.       ),
     4 k2 U5 ^9 z3 e! A1 @) |3 e
140.     );
     1 L. b$ v  x9 ~! V) V! x3 O
141.     $this->database->$table->aggregate($cond);
     * x  j/ x2 c7 F1 z" G
142.   }
     
143.   /**
     ; z% _& z: R$ _$ Z
144.    * 删除数据
     4 C! Q: E- m" R  }( p, U
145.    * @param $table
     0 H! O8 s* V/ e+ k6 o
146.    * @param $where
     , g9 Q! @8 d5 S, K/ }. D3 s
147.    * @return array|bool
     + h+ A' P7 @" M7 X- a; n: [
148.    */
     3 D/ M. S/ N) X* F
149.   public function toDelete($table, $where) {
     . \' x- j5 j/ v7 a! ~5 V
150.     $re = $this->database->$table->remove($where);
     , ^; u0 v8 r+ s/ t* q
151.     return $re;
     
152.   }
     
153.   /**
     
154.    * 插入数据
     ; d. T2 X) d: N! v9 T0 W# m
155.    * @param $table
     4 g# t. c" B1 G
156.    * @param $data
     , i# o$ g- o2 \
157.    * @return array|bool
     
158.    */
     4 P8 {+ j% f8 k2 n, ]
159.   public function toInsert($table, $data) {
     ; B' w; T. j9 m% J0 d) e* C
160.     $re = $this->database->$table->insert($data);
     
161.     return $re;
     
162.   }
     
163.   /**
     
164.    * 更新数据
     7 P3 \# o7 L" j( ?5 v3 r
165.    * @param $table
     
166.    * @param $where
     
167.    * @param $data
     
168.    * @return bool
     
169.    */
     
170.   public function toUpdate($table, $where, $data) {
     
171.     $re = $this->database->$table->update($where, array('$set' => $data));
     
172.     return $re;
     * r3 i$ a0 u. V* X) @
173.   }
     
174.   /**
     
175.    * 获取唯一数据
     * e  i  v" p6 H9 E
176.    * @param $table
     
177.    * @param $key
       x) V1 w! m: R( h2 }. j
178.    * @return array
     
179.    */
     1 z9 s1 ?3 t1 ]" v$ F
180.   public function distinctData($table, $key, $query = array()) {
     
181.     if (!empty($query)) {
     ' \1 h0 u" H* I* G2 ~9 ^% c5 l$ l  H
182.       $where = array('distinct' => $table, 'key' => $key, 'query' => $query);
     ( _, ^+ c7 L( T1 `
183.     } else {
     # y4 ?2 e% s5 S2 s. J
184.       $where = array('distinct' => $table, 'key' => $key);
     - m" J5 S- {( x6 b' |
185.     }
     7 f: U8 x9 V& p0 v. t3 B. F
186.     $data = $this->database->command($where);
     : K7 a4 i4 W/ w
187.     return $data['values'];
     
188.   }
     ) e2 z( l! [- `
189. }
     
190. ?>

复制代码

5 `: X0 |* B, |2 e7 X

---

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

Powered by Discuz! X3.2