php实现的mongodb操作类

说到php连mongoDB，不得不先介绍一下php的官方手册，网址在：http://us.php.net/manual/en/book.mongo.php，接下来给大家分享一个本人常用的MONGODB的操作类，详见的数据库操作都有了，小伙伴可以参考下。

mongo_db.php

1. <?php 
2.  
3. /** 
4. * Created by PhpStorm. 
5. * User: yangyulong 
6. * Date: 2015/5/26 
7. * Time: 13:45 
8. */ 
9. class Mongo_db 
10. { 
11. private static $instanceof = NULL; 
12. public $mongo; 
13. private $host = 'localhost'; 
14. private $port = '27017'; 
15.  
16. private $db; 
17. public $dbname; 
18. private $table = NULL; 
19.  
20. /** 
21. * 初始化类，得到mongo的实例对象 
22. */ 
23. public function __construct($host = NULL, $port = NULL, $dbname = NULL, $table = NULL) 
24. { 
25.  
26. if (NULL === $dbname) { 
27. $this->throwError('集合不能为空！'); 
28. } 
29.  
30. //判断是否传递了host和port 
31. if (NULL !== $host) { 
32. $this->host = $host; 
33. } 
34.  
35. if (NULL !== $port) { 
36. $this->port = $port; 
37. } 
38.  
39. $this->table = $table; 
40.  
41. $this->mongo = new MongoClient($this->host . ':' . $this->port); 
42. if ($this->getVersion() >= '0.9.0') { 
43. $this->dbname = $this->mongo->selectDB($dbname); 
44. $this->db = $this->dbname->selectCollection($table); 
45. } else { 
46. $this->db = $this->mongo->$dbname->$table; 
47. } 
48. } 
49.  
50. public function getVersion() 
51. { 
52. return MongoClient::VERSION; 
53. } 
54.  
55. /** 
56. * 单例模式 
57. * @return Mongo|null 
58. */ 
59. //public static function getInstance($host=null, $port=null, $dbname=null, $table=null){ 
60. // 
61. // if(!(self::$instanceof instanceof self)){ 
62. // self::$instanceof = new self($host, $port, $dbname, $table); 
63. // } 
64. // 
65. // return self::$instanceof; 
66. //} 
67.  
68. /** 
69. * 插入一条数据 
70. * @param array $doc 
71. */ 
72. public function insert($doc = array()) 
73. { 
74. if (emptyempty($doc)) { 
75. $this->throwError('插入的数据不能为空！'); 
76. } 
77. //保存数据信息 
78. try { 
79. if (!$this->db->insert($doc)) { 
80. throw new MongoException('插入数据失败'); 
81. } 
82. } catch (MongoException $e) { 
83. $this->throwError($e->getMessage()); 
84. } 
85. } 
86.  
87. /** 
88. * 插入多条数据信息 
89. * @param array $doc 
90. */ 
91. public function insertMulti($doc = array()) 
92. { 
93. if (emptyempty($doc)) { 
94. $this->throwError('插入的数据不能为空！'); 
95. } 
96. //插入数据信息 
97. foreach ($doc as $key => $val) { 
98. //判断$val是不是数组 
99. if (is_array($val)) { 
100. $this->insert($val); 
101. } 
102. } 
103. } 
104.  
105. /** 
106. * 查找一条记录 
107. * @return array|null 
108. */ 
109. public function findOne($where = NULL) 
110. { 
111. if (NULL === $where) { 
112. try { 
113. if ($result = $this->db->findOne()) { 
114. return $result; 
115. } else { 
116. throw new MongoException('查找数据失败'); 
117. } 
118. } catch (MongoException $e) { 
119. $this->throwError($e->getMessage()); 
120. } 
121. } else { 
122. try { 
123. if ($result = $this->db->findOne($where)) { 
124. return $result; 
125. } else { 
126. throw new MongoException('查找数据失败'); 
127. } 
128. } catch (MongoException $e) { 
129. $this->throwError($e->getMessage()); 
130. } 
131. } 
132.  
133. } 
134.  
135. /** 
136. * todo 带条件的随后做 
137. * 查找所有的文档 
138. * @return MongoCursor 
139. */ 
140. public function find($where = NULL) 
141. { 
142. if (NULL === $where) { 
143.  
144. try { 
145. if ($result = $this->db->find()) { 
146.  
147. } else { 
148. throw new MongoException('查找数据失败'); 
149. } 
150. } catch (MongoException $e) { 
151. $this->throwError($e->getMessage()); 
152. } 
153. } else { 
154. try { 
155. if ($result = $this->db->find($where)) { 
156.  
157. } else { 
158. throw new MongoException('查找数据失败'); 
159. } 
160. } catch (MongoException $e) { 
161. $this->throwError($e->getMessage()); 
162. } 
163. } 
164.  
165. $arr = array(); 
166. foreach ($result as $id => $val) { 
167. $arr[] = $val; 
168. } 
169.  
170. return $arr; 
171. } 
172.  
173. /** 
174. * 获取记录条数 
175. * @return int 
176. */ 
177. public function getCount() 
178. { 
179. try { 
180. if ($count = $this->db->count()) { 
181. return $count; 
182. } else { 
183. throw new MongoException('查找总数失败'); 
184. } 
185. } catch (MongoException $e) { 
186. $this->throwError($e->getMessage()); 
187. } 
188. } 
189.  
190. /** 
191. * 获取所有的数据库 
192. * @return array 
193. */ 
194. public function getDbs() 
195. { 
196. return $this->mongo->listDBs(); 
197. } 
198.  
199. /** 
200. * 删除数据库 
201. * @param null $dbname 
202. * @return mixed 
203. */ 
204. public function dropDb($dbname = NULL) 
205. { 
206. if (NULL !== $dbname) { 
207. $retult = $this->mongo->dropDB($dbname); 
208. if ($retult['ok']) { 
209. return TRUE; 
210. } else { 
211. return FALSE; 
212. } 
213. } 
214. $this->throwError('请输入要删除的数据库名称'); 
215. } 
216.  
217. /** 
218. * 强制关闭数据库的链接 
219. */ 
220. public function closeDb() 
221. { 
222. $this->mongo->close(TRUE); 
223. } 
224.  
225. /** 
226. * 输出错误信息 
227. * @param $errorInfo 错误内容 
228. */ 
229. public function throwError($errorInfo='') 
230. { 
231. echo "<h3>出错了：$errorInfo</h3>"; 
232. die(); 
233. } 
234.  
235. } 

以上所述就是本文的全部内容了，希望大家能够喜欢。