php操作mongodb封装类与用法实例

第php操作mongodb封装类与用法实例本文实例讲述了php操作mongodb封装类与用法。分享给大家供大家参考，具体如下：

近来学习了mongodb，刚好是做php开发的,随便写了php操作mongodb的封装类.

*CreatedbyPhpStorm.

*User:lee

*Date:2016/10/24

*Time:13:49

namespaceApp\Http\Controllers\Api;

useApp\Http\Common\ReturnApi;

mongdb常规操作

classMongdbCommonController

privatestatic$conn;

privatestatic$mon;

privatestatic$error;

privatefunction__construct(){

//self::$conn=new\MongoClient("mongodb://".env('MONGDB_USER').":".env('MONGDB_PASS')."@".env('MONGDB_HOST').":".env('MONGDB_PORT')."/".env('MONGDB_DB'));

self::$conn=new\MongoClient("mongodb://".env('MONGDB_USER').":".env('MONGDB_PASS')."@".env('MONGDB_HOST').":".env('MONGDB_PORT'));

//self::$conn=new\MongoClient("mongodb://".env('MONGDB_HOST').":".env('MONGDB_PORT'));

$db=env('MONGDB_DB');

self::$mon=self::$conn-

publicstaticfunctiongetInstance(){

if(!(self::$conninstanceofself)){

self::$conn=newself();

//returnself::$conn-mydb;

returnself::$conn;

privatefunction__clone(){

trigger_error('Cloneisnotallowed');

}//禁止克隆

//创建索引

publicfunctionensureIndex($table,$index,$index_param=array())

$index_param['safe']=1;

try{

self::$mon-$table-ensureIndex($index,$index_param);

returntrue;

catch(MongoCursorException$e)

self::$error=$e-getMessage();

returnfalse;

//添加

publicfunctioninsert($table,$arr){

try{

self::$mon-$table-insert($arr,array('w'=true));

returntrue;

catch(MongoCursorException$e)

self::$error=$e-getMessage();

returnfalse;

//更新

publicfunctionupdate($table,$condition,$new_arr,$options=array())

$options['w']=1;

if(!isset($options['multiple']))

$options['multiple']=0;

try{

self::$mon-$table-update($condition,$new_arr,$options);

returntrue;

catch(MongoCursorException$e)

self::$error=$e-getMessage();

returnfalse;

//删除

publicfunctionremove($table,$condition,$options=array())

$options['w']=1;

try{

self::$mon-$table-remove($condition,$options);

returntrue;

catch(MongoCursorException$e)

self::$error=$e-getMessage();

returnfalse;

//查找

publicfunctionfind($table,$query_condition,$result_condition=array(),$fields=array())

$cursor=self::$mon-$table-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(MongoCursorTimeoutException$e)

self::$error=$e-getMessage();

returnfalse;

return$result;

//查找一条记录

publicfunctionfindOne($table,$condition,$fields=array())

returnself::$mon-$table-findOne($condition,$fields);

//返回表的记录数

publicfunctioncount($table)

returnself::$mon-$table-count();

//返回错误信息

publicfunctiongetError()

returnself::$error;

操作实例：

useApp\Http\Controllers\Api\MongdbCommonController;

$db=MongdbCommonController::getInstance();

$collection='tab';

$data=array('tt'='sdsd',

'pp'='ssdsdf');

//返回记录数

echo$db-count($collection);

//插入记录

$db-insert($collection,array("id"=2,"title"="asdqw"));

$db-update($collection,array("id"=2),array('tt'='dfdfd',"gg"="bbb",'hh'='dfsdsd'));

//查找记录

echo'pre

print_r($db-find($collection,array("tt"='dfdfd'),array("start"=1,"limit"=4)));

$db-remove($collection,arra