本文实例讲述了PHP实现的mongoDB数据库操作类。分享给大家供大家参考,具体如下: 最近的项目开发中使用的数据库是mongodb数据库,因为小编的公司也是刚刚使用mongodb数据库,所以之前没有封装好的mongodb数据库操作类拿来使用,所以小编在项目中自己封装了一个mongodb数据库操作类,特拿出来分享,不尽人意的地方希望大家勿喷。 众所周知,mongodb是典型的nosql数据库的代表,受到很多开发者的追捧,近几年尤为火热,mongodb的流行不是没有原因的,下边给大家简单介绍下MongoDB。 MongoDB是一个介于关系数据库和非关系数据库之间的产品,是非关系数据库当中功能最丰富,最像关系数据库的。他支持的数据结构非常松散,是类似json的bjson格式,因此可以存储比较复杂的数据类型。Mongo最大的特点是他支持的查询语言非常强大,其语法有点类似于面向对象的查询语言,几乎可以实现类似关系数据库单表查询的绝大部分功能,而且还支持对数据建立索引。 它的特点是高性能、易部署、易使用,存储数据非常方便。主要功能特性有: 面向集合存储,易存储对象类型的数据。
2 s$ \7 @8 `* C* X# Z模式自由。
3 i6 m) ^0 l7 X6 K( A- K支持动态查询。5 [( R! }$ g2 c. [; D' f9 R* m
支持完全索引,包含内部对象。" z5 @% C! [# h! {. u! r8 d; b
支持查询。1 ?* K- f: E8 A' N% Y3 N( C
支持复制和故障恢复。
( H7 a2 M8 b$ U# X/ e4 y使用高效的二进制数据存储,包括大型对象(如视频等)。
V5 K. d, L8 e8 d2 r) e# Z" Y5 e. w6 n自动处理碎片,以支持云计算层次的扩展性9 }: G) a, i {$ l) B! ?
支持RUBY,PYTHON,JAVA,C++,PHP等多种语言。! q! X" e2 G& L
文件存储格式为BSON(一种JSON的扩展)+ v |7 v+ Y$ Q, ?, |, R2 P0 F4 Z2 u
可通过网络访问 所谓“面向集合”(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数据库的数据库操作类源码如下,仅供参考。 - <?php: K" A: R6 j, X. T- P
- /**
5 K( |* f3 @2 p - * PHP操作mongodb数据库操作类
7 O# u. Q5 v3 }& m- [! w2 J& T) D0 W: ^4 g - */. g1 |* n% m* ~0 B9 E
- class Database {. s+ s. v4 m3 L0 d; Y+ r
- protected $database = '';
; `4 ~: T8 m X0 x/ i% O- y - protected $mo;
2 l* R9 \6 R8 ^3 R6 Z" L: ` y - /**5 @* s! Y2 t9 b* Z5 ?- j
- * 构造方法1 R% n& l8 A$ `, d' ^9 i0 {# J
- */
' e' T0 h3 y' p4 H, e, i) V' c- L - public function __construct() {
6 {4 B* D& T6 Q; G - $server = DBSERVER;: L: v7 t# v( X2 g' X o, x
- $user = DBUSER;
( V) E- w5 z% w% H - $password = DBPASS;, b6 L1 h4 m3 I& l& M3 ]
- $port = DBPORT;
# D0 V* x& c- \0 g% L - $database = DBNAME;
; c4 k- M/ c" Z - $mongo = $this->getInstance($server, $user, $password, $port);
8 l8 `; {' ]& ` - $this->database = $mongo->$database; L+ h5 ~( c" L' P3 ~: @
- }9 C$ W. s+ n1 d, u& ~
- /**6 h0 D& C6 Y$ T5 ~ F& Y
- * 数据库单例方法
0 g2 B2 z$ Z/ B0 o3 W - * @param $server
- a7 p1 ?/ J5 I" ?& l t7 j - * @param $user. m: y/ z# ^ j4 v+ q
- * @param $password
; ^0 _) g5 \; `7 o% e8 s' a/ r9 z - * @param $port
: o# w9 q+ `6 M - * @return Mongo& M. w7 ~$ T& H
- */4 r9 _. C9 z. g
- public function getInstance($server, $user, $password, $port) {5 a9 T# @: n3 d; W" d
- if (isset($this->mo)) {0 ~7 y2 B! V* D3 {* Z4 \
- return $this->mo;1 Z" D9 x# |2 W
- } else {& T0 G5 i6 ^6 H/ i! ^, s' G2 b
- if (!empty($server)) {
: C; L( k/ F1 {2 r - if (!empty($port)) {* s; i2 {( I6 k/ t! G6 Z, y
- if (!empty($user) && !empty($password)) {* |3 n" Z: g% m) L
- $this->mo = new Mongo("mongodb://{$user}:{$password}@{$server}:{$port}");7 @* I p& V. J+ z. `) |+ A
- } else {! z) T& ]& ~% t) O7 f7 ~% p/ t3 Y
- $this->mo = new Mongo("mongodb://{$server}:{$port}");
9 `2 W$ \( N; \; d+ C& }& G( r - }
7 q% p% V/ V6 A8 o& G. q; \ - } else {
. Z& ]* b! K7 n: I1 U - $this->mo = new Mongo("mongodb://{$server}");$ |+ b2 F v2 [0 l) Q+ y/ h
- }6 }: E5 S5 G& U7 l
- } else {+ t6 T- R/ k! F0 K" ]
- $this->mo = new Mongo();7 n( X7 L! J! U! x: w* f
- }, ^; Y( w5 P' h; w' h
- return $this->mo;
6 w0 O1 _+ K9 F2 ~2 z! V' S9 }9 i - }
3 C. u9 S/ a5 _: @0 K2 D) E. Y - }
, g7 t" [2 \) ]. E% d* k- I4 y - /**
+ _+ O5 s, Q1 m; H `6 C - * 查询表中所有数据
( l( o/ D, ~; B6 M2 ]. x A) i1 g% n - * @param $table
2 t: |8 H# m& ]; C! \8 V - * @param array $where
$ k" q' T" Z6 ] - * @param array $sort
/ q' r8 W( q# E/ a, o - * @param string $limit5 _* r4 Z! t1 U' q n: g
- * @param string $skip
% z5 y: U' P) A0 n+ W# U - * @return array|int* e; a0 d6 B3 s
- */
% Q! U- S: p# Y2 b& G - public function getAll($table, $where = array(), $sort = array(), $limit = '', $skip = '') {
, a- v0 y6 l7 K& v - if (!empty($where)) {% V9 k) d1 d% y7 h2 c
- $data = $this->database->$table->find($where);5 H8 W: \6 o- _5 C* F
- } else {
! J2 L+ E) m9 @+ i& i C - $data = $this->database->$table->find(); r0 m! a+ X- |( T+ y! w
- }
% @: n5 j7 s/ q2 o% O; W, L - if (!empty($sort)) {
; ^. c% I2 ~( P: z4 } - $data = $data->sort($sort);
^& Y0 b4 w! } - }3 l7 J1 ~7 S/ K' f2 y$ R$ K
- if (!empty($limit)) {
( k9 Q* z3 U* q# B8 H2 Q2 K - $data = $data->limit($limit);; n% H) \% P1 x- J. ~+ T( X
- }. R" l! O% o4 \: Y
- if (!empty($skip)) {3 r1 L0 E+ o# C8 y
- $data = $data->skip($skip);
0 X3 m( [' W+ y" z! W( t - }
, q" L9 B k- F- W' Z - $newData = array(); r; s0 \* C0 V- w1 n
- while ($data->hasNext()) {
" J! o( o8 p0 r5 g/ g/ `7 m3 ]2 c - $newData[] = $data->getNext();9 [0 G8 ?& ?6 N! }
- }% J$ y) V- t) u+ `; {" @
- if (count($newData) == 0) {
7 _+ [0 j( i, B0 Q7 }: w& \0 c - return 0;& Q0 T5 d9 n2 L* A
- }
1 B# F% b/ ?/ O' M5 r4 [ - return $newData;5 X/ L* U3 K: f+ z. E, P( Q
- }& d, {- ^4 J ~1 ^7 q
- /**7 Y" z% |1 i9 z% z
- * 查询指定一条数据; A+ a6 _# G7 {
- * @param $table
; v% K- R* O/ {% E - * @param array $where
3 _. n5 Z) U, n - * @return int8 [1 n7 F0 X8 j; \
- */
. d" ^' p' U( g. ` - public function getOne($table, $where = array()) {$ P$ I1 K5 P& q4 y8 E6 {
- if (!empty($where)) {3 E! ^0 X- I0 A; i9 a. D
- $data = $this->database->$table->findOne($where);4 Y/ ] I ]0 W' i t! Z' _8 B' ~
- } else {
8 u$ F, u7 d5 Q' c - $data = $this->database->$table->findOne();2 t; s# H. k |3 @" G+ S* `9 O
- }) T% T0 {9 Q4 o6 K1 b
- return $data;" S+ D5 Z; u" ~+ p! T
- }1 x0 t* r' H7 x: z t
- /**
& w0 S w: x8 U' F2 G8 c+ Y - * 统计个数
0 D% W5 W# p$ R& }" ~% K) ~" w - * @param $table
+ z1 R) S- X* s6 E. G* @2 y6 w - * @param array $where
6 g2 L/ `% x5 v7 E+ Q! L& f @ - * @return mixed
) d1 e3 N- s, y' L - */( Q5 l. Z) v* ~
- public function getCount($table, $where = array()) {
$ _$ j6 U2 o; Y& i# E2 Z - if (!empty($where)) {' {+ v6 X# {: A# u
- $data = $this->database->$table->find($where)->count();
0 D4 J/ i; Y9 n v* k# e0 B - } else {
/ M5 ^5 J- T: C: c( e0 W - $data = $this->database->$table->find()->count();& E$ A* x: P4 @9 z0 }; | ?
- }2 ?. L! {6 d" R
- return $data;8 Q5 H5 ?! D) H
- } S; T5 R* \, d6 e5 L( F
- /*** O: n( ~( I9 g- B: X$ O5 f
- * 直接执行mongo命令
# `' U/ n e+ a1 W' D - * @param $sql
$ v F5 `; P, _4 E) s( z/ Z - * @return array
5 e: K. j$ o/ o; T8 l# w - */
3 `% d% u3 n" i/ o3 F, s - public function toExcute($sql) {( i* E+ ?( Z U: h* T
- $result = $this->database->execute($sql);$ z# D8 w( Z4 {8 b1 N. O
- return $result;
6 g4 t- L" x# D E; x- n7 G' P7 g - }
+ k' H* P7 @0 p; n - /**
/ Q b. ]; n- f1 C5 s - * 分组统计个数
3 R& ]( f; f$ a2 `3 | - * @param $table% d' m: c) c+ t- I
- * @param $where9 F" G. V# K% ~3 S! ~) d, R8 }+ u2 [
- * @param $field
8 x1 h7 }9 o6 w - */1 @2 W" x1 f4 R+ r
- public function groupCount($table, $where, $field) {9 n$ R Y8 M# w$ u: k: M
- $cond = array(9 n5 f, t0 T! h! S7 I
- array(
0 G Q1 b' J' m. B3 [% O - '$match' => $where,- z, [3 I, }# ]( E) L' K
- ),, t" f" p7 Q+ J6 b5 a6 Z
- array(
( o7 d. @/ ~1 j1 V - '$group' => array(
# T) h* g; ]" V& z9 p; V - '_id' => '
2 S- j, ~8 y6 J; H4 F2 R" _; k - $ a4 ^- W; c# j3 \( ?* w
- . $field,8 \+ A) M/ x) t
- 'count' => array('$sum' => 1),) u) S8 |2 Q- a! Z' C) f+ a' p0 r
- ),9 T' o7 \! g9 C- ?
- ),
1 x* _2 M, y* I7 {5 a6 Z% U7 W! c - array(
1 p7 p6 w' N: P' c - '$sort' => array("count" => -1),1 `5 u8 C0 O) d
- ),
+ n1 x1 T) ~- H3 [ h9 n/ ` - );
( `* Q% N5 I! m; Q - $this->database->$table->aggregate($cond);- X# z# ?( O2 ^% y/ L. s8 @9 E
- }
& o% S3 C- a6 I4 f$ \ - /**
- h/ N7 V% G/ P4 l- u( W/ b5 g7 B - * 删除数据& V* F2 n) z! ?& y0 K" B
- * @param $table
0 C, ~9 H2 x! ?9 O' u" [: U - * @param $where: }# g0 Z; q: z, c
- * @return array|bool) \! d5 A+ Z- ?& ^! q1 X9 C. H( F
- */
! B& s3 T: m' `. f. R, | - public function toDelete($table, $where) {% s9 B5 F0 |! R; E& {/ ]. @
- $re = $this->database->$table->remove($where);
# W! r7 T ^2 U) Q; Z% w9 t* q A - return $re;
# x) G' q* E* Y! T - }/ h1 Z: ^6 v( H0 q- ^( d, `2 a( n
- /**1 | {9 p, i. \% ^) Y$ A3 N! {. h
- * 插入数据
4 P' W7 W+ \, H) W - * @param $table
0 ^+ Z6 D: d( m( W( z ` - * @param $data0 W5 P3 \- S) ?" X9 g1 {- @
- * @return array|bool
2 `- ~, |" b7 j( c6 K - */
6 i, Q* n, [4 | - public function toInsert($table, $data) {
y6 O, x0 ^ V! \( u - $re = $this->database->$table->insert($data);
& O. l3 y Q, S5 [' ` - return $re;% k$ \& a% {5 i3 @
- }
7 E2 c! j' y& V7 j2 \# `9 D: \ - /**
; F2 s b, {* ~9 j! u0 m9 Z3 k - * 更新数据
& i% T9 z% |8 a: H$ D2 I+ a. V- l$ ] - * @param $table+ ^; [2 Q7 J \5 h- ]
- * @param $where
2 Q9 T" y; @& p( Z) y) b9 h - * @param $data
; `5 f! \" J4 c0 D - * @return bool
4 U& s4 b& i1 A5 L* f0 T3 u - */
8 v# y: H1 T7 x) j' p) J* } - public function toUpdate($table, $where, $data) {
* v+ G! E. t4 X: K* I& q - $re = $this->database->$table->update($where, array('$set' => $data));
9 }7 j. G6 z% R! `6 X - return $re;
2 P1 B/ c0 M2 V - }
+ E/ [; w5 w: P5 b - /**
0 f+ E9 R% t9 X6 _# [ - * 获取唯一数据( Y; d) ^! J* e( D; S3 H7 g1 ^% V
- * @param $table* O& ^1 {! E2 V) B
- * @param $key" S6 U) x5 W0 b) c6 f6 H
- * @return array
1 i/ I- W a9 X9 ~" G7 [: z. _ - */
7 ^. D6 h! w7 Z) a3 X* H - public function distinctData($table, $key, $query = array()) {* c+ @7 b% |1 w
- if (!empty($query)) {
+ [* N E9 P# s) j4 k( c- T- |$ v% ~ D' C- e - $where = array('distinct' => $table, 'key' => $key, 'query' => $query);
, U* U3 P' u Q' y2 o - } else {
$ }6 ?, v" x3 g# Q - $where = array('distinct' => $table, 'key' => $key);/ R# H3 c/ ~- p
- }9 o' I) k6 L8 K {: Y& l$ S6 M% W) N
- $data = $this->database->command($where);( F) x2 `) X2 N. d
- return $data['values']; T# ~9 Y" I5 z/ A3 U# g
- }
0 ]' o5 \6 i3 V' }: S. J6 P - }" @6 O' H- s; {% O2 A- m
- ?>
复制代码 5 @- V3 E+ c( v3 S4 \. K/ O9 A( P# f
/ g( j' Z0 B+ i
|