PHP实现的mongoDB数据库操作类完整实例

admin

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

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

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

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

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

面向集合存储，易存储对象类型的数据。
2 J8 N. s! w9 g9 F! }) l! v模式自由。
支持动态查询。
支持完全索引，包含内部对象。
支持查询。
支持复制和故障恢复。
/ B. n" y/ t! V' w9 }7 |使用高效的二进制数据存储，包括大型对象（如视频等）。
/ g9 u( \' T" e. Z  O自动处理碎片，以支持云计算层次的扩展性
支持RUBY，PYTHON，JAVA，C++，PHP等多种语言。
文件存储格式为BSON（一种JSON的扩展）
0 N# H. I- e' G3 E% }7 s可通过网络访问

所谓“面向集合”（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
   . Z4 ]: A: ~- S! t$ K
2. /**
   9 Z) Q1 r- f. F) ?' e& D
3. * PHP操作mongodb数据库操作类
   
4. */
   ( u1 ~# C7 E: ~6 }  V8 F
5. class Database {
   
6.   protected $database  = '';
   ! H- ^/ j$ D$ h% W) u% _
7.   protected $mo;
   
8.   /**
   : w6 Q$ B  A! x/ w
9.    * 构造方法
   5 j, Q' D& Q7 {% `
10.    */
    
11.   public function __construct() {
    8 W& S- B# P0 B. L9 a4 F2 ~
12.     $server = DBSERVER;
      k9 R' k8 R- u1 E% H
13.     $user = DBUSER;
    
14.     $password = DBPASS;
    
15.     $port = DBPORT;
    1 ~) u& ?6 N9 g- P
16.     $database = DBNAME;
    
17.     $mongo = $this->getInstance($server, $user, $password, $port);
    
18.     $this->database = $mongo->$database;
    8 B) R7 ^" G" B' r& E
19.   }
    4 z* Q/ n: r2 ?* O- v; m' s
20.   /**
    
21.    * 数据库单例方法
    
22.    * @param $server
    
23.    * @param $user
    " \2 {) [( \2 e, Q$ J4 _
24.    * @param $password
    ) t& ~% y; J* d6 v
25.    * @param $port
    
26.    * @return Mongo
    8 g5 K: i0 f" J' y+ }
27.    */
    2 W, O2 T, q, G) v, W$ a
28.   public function getInstance($server, $user, $password, $port) {
    + ?8 X' f3 y: ?3 [+ e( A
29.     if (isset($this->mo)) {
    
30.       return $this->mo;
    : _2 y+ u% a) X! t4 ?
31.     } else {
    
32.       if (!empty($server)) {
    
33.         if (!empty($port)) {
    8 |2 Z# }/ }( O- B0 X: a* S4 ~
34.           if (!empty($user) && !empty($password)) {
    
35.             $this->mo = new Mongo("mongodb://{$user}:{$password}@{$server}:{$port}");
    
36.           } else {
    
37.             $this->mo = new Mongo("mongodb://{$server}:{$port}");
    - e% l* T4 y9 J( n) x( W- l( ?
38.           }
    % c) Z: i2 W& i. P, K
39.         } else {
    3 p4 M/ {* H' o0 S' P
40.           $this->mo = new Mongo("mongodb://{$server}");
    
41.         }
    
42.       } else {
    9 T: D) r* T* g/ y- a, j! l9 ?
43.         $this->mo = new Mongo();
    4 L+ ?( M4 E9 O) Y, k% b
44.       }
    
45.       return $this->mo;
    1 B; ]$ T# [3 F
46.     }
    
47.   }
    ) E- }3 Q- |" N, N- M; G
48.   /**
    
49.    * 查询表中所有数据
    
50.    * @param $table
    
51.    * @param array $where
    
52.    * @param array $sort
      j, P6 |: p# o7 ]/ d' D
53.    * @param string $limit
    
54.    * @param string $skip
    
55.    * @return array|int
    & f7 l' E0 x* O3 N7 W
56.    */
    
