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

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

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

<?php/** * Created by PhpStorm. * User: lee * Date: 2016/10/24 * Time: 13:49 */namespace AppHttpControllersApi;use AppHttpCommonReturnApi;/* * * 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 AppHttpControllersApiMongdbCommonController;$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程序设计有所帮助。