mongoDb的mapReduce应用 外部变量使用关键部分springMVC;

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了mongoDb的mapReduce应用 外部变量使用关键部分springMVC;，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1666字，纯文字阅读大概需要3分钟。

内容图文

查询过滤条件 query.addCriteria(Criteria.where("mDay").is(1));//添加过滤条件 MapReduceOptions options = MapReduceOptions.options();//设置reduce配置项 Map scope = new HashMap(); scope.put("interval", interval); scope.put("startTime", startTime); options.scopeVariables(scope).verbose(true).outputTypeInline();//mapreduce外部变量插入 String mapFunction1 = "function () {" + "var sSecond=new Date(this.Atime).getTime()," + "tag=parseInt((sSecond-startTime)/interval);" + "emit({guid:this.TagGuid,time:tag},{tagUid:this.TagGuid,atime:this.Atime,value:this.TagValue,year:this.mYear,month:this.mMonth,day:this.mDay,seeId:this.SeeID})}";//map方法编写 String reduceFunction = "function(key,values){ return values[0];} ";//reduce方法编写 MapReduceResults<ReturnMessage> result = mongoTemplate.mapReduce(query, "Hdata03", mapFunction1, reduceFunction,options, ReturnMessage.class);//方法调用 Iterator<ReturnMessage> it = result.iterator();//得到结果 long p=0; while (it.hasNext()) { ReturnMessage message = it.next();//自定义实体类容器 String key=(String) JSONObject.fromObject(message.getId()).get("guid"); String insertSql="INSERT INTO t_base_data (data) VALUES (‘"+message.getValue()+"‘)";//插入postgresql baseDao.updateBySql(insertSql); }

最后插入postgesql做了循环插入  很不科学,浪费大量时间;

主要演示了一个mapreduce全局变量的使用;

其他循环只是测试用的,有点累赘;可以不看;

mongoDb的mapReduce应用 外部变量使用关键部分springMVC;

标签：mapred   putty   into   function   str   ndt   red   style   全局变量   

本文系统来源：http://www.cnblogs.com/xiaomurunning/p/7448569.html

内容总结

以上是互联网集市为您收集整理的mongoDb的mapReduce应用 外部变量使用关键部分springMVC;全部内容，希望文章能够帮你解决mongoDb的mapReduce应用 外部变量使用关键部分springMVC;所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

---