57.   public function getAll($table, $where = array(), $sort = array(), $limit = '', $skip = '') {
    
58.     if (!empty($where)) {
    ! |- H* h0 M$ N
59.       $data = $this->database->$table->find($where);
    
60.     } else {
    % r# p( P. F0 P* Z; ~% w/ P
61.       $data = $this->database->$table->find();
    
62.     }
    ! P1 x3 d) E" U) W0 G
63.     if (!empty($sort)) {
    - D, m2 W! d$ d4 Y& N
64.       $data = $data->sort($sort);
    * N8 ?' z# o5 u# j. Y
65.     }
    
66.     if (!empty($limit)) {
    / d2 F- F! t" E
67.       $data = $data->limit($limit);
    
68.     }
    8 X+ ~, k7 h3 k4 @
69.     if (!empty($skip)) {
    ; _$ Z9 p5 H! y5 j2 l0 A
70.       $data = $data->skip($skip);
    2 \& k, H: Y' J
71.     }
    
72.     $newData = array();
    
73.     while ($data->hasNext()) {
    $ A2 b7 c0 c. E* H2 P# H
74.       $newData[] = $data->getNext();
    
75.     }
    0 H4 Z" O% _3 y- q( |5 I
76.     if (count($newData) == 0) {
    
77.       return 0;
    7 X2 S& w7 P0 }- c& e
78.     }
    . _4 L. M4 t: `* d: j
79.     return $newData;
    
80.   }
    
81.   /**
    " @) c" M* q4 t: J8 K/ G
82.    * 查询指定一条数据
    - b0 I$ L! i4 ]
83.    * @param $table
    & b9 _& y* F0 U  |
84.    * @param array $where
    2 O! T, ^: D; |) H! ]% F* n
85.    * @return int
    
86.    */
    
87.   public function getOne($table, $where = array()) {
    1 O4 h7 n' R' }. V  p
88.     if (!empty($where)) {
    6 r- g# N) E( o, H  Z5 o! z/ ]
89.       $data = $this->database->$table->findOne($where);
    
90.     } else {
    & K3 H2 C: C9 I
91.       $data = $this->database->$table->findOne();
    8 `- M" I( d5 X9 `3 \# y9 Z6 H! c
92.     }
    : M6 W' r; B! ?: ?% T
93.     return $data;
    / C0 D! K6 K+ H
94.   }
    
95.   /**
    
96.    * 统计个数
    
97.    * @param $table
    
98.    * @param array $where
    
99.    * @return mixed
    % h! p/ w6 H# n5 t5 U. E, M& z- T) x
100.    */
     
101.   public function getCount($table, $where = array()) {
     
102.     if (!empty($where)) {
     
103.       $data = $this->database->$table->find($where)->count();
     
104.     } else {
     . |) R% o+ s( n/ B
105.       $data = $this->database->$table->find()->count();
     $ q7 g# E4 w1 ?0 }/ Z6 O* A  g0 C( l
106.     }
     
107.     return $data;
     6 z! `# H- a* \
108.   }
     ( t5 X' x0 K3 K' T* k
109.   /**
     , a- o: X0 Q) E4 s7 p
110.    * 直接执行mongo命令
     * I1 {# ]4 k9 ]; j' L0 Q8 r
111.    * @param $sql
     4 |; m" S8 H& n* R
112.    * @return array
     5 @! n3 F$ C- d
113.    */
     
114.   public function toExcute($sql) {
     
115.     $result = $this->database->execute($sql);
     
116.     return $result;
     
117.   }
     
118.   /**
     , H# v# C0 x+ k. N% |( U+ h
119.    * 分组统计个数
     / G- H. K) R4 U! }$ u2 ~
120.    * @param $table
     ; |# u. m8 I: E0 \3 [- e7 [5 b" e
121.    * @param $where
     
122.    * @param $field
     
123.    */
     
124.   public function groupCount($table, $where, $field) {
     : U! h0 ^9 ~# s- S7 s5 n
125.     $cond = array(
     3 K' n, }3 f- H! x  ?1 X
126.       array(
     
127.         '$match' => $where,
     & ^3 D) _1 g, D+ |% _! J8 p# m- c. r
128.       ),
     7 Z. q0 G, N' B8 A" q
129.       array(
       h( g0 M- u$ e4 J6 N
130.         '$group' => array(
     
131.           '_id' => '
     , q( w) ^2 |: o/ o$ P2 _0 y, y
132. 
     ! a2 {2 A8 n# h( K0 r0 J8 Q% ~
133. . $field,
     6 E% v  `& c/ `: b7 Y. a' ?) ~
134.           'count' => array('$sum' => 1),
     
135.         ),
     
136.       ),
     5 Z/ k. i7 ^8 X
137.       array(
     
138.         '$sort' => array("count" => -1),
     
139.       ),
     . M8 b1 {+ t: L! r' f
140.     );
     . v/ H- _& |3 o0 ?' V4 t
141.     $this->database->$table->aggregate($cond);
     
142.   }
     " `- g0 ]4 V- M9 K
