PHP7 mongoDB扩展使用的方法分享


						前言

最近在做的项目需要将PHP5.6升级到PHP7.0，使用过PHP-mongo扩展的同学应该知道，PHP7.0的mongodb扩展是完全不兼容PHP5.6的mongo扩展的，php-mongodb改如何使用呢。

下面直接说明各种方法的使用:

1.mongodb连接：







private function connect($confArr) {

 try{

  $connStr = "mongodb://" . $confArr['host'] . ":" . $confArr['port'] . "/" . $confArr['db_name'];

  $options = array(

   'username' => $confArr['username'],

   'password' => $confArr['password'],

   'readPreference' => $confArr['read_preference'],

   'connectTimeoutMS' => intval($confArr['connect_timeout_ms']),

   'socketTimeoutMS' => intval($confArr['socket_timeout_ms']),

  );

  $mc = new MongoDB\Driver\Manager($connStr, $options);

  return $mc;

 }

 catch(Exception $e){

  return false;

 }

}



2.查询find:







public function find($query = array(), $fields = array(), $collection, $sort = array(), $limit = 0, $skip = 0) {

 $conn = $this->connect();

 if (empty($conn)) {

  return false;

 }

 try {

  $data = array();

  $options = array();

  if (!empty($query)) {

   $options['projection'] = array_fill_keys($fields, 1);

  }

  if (!empty($sort)) {

   $options['sort'] = $sort;

  }

  if (!empty($limit)) {

   $options['skip'] = $skip;

   $options['limit'] = $limit;

  }

  $mongoQuery = new MongoDB\Driver\Query($query, $options);

  $readPreference = new MongoDB\Driver\ReadPreference(MongoDB\Driver\ReadPreference::RP_SECONDARY);

  $cursor = $conn->executeQuery($collection, $mongoQuery, $readPreference);

  foreach($cursor as $value) {

   $data[] = (array)$value;

  }

  return $data;

 } catch (Exception $e) {

  //记录错误日志

 }

 return false;

}



3.插入操作insert:







public function insert($addArr, $collection) {

 if (empty($addArr) || !is_array($addArr)) {

  return false;

 }

 $conn = $this->connect();

 if (empty($conn)) {

  return false;

 }

 try {

  $bulk = new MongoDB\Driver\BulkWrite();

  $bulk->insert($addArr);

  $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 6000);

  $result = $conn->executeBulkWrite($collection, $bulk, $writeConcern);

  if ($result->getInsertedCount()) {

   return true;

  }

 } catch (Exception $e) {

  //记录错误日志

 }

 return false;

}



4.删除delete：







public function delete($whereArr, $options = array(), $collection) {

 if (empty($whereArr)) {

  return false;

 }

 if (!isset($options['justOne'])) {

  $options = array(

   'justOne' => false,

  );

 }

 $conn = $this->connect();

 if (empty($conn)) {

  return false;

 }

 try {

  $bulk = new MongoDB\Driver\BulkWrite();

  $bulk->delete($whereArr, $options);

  $writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 30000);

  $result = $conn->executeBulkWrite($collection, $bulk, $writeConcern);

  return true;

 } catch (Exception $e) {

  //记录错误日志

 }

 return false;

}



5.执行command操作:







private function command($params, $dbName) {

 $conn = $this->connect();

 if (empty($conn)) {

  return false;

 }

 try {

  $cmd = new MongoDB\Driver\Command($params);

  $result = $conn->executeCommand($dbName, $cmd);

  return $result;

 } catch (Exception $e) {

  //记录错误

 }

 return false;

}



6.统计count:







public function count($query, $collection) {

 try {

  $cmd = array(

   'count' => $collection,

   'query' => $query,

  );

  $res = $this->command($cmd);

  $result = $res->toArray();

  return $result[0]->n;

 } catch (Exception $e) {

  //记录错误

 }

 return false;

}



7.聚合distinct:







public function distinct($key, $where, $collection) {

 try {

  $cmd = array(

   'distinct' => $collection,

   'key' => $key,

   'query' => $where,

  );

  $res = $this->command($cmd);

  $result = $res->toArray();

  return $result[0]->values;

 } catch (Exception $e) {

  //记录错误

 }

 return false;

}



8.aggregate操作：







public function aggregate($where, $group, $collection) {

 try {

  $cmd = array(

   'aggregate' => $collection,

   'pipeline' => array(

    array(

     '$match' => $where,

    ),

    array(

     '$group' => $group,

    ),

   ),

   'explain' => false,

  );

  $res = $this->command($cmd);

  if (!$res) {

   return false;

  }

  $result = $res->toArray();

  return $result[0]->total;

 } catch (Exception $e) {

  //记录错误

 }

 return false;

}



总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对中文源码网的支持。