[李景山php]thinkphp核心源码注释|Mongo.class.php
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了[李景山php]thinkphp核心源码注释|Mongo.class.php,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含21463字,纯文字阅读大概需要31分钟。
内容图文
<?php
// +----------------------------------------------------------------------
// | ThinkPHP [ WE CAN DO IT JUST THINK IT ]
// +----------------------------------------------------------------------
// | Copyright (c) 2006-2014 http://thinkphp.cn All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: liu21st <liu21st@gmail.com>
// +----------------------------------------------------------------------
namespace
Think\Db\Driver;
useThink\Db\Driver;
/**
* Mongo数据库驱动
* 这驱动,基本就重新了。
* 大哥,这个驱动类是不是你自己下载的呢,
*/classMongoextendsDriver {protected$_mongo = null; // MongoDb Object 数据库对象protected$_collection = null; // MongoCollection Object 数据库连接对象protected$_dbName = ‘‘; // dbName 选择数据库 名称protected$_collectionName = ‘‘; // collectionName 连接名称protected$_cursor = null; // MongoCursor Object 当前对象 当前执行的对象protected$comparison = array(‘neq‘=>‘ne‘,‘ne‘=>‘ne‘,‘gt‘=>‘gt‘,‘egt‘=>‘gte‘,‘gte‘=>‘gte‘,‘lt‘=>‘lt‘,‘elt‘=>‘lte‘,‘lte‘=>‘lte‘,‘in‘=>‘in‘,‘not in‘=>‘nin‘,‘nin‘=>‘nin‘);
/**
* 架构函数 读取数据库配置信息
* @access public
* @param array $config 数据库配置数组
*/publicfunction__construct($config=‘‘){if ( !class_exists(‘mongoClient‘) ) { // 如果没有
E(L(‘_NOT_SUPPORT_‘).‘:Mongo‘);
}
if(!empty($config)) {// 非空$this->config = array_merge($this->config,$config);
if(empty($this->config[‘params‘])){
$this->config[‘params‘] = array();
}
}
}
// 做了两个事情:// 检查没有 连接的处理功能// 非空的话,合并 配置数组/**
* 连接数据库方法
* @access public
* 连接字符串
*/publicfunctionconnect($config=‘‘,$linkNum=0) {if ( !isset($this->linkID[$linkNum]) ) {
if(empty($config)) $config = $this->config;
// 生成 数据验证 字符串$host = ‘mongodb://‘.($config[‘username‘]?"{$config[‘username‘]}":‘‘).($config[‘password‘]?":{$config[‘password‘]}@":‘‘).$config[‘hostname‘].($config[‘hostport‘]?":{$config[‘hostport‘]}":‘‘).‘/‘.($config[‘database‘]?"{$config[‘database‘]}":‘‘);
try{
// 防止出错。$this->linkID[$linkNum] = new \mongoClient( $host,$this->config[‘params‘]);
}catch (\MongoConnectionException $e){
E($e->getmessage());// 获取错误信息
}
}
return$this->linkID[$linkNum];
}
// 单列模式执行,/**
* 切换当前操作的Db和Collection
* @access public
* @param string $collection collection
* @param string $db db
* @param boolean $master 是否主服务器
* @return void
* 切换位置 以及数据连接
*/publicfunctionswitchCollection($collection,$db=‘‘,$master=true){// 当前没有连接 则首先进行数据库连接if ( !$this->_linkID ) $this->initConnect($master);// 首先确保当前数据库连接的正常try{ // 一个大的 try catchif(!empty($db)) { // 传人Db则切换数据库// 当前MongoDb对象$this->_dbName = $db;
$this->_mongo = $this->_linkID->selectDb($db);
}// 进行数据库 切换// 当前MongoCollection对象if($this->config[‘debug‘]) {
$this->queryStr = $this->_dbName.‘.getCollection(‘.$collection.‘)‘;
}// 这个数据库 位置了if($this->_collectionName != $collection) { // 就是个数据切换$this->queryTimes++;
N(‘db_query‘,1); // 兼容代码 $this->debug(true);
$this->_collection = $this->_mongo->selectCollection($collection);
$this->debug(false);
$this->_collectionName = $collection; // 记录当前Collection名称
}
}catch (MongoException $e){
E($e->getMessage());
}
}// 数据切换// 总结:// 数据库 以及 数据连接的一个切换/**
* 释放查询结果
* @access public
*/publicfunctionfree() {$this->_cursor = null;
}// 这种释放,真的很安心啊/**
* 执行命令
* @access public
* @param array $command 指令
* @return array
*/publicfunctioncommand($command=array(), $options=array()) {$cache = isset($options[‘cache‘])?$options[‘cache‘]:false;
if($cache) { // 查询缓存检测$key = is_string($cache[‘key‘])?$cache[‘key‘]:md5(serialize($command));
$value = S($key,‘‘,‘‘,$cache[‘type‘]);
if(false !== $value) {
return$value;
}
}// 这个是另外的一种缓存
N(‘db_write‘,1); // 兼容代码$this->executeTimes++;
try{
if($this->config[‘debug‘]) {
$this->queryStr = $this->_dbName.‘.‘.$this->_collectionName.‘.runCommand(‘;
$this->queryStr .= json_encode($command);
$this->queryStr .= ‘)‘;
}// 这个是 一个 配置项目$this->debug(true);
$result = $this->_mongo->command($command);// 调用内部函数$this->debug(false);
if($cache && $result[‘ok‘]) { // 查询缓存写入
S($key,$result,$cache[‘expire‘],$cache[‘type‘]); // 大写函数执行
}
return$result;
} catch (\MongoCursorException $e) {
E($e->getMessage());
}
}// 这个 其实,就是关于内部函数的一个调用了/**
* 执行语句
* @access public
* @param string $code sql指令
* @param array $args 参数
* @return mixed
*/publicfunctionexecute($code,$args=array()) {$this->executeTimes++;
N(‘db_write‘,1); // 兼容代码$this->debug(true);
$this->queryStr = ‘execute:‘.$code;
$result = $this->_mongo->execute($code,$args);
$this->debug(false);
if($result[‘ok‘]) {
return$result[‘retval‘]; // 返回结果集
}else{
E($result[‘errmsg‘]);// 报错
}
}
// 对内部函数,转换输入数据兼容的一个封装,外加一个输出转换/**
* 关闭数据库
* @access public
*/publicfunctionclose() {if($this->_linkID) {
$this->_linkID->close();
$this->_linkID = null;
$this->_mongo = null;
$this->_collection = null;
$this->_cursor = null;
}
}
// 关闭,突然间,感觉爱上了,这个 对象操作,太舒服了,这个感觉是思路不乱。/**
* 数据库错误信息
* @access public
* @return string
*/publicfunctionerror() {$this->error = $this->_mongo->lastError();
trace($this->error,‘‘,‘ERR‘);
return$this->error;
} // 错误信息反馈/**
* 插入记录
* @access public
* @param mixed $data 数据
* @param array $options 参数表达式
* @param boolean $replace 是否replace
* @return false | integer
*/publicfunctioninsert($data,$options=array(),$replace=false) {if(isset($options[‘table‘])) {
$this->switchCollection($options[‘table‘]);
}
// 数据插入,这个数据库 是随机建立的 ,不,是有一定的需求建立的$this->model = $options[‘model‘];
$this->executeTimes++;
N(‘db_write‘,1); // 兼容代码 if($this->config[‘debug‘]) {
$this->queryStr = $this->_dbName.‘.‘.$this->_collectionName.‘.insert(‘;
$this->queryStr .= $data?json_encode($data):‘{}‘;
$this->queryStr .= ‘)‘;
}
// 跟着上面看起来,很像啊,哈哈try{
$this->debug(true);
$result = $replace? $this->_collection->save($data): $this->_collection->insert($data);
$this->debug(false);
if($result) {
$_id = $data[‘_id‘];
if(is_object($_id)) {
$_id = $_id->__toString();
}
$this->lastInsID = $_id;
}
return$result;
} catch (\MongoCursorException $e) {
E($e->getMessage());
}
} // 单条插入,其实就是调用 mongo 的api 而已了。这个没什么的/**
* 插入多条记录
* @access public
* @param array $dataList 数据
* @param array $options 参数表达式
* @return bool
*/publicfunctioninsertAll($dataList,$options=array()) {if(isset($options[‘table‘])) {
$this->switchCollection($options[‘table‘]);
}
$this->model = $options[‘model‘];
$this->executeTimes++;
N(‘db_write‘,1); // 兼容代码 try{
$this->debug(true);
$result = $this->_collection->batchInsert($dataList);
$this->debug(false);
return$result;
} catch (\MongoCursorException $e) {
E($e->getMessage());
}
}// 调用批量插入接口,封装上自己喜欢的东西。/**
* 生成下一条记录ID 用于自增非MongoId主键
* @access public
* @param string $pk 主键名
* @return integer
* 你这个处理不错哎,我喜欢,比较人性化
*/publicfunctiongetMongoNextId($pk) {if($this->config[‘debug‘]) {
$this->queryStr = $this->_dbName.‘.‘.$this->_collectionName.‘.find({},{‘.$pk.‘:1}).sort({‘.$pk.‘:-1}).limit(1)‘;
}
try{
$this->debug(true);
$result = $this->_collection->find(array(),array($pk=>1))->sort(array($pk=>-1))->limit(1);
$this->debug(false);
} catch (\MongoCursorException $e) {
E($e->getMessage());
}
$data = $result->getNext();// 这里就是获取后的执行数据了returnisset($data[$pk])?$data[$pk]+1:1; // 自己+1
} // 获取数据 +1/**
* 更新记录
* @access public
* @param mixed $data 数据
* @param array $options 表达式
* @return bool
*/publicfunctionupdate($data,$options) {if(isset($options[‘table‘])) {
$this->switchCollection($options[‘table‘]);
}
$this->executeTimes++;
N(‘db_write‘,1); // 兼容代码 $this->model = $options[‘model‘];
$query = $this->parseWhere(isset($options[‘where‘])?$options[‘where‘]:array());
$set = $this->parseSet($data);
if($this->config[‘debug‘]) {
$this->queryStr = $this->_dbName.‘.‘.$this->_collectionName.‘.update(‘;
$this->queryStr .= $query?json_encode($query):‘{}‘;
$this->queryStr .= ‘,‘.json_encode($set).‘)‘;
}// 整理数据try{
$this->debug(true);
if(isset($options[‘limit‘]) && $options[‘limit‘] == 1) {
$multiple = array("multiple" => false);
}else{
$multiple = array("multiple" => true);
}
$result = $this->_collection->update($query,$set,$multiple); // 这么mongo 相对更人性化一点$this->debug(false);
return$result;
} catch (\MongoCursorException $e) {
E($e->getMessage());
}
}// 执行 数据/**
* 删除记录
* @access public
* @param array $options 表达式
* @return false | integer
*/publicfunctiondelete($options=array()) {if(isset($options[‘table‘])) {
$this->switchCollection($options[‘table‘]);
}
$query = $this->parseWhere(isset($options[‘where‘])?$options[‘where‘]:array());
$this->model = $options[‘model‘];
$this->executeTimes++;
N(‘db_write‘,1); // 兼容代码 if($this->config[‘debug‘]) {
$this->queryStr = $this->_dbName.‘.‘.$this->_collectionName.‘.remove(‘.json_encode($query).‘)‘;
}
try{
$this->debug(true);
$result = $this->_collection->remove($query);
$this->debug(false);
return$result;
} catch (\MongoCursorException $e) {
E($e->getMessage());
}
}// 一样的执行流程/**
* 清空记录
* @access public
* @param array $options 表达式
* @return false | integer
*/publicfunctionclear($options=array()){if(isset($options[‘table‘])) {
$this->switchCollection($options[‘table‘]);
}
$this->model = $options[‘model‘];
$this->executeTimes++;
N(‘db_write‘,1); // 兼容代码 if($this->config[‘debug‘]) {
$this->queryStr = $this->_dbName.‘.‘.$this->_collectionName.‘.remove({})‘;
}
try{// 这里$this->debug(true);
$result = $this->_collection->drop();// 调用 系统 api 函数$this->debug(false);
return$result;
} catch (\MongoCursorException $e) {
E($e->getMessage());
}
}
/**
* 查找记录
* @access public
* @param array $options 表达式
* @return iterator
*/publicfunctionselect($options=array()) {if(isset($options[‘table‘])) {
$this->switchCollection($options[‘table‘],‘‘,false);
}
$this->model = $options[‘model‘];
$this->queryTimes++;
N(‘db_query‘,1); // 兼容代码 $query = $this->parseWhere(isset($options[‘where‘])?$options[‘where‘]:array());
$field = $this->parseField(isset($options[‘field‘])?$options[‘field‘]:array());
// 这个 是个 字符串 准备try{
if($this->config[‘debug‘]) {
$this->queryStr = $this->_dbName.‘.‘.$this->_collectionName.‘.find(‘;
$this->queryStr .= $query? json_encode($query):‘{}‘;
if(is_array($field) && count($field)) {
foreach ($fieldas$f=>$v)
$_field_array[$f] = $v ? 1 : 0;
$this->queryStr .= $field? ‘, ‘.json_encode($_field_array):‘, {}‘;
}
$this->queryStr .= ‘)‘;
}
$this->debug(true);
$_cursor = $this->_collection->find($query,$field);
if(!empty($options[‘order‘])) {
$order = $this->parseOrder($options[‘order‘]);
if($this->config[‘debug‘]) {
$this->queryStr .= ‘.sort(‘.json_encode($order).‘)‘;
}
$_cursor = $_cursor->sort($order);
}// 整理排序行if(isset($options[‘page‘])) { // 根据页数计算limitlist($page,$length) = $options[‘page‘];
$page = $page>0 ? $page : 1;
$length = $length>0 ? $length : (is_numeric($options[‘limit‘])?$options[‘limit‘]:20);
$offset = $length*((int)$page-1);
$options[‘limit‘] = $offset.‘,‘.$length;
}// 整理限制条数if(isset($options[‘limit‘])) {
list($offset,$length) = $this->parseLimit($options[‘limit‘]);
if(!empty($offset)) {
if($this->config[‘debug‘]) {
$this->queryStr .= ‘.skip(‘.intval($offset).‘)‘;
}
$_cursor = $_cursor->skip(intval($offset));
}
if($this->config[‘debug‘]) {
$this->queryStr .= ‘.limit(‘.intval($length).‘)‘;
}
$_cursor = $_cursor->limit(intval($length));
}// 整理 其它的$this->debug(false);
$this->_cursor = $_cursor;
$resultSet = iterator_to_array($_cursor); // 从迭代器 里面 获取到 数组数据return$resultSet;
} catch (\MongoCursorException $e) {
E($e->getMessage());
}
}
/**
* 查找某个记录
* @access public
* @param array $options 表达式
* @return array
*/publicfunctionfind($options=array()){$options[‘limit‘] = 1;
$find = $this->select($options);
return array_shift($find);// 踢出最后一条数据
}// 单条数据,获取,就是整体的一个特例/**
* 统计记录数
* @access public
* @param array $options 表达式
* @return iterator
* 统计条数
*/publicfunctioncount($options=array()){if(isset($options[‘table‘])) {
$this->switchCollection($options[‘table‘],‘‘,false);
}
$this->model = $options[‘model‘];
$this->queryTimes++;
N(‘db_query‘,1); // 兼容代码 $query = $this->parseWhere(isset($options[‘where‘])?$options[‘where‘]:array());
if($this->config[‘debug‘]) {
$this->queryStr = $this->_dbName.‘.‘.$this->_collectionName;
$this->queryStr .= $query?‘.find(‘.json_encode($query).‘)‘:‘‘;
$this->queryStr .= ‘.count()‘;
}// 这个是准备 东西try{
$this->debug(true);
$count = $this->_collection->count($query);// 统计数据$this->debug(false);
return$count;
} catch (\MongoCursorException $e) {
E($e->getMessage());
}
}// 准备基础数据 加上对应api执行publicfunctiongroup($keys,$initial,$reduce,$options=array()){if(isset($options[‘table‘]) && $this->_collectionName != $options[‘table‘]) {
$this->switchCollection($options[‘table‘],‘‘,false);
}
$cache = isset($options[‘cache‘])?$options[‘cache‘]:false;// 获取缓存if($cache) {
$key = is_string($cache[‘key‘])?$cache[‘key‘]:md5(serialize($options));
$value = S($key,‘‘,‘‘,$cache[‘type‘]);
if(false !== $value) {
return$value;
}
}
$this->model = $options[‘model‘];
$this->queryTimes++;
N(‘db_query‘,1); // 兼容代码 $query = $this->parseWhere(isset($options[‘where‘])?$options[‘where‘]:array());
// 解析代码if($this->config[‘debug‘]) {
$this->queryStr = $this->_dbName.‘.‘.$this->_collectionName.‘.group({key:‘.json_encode($keys).‘,cond:‘.
json_encode($options[‘condition‘]) . ‘,reduce:‘ .
json_encode($reduce).‘,initial:‘.
json_encode($initial).‘})‘;
}// 准备完成try{
$this->debug(true);
$option = array(‘condition‘=>$options[‘condition‘], ‘finalize‘=>$options[‘finalize‘], ‘maxTimeMS‘=>$options[‘maxTimeMS‘]);
$group = $this->_collection->group($keys,$initial,$reduce,$options);
$this->debug(false);
if($cache && $group[‘ok‘])
S($key,$group,$cache[‘expire‘],$cache[‘type‘]);
return$group;
} catch (\MongoCursorException $e) {
E($e->getMessage());
}
} // 同上的一个数据准备/**
* 取得数据表的字段信息
* @access public
* @return array
*/publicfunctiongetFields($collection=‘‘){if(!empty($collection) && $collection != $this->_collectionName) {
$this->switchCollection($collection,‘‘,false);
}
$this->queryTimes++;
N(‘db_query‘,1); // 兼容代码 if($this->config[‘debug‘]) {
$this->queryStr = $this->_dbName.‘.‘.$this->_collectionName.‘.findOne()‘;
}
try{
$this->debug(true);
$result = $this->_collection->findOne();
$this->debug(false);
} catch (\MongoCursorException $e) {
E($e->getMessage());
}
if($result) { // 存在数据则分析字段$info = array();
foreach ($resultas$key=>$val){
$info[$key] = array(
‘name‘ => $key,
‘type‘ => getType($val),
);
}
return$info;
}
// 暂时没有数据 返回falsereturnfalse;
}// 直接获取数据/**
* 取得当前数据库的collection信息
* @access public
*/publicfunctiongetTables(){if($this->config[‘debug‘]) {
$this->queryStr = $this->_dbName.‘.getCollenctionNames()‘;
}
$this->queryTimes++;
N(‘db_query‘,1); // 兼容代码 $this->debug(true);
$list = $this->_mongo->listCollections();// 获取数据库的连接信息$this->debug(false);
$info = array();
foreach ($listas$collection){
$info[] = $collection->getName();
}
return$info;
}// 获取表名/**
* 取得当前数据库的对象
* @access public
* @return object mongoClient
*/publicfunctiongetDB(){return$this->_mongo;
} // 最土的返回方式/**
* 取得当前集合的对象
* @access public
* @return object MongoCollection
*/publicfunctiongetCollection(){return$this->_collection;
} // 返回连接结果集/**
* set分析
* @access protected
* @param array $data
* @return string
*/protectedfunctionparseSet($data) {$result = array();
foreach ($dataas$key=>$val){
if(is_array($val)) {
switch($val[0]) {
case‘inc‘:
$result[‘$inc‘][$key] = (int)$val[1];
break;
case‘set‘:
case‘unset‘:
case‘push‘:
case‘pushall‘:
case‘addtoset‘:
case‘pop‘:
case‘pull‘:
case‘pullall‘:
$result[‘$‘.$val[0]][$key] = $val[1];
break;
default:
$result[‘$set‘][$key] = $val;
}
}else{
$result[‘$set‘][$key] = $val;
}
}
return$result;
}
// 各种标准的 接口诡异的解析,转换/**
* order分析
* @access protected
* @param mixed $order
* @return array
*/protectedfunctionparseOrder($order) {if(is_string($order)) {
$array = explode(‘,‘,$order);
$order = array();
foreach ($arrayas$key=>$val){
$arr = explode(‘ ‘,trim($val));
if(isset($arr[1])) {
$arr[1] = $arr[1]==‘asc‘?1:-1;
}else{
$arr[1] = 1;
}
$order[$arr[0]] = $arr[1];
}
}
return$order;
}// 各种标准的 接口诡异的解析,转换/**
* limit分析
* @access protected
* @param mixed $limit
* @return array
*/protectedfunctionparseLimit($limit) {if(strpos($limit,‘,‘)) {
$array = explode(‘,‘,$limit);
}else{
$array = array(0,$limit);
}
return$array;
}// 各种标准的 接口诡异的解析,转换/**
* field分析
* @access protected
* @param mixed $fields
* @return array
*/publicfunctionparseField($fields){if(empty($fields)) {
$fields = array();
}
if(is_string($fields)) {
$_fields = explode(‘,‘,$fields);
$fields = array();
foreach ($_fieldsas$f)
$fields[$f] = true;
}elseif(is_array($fields)) {
$_fields = $fields;
$fields = array();
foreach ($_fieldsas$f=>$v) {
if(is_numeric($f))
$fields[$v] = true;
else$fields[$f] = $v ? true : false;
}
}
return$fields;
}// 各种标准的 接口诡异的解析,转换/**
* where分析
* @access protected
* @param mixed $where
* @return array
*/publicfunctionparseWhere($where){$query = array();
$return = array();
$_logic = ‘$and‘;
if(isset($where[‘_logic‘])){
$where[‘_logic‘] = strtolower($where[‘_logic‘]);
$_logic = in_array($where[‘_logic‘], array(‘or‘,‘xor‘,‘nor‘, ‘and‘))?‘$‘.$where[‘_logic‘]:$_logic;
unset($where[‘_logic‘]);
}
foreach ($whereas$key=>$val){
if(‘_id‘ != $key && 0===strpos($key,‘_‘)) {
// 解析特殊条件表达式$parse = $this->parseThinkWhere($key,$val);
$query = array_merge($query,$parse);
}else{
// 查询字段的安全过滤if(!preg_match(‘/^[A-Z_\|\&\-.a-z0-9]+$/‘,trim($key))){
E(L(‘_ERROR_QUERY_‘).‘:‘.$key);
}
$key = trim($key);
if(strpos($key,‘|‘)) {
$array = explode(‘|‘,$key);
$str = array();
foreach ($arrayas$k){
$str[] = $this->parseWhereItem($k,$val);
}
$query[‘$or‘] = $str;
}elseif(strpos($key,‘&‘)){
$array = explode(‘&‘,$key);
$str = array();
foreach ($arrayas$k){
$str[] = $this->parseWhereItem($k,$val);
}
$query = array_merge($query,$str);
}else{
$str = $this->parseWhereItem($key,$val);
$query = array_merge($query,$str);
}
}
}
if($_logic == ‘$and‘)
return$query;
foreach($queryas$key=>$val)
$return[$_logic][] = array($key=>$val);
return$return;
}// 各种标准的 接口诡异的解析,转换/**
* 特殊条件分析
* @access protected
* @param string $key
* @param mixed $val
* @return string
*/protectedfunctionparseThinkWhere($key,$val) {$query = array();
$_logic = array(‘or‘,‘xor‘,‘nor‘, ‘and‘);
switch($key) {
case‘_query‘: // 字符串模式查询条件
parse_str($val,$query);
if(isset($query[‘_logic‘]) && strtolower($query[‘_logic‘]) == ‘or‘ ) {
unset($query[‘_logic‘]);
$query[‘$or‘] = $query;
}
break;
case‘_complex‘: // 子查询模式查询条件$__logic = strtolower($val[‘_logic‘]);
if(isset($val[‘_logic‘]) && in_array($__logic, $_logic) ) {
unset($val[‘_logic‘]);
$query[‘$‘.$__logic] = $val;
}
break;
case‘_string‘:// MongoCode查询$query[‘$where‘] = new \MongoCode($val);
break;
}
//兼容 MongoClient OR条件查询方法if(isset($query[‘$or‘]) && !is_array(current($query[‘$or‘]))) {
$val = array();
foreach ($query[‘$or‘] as$k=>$v)
$val[] = array($k=>$v);
$query[‘$or‘] = $val;
}
return$query;
}// 各种标准的 接口诡异的解析,转换/**
* where子单元分析
* @access protected
* @param string $key
* @param mixed $val
* @return array
*/protectedfunctionparseWhereItem($key,$val) {$query = array();
if(is_array($val)) {
if(is_string($val[0])) {
$con = strtolower($val[0]);
if(in_array($con,array(‘neq‘,‘ne‘,‘gt‘,‘egt‘,‘gte‘,‘lt‘,‘lte‘,‘elt‘))) { // 比较运算$k = ‘$‘.$this->comparison[$con];
$query[$key] = array($k=>$val[1]);
}elseif(‘like‘== $con){ // 模糊查询 采用正则方式$query[$key] = new \MongoRegex("/".$val[1]."/");
}elseif(‘mod‘==$con){ // mod 查询$query[$key] = array(‘$mod‘=>$val[1]);
}elseif(‘regex‘==$con){ // 正则查询$query[$key] = new \MongoRegex($val[1]);
}elseif(in_array($con,array(‘in‘,‘nin‘,‘not in‘))){ // IN NIN 运算$data = is_string($val[1])? explode(‘,‘,$val[1]):$val[1];
$k = ‘$‘.$this->comparison[$con];
$query[$key] = array($k=>$data);
}elseif(‘all‘==$con){ // 满足所有指定条件$data = is_string($val[1])? explode(‘,‘,$val[1]):$val[1];
$query[$key] = array(‘$all‘=>$data);
}elseif(‘between‘==$con){ // BETWEEN运算$data = is_string($val[1])? explode(‘,‘,$val[1]):$val[1];
$query[$key] = array(‘$gte‘=>$data[0],‘$lte‘=>$data[1]);
}elseif(‘not between‘==$con){
$data = is_string($val[1])? explode(‘,‘,$val[1]):$val[1];
$query[$key] = array(‘$lt‘=>$data[0],‘$gt‘=>$data[1]);
}elseif(‘exp‘==$con){ // 表达式查询$query[‘$where‘] = new \MongoCode($val[1]);
}elseif(‘exists‘==$con){ // 字段是否存在$query[$key] = array(‘$exists‘=>(bool)$val[1]);
}elseif(‘size‘==$con){ // 限制属性大小$query[$key] = array(‘$size‘=>intval($val[1]));
}elseif(‘type‘==$con){ // 限制字段类型 1 浮点型 2 字符型 3 对象或者MongoDBRef 5 MongoBinData 7 MongoId 8 布尔型 9 MongoDate 10 NULL 15 MongoCode 16 32位整型 17 MongoTimestamp 18 MongoInt64 如果是数组的话判断元素的类型$query[$key] = array(‘$type‘=>intval($val[1]));
}else{
$query[$key] = $val;
}
return$query;
}
}
$query[$key] = $val;
return$query;
}// 各种标准的 接口诡异的解析,转换
}
原文:http://blog.csdn.net/lijingshan34/article/details/51979351
内容总结
以上是互联网集市为您收集整理的[李景山php]thinkphp核心源码注释|Mongo.class.php全部内容,希望文章能够帮你解决[李景山php]thinkphp核心源码注释|Mongo.class.php所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。