前言
最近在做的项目需要将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;
}
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对移动技术网的支持。
如对本文有疑问， 点击进行留言回复！！
thinkphp5 + ajax 使用formdata提交数据（包括文件上传） 后台返回json完整实例
网友评论