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

2020-03-22 19:08:35

字體：大中小

供稿：網(wǎng)友

html' target='_blank'>public function __construct($host = NULL, $port = NULL, $dbname = NULL, $table = NULL) if (NULL === $dbname) { $this- throwError('集合不能為空！'); //判斷是否傳遞了host和port if (NULL !== $host) { $this- host = $host; if (NULL !== $port) { $this- port = $port; $this- table = $table; $this- mongo = new MongoClient($this- host . ':' . $this- port); if ($this- getVersion() = '0.9.0') { $this- dbname = $this- mongo- selectDB($dbname); $this- db = $this- dbname- selectCollection($table); } else { $this- db = $this- mongo- $dbname- $table; public function getVersion() return MongoClient::VERSION; * 單例模式 * @return Mongo|null //public static function getInstance($host=null, $port=null, $dbname=null, $table=null){ // if(!(self::$instanceof instanceof self)){ // self::$instanceof = new self($host, $port, $dbname, $table); // } // return self::$instanceof; * 插入一條數(shù)據(jù) * @param array $doc public function insert($doc = array()) if (empty($doc)) { $this- throwError('插入的數(shù)據(jù)不能為空！'); //保存數(shù)據(jù)信息 try { if (!$this- db- insert($doc)) { throw new MongoException('插入數(shù)據(jù)失敗'); } catch (MongoException $e) { $this- throwError($e- getMessage()); * 插入多條數(shù)據(jù)信息 * @param array $doc public function insertMulti($doc = array()) if (empty($doc)) { $this- throwError('插入的數(shù)據(jù)不能為空！'); //插入數(shù)據(jù)信息 foreach ($doc as $key = $val) { //判斷$val是不是數(shù)組 if (is_array($val)) { $this- insert($val); * 查找一條記錄 * @return array|null public function findOne($where = NULL) if (NULL === $where) { try { if ($result = $this- db- findOne()) { return $result; } else { throw new MongoException('查找數(shù)據(jù)失敗'); } catch (MongoException $e) { $this- throwError($e- getMessage()); } else { try { if ($result = $this- db- findOne($where)) { return $result; } else { throw new MongoException('查找數(shù)據(jù)失敗'); } catch (MongoException $e) { $this- throwError($e- getMessage()); * todo 帶條件的隨后做 * 查找所有的文檔 * @return MongoCursor public function find($where = NULL) if (NULL === $where) { try { if ($result = $this- db- find()) { } else { throw new MongoException('查找數(shù)據(jù)失敗'); } catch (MongoException $e) { $this- throwError($e- getMessage()); } else { try { if ($result = $this- db- find($where)) { } else { throw new MongoException('查找數(shù)據(jù)失敗'); } catch (MongoException $e) { $this- throwError($e- getMessage()); $arr = array(); foreach ($result as $id = $val) { $arr[] = $val; return $arr; * 獲取記錄條數(shù) * @return int public function getCount() try { if ($count = $this- db- count()) { return $count; } else { throw new MongoException('查找總數(shù)失敗'); } catch (MongoException $e) { $this- throwError($e- getMessage()); * 獲取所有的數(shù)據(jù)庫(kù) * @return array public function getDbs() return $this- mongo- listDBs(); * 刪除數(shù)據(jù)庫(kù) * @param null $dbname * @return mixed public function dropDb($dbname = NULL) if (NULL !== $dbname) { $retult = $this- mongo- dropDB($dbname); if ($retult['ok']) { return TRUE; } else { return FALSE; $this- throwError('請(qǐng)輸入要?jiǎng)h除的數(shù)據(jù)庫(kù)名稱'); * 強(qiáng)制關(guān)閉數(shù)據(jù)庫(kù)的鏈接 public function closeDb() $this- mongo- close(TRUE); * 輸出錯(cuò)誤信息 * @param $errorInfo 錯(cuò)誤內(nèi)容 public function throwError($errorInfo='') echo " h3 出錯(cuò)了：$errorInfo /h3 die();以上所述就是本文的全部?jī)?nèi)容了，希望大家能夠喜歡。PHP教程

鄭重聲明：本文版權(quán)歸原作者所有，轉(zhuǎn)載文章僅為傳播更多信息之目的，如作者信息標(biāo)記有誤，請(qǐng)第一時(shí)間聯(lián)系我們修改或刪除，多謝。

上一篇：php實(shí)現(xiàn)的mongodb操作類實(shí)例

下一篇：PHP7中 MongoDB Driver的使用介紹