摘要:最近在做的項(xiàng)目需要將升級(jí)到,使用過擴(kuò)展的同學(xué)應(yīng)該知道,的擴(kuò)展是完全不兼容的擴(kuò)展的,改如何使用呢。
最近在做的項(xiàng)目需要將PHP5.6升級(jí)到PHP7.0,使用過PHP-mongo擴(kuò)展的同學(xué)應(yīng)該知道,PHP7.0的mongodb擴(kuò)展是完全不兼容PHP5.6的mongo擴(kuò)展的,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 MongoDBDriverManager($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 MongoDBDriverQuery($query, $options); $readPreference = new MongoDBDriverReadPreference(MongoDBDriverReadPreference::RP_SECONDARY); $cursor = $conn->executeQuery($collection, $mongoQuery, $readPreference); foreach($cursor as $value) { $data[] = (array)$value; } return $data; } catch (Exception $e) { //記錄錯(cuò)誤日志 } 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 MongoDBDriverBulkWrite(); $bulk->insert($addArr); $writeConcern = new MongoDBDriverWriteConcern(MongoDBDriverWriteConcern::MAJORITY, 6000); $result = $conn->executeBulkWrite($collection, $bulk, $writeConcern); if ($result->getInsertedCount()) { return true; } } catch (Exception $e) { //記錄錯(cuò)誤日志 } 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 MongoDBDriverBulkWrite(); $bulk->delete($whereArr, $options); $writeConcern = new MongoDBDriverWriteConcern(MongoDBDriverWriteConcern::MAJORITY, 30000); $result = $conn->executeBulkWrite($collection, $bulk, $writeConcern); return true; } catch (Exception $e) { //記錄錯(cuò)誤日志 } return false; }5.執(zhí)行command操作:
private function command($params, $dbName) { $conn = $this->connect(); if (empty($conn)) { return false; } try { $cmd = new MongoDBDriverCommand($params); $result = $conn->executeCommand($dbName, $cmd); return $result; } catch (Exception $e) { //記錄錯(cuò)誤 } return false; }6.統(tǒng)計(jì)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) { //記錄錯(cuò)誤 } 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) { //記錄錯(cuò)誤 } 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) { //記錄錯(cuò)誤 } return false; }
文章版權(quán)歸作者所有,未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址:http://specialneedsforspecialkids.com/yun/19516.html
摘要:上的擴(kuò)展有兩個(gè),都是官方出品的,一個(gè)叫,一個(gè)是,前者已經(jīng)被官方廢棄,不再提供穩(wěn)定的更新,官方推薦使用后者,并且后者是支持的。在上搜索即可找到,也可以通過安裝。使用作為中間件,不用修改現(xiàn)有代碼。 pecl上的mongodb擴(kuò)展有兩個(gè),都是官方出品的,一個(gè)叫mongo,一個(gè)是mongodb,前者已經(jīng)被官方廢棄,不再提供穩(wěn)定的更新,官方推薦使用后者,并且后者是支持php7的。在pecl上搜索...
摘要:上的擴(kuò)展有兩個(gè),都是官方出品的,一個(gè)叫,一個(gè)是,前者已經(jīng)被官方廢棄,不再提供穩(wěn)定的更新,官方推薦使用后者,并且后者是支持的。在上搜索即可找到,也可以通過安裝。使用作為中間件,不用修改現(xiàn)有代碼。 pecl上的mongodb擴(kuò)展有兩個(gè),都是官方出品的,一個(gè)叫mongo,一個(gè)是mongodb,前者已經(jīng)被官方廢棄,不再提供穩(wěn)定的更新,官方推薦使用后者,并且后者是支持php7的。在pecl上搜索...
摘要:在及以前,官方提供了兩個(gè)擴(kuò)展,和,其中是對(duì)以等幾個(gè)核心類為基礎(chǔ)的類群進(jìn)行操作,封裝得很方便,所以基本上都會(huì)選擇擴(kuò)展。這種想法很違背簡化操作帶來的語法問題而專注邏輯優(yōu)化的思路。 前言 使用 PHP+MongoDB 的用戶很多,因?yàn)?MongoDB 對(duì)非結(jié)構(gòu)化數(shù)據(jù)的存儲(chǔ)很方便。在 PHP5 及以前,官方提供了兩個(gè)擴(kuò)展,Mongo 和 MongoDB,其中 Mongo 是對(duì)以 MongoCl...
摘要:在及以前,官方提供了兩個(gè)擴(kuò)展,和,其中是對(duì)以等幾個(gè)核心類為基礎(chǔ)的類群進(jìn)行操作,封裝得很方便,所以基本上都會(huì)選擇擴(kuò)展。這種想法很違背簡化操作帶來的語法問題而專注邏輯優(yōu)化的思路。 前言 使用 PHP+MongoDB 的用戶很多,因?yàn)?MongoDB 對(duì)非結(jié)構(gòu)化數(shù)據(jù)的存儲(chǔ)很方便。在 PHP5 及以前,官方提供了兩個(gè)擴(kuò)展,Mongo 和 MongoDB,其中 Mongo 是對(duì)以 MongoCl...
摘要:最近在做的項(xiàng)目需要將升級(jí)到,使用過擴(kuò)展的同學(xué)應(yīng)該知道,的擴(kuò)展是完全不兼容的擴(kuò)展的,改如何使用呢。 最近在做的項(xiàng)目需要將PHP5.6升級(jí)到PHP7.0,使用過PHP-mongo擴(kuò)展的同學(xué)應(yīng)該知道,PHP7.0的mongodb擴(kuò)展是完全不兼容PHP5.6的mongo擴(kuò)展的,php-mongodb改如何使用呢。 下面直接說明各種方法的使用: 1.mongodb連接: private func...
閱讀 2219·2019-08-30 15:53
閱讀 2444·2019-08-30 12:54
閱讀 1187·2019-08-29 16:09
閱讀 718·2019-08-29 12:14
閱讀 746·2019-08-26 10:33
閱讀 2461·2019-08-23 18:36
閱讀 2950·2019-08-23 18:30
閱讀 2111·2019-08-22 17:09