php mongodb操作類(lèi) 帶幾個(gè)簡(jiǎn)單的例子
更新時(shí)間：2016年08月25日 19:41:34 投稿：mdxy-dxy
這篇文章主要介紹了php mongodb操作類(lèi) 帶幾個(gè)簡(jiǎn)單的例子,需要的朋友可以參考下
之前腳本之家已經(jīng)發(fā)過(guò)幾篇類(lèi)似的文章，大家可以參考一下。
核心代碼：
class NewMongodb {
private $mongo; //NewMongodb連接
private $curr_db_name;
private $curr_table_name;
private $error;
public $config;
public function getInstance($mongo_server, $flag=array())
{
static $NewMongodb_arr;
if (empty($flag['tag']))
{
$flag['tag'] = 'default'; }
if (isset($flag['force']) && $flag['force'] == true)
{
$mongo = new NewMongodb($mongo_server);
if (empty($NewMongodb_arr[$flag['tag']]))
{
$NewMongodb_arr[$flag['tag']] = $mongo;
}
return $mongo;
}
else if (isset($NewMongodb_arr[$flag['tag']]) && is_resource($NewMongodb_arr[$flag['tag']]))
{
return $NewMongodb_arr[$flag['tag']];
}
else
{
$mongo = new NewMongodb($mongo_server);
$NewMongodb_arr[$flag['tag']] = $mongo;
return $mongo;
}
}
/**
* 構(gòu)造函數(shù)
* 支持傳入多個(gè)mongo_server(1.一個(gè)出問(wèn)題時(shí)連接其它的server 2.自動(dòng)將查詢(xún)均勻分發(fā)到不同server)
*
* 參數(shù)：
* $mongo_server:數(shù)組或字符串-array("127.0.0.1:1111", "127.0.0.1:2222")-"127.0.0.1:1111"
* $connect:初始化mongo對(duì)象時(shí)是否連接，默認(rèn)連接
* $auto_balance:是否自動(dòng)做負(fù)載均衡，默認(rèn)是
*
* 返回值：
* 成功：mongo object
* 失?。篺alse
*/
public function __construct($mongo_server, $connect=true, $auto_balance=true)
{
if (is_array($mongo_server))
{
$mongo_server_num = count($mongo_server);
if ($mongo_server_num > 1 && $auto_balance)
{
$prior_server_num = rand(1, $mongo_server_num);
$rand_keys = array_rand($mongo_server,$mongo_server_num);
$mongo_server_str = $mongo_server[$prior_server_num-1];
foreach ($rand_keys as $key)
{
if ($key != $prior_server_num - 1)
{
$mongo_server_str .= ',' . $mongo_server[$key];
}
}
}
else
{
$mongo_server_str = implode(',', $mongo_server);
} }
else
{
$mongo_server_str = $mongo_server;
}
try {
$this->mongo = new MongoClient($mongo_server, array('connect'=>$connect));
}
catch (MongoConnectionException $e)
{
$this->error = $e->getMessage();
return false;
}
}
/**
* 連接NewMongodb server
*
* 參數(shù)：無(wú)
*
* 返回值：
* 成功：true
* 失?。篺alse
*/
public function connect()
{
try {
$this->mongo->connect();
return true;
}
catch (MongoConnectionException $e)
{
$this->error = $e->getMessage();
return false;
}
}
/**
* select db
*
* 參數(shù)：$dbname
*
* 返回值：無(wú)
*/
public function selectDb($dbname)
{
$this->curr_db_name = $dbname;
}
/**
* 創(chuàng)建索引：如索引已存在，則返回。
*
* 參數(shù)：
* $table_name:表名
* $index:索引-array("id"=>1)-在id字段建立升序索引
* $index_param:其它條件-是否唯一索引等
*
* 返回值：
* 成功：true
* 失?。篺alse
*/
public function ensureIndex($table_name, $index, $index_param=array())
{
$dbname = $this->curr_db_name;
$index_param['safe'] = 1;
try {
$this->mongo->$dbname->$table_name->ensureIndex($index, $index_param);
return true;
}
catch (MongoCursorException $e)
{
$this->error = $e->getMessage();
return false;
}
}
/**
* 插入記錄
*
* 參數(shù)：
* $table_name:表名
* $record:記錄
*
* 返回值：
* 成功：true
* 失敗：false
*/
public function insert($table_name, $record)
{
$dbname = $this->curr_db_name;
try {
$this->mongo->$dbname->$table_name->insert($record, array('safe'=>true));
return true;
}
catch (MongoCursorException $e)
{
$this->error = $e->getMessage();
return false;
}
}
/**
* 查詢(xún)表的記錄數(shù)
*
* 參數(shù)：
* $table_name:表名
*
* 返回值：表的記錄數(shù)
*/
public function count($table_name)
{
$dbname = $this->curr_db_name;
return $this->mongo->$dbname->$table_name->count();
}
/**
* 更新記錄
*
* 參數(shù)：
* $table_name:表名
* $condition:更新條件
* $newdata:新的數(shù)據(jù)記錄
* $options:更新選擇-upsert/multiple
*
* 返回值：
* 成功：true
* 失?。篺alse
*/
public function update($table_name, $condition, $newdata, $options=array())
{
$dbname = $this->curr_db_name;
$options['safe'] = 1;
if (!isset($options['multiple']))
{
$options['multiple'] = 0; }
try {
$this->mongo->$dbname->$table_name->update($condition, $newdata, $options);
return true;
}
catch (MongoCursorException $e)
{
$this->error = $e->getMessage();
return false;
}
}
/**
* 刪除記錄
*
* 參數(shù)：
* $table_name:表名
* $condition:刪除條件
* $options:刪除選擇-justOne
*
* 返回值：
* 成功：true
* 失敗：false
*/
public function remove($table_name, $condition, $options=array())
{
$dbname = $this->curr_db_name;
$options['safe'] = 1;
try {
$this->mongo->$dbname->$table_name->remove($condition, $options);
return true;
}
catch (MongoCursorException $e)
{
$this->error = $e->getMessage();
return false;
} }
/**
* 查找記錄
*
* 參數(shù)：
* $table_name:表名
* $query_condition:字段查找條件
* $result_condition:查詢(xún)結(jié)果限制條件-limit/sort等
* $fields:獲取字段
*
* 返回值：
* 成功：記錄集
* 失?。篺alse
*/
public function find($table_name, $query_condition, $result_condition=array(), $fields=array())
{
$dbname = $this->curr_db_name;
$cursor = $this->mongo->$dbname->$table_name->find($query_condition, $fields);
if (!empty($result_condition['start']))
{
$cursor->skip($result_condition['start']);
}
if (!empty($result_condition['limit']))
{
$cursor->limit($result_condition['limit']);
}
if (!empty($result_condition['sort']))
{
$cursor->sort($result_condition['sort']);
}
$result = array();
try {
while ($cursor->hasNext())
{
$result[] = $cursor->getNext();
}
}
catch (MongoConnectionException $e)
{
$this->error = $e->getMessage();
return false;
}
catch (MongoCursorTimeoutException $e)
{
$this->error = $e->getMessage();
return false;
}
return $result;
}
/**
* 查找一條記錄
*
* 參數(shù)：
* $table_name:表名
* $condition:查找條件
* $fields:獲取字段
*
* 返回值：
* 成功：一條記錄
* 失?。篺alse
*/
public function findOne($table_name, $condition, $fields=array())
{
$dbname = $this->curr_db_name;
return $this->mongo->$dbname->$table_name->findOne($condition, $fields);
}
/**
* 獲取當(dāng)前錯(cuò)誤信息
*
* 參數(shù)：無(wú)
*
* 返回值：當(dāng)前錯(cuò)誤信息
*/
public function getError()
{
return $this->error;
}
/*** NewMongodb類(lèi)** examples:
* $mongo = new NewMongodb("127.0.0.1:11223");
* $mongo->selectDb("test_db");
* 創(chuàng)建索引
* $mongo->ensureIndex("test_table", array("id"=>1), array('unique'=>true));
* 獲取表的記錄
* $mongo->count("test_table");
* 插入記錄
* $mongo->insert("test_table", array("id"=>2, "title"=>"asdqw"));
* 更新記錄
* $mongo->update("test_table", array("id"=>1),array("id"=>1,"title"=>"bbb"));
* 更新記錄-存在時(shí)更新，不存在時(shí)添加-相當(dāng)于set
* $mongo->update("test_table", array("id"=>1),array("id"=>1,"title"=>"bbb"),array("upsert"=>1));
* 查找記錄
* $mongo->find("c", array("title"=>"asdqw"), array("start"=>2,"limit"=>2,"sort"=>array("id"=>1)))
* 查找一條記錄
* $mongo->findOne("$mongo->findOne("ttt", array("id"=>1))", array("id"=>1));
* 刪除記錄
* $mongo->remove("ttt", array("title"=>"bbb"));
* 僅刪除一條記錄
* $mongo->remove("ttt", array("title"=>"bbb"), array("justOne"=>1));
* 獲取Mongo操作的錯(cuò)誤信息
* $mongo->getError();
*/
}
您可能感興趣的文章:
- php封裝的mongodb操作類(lèi)代碼
- PHP實(shí)現(xiàn)的MongoDB數(shù)據(jù)庫(kù)操作類(lèi)分享
- php實(shí)現(xiàn)的mongodb操作類(lèi)
- PHP實(shí)現(xiàn)的mongoDB數(shù)據(jù)庫(kù)操作類(lèi)完整實(shí)例
- php實(shí)現(xiàn)的mongodb操作類(lèi)實(shí)例
- php實(shí)現(xiàn)的mongoDB單例模式操作類(lèi)
- PHP mongodb操作類(lèi)定義與用法示例【適合mongodb2.x和mongodb3.x】
- MongoDB操作類(lèi)封裝實(shí)例代碼
相關(guān)文章
Php中用PDO查詢(xún)Mysql來(lái)避免SQL注入風(fēng)險(xiǎn)的方法
本篇文章介紹了，Php中用PDO查詢(xún)Mysql來(lái)避免SQL注入風(fēng)險(xiǎn)的方法。需要的朋友參考下2013-04-04
PHPUnit是一個(gè)輕量級(jí)的PHP測(cè)試框架。它是在PHP5下面對(duì)JUnit3系列版本的完整移植，是xUnit測(cè)試框架家族的一員(它們都基于模式先鋒Kent Beck的設(shè)計(jì))。2011-03-03
php在頁(yè)面中調(diào)用fckeditor編輯器的方法
fckeditor編輯器的代碼可以寫(xiě)成一個(gè)函數(shù)或者類(lèi)別，直接調(diào)用，不用每次都要寫(xiě)那么多代碼！2011-06-06
php實(shí)現(xiàn)轉(zhuǎn)換ubb代碼的方法
這篇文章主要介紹了php實(shí)現(xiàn)轉(zhuǎn)換ubb代碼的方法,涉及php正則替換的使用技巧,需要的朋友可以參考下2015-06-06
php基于登陸時(shí)間判斷實(shí)現(xiàn)一天多次登錄只積分一次功能示例
這篇文章主要介紹了php基于登陸時(shí)間判斷實(shí)現(xiàn)一天多次登錄只積分一次功能,適合會(huì)員系統(tǒng)的積分功能,涉及php時(shí)間判斷與數(shù)據(jù)庫(kù)相關(guān)操作技巧,需要的朋友可以參考下2017-10-10
var_export必須返回合法的php代碼，也就是說(shuō)，var_export返回的代碼，可以直接當(dāng)作php代碼賦值個(gè)一個(gè)變量。 而這個(gè)變量就會(huì)取得和被var_export一樣的類(lèi)型的值2013-08-08
PHP實(shí)現(xiàn)字符串大小寫(xiě)轉(zhuǎn)函數(shù)的功能實(shí)例
這篇文章主要給大家介紹了關(guān)于利用PHP如何實(shí)現(xiàn)字符串大小寫(xiě)轉(zhuǎn)函數(shù)功能的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友一起來(lái)看看啊2019-02-02
php+MySql實(shí)現(xiàn)登錄系統(tǒng)與輸出瀏覽者信息功能
這篇文章主要介紹了php+MySql實(shí)現(xiàn)登錄系統(tǒng)與輸出瀏覽者信息功能 的相關(guān)資料,需要的朋友可以參考下2016-07-07
PHP+redis實(shí)現(xiàn)微博的推模型案例分析
這篇文章主要介紹了PHP+redis實(shí)現(xiàn)微博的推模型案例,結(jié)合實(shí)例形式分析了php+redis實(shí)現(xiàn)微博推送與關(guān)注功能相關(guān)操作技巧,需要的朋友可以參考下2019-07-07
php 正確解碼javascript中通過(guò)escape編碼后的字符
js的escape如何在PHP中來(lái)解呢?下面的這個(gè)函數(shù)可以正確的解析,網(wǎng)上有不少u(mài)nescape的函數(shù),但好用的不多.2010-01-01