您当前的位置:首页 > 电脑百科 > 程序开发 > 语言 > php

php7的Mongodb扩展笔记

时间:2019-09-24 13:35:00  来源:  作者:

php7.0的mongodb扩展是完全不兼容以前老的php5.6的mongo扩展的,在这里对mongodb的扩展做一个简单的总结。

废话不多说直接写代码

# 创建mongodb链接
public function connect($conf_arr) {
 try{
 $conn_str = "mongodb://" . $conf_arr['host'] . ":" . $conf_arr['port'] . "/" . $conf_arr['db_name'];
 $options = array(
 'username' => $conf_arr['username'],
 'password' => $conf_arr['password'],
 'readPreference' => $conf_arr['read_preference'],
 'connectTimeoutMS' => intval($conf_arr['connect_timeout_ms']),
 'socketTimeoutMS' => intval($conf_arr['socket_timeout_ms']),
 );
 return new MongoDBDriverManager($conn_str, $options);
 }
 catch(Exception $e){
 return false;
 }
}
# find查询方法
public function find($query = [], $fields = [], $collection, $sort = [], $limit = 0, $skip = 0) {
 $conn = $this->connect();
 if (empty($conn)) return false;
 try {
 $data = [];
 $options = [];
 if (!empty($query)) {
 $options['projection'] = array_fill_keys($fields, 1);
 }
 if (!empty($sort)) $options['sort'] = $sort;
 if (!empty($limit)) $options['limit'] = $limit;
 if (!empty($skip)) $options['skip'] = $skip;
 $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) {
 // write log
 }
 return false;
}
# insert 插入方法
public function insert($add_arr, $collection) {
 if (empty($add_arr) || !is_array($add_arr) || '' == $collection) {
 return false;
 }
 $conn = $this->connect();
 if (empty($conn)) {
 return false;
 }
 try {
 $bulk = new MongoDBDriverBulkWrite();
 $bulk->insert($add_arr);
 $writeConcern = new MongoDBDriverWriteConcern(MongoDBDriverWriteConcern::MAJORITY, 6000);
 $result = $conn->executeBulkWrite($collection, $bulk, $writeConcern);
 if ($result->getInsertedCount()) {
 return true;
 }
 } catch (Exception $e) {
 // write log pass
 }
 return false;
}
# delete 删除方法
public function delete($where_arr, $options = [], $collection) {
 if (empty($where_arr) || '' == $collection) {
 return false;
 }
 if (!isset($options['justOne'])) {
 $options['justOne'] = false;
 }
 $conn = $this->connect();
 if (empty($conn)) {
 return false;
 }
 try {
 $bulk = new MongoDBDriverBulkWrite();
 $bulk->delete($where_arr, $options);
 $writeConcern = new MongoDBDriverWriteConcern(MongoDBDriverWriteConcern::MAJORITY, 30000);
 $result = $conn->executeBulkWrite($collection, $bulk, $writeConcern);
 return true;
 } catch (Exception $e) {
 // write log pass
 }
 return false;
}
# 执行cmd命令操作
public 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) {
 // write log pass
 }
 return false;
}
# distinct方法
public function distinct($key, $where, $collection) {
 try {
 $cmd = [
 'distinct' => $collection,
 'key' => $key,
 'query' => $where,
 ];
 $res = $this->command($cmd);
 $result = $res->toArray();
 return $result[0]->values;
 } catch (Exception $e) {
 // write log pass
 }
 return false;
}
# count方法
public function count($query, $collection) {
 try {
 $cmd = [
 'count' => $collection,
 'query' => $query,
 ];
 $res = $this->command($cmd);
 $result = $res->toArray();
 return $result[0]->n;
 } catch (Exception $e) {
 // write log pass
 }
 return false;
}
# aggregate 方法
public function aggregate($where, $group, $collection) {
 try {
 $cmd = [
 'aggregate' => $collection,
 'pipeline' => [
 ['$match' => $where],
 ['$group' => $group],
 ],
 'explain' => false,
 ];
 $res = $this->command($cmd);
 if (!$res) {
 return false;
 }
 $result = $res->toArray();
 return $result[0]->total;
 } catch (Exception $e) {
 // write log
 }
 return false;
}
php7的Mongodb扩展笔记

 



