php操作mongodb封装类与用法实例
2018-09-01 11:36
846 查看
本文实例讲述了php操作mongodb封装类与用法。分享给大家供大家参考,具体如下:
近来学习了mongodb,刚好是做php开发的,随便写了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常规操作 */ 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'); }//禁止克隆 //创建索引 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); } //返回表的记录数 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'); //返回记录数 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'));
更多关于PHP相关内容感兴趣的读者可查看本站专题:《PHP+MongoDB数据库操作技巧大全》、《PHP基于pdo操作数据库技巧总结》、《php面向对象程序设计入门教程》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》
希望本文所述对大家PHP程序设计有所帮助。
您可能感兴趣的文章:
- python连接mongodb操作数据示例(mongodb数据库配置类)
- MongoDB基础命令以及操作示例详解
- Python常见MongoDB数据库操作实例总结
- Python使用pymongo模块操作MongoDB的方法示例
- Golang对MongoDB数据库的操作简单封装教程
- PHP操作Mongodb封装类完整实例
- PHP mongodb操作类定义与用法示例【适合mongodb2.x和mongodb3.x】
- Python操作mongodb数据库进行模糊查询操作示例
- Python操作mongodb的9个步骤
- 关于MongoDB索引管理-索引的创建、查看、删除操作详解
- Mongodb基本操作与Python连接mongodb并进行基础操作的方法
相关文章推荐
- PHP数据库表操作的封装类及用法实例详解
- 使用PHPExcel操作Excel用法实例分析_PHP教程
- 解析php mysql 事务处理回滚操作(附实例)
- 解析php mysql 事务处理回滚操作(附实例)
- PHP文件上传操作实例详解
- PHP使用Pthread实现的多线程操作实例
- php数组操作实例三
- php操作MongoDB类实例
- PHP弱类型语言中类型判断操作实例详解
- php中使用redis队列操作实例代码
- PHP中__get()和__set()的用法实例详解
- php文件压缩之PHPZip类用法实例
- PHP队列用法实例
- PHP常用文件操作函数和简单实例分析
- php针对cookie操作的队列操作类实例
- PHP5.5迭代生成器用法实例详解
- php过滤html标记属性类用法实例
- php传值赋值和传地址赋值用法实例分析
- PHP操作Memcache实例介绍
- php字符串替换函数substr_replace()用法实例