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

admin

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

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

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

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

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

面向集合存储，易存储对象类型的数据。
模式自由。
: z, g* L5 P- Y8 f/ s支持动态查询。
8 _, Z7 v- G, i; A8 t支持完全索引，包含内部对象。
1 Z! i5 S+ A9 _) j1 o. z7 }支持查询。
支持复制和故障恢复。
( u. U1 I/ X: p使用高效的二进制数据存储，包括大型对象（如视频等）。
% K. g3 d, q6 a) D" m自动处理碎片，以支持云计算层次的扩展性
( E! g# [" o: R支持RUBY，PYTHON，JAVA，C++，PHP等多种语言。
1 k) i+ D( N5 `/ W$ _0 e% P文件存储格式为BSON（一种JSON的扩展）
可通过网络访问

所谓“面向集合”（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
   ( [6 b, \3 X! \! @( D" [/ R
2. /**
   ( c3 J+ I% j0 x
3. * PHP操作mongodb数据库操作类
   9 f& J9 m. {$ d6 p: G9 {3 i
4. */
   ! l9 o% n, o4 F) o. J
5. class Database {
   . r7 a1 M# O9 x! Y9 d. T6 [+ m
6.   protected $database  = '';
   
7.   protected $mo;
   % @: u3 A" j& }$ U
8.   /**
   1 a( A  Z1 g) K) w! W8 R; q
9.    * 构造方法
   
10.    */
      n# |. l# r6 C+ |. t
11.   public function __construct() {
    0 @. J# W- z# ?
12.     $server = DBSERVER;
    
13.     $user = DBUSER;
    , Z0 {! i; p  y! U4 i* i. q
14.     $password = DBPASS;
    3 n0 z7 z1 E/ h- v4 Z8 `3 [' Y" R! @
15.     $port = DBPORT;
    
16.     $database = DBNAME;
    4 ?/ j$ I- J5 F* v" Y3 L; |% w& `
17.     $mongo = $this->getInstance($server, $user, $password, $port);
    
18.     $this->database = $mongo->$database;
    ! x* {) Q4 _  |0 Z- Y6 k' d' N0 H
19.   }
    4 H% i7 M/ ]% V% Y% _' S
20.   /**
    
21.    * 数据库单例方法
    
22.    * @param $server
    + O! F" R7 r4 H4 \8 p0 s3 I
23.    * @param $user
    2 `; k6 t' q8 D& f- b$ e+ t
24.    * @param $password
    ( D: ?) K1 V% Z9 M0 l
25.    * @param $port
    
26.    * @return Mongo
    
27.    */
    3 O1 g* d: W3 G' B" A% s