Tags:php7 Mongodb   点击:()  评论:()
声明:本站部分内容及图片来自互联网,转载是出于传递更多信息之目的,内容观点仅代表作者本人,如有任何标注错误或版权侵犯请与我们联系(Email:2595517585@qq.com),我们将及时更正、删除,谢谢。
▌相关推荐
php7.0的mongodb扩展是完全不兼容以前老的php5.6的mongo扩展的,在这里对mongodb的扩展做一个简单的总结。废话不多说直接写代码# 创建mongodb链接public function connect($c...【详细内容】
2019-09-24  Tags: php7 Mongodb  点击:(101)  评论:(0)  加入收藏
▌简易百科推荐
序言:前段时间织梦因为版权的问题在网上闹得沸沸扬扬,也提醒了众多开发者选择cms上应该谨慎使用,今天给大家展示一款自己搭建的内容管理系统,不用担心版权的问题,而且非常容易维...【详细内容】
2021-11-30  小程序软件开发    Tags:管理系统   点击:(34)  评论:(0)  加入收藏
准备安装包(PHP: Hypertext Preprocessor)下载安装包以及组件wget https://www.php.net/distributions/php-8.0.0.tar.bz2wget https://github.com/phpredis/phpredis/archive...【详细内容】
2021-11-09  mimic96    Tags:PHP   点击:(40)  评论:(0)  加入收藏
golang context 很好用,就使用php实现了github地址 : https://github.com/qq1060656096/php-go-context context使用闭坑指南1. 将一个Context参数作为第一个参数传递给传入和...【详细内容】
2021-11-05  1060656096    Tags:PHP   点击:(41)  评论:(0)  加入收藏
一段数组为例:$list = array:4 [ 0 => array:7 [ "id" => 56 "mer_id" => 7 "order_id" => "wx163265961408769974" "is_postage" => 0 "store_name" => "奇...【详细内容】
2021-09-29  七七小影视    Tags:PHP   点击:(65)  评论:(0)  加入收藏
利用JS的CryptoJS 3.x和PHP的openssl_encrypt,openssl_decrypt实现AES对称加密解密,由于需要两种语言对同一字符串的操作,而CryptoJS 的默认加密方式为“aes-256-cbc”,PHP端也...【详细内容】
2021-09-16  李老师tome    Tags:对称加密   点击:(79)  评论:(0)  加入收藏
1、checkdate()验证格利高里日期即:日期是否存在。checkdate(month,day,year);month必需。一个从 1 到 12 的数字,规定月。day必需。一个从 1 到 31 的数字,规定日。year必需。...【详细内容】
2021-08-31  七七小影视    Tags:时间函数   点击:(80)  评论:(0)  加入收藏
对于各类开发语言来说,整数都有一个最大的位数,如果超过位数就无法显示或者操作了。其实,这也是一种精度越界之后产生的精度丢失问题。在我们的 PHP 代码中,最大的整数非常大,我...【详细内容】
2021-08-26  硬核项目经理    Tags:PHP   点击:(83)  评论:(0)  加入收藏
遵从所有教材以及各类数据结构相关的书书籍,我们先从线性表开始入门。今天这篇文章更偏概念,是关于有线性表的一个知识点的汇总。上文说过,物理结构是用于确定数据以何种方式存...【详细内容】
2021-07-19  硬核项目经理    Tags:线性表   点击:(94)  评论:(0)  加入收藏
一、开启IIS全部功能。二、部署PHP1.官网下载并解压PHP: https://windows.php.net/downloads/releases/2.将php.ini-development文件改为php.ini3.修改php.ini(1)去掉注释,并修...【详细内容】
2021-07-15  炘蓝火诗  今日头条  Tags:PHP环境   点击:(129)  评论:(0)  加入收藏
一、环境说明本文中使用本地VM虚机部署测试。OS:CentOS Linux release 7.8.2003 (Core)虚机配置:2核CPU、4G内存①系统为CentOS 7.8 x64最小化安装,部署前已完成系统初始化、...【详细内容】
2021-06-25  IT运维笔记  今日头条  Tags:PHP8.0.7   点击:(141)  评论:(0)  加入收藏
最新更新
栏目热门
栏目头条