這篇文章主要為大家詳細介紹了升級PHP7操作MongoDB的方法,文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下。

成都創(chuàng)新互聯(lián)公司專注于江山企業(yè)網(wǎng)站建設,響應式網(wǎng)站設計,成都做商城網(wǎng)站。江山網(wǎng)站建設公司,為江山等地區(qū)提供建站服務。全流程定制制作,專業(yè)設計,全程項目跟蹤,成都創(chuàng)新互聯(lián)公司專業(yè)和態(tài)度為您提供的服務
前言
使用 PHP+MongoDB 的用戶很多,因為 MongoDB 對非結構化數(shù)據(jù)的存儲很方便。在 PHP5 及以前,官方提供了兩個擴展,Mongo 和 MongoDB,其中 Mongo 是對以 MongoClient 等幾個核心類為基礎的類群進行操作,封裝得很方便,所以基本上都會選擇 Mongo 擴展。
詳情請見官方手冊:https://www.php.net/manual/zh/book.mongo.php
但是隨著 PHP5 升級到 PHP7,官方不再支持 Mongo 擴展,只支持 MongoDB,而 PHP7 的性能提升巨大,讓人無法割舍,所以怎么把 Mongo 替換成 MongoDB 成為了一個亟待解決的問題。MongoDB 引入了命名空間,但是功能封裝非常差,如果非要用原生的擴展,幾乎意味著寫原生的 Mongo 語句。這種想法很違背 ORM 簡化 DB IO 操作帶來的語法問題而專注邏輯優(yōu)化的思路。
詳情也可參見官方手冊:https://www.php.net/manual/zh/set.mongodb.php
在這種情況之下,MongoDB 官方忍不住了,為了方便使用,增加市場占有率,推出了基于MongoDB 擴展的庫:https://github.com/mongodb/mongo-php-library
該庫的詳細文檔見:https://docs.mongodb.com/php-library/current/reference/
MongoDB 驅動
如果使用原驅動的話,大致語法如下:
<?php
use MongoDB\Driver\Manager;
use MongoDB\Driver\BulkWrite;
use MongoDB\Driver\WriteConcern;
use MongoDB\Driver\Query;
use MongoDB\Driver\Command;
class MongoDb {
protected $mongodb;
protected $database;
protected $collection;
protected $bulk;
protected $writeConcern;
protected $defaultConfig
= [
'hostname' => 'localhost',
'port' => '27017',
'username' => '',
'password' => '',
'database' => 'test'
];
public function __construct($config) {
$config = array_merge($this->defaultConfig, $config);
$mongoServer = "mongodb://";
if ($config['username']) {
$mongoServer .= $config['username'] . ':' . $config['password'] . '@';
}
$mongoServer .= $config['hostname'];
if ($config['port']) {
$mongoServer .= ':' . $config['port'];
}
$mongoServer .= '/' . $config['database'];
$this->mongodb = new Manager($mongoServer);
$this->database = $config['database'];
$this->collection = $config['collection'];
$this->bulk = new BulkWrite();
$this->writeConcern = new WriteConcern(WriteConcern::MAJORITY, 100);
}
public function query($where = [], $option = []) {
$query = new Query($where, $option);
$result = $this->mongodb->executeQuery("$this->database.$this->collection", $query);
return json_encode($result);
}
public function count($where = []) {
$command = new Command(['count' => $this->collection, 'query' => $where]);
$result = $this->mongodb->executeCommand($this->database, $command);
$res = $result->toArray();
$count = 0;
if ($res) {
$count = $res[0]->n;
}
return $count;
}
public function update($where = [], $update = [], $upsert = false) {
$this->bulk->update($where, ['$set' => $update], ['multi' => true, 'upsert' => $upsert]);
$result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
return $result->getModifiedCount();
}
public function insert($data = []) {
$this->bulk->insert($data);
$result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
return $result->getInsertedCount();
}
public function delete($where = [], $limit = 1) {
$this->bulk->delete($where, ['limit' => $limit]);
$result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
return $result->getDeletedCount();
}
}這樣的語法和之前差異太大,改動不方便,換 PHP MongoDB 庫
MongoDB 庫
1.連接
原
new MongoClient();
新
new MongoDB\Client();
2.新增
原
$collention->insert($array, $options);
新
$resultOne = $collention->insertOne($array, $options);//單 $lastId = $resultOne->getInsertedId(); $resultMany = $collention->insertMany($array, $options);//多 $count = $resultMany->getInsertedCount();
3.修改
原
$collention->update($condition, [
'$set' => $values
,[
'multiple' => true//多條,單條false
]);新
$collection->updateOne(
['state' => 'ny'],
['$set' => ['country' => 'us']]
);
$updateResult = $collection->updateMany(
['state' => 'ny'],
['$set' => ['country' => 'us']]
);
$count = $updateResult->getModifiedCount();4.查詢
原
$cursor = $collection->find($condition, [
'name' => true//指定字段
]);
$cursor->skip(5);
$cursor->limit(5);
$cursor->sort([
'time' => -1
]);新
$cursor = $collection->find($condition, [
'skip' => 5,
'limit' => 5,
'sort' => [
'time' => -1
],//排序
'projection' => [
'name' => 1//指定字段
]
]);5.刪除
原
$collention->remove($condition, [
'justOne' => false//刪單條
]);
$collention->remove([]);//刪所有新
$result = $collention->deleteOne($condition, $options); $collention->deleteMany($condition, $options); $result->getDeletedCount();
補充
有些人可能習慣以類似 MySQL 的自增 ID 來處理數(shù)據(jù),以前可能使用 findAndModify() 方法來查詢并修改:
$collention->findAndModify([
'_id' => $tableName//我在自增表中用其它的表名作主鍵
], [
'$inc' => ['id' => 1]//自增
], [
'_id' => 0
], [
'new' => 1//返回修改后的結果,默認是修改前的
]);現(xiàn)在使用 MongoDB 庫的話需要修改為:
$collention->findOneAndUpdate([
'_id' => $tableName
], [
'$inc' => ['id' => 1]
], [
'projection' => ['id' => 1],
'returnDocument' => MongoDB\Operation\FindOneAndUpdate::RETURN_DOCUMENT_AFTER
]);以上就是升級PHP7操作MongoDB方法的簡略介紹,當然詳細使用上面的不同還得要大家自己使用過才領會。如果想了解更多,歡迎關注創(chuàng)新互聯(lián)行業(yè)資訊頻道哦!
當前文章:升級PHP7操作MongoDB的方法介紹
網(wǎng)站鏈接:http://jinyejixie.com/article10/posggo.html
成都網(wǎng)站建設公司_創(chuàng)新互聯(lián),為您提供做網(wǎng)站、網(wǎng)站制作、電子商務、微信公眾號、網(wǎng)站策劃、搜索引擎優(yōu)化
聲明:本網(wǎng)站發(fā)布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經(jīng)允許不得轉載,或轉載時需注明來源: 創(chuàng)新互聯(lián)