28.   public function getInstance($server, $user, $password, $port) {
    
29.     if (isset($this->mo)) {
    
30.       return $this->mo;
    
31.     } else {
    
32.       if (!empty($server)) {
    
33.         if (!empty($port)) {
    
34.           if (!empty($user) && !empty($password)) {
    
35.             $this->mo = new Mongo("mongodb://{$user}:{$password}@{$server}:{$port}");
    9 e& ~0 ^+ R" K
36.           } else {
    7 n; s" Q1 h( ~5 g" c
37.             $this->mo = new Mongo("mongodb://{$server}:{$port}");
    
38.           }
    / `% T+ J! K) w6 C+ ]
39.         } else {
    ; |" P- L0 _7 R  d" k0 [
40.           $this->mo = new Mongo("mongodb://{$server}");
    
41.         }
    6 {( b7 g3 B+ t( K) v0 b/ ^
42.       } else {
    ! I& U4 x$ s& \; F+ s2 x. O5 X
43.         $this->mo = new Mongo();
    
44.       }
    1 X! K" W1 t% E
45.       return $this->mo;
    % \3 @9 T6 A+ z9 o0 ^% h2 Z! O. f+ a
46.     }
    7 l3 ]% p$ K; e
47.   }
    $ U, O: U: Y" r6 }& ?: w
48.   /**
    
49.    * 查询表中所有数据
    
50.    * @param $table
    
51.    * @param array $where
    
52.    * @param array $sort
    
53.    * @param string $limit
    
54.    * @param string $skip
    
55.    * @return array|int
    
56.    */
    5 a: p; S7 {/ e% K; B
57.   public function getAll($table, $where = array(), $sort = array(), $limit = '', $skip = '') {
    
58.     if (!empty($where)) {
      {3 s* N, _8 ?* ~& j
59.       $data = $this->database->$table->find($where);
    / P- b+ C( |5 _" m" ?
60.     } else {
    + Q4 `/ |/ W+ [5 y; N
61.       $data = $this->database->$table->find();
    4 ^$ R3 x* c; k
62.     }
    
63.     if (!empty($sort)) {
    
64.       $data = $data->sort($sort);
    % i8 J4 R3 c( k/ R! \
65.     }
    + J! p6 c7 Q: k1 d% a
66.     if (!empty($limit)) {
    
67.       $data = $data->limit($limit);
    & X) D0 U6 P  H  m8 R5 Q: U
68.     }
    
69.     if (!empty($skip)) {
    * s7 q" u, P9 A8 E6 r* l# V: p
70.       $data = $data->skip($skip);
    # h+ z1 Q4 n! b( @% ^. s
71.     }
    / }# o  U9 @' ?, v8 y% D% ]
72.     $newData = array();
    
73.     while ($data->hasNext()) {
    
74.       $newData[] = $data->getNext();
    
75.     }
    
76.     if (count($newData) == 0) {
      f6 p! T* @$ N) u
77.       return 0;
    8 s4 B1 s" [3 }" K
78.     }
    : ~& @. g8 Y1 b2 U  u- v* ?
79.     return $newData;
    " l9 a# M. A  ^6 X: x  w) H2 T2 u
80.   }
    
81.   /**
    
82.    * 查询指定一条数据
    8 X8 m8 Y5 D0 z4 q
83.    * @param $table
    0 ?6 f. ]7 ^- k  ^
84.    * @param array $where
    
85.    * @return int
    6 f+ r8 m! \/ s$ ~8 K6 Q
86.    */
    
87.   public function getOne($table, $where = array()) {
    1 g$ j9 z+ P1 E, w
88.     if (!empty($where)) {
    3 j0 E' _8 P- a, \% ~2 i
89.       $data = $this->database->$table->findOne($where);
    
90.     } else {
    ! V9 F) g- o+ R, \; p
91.       $data = $this->database->$table->findOne();
    ) p4 G& I, M* K+ M' {
92.     }
    
93.     return $data;
    1 N  T$ N2 n3 O9 {7 u/ o. G
94.   }
    
95.   /**
    : n/ o! H/ p" P9 r
96.    * 统计个数
    % \) ?3 O! O7 N
97.    * @param $table
    % z* q9 O7 c( S3 T
98.    * @param array $where
    # P# a6 O; u; m  k  O, q. B
99.    * @return mixed
    
100.    */
     
101.   public function getCount($table, $where = array()) {
     % a5 J, a- y! S; @% N- t
102.     if (!empty($where)) {
     
103.       $data = $this->database->$table->find($where)->count();
     
104.     } else {
     ) Z  z6 m5 d" c1 }- \
105.       $data = $this->database->$table->find()->count();
     
106.     }
     
107.     return $data;
     ) k1 E3 q: A" r
108.   }
     8 |. ?; e/ y$ @7 t- f0 l
109.   /**
     
110.    * 直接执行mongo命令
     
111.    * @param $sql
     
112.    * @return array
     % u5 y' Y* r3 j5 x% |' X- \) t
113.    */
     0 Y- x' H, E+ E8 T1 [- m
