php實(shí)現(xiàn)的mongodb操作類

bigstarr

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的實(shí)例對(duì)象
    
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.      * 插入一條數(shù)據(jù)
    
70.      * @param array $doc
    
71.      */
    
72.     public function insert($doc = array())
    
73.     {
    
74.         if (empty($doc)) {
    
75.             $this->throwError('插入的數(shù)據(jù)不能為空！');
    
76.         }
    
77.         //保存數(shù)據(jù)信息
    
78.         try {
    
79.             if (!$this->db->insert($doc)) {
    
80.                 throw new MongoException('插入數(shù)據(jù)失敗');
    
81.             }
    
82.         } catch (MongoException $e) {
    
83.             $this->throwError($e->getMessage());
    
84.         }
    
85.     }
    
86. 
    
87.     /**
    
88.      * 插入多條數(shù)據(jù)信息
    
89.      * @param array $doc
    
90.      */
    
91.     public function insertMulti($doc = array())
    
92.     {
    
93.         if (empty($doc)) {
    
94.             $this->throwError('插入的數(shù)據(jù)不能為空！');
    
95.         }
    
96.         //插入數(shù)據(jù)信息
    
97.         foreach ($doc as $key => $val) {
    
98.             //判斷$val是不是數(shù)組
    
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('查找數(shù)據(jù)失敗');
     
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('查找數(shù)據(jù)失敗');
     
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('查找數(shù)據(jù)失敗');
     
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('查找數(shù)據(jù)失敗');
     
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.      * 獲取記錄條數(shù)
     
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('查找總數(shù)失敗');
     
184.             }
     
185.         } catch (MongoException $e) {
     
186.             $this->throwError($e->getMessage());
     
187.         }
     
188.     }
     
189. 
     
190.     /**
     
191.      * 獲取所有的數(shù)據(jù)庫(kù)
     
192.      * @return array
     
193.      */
     
194.     public function getDbs()
     
195.     {
     
196.         return $this->mongo->listDBs();
     
197.     }
     
198. 
     
199.     /**
     
200.      * 刪除數(shù)據(jù)庫(kù)
     
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('請(qǐng)輸入要?jiǎng)h除的數(shù)據(jù)庫(kù)名稱');
     
215.     }
     
216. 
     
217.     /**
     
218.      * 強(qiáng)制關(guān)閉數(shù)據(jù)庫(kù)的鏈接
     
219.      */
     
220.     public function closeDb()
     
221.     {
     
222.         $this->mongo->close(TRUE);
     
223.     }
     
224. 
     
225.     /**
     
226.      * 輸出錯(cuò)誤信息
     
227.      * @param $errorInfo 錯(cuò)誤內(nèi)容
     
228.      */
     
229.     public function throwError($errorInfo='')
     
230.     {
     
231.         echo "<h3>出錯(cuò)了：$errorInfo</h3>";
     
232.         die();
     
233.     }
     
234. 
     
235. }

復(fù)制代碼