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

本文实例讲述了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;  }}