解析:使用php mongodb扩展时 需要注意的事项
2015-01-24信息快讯网
本篇文章是对使用php mongodb扩展时,需要注意的事项进行了详细的分析介绍,需要的朋友参考下
最近在使用php的mongo 扩展进行数据统计计算,其中有一个时间戳字段,由于精确到了毫秒,长度有13位,但由于开始的时候是以字符串的形式存储:{ "_id" : ObjectId("504eea97e4b023cf38e34039"), "in_ts" : NumberLong("1347349143699"), "log" : { "guid" : "4D1F3079-7507-F4B0-E7AF-5432D5D8229D", "p" : "View_Prop_YepPage_Zheng", "cid" : "11", "url" : "http://shanghai.haozu.com/rental/broker/n/10481780", "rfpn" : "Listing_V2_IndexPage_All", "site" : "haozu", "agent" : "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1)", "stamp" : "1347349162159", "cip" : "116.226.70.44", "referer" : "http://shanghai.haozu.com/shop/1464934/", "cstamp" : "1347349323125", "sessid" : "FA798056-F9E7-F961-41E0-CC95C850FA47", "uguid" : "C00FF55B-3D3D-4B31-4318-12345B0DBE64", "pn" : "View_Prop_YepPage_Zheng", "cstparam" : { "proId" : NumberLong(10481780), "brokerId" : "326792", "tradeType" : "2", "userType" : "0", "channel" : "site", "entry" : "1", "COMMID" : "1666" } }, "out_ts" : NumberLong("1347349466083"), "rule" : 0, "status" : "ok", "txid" : 0 }
后来改成数字格式:
{ "_id" : ObjectId("504eea97e4b023cf38e34039"), "in_ts" : NumberLong("1347349143699"), "log" : { "guid" : "4D1F3079-7507-F4B0-E7AF-5432D5D8229D", "p" : "View_Prop_YepPage_Zheng", "cid" : "11", "url" : "http://shanghai.haozu.com/rental/broker/n/10481780", "rfpn" : "Listing_V2_IndexPage_All", "site" : "haozu", "agent" : "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1)", "stamp" : NumberLong("1347349162159"), "cip" : "116.226.70.44", "referer" : "http://shanghai.haozu.com/shop/1464934/", "cstamp" : "1347349323125", "sessid" : "FA798056-F9E7-F961-41E0-CC95C850FA47", "uguid" : "C00FF55B-3D3D-4B31-4318-12345B0DBE64", "pn" : "View_Prop_YepPage_Zheng", "cstparam" : { "proId" : NumberLong(10481780), "brokerId" : "326792", "tradeType" : "2", "userType" : "0", "channel" : "site", "entry" : "1", "COMMID" : "1666" } }, "out_ts" : NumberLong("1347349466083"), "rule" : 0, "status" : "ok", "txid" : 0 }
为字符串时,使用下面的查询是正常的
$query = array ('log.stamp' => array ('$gte' => ‘1347346800000', '$lt' => ‘1347350400000'));
但是改为数字后,使用下面的查询,死活没有结果,但是直接在mongo客户端直接查询是有结果的:
db.haozu_success.find({'log.stamp':{$gte:1347346800000,$lt:1347350400000}})
php手册上也是这么个用法:
$query = array ('log.stamp' => array ('$gte' => 1347346800000, '$lt' => 1347350400000));
花了好大一会找原因,开始时怀疑是php扩展的bug导致,经过一番思考。突然想到可能是类型问题导致,发现手册上有Types 介绍,所以正确的用法如下:
$query = array ('log.stamp' => array ('$gte' => new MongoInt64($time_range['start']), '$lt' => new MongoInt64($time_range['end'])));
另外,在使用mapreduce进行数据统计时,为了防止cursor出现超时异常,还需要设置一下超时时间
$map = new MongoCode ( ' function(){ var prop_id=this.log.cstparam.proId; var key=this.log.site+prop_id emit(key,{"channel":this.log.site,"prop_id":prop_id,"count":1}); } ' ); $reduce = new MongoCode ( ' function(key,emits){ var total=0; for(var i in emits){ total+=emits[i].count; } return {"channel":emits[0].channel,"prop_id":eval(emits[0].prop_id),"count":total}; } ' ); $this->mongo_db->command ( array ('mapreduce' => $collection_name, 'map' => $map, 'reduce' => $reduce, 'out' => $tmp_result, 'query' => $query),array('timeout'=>self::MONGO_CURSOR_TIMEOUT) );
linux系统下php安装mbstring扩展的二种方法
php环境下利用session防止页面重复刷新的具体实现
php检测用户是否用手机(Mobile)访问网站的类
PHP修改session_id示例代码
php缩小png图片不损失透明色的解决方法
linux实现php定时执行cron任务详解
解决file_get_contents无法请求https连接的方法
php使用curl发送json格式数据实例
php使用mb_check_encoding检查字符串在指定的编码里是否有效
mac下安装nginx和php
php cURL和Rolling cURL并发方式比较
php增删改查示例自己写的demo
完美解决PHP中的Cannot modify header information 问题
mongo Table类文件 获取MongoCursor(游标)的实现方法分析
PHP操作MongoDB GridFS 存储文件的详解
解析PHP中常见的mongodb查询操作
基于xcache的配置与使用详解
解析:通过php socket并借助telnet实现简单的聊天程序
解析mysql left( right ) join使用on与where筛选的差异
解析php中static,const与define的使用区别
解析php中const与define的应用区别
Session服务器配置指南与使用经验的深入解析
解析php中session的实现原理以及大网站应用应注意的问题
深入Apache与Nginx的优缺点比较详解
PHP与MongoDB简介|安全|M+PHP应用实例详解
基于PHP输出缓存(output_buffering)的深入理解
php缓冲 output_buffering的使用详解
探讨PHP函数ip2long转换IP时数值太大产生负数的解决方法
php IP转换整形(ip2long)的详解
基于MySQL到MongoDB简易对照表的详解
作为PHP程序员应该了解MongoDB的五件事
深入PHP操作MongoDB的技术总结
setcookie中Cannot modify header information-headers already sent by错误的解决方法详解