前言
最近在做的項目需要將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;
}
總結
以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，謝謝大家對腳本之家的支持。
您可能感興趣的文章:- PHP擴展Swoole實現實時異步任務隊列示例
- PHP基于mcript擴展實現對稱加密功能示例
- PHP安裝memcache擴展的步驟講解
- PHP安裝BCMath擴展的方法
- PHP擴展mcrypt實現的AES加密功能示例
- php的擴展寫法總結
