本文實例講述了php操作mongodb封裝類與用法。分享給大家供大家參考，具體如下：
近來學(xué)習(xí)了mongodb，剛好是做php開發(fā)的,隨便寫了php操作mongodb的封裝類.
?php
/**
* Created by PhpStorm.
* User: lee
* Date: 2016/10/24
* Time: 13:49
*/
namespace App\Http\Controllers\Api;
use App\Http\Common\ReturnApi;
/*
*
*
mongdb常規(guī)操作
*/
class MongdbCommonController
{
private static $conn;
private static $mon;
private static $error;
private function __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->$db;
}
public static function getInstance(){
if(!(self::$conn instanceof self)){
self::$conn = new self();
}
//return self::$conn->mydb;
return self::$conn;
}
private function __clone(){
trigger_error('Clone is not allowed');
}//禁止克隆
//創(chuàng)建索引
public function ensureIndex($table, $index, $index_param=array())
{
$index_param['safe'] = 1;
try {
self::$mon->$table->ensureIndex($index, $index_param);
return true;
}
catch (MongoCursorException $e)
{
self::$error = $e->getMessage();
return false;
}
}
//添加
public function insert($table,$arr){
try {
self::$mon->$table->insert($arr, array('w'=>true));
return true;
}
catch (MongoCursorException $e)
{
self::$error = $e->getMessage();
return false;
}
}
//更新
public function update($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);
return true;
}
catch (MongoCursorException $e)
{
self::$error = $e->getMessage();
return false;
}
}
//刪除
public function remove($table, $condition, $options=array())
{
$options['w'] = 1;
try {
self::$mon->$table->remove($condition, $options);
return true;
}
catch (MongoCursorException $e)
{
self::$error = $e->getMessage();
return false;
}
}
//查找
public function find($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();
return false;
}
return $result;
}
//查找一條記錄
public function findOne($table, $condition, $fields=array())
{
return self::$mon->$table->findOne($condition, $fields);
}
//返回表的記錄數(shù)
public function count($table)
{
return self::$mon->$table->count();
}
//返回錯誤信息
public function getError()
{
return self::$error;
}
}
操作實例：
use App\Http\Controllers\Api\MongdbCommonController;
$db = MongdbCommonController::getInstance();
$collection = 'tab';
$data = array('tt' =>'sdsd',
'pp' => 'ssdsdf');
//返回記錄數(shù)
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, array('tt' =>'sdsd'));
更多關(guān)于PHP相關(guān)內(nèi)容感興趣的讀者可查看本站專題：《PHP+MongoDB數(shù)據(jù)庫操作技巧大全》、《PHP基于pdo操作數(shù)據(jù)庫技巧總結(jié)》、《php面向?qū)ο蟪绦蛟O(shè)計入門教程》、《php字符串(string)用法總結(jié)》、《php+mysql數(shù)據(jù)庫操作入門教程》及《php常見數(shù)據(jù)庫操作技巧匯總》
希望本文所述對大家PHP程序設(shè)計有所幫助。
您可能感興趣的文章:- PHP封裝的簡單連接MongoDB類示例
- PHP使用mongoclient簡單操作mongodb數(shù)據(jù)庫示例
- php如何利用pecl安裝mongodb擴展詳解
- TP5(thinkPHP5)框架mongodb擴展安裝及特殊操作示例
- PHP操作Mongodb封裝類完整實例
- mongodb和php的用法詳解