143.   /**
     
144.    * 删除数据
       F0 J; w+ t; T' Q3 Q" a5 Z
145.    * @param $table
     , L) `6 W( A, y+ D( h! A, c
146.    * @param $where
     
147.    * @return array|bool
       G8 o5 n4 I, D/ P# N" `
148.    */
     " Y; r3 A' s9 ?# g4 K/ M8 w8 D- w* O4 a
149.   public function toDelete($table, $where) {
     
150.     $re = $this->database->$table->remove($where);
     
151.     return $re;
     ; F2 _9 o6 e/ a3 ~7 j* W1 _
152.   }
     % \- i$ c0 f! e
153.   /**
     7 _( }- ~* u! W& C; ^7 `  F! i
154.    * 插入数据
     
155.    * @param $table
     
156.    * @param $data
     7 _- J# E& l! S" p; g" L
157.    * @return array|bool
     
158.    */
     
159.   public function toInsert($table, $data) {
     - ?' [- L7 d; l+ ]: q, o% Q4 x" i. @
160.     $re = $this->database->$table->insert($data);
     
161.     return $re;
     # J: h/ [% a8 `6 Z4 X/ t: h
162.   }
     
163.   /**
     
164.    * 更新数据
     , D. a0 X  R! F, X+ Y5 D4 n) w9 [
165.    * @param $table
     ' D, w/ z( K& r) s# S! [
166.    * @param $where
     
167.    * @param $data
     
168.    * @return bool
     8 P; L# E+ }% M" h  v5 Z4 K2 l; s
169.    */
     
170.   public function toUpdate($table, $where, $data) {
     
171.     $re = $this->database->$table->update($where, array('$set' => $data));
     
172.     return $re;
     3 I7 a. t2 S8 \8 ]1 d
173.   }
     & Y% A7 H4 l+ m9 b- V$ b
174.   /**
     
175.    * 获取唯一数据
     
176.    * @param $table
     
177.    * @param $key
     0 Q1 Q& U0 B1 O3 r- `) f! T' w/ \
178.    * @return array
     
179.    */
     4 R6 N9 o8 h; L# `' ?$ t# d0 w
180.   public function distinctData($table, $key, $query = array()) {
     ( {+ ~# r* q5 |! o7 }
181.     if (!empty($query)) {
     1 D( M3 _0 |; r5 y6 y
182.       $where = array('distinct' => $table, 'key' => $key, 'query' => $query);
     4 i, Z  \+ G! |4 L* f+ L1 [' U
183.     } else {
     ' ?; F( C5 V. N4 R2 B- c
184.       $where = array('distinct' => $table, 'key' => $key);
     # d. N' N0 I0 i& u/ t
185.     }
     
186.     $data = $this->database->command($where);
     % E2 u8 l* P7 u8 G" P
187.     return $data['values'];
     ( n+ D4 R1 Z  h; K) K9 c
188.   }
     
189. }
     # d9 S$ |( p( A( I
190. ?>

复制代码

; \. ^5 U5 M3 `( o3 }% Y
* ]- H  }1 _# f/ d1 m