分析php中的mongodb操作类

2020-03-22 18:14:07

字体：大中小

来源：转载

供稿：网友

这篇文章主要介绍了php实现的mongodb操作类,较为详细的分析了php针对mongodb数据库操作的各种常用技巧,并将其封装进一个完整的类文件中以便于调用,非常具有实用价值,需要的朋友可以参考下

本文实例讲述了php实现的mongodb操作类。分享给大家供大家参考。具体如下：

 ?php  * To change this template, choose Tools | Templates * and open the template in the editor.html' target='_blank'>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( Mongo )) {  //$this- error( The MongoDB PECL extension has not been installed or enabled , 500);  $configs =wxcity_base::load_config( cache , mongo_db  $num = count($configs[ connect  $this- timeout = trim($configs[ timeout  $keys = wxcity_base::load_config( double  $this- key = $keys[ mongo_db  $this- config = $configs[ connect ][$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[ connect ][$key];  $status = $this- connect();  if($status!=false)  $keys[ mongo_db ] = $key ;  $this- key = $key;  $data = ?php/nreturn .var_export($keys, true). /n?  file_put_contents(WHTY_PATH. configs/double.php , $data, LOCK_EX);  break;  if($status==false)  die( mongoDB not connect  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 mongo_persist_key was set to true in the  * config file, establish a persistent connection. We allow for only the persist  * option to be set because we want to  establish a connection immediately. private function connect() {  $this- connection_string();  $options = array( connect = true, timeout = $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[ hostname  $this- port = trim($this- config[ port  $this- user = trim($this- config[ username  $this- pass = trim($this- config[ password  $this- dbname = trim($this- config[ database  $this- persist = trim($this- config[ autoconnect  $this- persist_key = trim($this- config[ mongo_persist_key  $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 = ) {  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( foo , bar ))- get( foobar  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( foo = bar ))- get( foobar  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( foo , array( bar , zoo , blah ))- get( foobar  public function where_in($field = , $in = array()) {  $this- where_init($field);  $this- wheres[$field][ $in ] = $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( foo , array( bar , zoo , blah ))- get( foobar  public function where_not_in($field = , $in = array()) {  $this- where_init($field);  $this- wheres[$field][ $nin ] = $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( foo , 20); public function where_gt($field = , $x) {  $this- where_init($field);  $this- wheres[$field][ $gt ] = $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( foo , 20); public function where_gte($field = , $x) {  $this- where_init($field);  $this- wheres[$field][ $gte ] = $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( foo , 20); public function where_lt($field = , $x) {  $this- where_init($field);  $this- wheres[$field][ $lt ] = $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( foo , 20); public function where_lte($field = , $x) {  $this- where_init($field);  $this- wheres[$field][ $lte ] = $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( foo , 20, 30); public function where_between($field = , $x, $y) {  $this- where_init($field);  $this- wheres[$field][ $gte ] = $x;  $this- wheres[$field][ $lte ] = $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( foo , 20, 30); public function where_between_ne($field = , $x, $y) {  $this- where_init($field);  $this- wheres[$field][ $gt ] = $x;  $this- wheres[$field][ $lt ] = $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( foo , 20, 30); public function where_ne($field = , $x) {  $this- where_init($field);  $this- wheres[$field][ $ne ] = $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( foo , array( foo , bar , blegh  public function where_or($field = , $values) {  $this- where_init($field);  $this- wheres[$field][ $or ] = $values;  return($this);  * WHERE AND * * Get the documents where the elements match  the specified values * * @usage = $this- mongo_db- where_and( array ( foo = 1, b = someexample  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( foo , 10, 1 ); public function where_mod($field, $num, $result) {  $this- where_init($field);  $this- wheres[$field][ $mod ] = 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( foo , 1)- get( foobar */  public function where_size($field = , $size = ) {  $this- _where_init($field);  $this- wheres[$field][ $size ] = $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( foo , bar , im , 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, desc , or DESC , else they will be * set to 1 (ASC). * @usage = $this- mongo_db- where_between( foo , 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) == desc ) {  $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( foo , array( bar = something  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( foo , array( bar = something  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( foo  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( foo , $data = array()); public function insert($collection = , $data = array(), $name= ID ) {  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( whtysqs , ,0);  $mongoseq_class = new whtysqs( creaseidsqs  $re = $mongoseq_class- query( ?name= . $collection . opt=put data=1  **/  $re = put_sqs( list_mongo_creaseidsqs , 1  if(is_numeric($re)){  $re++;  $data[$name] = intval($re);  }else{  $data[$name] = intval(time());  //die( mongosqs error  $this- db- {$collection}- insert($data, array( fsync = 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( fsync = 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( foo , $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( $set = $data), array( fsync = TRUE, multiple = 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( foo , $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( $set = $data), array( fsync = TRUE, multiple = 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( foo , $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( fsync = TRUE, justOne = 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( foo , $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( fsync = TRUE, justOne = 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, desc , or DESC , else they will be * set to 1 (ASC). * * @usage = $this- mongo_db- add_index($collection, array( first_name = ASC , last_name = -1), array( unique = 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) == desc ) {  $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, desc , or DESC , else they will be * set to 1 (ASC). * * @usage = $this- mongo_db- remove_index($collection, array( first_name = ASC , last_name = -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( AID = DESC ):array( AID = ASC //升序降序 $infos=$this- mongo_db- listinfo($table_name,$order,$page,$pagesize);

总结：以上就是本篇文的全部内容，希望能对大家的学习有所帮助。