114.   public function toExcute($sql) {
     
115.     $result = $this->database->execute($sql);
     
116.     return $result;
     ' }- o' L5 S. N3 _
117.   }
     1 ?* d: {* M$ R; t
118.   /**
     
119.    * 分组统计个数
     & I% _% Q, z9 j: m1 V1 Q' ?
120.    * @param $table
       ^, X8 u1 ^/ u9 v
121.    * @param $where
     1 y" @: P+ [/ v+ E% h
122.    * @param $field
     $ F2 u) Z. ^5 f! u3 O; ]- b8 p6 Y
123.    */
     
124.   public function groupCount($table, $where, $field) {
     
125.     $cond = array(
     / n1 k0 x. Q4 G; ?* ]- V' U
126.       array(
     , g5 v* A# \& ~' i3 T0 E5 r3 J
127.         '$match' => $where,
     
128.       ),
     $ e  Y  a8 S; N3 P+ ?
129.       array(
     
130.         '$group' => array(
     
131.           '_id' => '
     % N6 f: c( t( ~  a; ]' E9 s+ {
132. 
     
133. . $field,
     
134.           'count' => array('$sum' => 1),
     
135.         ),
     : a: M5 ]! X  Z8 x
136.       ),
     * w' L' a8 U0 C4 `+ T5 h
137.       array(
     % g% l+ ?% s/ y& s
138.         '$sort' => array("count" => -1),
     
139.       ),
     4 `# I+ O9 c! E4 @! T
140.     );
     
141.     $this->database->$table->aggregate($cond);
     9 M$ \" K! W  U( U% ]1 _3 k
142.   }
     ' f( B) Q4 H! c: ~! n8 p& Z" b7 D; i
143.   /**
     
144.    * 删除数据
     ! o2 G4 ]0 n, c& C4 O. e
145.    * @param $table
     
146.    * @param $where
     
147.    * @return array|bool
     
148.    */
     & P( h8 a1 U0 S
149.   public function toDelete($table, $where) {
     + g! V! n& r0 M" p( }- X
150.     $re = $this->database->$table->remove($where);
     
151.     return $re;
     , O- g: @7 D; x
152.   }
     
153.   /**
     7 R  i4 r! k; }0 F# m( G6 R
154.    * 插入数据
     % _" q9 R$ C5 {: C1 T% R
155.    * @param $table
     
156.    * @param $data
     4 `/ r) K' k/ m" A( n
157.    * @return array|bool
     
158.    */
     
159.   public function toInsert($table, $data) {
     8 A* Z+ x6 H& C3 W8 ^4 b( }+ [% u
160.     $re = $this->database->$table->insert($data);
     
161.     return $re;
     + t5 `! q% Y, U/ I  V( f. Z
162.   }
     * T0 b  T" j+ z  l7 q" D' e
163.   /**
     ( d# T+ J' A. q9 E! i, I& _; `
164.    * 更新数据
     ( u: n2 Q4 {! ~$ `( k3 L
165.    * @param $table
     0 A+ l7 S# Z5 v
166.    * @param $where
     4 z4 _/ K) D  F5 s$ {
167.    * @param $data
     
168.    * @return bool
     + X7 p) x; X9 Z/ Y7 u# `2 R
169.    */
     
170.   public function toUpdate($table, $where, $data) {
     ( S/ U) X1 j+ g& @
171.     $re = $this->database->$table->update($where, array('$set' => $data));
     4 @6 F& O7 ~2 h8 I. S' {
172.     return $re;
     " D* ~3 P" s2 V  u) n. H' [
173.   }
     . G: D% Y# O  E3 Z4 e  ]
174.   /**
     
175.    * 获取唯一数据
     
176.    * @param $table
     ! e: E' D' ~$ J
177.    * @param $key
     ) ]( x+ }3 m3 P4 G. \! l$ k+ ?
178.    * @return array
     
179.    */
     3 S9 `  N  o# M7 [& Y
180.   public function distinctData($table, $key, $query = array()) {
     " m6 I) \& X0 S: n, u! ^
181.     if (!empty($query)) {
     
182.       $where = array('distinct' => $table, 'key' => $key, 'query' => $query);
     0 r: Z& D. n- ]# G3 O) I
183.     } else {
     
184.       $where = array('distinct' => $table, 'key' => $key);
     & C8 p/ o8 ?8 o; F6 a+ Y; q: ]& M
185.     }
     9 f8 x7 k3 r+ }6 r1 x
186.     $data = $this->database->command($where);
     
187.     return $data['values'];
     ) A5 W+ L, l/ d8 Z" F
188.   }
     
189. }
     
190. ?>

复制代码

8 l4 Q8 f- O8 ^7 M