首页 后端开发 php教程 php封装mongodb操作类代码分享

php封装mongodb操作类代码分享

Jan 30, 2018 am 10:48 AM
mongodb php 分享

本文主要分享一个php封装的mongodb操作类,有需要的朋友们可以参考一下,希望能帮助到大家。

核心代码


<?php

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */


class mongo_db {

  private $config;
  private $connection;
  private $db;
  private $connection_string;
  private $host;
  private $port;
  private $user;
  private $pass;
  private $dbname;
  private $persist;
  private $persist_key;
  private $selects = array();
  private $wheres = array();
  private $sorts = array();
  private $limit = 999999;
  private $offset = 0;
  private $timeout = 200;
  private $key = 0;
  /**   *  --------------------------------------------------------------------------------   * CONSTRUCTOR * --------------------------------------------------------------------------------   *  * Automatically check if the Mongo PECL extension has been installed/enabled. * Generate the connection string and establish a connection to the MongoDB.  */

  public function __construct() {
    if((IS_NOSQL != 1)){
      return;
    }
    if (!class_exists(&#39;Mongo&#39;)) {
      //$this->error("The MongoDB PECL extension has not been installed or enabled", 500);
    }
    $configs =wxcity_base::load_config("cache","mongo_db");
    $num = count($configs[&#39;connect&#39;]);
    $this->timeout = trim($configs[&#39;timeout&#39;]);
    $keys = wxcity_base::load_config(&#39;double&#39;);
    $this->key = $keys[&#39;mongo_db&#39;];
    $this->config = $configs[&#39;connect&#39;][$this->key];
    $status = $this->connect();
    if($status == false)
    {
      for($i = 1; $i < $num; $i++)
      {
        $n = $this->key + $i;
        $key = $n >= $num ? $n - $num : $n;
        $this->config = $configs[&#39;connect&#39;][$key];
        $status = $this->connect();
        if($status!=false)
        {
          $keys[&#39;mongo_db&#39;] = $key ;
          $this->key = $key;
          $data = "<?php\nreturn ".var_export($keys, true).";\n?>";
          file_put_contents(WHTY_PATH.&#39;configs/double.php&#39;, $data, LOCK_EX);
          break;
        }
      }
    }
    if($status==false)
    {
      die(&#39;mongoDB not connect&#39;);
    }
  }

  function __destruct() {
    if((IS_NOSQL != 1)){
      return;
    }
    if($this->connection)
    {
      $this->connection->close();
    }
  }

  /**   *  --------------------------------------------------------------------------------   * CONNECT TO MONGODB  * --------------------------------------------------------------------------------   *  * Establish a connection to MongoDB using the connection string generated in  * the connection_string() method. If &#39;mongo_persist_key&#39; was set to true in the  * config file, establish a persistent connection. We allow for only the &#39;persist&#39;   * option to be set because we want to establish a connection immediately. */
  private function connect() {
    $this->connection_string();
    $options = array(&#39;connect&#39;=>true,&#39;timeout&#39;=>$this->timeout);
    try {
      $this->connection = new Mongo($this->connection_string, $options);
      $this->db = $this->connection->{$this->dbname};
      return($this);
    } catch (MongoConnectionException $e) {
      return false;
    }

  }
  /**   *  --------------------------------------------------------------------------------   * BUILD CONNECTION STRING * --------------------------------------------------------------------------------   *  * Build the connection string from the config file.  */
  private function connection_string() {
    $this->host = trim($this->config[&#39;hostname&#39;]);
    $this->port = trim($this->config[&#39;port&#39;]);
    $this->user = trim($this->config[&#39;username&#39;]);
    $this->pass = trim($this->config[&#39;password&#39;]);
    $this->dbname = trim($this->config[&#39;database&#39;]);
    $this->persist = trim($this->config[&#39;autoconnect&#39;]);
    $this->persist_key = trim($this->config[&#39;mongo_persist_key&#39;]);

    $connection_string = "mongodb://";
    if (emptyempty($this->host)) {
      $this->error("The Host must be set to connect to MongoDB", 500);
    } if (emptyempty($this->dbname)) {
      $this->error("The Database must be set to connect to MongoDB", 500);
    } if (!emptyempty($this->user) && !emptyempty($this->pass)) {
      $connection_string .= "{$this->user}:{$this->pass}@";
    } if (isset($this->port) && !emptyempty($this->port)) {
      $connection_string .= "{$this->host}:{$this->port}";
    } else {
      $connection_string .= "{$this->host}";
    } $this->connection_string = trim($connection_string);
  }

  /**   *  --------------------------------------------------------------------------------   * Switch_db  * --------------------------------------------------------------------------------   *  * Switch from default database to a different db  */
  public function switch_db($database = &#39;&#39;) {
    if (emptyempty($database)) {
      $this->error("To switch MongoDB databases, a new database name must be specified", 500);
    } $this->dbname = $database;
    try {
      $this->db = $this->connection->{$this->dbname};
      return(TRUE);
    } catch (Exception $e) {
      $this->error("Unable to switch Mongo Databases: {$e->getMessage()}", 500);
    }
  }

  /**   *  --------------------------------------------------------------------------------   * SELECT FIELDS  * --------------------------------------------------------------------------------   *  * Determine which fields to include OR which to exclude during the query process. * Currently, including and excluding at the same time is not available, so the   * $includes array will take precedence over the $excludes array. If you want to  * only choose fields to exclude, leave $includes an empty array().   *  * @usage: $this->mongo_db->select(array(&#39;foo&#39;, &#39;bar&#39;))->get(&#39;foobar&#39;);  */
  public function select($includes = array(), $excludes = array()) {
    if (!is_array($includes)) {
      $includes = array();
    }
    if (!is_array($excludes)) {
      $excludes = array();
    }
    if (!emptyempty($includes)) {
      foreach ($includes as $col) {
        $this->selects[$col] = 1;
      }
    } else {
      foreach ($excludes as $col) {
        $this->selects[$col] = 0;
      }
    } return($this);
  }

  /**   *  --------------------------------------------------------------------------------   * WHERE PARAMETERS   * --------------------------------------------------------------------------------   *  * Get the documents based on these search parameters. The $wheres array should  * be an associative array with the field as the key and the value as the search  * criteria.  *  * @usage = $this->mongo_db->where(array(&#39;foo&#39; => &#39;bar&#39;))->get(&#39;foobar&#39;);  */
  public function where($wheres = array()) {
    foreach ((array)$wheres as $wh => $val) {
      $this->wheres[$wh] = $val;
    } return($this);
  }

  /**   *  --------------------------------------------------------------------------------   * WHERE_IN PARAMETERS * --------------------------------------------------------------------------------   *  * Get the documents where the value of a $field is in a given $in array().   *  * @usage = $this->mongo_db->where_in(&#39;foo&#39;, array(&#39;bar&#39;, &#39;zoo&#39;, &#39;blah&#39;))->get(&#39;foobar&#39;); */
  public function where_in($field = "", $in = array()) {
    $this->where_init($field);
    $this->wheres[$field][&#39;$in&#39;] = $in;
    return($this);
  }

  /**   *  --------------------------------------------------------------------------------   * WHERE_NOT_IN PARAMETERS * --------------------------------------------------------------------------------   *  * Get the documents where the value of a $field is not in a given $in array().   *  * @usage = $this->mongo_db->where_not_in(&#39;foo&#39;, array(&#39;bar&#39;, &#39;zoo&#39;, &#39;blah&#39;))->get(&#39;foobar&#39;); */
  public function where_not_in($field = "", $in = array()) {
    $this->where_init($field);
    $this->wheres[$field][&#39;$nin&#39;] = $in;
    return($this);
  }

  /**   *  --------------------------------------------------------------------------------   * WHERE GREATER THAN PARAMETERS  * --------------------------------------------------------------------------------   *  * Get the documents where the value of a $field is greater than $x   *  * @usage = $this->mongo_db->where_gt(&#39;foo&#39;, 20);   */
  public function where_gt($field = "", $x) {
    $this->where_init($field);
    $this->wheres[$field][&#39;$gt&#39;] = $x;
    return($this);
  }

  /**   *  --------------------------------------------------------------------------------   * WHERE GREATER THAN OR EQUAL TO PARAMETERS  * --------------------------------------------------------------------------------   *  * Get the documents where the value of a $field is greater than or equal to $x   *  * @usage = $this->mongo_db->where_gte(&#39;foo&#39;, 20);  */
  public function where_gte($field = "", $x) {
    $this->where_init($field);
    $this->wheres[$field][&#39;$gte&#39;] = $x;
    return($this);
  }

  /**   *  --------------------------------------------------------------------------------   * WHERE LESS THAN PARAMETERS  * --------------------------------------------------------------------------------   *  * Get the documents where the value of a $field is less than $x  *  * @usage = $this->mongo_db->where_lt(&#39;foo&#39;, 20);   */
  public function where_lt($field = "", $x) {
    $this->where_init($field);
    $this->wheres[$field][&#39;$lt&#39;] = $x;
    return($this);
  }

  /**   *  --------------------------------------------------------------------------------   * WHERE LESS THAN OR EQUAL TO PARAMETERS  * --------------------------------------------------------------------------------   *  * Get the documents where the value of a $field is less than or equal to $x  *  * @usage = $this->mongo_db->where_lte(&#39;foo&#39;, 20);  */
  public function where_lte($field = "", $x) {
    $this->where_init($field);
    $this->wheres[$field][&#39;$lte&#39;] = $x;
    return($this);
  }

  /**   *  --------------------------------------------------------------------------------   * WHERE BETWEEN PARAMETERS   * --------------------------------------------------------------------------------   *  * Get the documents where the value of a $field is between $x and $y  *  * @usage = $this->mongo_db->where_between(&#39;foo&#39;, 20, 30);  */
  public function where_between($field = "", $x, $y) {
    $this->where_init($field);
    $this->wheres[$field][&#39;$gte&#39;] = $x;
    $this->wheres[$field][&#39;$lte&#39;] = $y;
    return($this);
  }

  /**   *  --------------------------------------------------------------------------------   * WHERE BETWEEN AND NOT EQUAL TO PARAMETERS  * --------------------------------------------------------------------------------   *  * Get the documents where the value of a $field is between but not equal to $x and $y *  * @usage = $this->mongo_db->where_between_ne(&#39;foo&#39;, 20, 30);   */
  public function where_between_ne($field = "", $x, $y) {
    $this->where_init($field);
    $this->wheres[$field][&#39;$gt&#39;] = $x;
    $this->wheres[$field][&#39;$lt&#39;] = $y;
    return($this);
  }

  /**   *  --------------------------------------------------------------------------------   * WHERE NOT EQUAL TO PARAMETERS  * --------------------------------------------------------------------------------   *  * Get the documents where the value of a $field is not equal to $x   *  * @usage = $this->mongo_db->where_between(&#39;foo&#39;, 20, 30);  */
  public function where_ne($field = "", $x) {
    $this->where_init($field);
    $this->wheres[$field][&#39;$ne&#39;] = $x;
    return($this);
  }

  /**   *  --------------------------------------------------------------------------------   * WHERE OR   * --------------------------------------------------------------------------------   *  * Get the documents where the value of a $field is in one or more values  *  * @usage = $this->mongo_db->where_or(&#39;foo&#39;, array( &#39;foo&#39;, &#39;bar&#39;, &#39;blegh&#39; ); */
  public function where_or($field = "", $values) {
    $this->where_init($field);
    $this->wheres[$field][&#39;$or&#39;] = $values;
    return($this);
  }

  /**   *  --------------------------------------------------------------------------------   * WHERE AND  * --------------------------------------------------------------------------------   *  * Get the documents where the elements match the specified values *  * @usage = $this->mongo_db->where_and( array ( &#39;foo&#39; => 1, &#39;b&#39; => &#39;someexample&#39; );   */
  public function where_and($elements_values = array()) {
    foreach ((array)$elements_values as $element => $val) {
      $this->wheres[$element] = $val;
    } return($this);
  }

  /**   *  --------------------------------------------------------------------------------   * WHERE MOD  * --------------------------------------------------------------------------------   *  * Get the documents where $field % $mod = $result *  * @usage = $this->mongo_db->where_mod( &#39;foo&#39;, 10, 1 );  */
  public function where_mod($field, $num, $result) {
    $this->where_init($field);
    $this->wheres[$field][&#39;$mod&#39;] = array($num, $result);
    return($this);
  }

  /**   *  --------------------------------------------------------------------------------  *  Where size *  --------------------------------------------------------------------------------  *  *  Get the documents where the size of a field is in a given $size int *  *  @usage : $this->mongo_db->where_size(&#39;foo&#39;, 1)->get(&#39;foobar&#39;); */
  public function where_size($field = "", $size = "") {
    $this->_where_init($field);
    $this->wheres[$field][&#39;$size&#39;] = $size;
    return ($this);
  }

  /**   *  --------------------------------------------------------------------------------   * LIKE PARAMETERS * --------------------------------------------------------------------------------   *    * Get the documents where the (string) value of a $field is like a value. The defaults   * allow for a case-insensitive search.   *  * @param $flags  * Allows for the typical regular expression flags:   *   i = case insensitive   *   m = multiline  *   x = can contain comments   *   l = locale  *   s = dotall, "." matches everything, including newlines  *   u = match unicode  *  * @param $enable_start_wildcard  * If set to anything other than TRUE, a starting line character "^" will be prepended * to the search value, representing only searching for a value at the start of   * a new line. *  * @param $enable_end_wildcard * If set to anything other than TRUE, an ending line character "$" will be appended  * to the search value, representing only searching for a value at the end of  * a line. *  * @usage = $this->mongo_db->like(&#39;foo&#39;, &#39;bar&#39;, &#39;im&#39;, FALSE, TRUE);  */
  public function like($field = "", $value = "", $flags = "i", $enable_start_wildcard = TRUE, $enable_end_wildcard = TRUE) {
    $field = (string) trim($field);
    $this->where_init($field);
    $value = (string) trim($value);
    $value = quotemeta($value);
    if ($enable_start_wildcard !== TRUE) {
      $value = "^" . $value;
    } if ($enable_end_wildcard !== TRUE) {
      $value .= "$";
    } $regex = "/$value/$flags";
    $this->wheres[$field] = new MongoRegex($regex);
    return($this);
  }

  public function wheres($where){
    $this->wheres = $where;
  }

  /**   *  --------------------------------------------------------------------------------   * ORDER BY PARAMETERS * --------------------------------------------------------------------------------   *  * Sort the documents based on the parameters passed. To set values to descending order,  * you must pass values of either -1, FALSE, &#39;desc&#39;, or &#39;DESC&#39;, else they will be  * set to 1 (ASC). *  * @usage = $this->mongo_db->where_between(&#39;foo&#39;, 20, 30);  */
  public function order_by($fields = array()) {
    if (!is_array($fields) || !count($fields)) return ;
    foreach ($fields as $col => $val) {
      if ($val == -1 || $val === FALSE || strtolower($val) == &#39;desc&#39;) {
        $this->sorts[$col] = -1;
      } else {
        $this->sorts[$col] = 1;
      }
    } return($this);
  }

  /**   *  --------------------------------------------------------------------------------   * LIMIT DOCUMENTS * --------------------------------------------------------------------------------   *  * Limit the result set to $x number of documents  *  * @usage = $this->mongo_db->limit($x);  */
  public function limit($x = 99999) {
    if ($x !== NULL && is_numeric($x) && $x >= 1) {
      $this->limit = (int) $x;
    } return($this);
  }

  /**   *  --------------------------------------------------------------------------------   * OFFSET DOCUMENTS   * --------------------------------------------------------------------------------   *  * Offset the result set to skip $x number of documents   *  * @usage = $this->mongo_db->offset($x); */
  public function offset($x = 0) {
    if ($x !== NULL && is_numeric($x) && $x >= 1) {
      $this->offset = (int) $x;
    } return($this);
  }

  /**   *  --------------------------------------------------------------------------------   * GET_WHERE  * --------------------------------------------------------------------------------   *  * Get the documents based upon the passed parameters  *  * @usage = $this->mongo_db->get_where(&#39;foo&#39;, array(&#39;bar&#39; => &#39;something&#39;));  */
  public function get_where($collection = "", $where = array(), $limit = 99999, $orderby=array()) {
    if (is_array($orderby) || !emptyempty($orderby)) {
      $order_by = $this->order_by($order_by);
    }
    return($this->where($where)->limit($limit)->get($collection));
  }
  public function selectA($collection = "", $limit = 99999, $orderby=array()) {
    if(intval($limit)<1){
      $limit = 999999;
    }
    $order_by = $this->order_by($orderby);
    $re = $this->limit($limit)->get($collection);
    $this->clear();
    return (array)$re;
  }

  public function listinfo($collection = "", $orderby=array(), $page=1, $pagesize=12) {
    $page = max(intval($page), 1);
    $offset = $pagesize * ($page - 1);
    $pagesizes = $offset + $pagesize;
    $this->offset($offset);
    $order_by = $this->order_by($orderby);
    $re = $this->limit($pagesize)->get($collection);
    $this->limit(999999);
    $count = $this->count($collection);
    $this->pages = pages($count, $page, $pagesize);
    return (array)$re;
  }

  /**   *  --------------------------------------------------------------------------------   * GET * --------------------------------------------------------------------------------   *  * Get the documents based upon the passed parameters  *  * @usage = $this->mongo_db->get(&#39;foo&#39;, array(&#39;bar&#39; => &#39;something&#39;)); */
  public function get($collection = "") {
    if (emptyempty($collection)) {
      $this->error("In order to retreive documents from MongoDB, a collection name must be passed", 500);
    } $results = array();
    $documents = $this->db->{$collection}->find($this->wheres, $this->selects)->limit((int) $this->limit)->skip((int) $this->offset)->sort($this->sorts);
    $returns = array();
    foreach ($documents as $doc): $returns[] = $doc;
    endforeach;
    return($returns);
  }

  public function getMy($collection = "") {
    if (emptyempty($collection)) {
      $this->error("In order to retreive documents from MongoDB, a collection name must be passed", 500);
    } $results = array();
    $documents = $this->db->{$collection}->find($this->wheres, $this->selects)->limit((int) $this->limit)->skip((int) $this->offset)->sort($this->sorts);
    $returns = array();
    foreach ($documents as $doc): $returns[] = $doc;
    endforeach;
    $this -> clear();
    return($returns);
  }

  /**   *  --------------------------------------------------------------------------------   * COUNT  * --------------------------------------------------------------------------------   *  * Count the documents based upon the passed parameters   *  * @usage = $this->mongo_db->get(&#39;foo&#39;); */
  public function count($collection = "") {
    if (emptyempty($collection)) {
      $this->error("In order to retreive a count of documents from MongoDB, a collection name must be passed", 500);
    } $count = $this->db->{$collection}->find($this->wheres)->limit((int) $this->limit)->skip((int) $this->offset)->count();
    $this->clear();
    return($count);
  }

  /**   *  --------------------------------------------------------------------------------   * INSERT  * --------------------------------------------------------------------------------   *  * Insert a new document into the passed collection   *  * @usage = $this->mongo_db->insert(&#39;foo&#39;, $data = array()); */
  public function insert($collection = "", $data = array(), $name=&#39;ID&#39;) {
    if (emptyempty($collection)) {
      $this->error("No Mongo collection selected to insert into", 500);
    } if (count($data) == 0 || !is_array($data)) {
      $this->error("Nothing to insert into Mongo collection or insert is not an array", 500);
    } try {
      /**
      wxcity_base::load_sys_class(&#39;whtysqs&#39;,&#39;&#39;,0);
      $mongoseq_class = new whtysqs(&#39;creaseidsqs&#39;);
      $re = $mongoseq_class->query("?name=" . $collection . "&opt=put&data=1");
       **/
      $re = put_sqs(&#39;list_mongo_creaseidsqs&#39;,&#39;1&#39;);
      if(is_numeric($re)){
        $re++;
        $data[$name] = intval($re);
      }else{
        $data[$name] = intval(time());
        //die(&#39;mongosqs error&#39;);
      }
      $this->db->{$collection}->insert($data, array(&#39;fsync&#39; => TRUE));
      $this->clear();
      return $data[$name];
    } catch (MongoCursorException $e) {
      $this->error("Insert of data into MongoDB failed: {$e->getMessage()}", 500);
    }
  }

  public function insertWithId($collection = "", $data = array()) {
    if (emptyempty($collection)) {
      $this->error("No Mongo collection selected to insert into", 500);
    } if (count($data) == 0 || !is_array($data)) {
      $this->error("Nothing to insert into Mongo collection or insert is not an array", 500);
    } try {
      $this->db->{$collection}->insert($data, array(&#39;fsync&#39; => TRUE));
      $this->clear();
      return 1;
    } catch (MongoCursorException $e) {
      $this->error("Insert of data into MongoDB failed: {$e->getMessage()}", 500);
    }
  }
  /**   *  --------------------------------------------------------------------------------   * UPDATE  * --------------------------------------------------------------------------------   *  * Update a document into the passed collection   *  * @usage = $this->mongo_db->update(&#39;foo&#39;, $data = array()); */
  public function update($collection = "", $data = array()) {
    if (emptyempty($collection)) {
      $this->error("No Mongo collection selected to update", 500);
    } if (count($data) == 0 || !is_array($data)) {
      $this->error("Nothing to update in Mongo collection or update is not an array", 500);
    } try {
      $this->db->{$collection}->update($this->wheres, array(&#39;$set&#39; => $data), array(&#39;fsync&#39; => TRUE, &#39;multiple&#39; => FALSE));
      $this->clear();
      return(TRUE);
    } catch (MongoCursorException $e) {
      $this->error("Update of data into MongoDB failed: {$e->getMessage()}", 500);
    }
  }

  /**   *  --------------------------------------------------------------------------------   * UPDATE_ALL  * --------------------------------------------------------------------------------   *  * Insert a new document into the passed collection   *  * @usage = $this->mongo_db->update_all(&#39;foo&#39;, $data = array()); */
  public function update_all($collection = "", $data = array()) {
    if (emptyempty($collection)) {
      $this->error("No Mongo collection selected to update", 500);
    } if (count($data) == 0 || !is_array($data)) {
      $this->error("Nothing to update in Mongo collection or update is not an array", 500);
    } try {
      $this->db->{$collection}->update($this->wheres, array(&#39;$set&#39; => $data), array(&#39;fsync&#39; => TRUE, &#39;multiple&#39; => TRUE));
      return(TRUE);
    } catch (MongoCursorException $e) {
      $this->error("Update of data into MongoDB failed: {$e->getMessage()}", 500);
    }
  }

  /**   *  --------------------------------------------------------------------------------   * DELETE  * --------------------------------------------------------------------------------   *  * delete document from the passed collection based upon certain criteria  *  * @usage = $this->mongo_db->delete(&#39;foo&#39;, $data = array()); */
  public function delete($collection = "") {
    if (emptyempty($collection)) {
      $this->error("No Mongo collection selected to delete from", 500);
    } try {
      $this->db->{$collection}->remove($this->wheres, array(&#39;fsync&#39; => TRUE, &#39;justOne&#39; => TRUE));
      $this->clear();
      return(TRUE);
    } catch (MongoCursorException $e) {
      $this->error("Delete of data into MongoDB failed: {$e->getMessage()}", 500);
    }
  }

  /**   *  --------------------------------------------------------------------------------   * DELETE_ALL  * --------------------------------------------------------------------------------   *  * Delete all documents from the passed collection based upon certain criteria *  * @usage = $this->mongo_db->delete_all(&#39;foo&#39;, $data = array()); */
  public function delete_all($collection = "") {
    if (emptyempty($collection)) {
      $this->error("No Mongo collection selected to delete from", 500);
    } try {
      $this->db->{$collection}->remove($this->wheres, array(&#39;fsync&#39; => TRUE, &#39;justOne&#39; => FALSE));
      return(TRUE);
    } catch (MongoCursorException $e) {
      $this->error("Delete of data into MongoDB failed: {$e->getMessage()}", 500);
    }
  }

  /**   *  --------------------------------------------------------------------------------   * ADD_INDEX  * --------------------------------------------------------------------------------   *  * Ensure an index of the keys in a collection with optional parameters. To set values to descending order,   * you must pass values of either -1, FALSE, &#39;desc&#39;, or &#39;DESC&#39;, else they will be  * set to 1 (ASC). *  * @usage = $this->mongo_db->add_index($collection, array(&#39;first_name&#39; => &#39;ASC&#39;, &#39;last_name&#39; => -1), array(&#39;unique&#39; => TRUE));  */
  public function add_index($collection = "", $keys = array(), $options = array()) {
    if (emptyempty($collection)) {
      $this->error("No Mongo collection specified to add index to", 500);
    } if (emptyempty($keys) || !is_array($keys)) {
      $this->error("Index could not be created to MongoDB Collection because no keys were specified", 500);
    } foreach ($keys as $col => $val) {
      if ($val == -1 || $val === FALSE || strtolower($val) == &#39;desc&#39;) {
        $keys[$col] = -1;
      } else {
        $keys[$col] = 1;
      }
    } if ($this->db->{$collection}->ensureIndex($keys, $options) == TRUE) {
      $this->clear();
      return($this);
    } else {
      $this->error("An error occured when trying to add an index to MongoDB Collection", 500);
    }
  }

  /**   *  --------------------------------------------------------------------------------   * REMOVE_INDEX   * --------------------------------------------------------------------------------   *  * Remove an index of the keys in a collection. To set values to descending order, * you must pass values of either -1, FALSE, &#39;desc&#39;, or &#39;DESC&#39;, else they will be  * set to 1 (ASC). *  * @usage = $this->mongo_db->remove_index($collection, array(&#39;first_name&#39; => &#39;ASC&#39;, &#39;last_name&#39; => -1));  */
  public function remove_index($collection = "", $keys = array()) {
    if (emptyempty($collection)) {
      $this->error("No Mongo collection specified to remove index from", 500);
    } if (emptyempty($keys) || !is_array($keys)) {
      $this->error("Index could not be removed from MongoDB Collection because no keys were specified", 500);
    } if ($this->db->{$collection}->deleteIndex($keys, $options) == TRUE) {
      $this->clear();
      return($this);
    } else {
      $this->error("An error occured when trying to remove an index from MongoDB Collection", 500);
    }
  }

  /**   *  --------------------------------------------------------------------------------   * REMOVE_ALL_INDEXES  * --------------------------------------------------------------------------------   *  * Remove all indexes from a collection.  *  * @usage = $this->mongo_db->remove_all_index($collection);  */
  public function remove_all_indexes($collection = "") {
    if (emptyempty($collection)) {
      $this->error("No Mongo collection specified to remove all indexes from", 500);
    } $this->db->{$collection}->deleteIndexes();
    $this->clear();
    return($this);
  }

  /**   *  --------------------------------------------------------------------------------   * LIST_INDEXES   * --------------------------------------------------------------------------------   *  * Lists all indexes in a collection.  *  * @usage = $this->mongo_db->list_indexes($collection);  */
  public function list_indexes($collection = "") {
    if (emptyempty($collection)) {
      $this->error("No Mongo collection specified to remove all indexes from", 500);
    } return($this->db->{$collection}->getIndexInfo());
  }

  /**   *  --------------------------------------------------------------------------------   * DROP COLLECTION * --------------------------------------------------------------------------------   *  * Removes the specified collection from the database. Be careful because this   * can have some very large issues in production!  */
  public function drop_collection($collection = "") {
    if (emptyempty($collection)) {
      $this->error("No Mongo collection specified to drop from database", 500);
    } $this->db->{$collection}->drop();
    return TRUE;
  }

  /**   *  --------------------------------------------------------------------------------   * CLEAR  * --------------------------------------------------------------------------------   *  * Resets the class variables to default settings  */
  private function clear() {
    $this->selects = array();
    $this->wheres = array();
    $this->limit = NULL;
    $this->offset = NULL;
    $this->sorts = array();
  }

  /**   *  --------------------------------------------------------------------------------   * WHERE INITIALIZER  * --------------------------------------------------------------------------------   *  * Prepares parameters for insertion in $wheres array().  */
  private function where_init($param) {
    if (!isset($this->wheres[$param])) {
      $this->wheres[$param] = array();
    }
  }

  public function error($str, $t) {
    echo $str;
    exit;
  }

}

?>
登录后复制

使用范例:


$table_name=trim(strtolower($this->table_name));
$this->mongo_db->where($where);
$order=!emptyempty($order)?array(&#39;AID&#39;=>&#39;DESC&#39;):array(&#39;AID&#39;=>&#39;ASC&#39;);//升序降序
$infos=$this->mongo_db->listinfo($table_name,$order,$page,$pagesize);
登录后复制

相关推荐:

php实现的mongodb操作类

php mongodb操作类 带几个简单的例子

php实现的mongodb操作类实例_PHP教程


以上是php封装mongodb操作类代码分享的详细内容。更多信息请关注PHP中文网其他相关文章!

本站声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover

AI Clothes Remover

用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool

Undress AI Tool

免费脱衣服图片

Clothoff.io

Clothoff.io

AI脱衣机

Video Face Swap

Video Face Swap

使用我们完全免费的人工智能换脸工具轻松在任何视频中换脸!

热工具

记事本++7.3.1

记事本++7.3.1

好用且免费的代码编辑器

SublimeText3汉化版

SublimeText3汉化版

中文版,非常好用

禅工作室 13.0.1

禅工作室 13.0.1

功能强大的PHP集成开发环境

Dreamweaver CS6

Dreamweaver CS6

视觉化网页开发工具

SublimeText3 Mac版

SublimeText3 Mac版

神级代码编辑软件(SublimeText3)

PHP和Python:比较两种流行的编程语言 PHP和Python:比较两种流行的编程语言 Apr 14, 2025 am 12:13 AM

PHP和Python各有优势,选择依据项目需求。1.PHP适合web开发,尤其快速开发和维护网站。2.Python适用于数据科学、机器学习和人工智能,语法简洁,适合初学者。

PHP:网络开发的关键语言 PHP:网络开发的关键语言 Apr 13, 2025 am 12:08 AM

PHP是一种广泛应用于服务器端的脚本语言,特别适合web开发。1.PHP可以嵌入HTML,处理HTTP请求和响应,支持多种数据库。2.PHP用于生成动态网页内容,处理表单数据,访问数据库等,具有强大的社区支持和开源资源。3.PHP是解释型语言,执行过程包括词法分析、语法分析、编译和执行。4.PHP可以与MySQL结合用于用户注册系统等高级应用。5.调试PHP时,可使用error_reporting()和var_dump()等函数。6.优化PHP代码可通过缓存机制、优化数据库查询和使用内置函数。7

PHP的当前状态:查看网络开发趋势 PHP的当前状态:查看网络开发趋势 Apr 13, 2025 am 12:20 AM

PHP在现代Web开发中仍然重要,尤其在内容管理和电子商务平台。1)PHP拥有丰富的生态系统和强大框架支持,如Laravel和Symfony。2)性能优化可通过OPcache和Nginx实现。3)PHP8.0引入JIT编译器,提升性能。4)云原生应用通过Docker和Kubernetes部署,提高灵活性和可扩展性。

PHP与其他语言:比较 PHP与其他语言:比较 Apr 13, 2025 am 12:19 AM

PHP适合web开发,特别是在快速开发和处理动态内容方面表现出色,但不擅长数据科学和企业级应用。与Python相比,PHP在web开发中更具优势,但在数据科学领域不如Python;与Java相比,PHP在企业级应用中表现较差,但在web开发中更灵活;与JavaScript相比,PHP在后端开发中更简洁,但在前端开发中不如JavaScript。

PHP的持久相关性:它还活着吗? PHP的持久相关性:它还活着吗? Apr 14, 2025 am 12:12 AM

PHP仍然具有活力,其在现代编程领域中依然占据重要地位。1)PHP的简单易学和强大社区支持使其在Web开发中广泛应用;2)其灵活性和稳定性使其在处理Web表单、数据库操作和文件处理等方面表现出色;3)PHP不断进化和优化,适用于初学者和经验丰富的开发者。

PHP的目的:构建动态网站 PHP的目的:构建动态网站 Apr 15, 2025 am 12:18 AM

PHP用于构建动态网站,其核心功能包括:1.生成动态内容,通过与数据库对接实时生成网页;2.处理用户交互和表单提交,验证输入并响应操作;3.管理会话和用户认证,提供个性化体验;4.优化性能和遵循最佳实践,提升网站效率和安全性。

PHP与Python:核心功能 PHP与Python:核心功能 Apr 13, 2025 am 12:16 AM

PHP和Python各有优势,适合不同场景。1.PHP适用于web开发,提供内置web服务器和丰富函数库。2.Python适合数据科学和机器学习,语法简洁且有强大标准库。选择时应根据项目需求决定。

PHP:许多网站的基础 PHP:许多网站的基础 Apr 13, 2025 am 12:07 AM

PHP成为许多网站首选技术栈的原因包括其易用性、强大社区支持和广泛应用。1)易于学习和使用,适合初学者。2)拥有庞大的开发者社区,资源丰富。3)广泛应用于WordPress、Drupal等平台。4)与Web服务器紧密集成,简化开发部署。

See all articles