Welcome 微信登录

首页 / 数据库 / MySQL / 在Java中实现MongoDB的Group功能

在非关系型数据库MongoDB中，并没有任何现成的框架可以像SQL那样通过Group By就轻松实现数据库的分组功能。如果我们想要实现MongoDB的Group功能，就必须写原生态的NO-SQL 查询语句来实现Group功能，这样既费时又费力，而且很容易出错，本文提供了一个封装的接口来实现MongoDB的Group功能，让程序员从此不再为MongoDB的Group而发愁。
接口方法如下：
/**
   * keyColumn : new String[]{"xxxName","xxxType"} <br>
   * condition : 查询条件 ，可为空<br>
   * initial : 分组统计初始变量，为空时自动为每列提供初始变量<br>
   * reduce ： 记录处理function<br>
   * finalize : finalize函数，可为空 <br>
   */
    public BasicDBList group（String[] keyColumn, DBObject condition,
            DBObject initial, String reduce, String finalize） {
        DBCollection coll = getCollection（）;
        DBObject key = new BasicDBObject（）;
        for （int i = 0; i < keyColumn.length; i++） {
            key.put（keyColumn[i], true）;
        }
        condition = （condition == null） ？ new BasicDBObject（） : condition;
        if （StringUtils.isEmpty（finalize）） {
            finalize = null;
        }
        if （initial == null） {      //定义一些初始变量
            initial = new BasicDBObject（）;
            for （int i = 0; i < keyColumn.length; i++） {
                DBObject index = new BasicDBObject（）;
                index.put（"count", 0）;
                index.put（"sum", 0）;
                index.put（"max", 0）;
                index.put（"min", 0）;
                index.put（"avg", 0）;
                index.put（"self", ""）;
                initial.put（keyColumn[i], index）;
            }
        }
        BasicDBList resultList = （BasicDBList） coll.group（key, condition,
                initial, reduce, finalize）;
        return resultList;
    } 实现案例：//任务统计
    @Action（value = "getTaskStatistic", results = { @Result（name = "success", type = "json", params = {
            "includeProperties", "jsonResult" }） }）
    public String getTaskStatistic（） {
        DBObject initial = new BasicDBObject（）;
        DBObject index = new BasicDBObject（）;
        index.put（"count", 0）;
        index.put（"taskStatus", ""）;
        initial.put（"taskStatus", index）;
                     
        String reduce = "function （doc, out） { "
                    + " out.taskStatus.count = out.taskStatus.count+=1; "
                    + " out.taskStatus.inspectStatus = doc.taskStatus;"
                + "}";
        BasicDBList group = （BasicDBList） taskStatusService.group（new String[] { "taskStatus"}, null, initial, reduce, null）;
                     
        this.jsonResult = group.toString（）;
        return SUCCESS;
    }返回数据：
[ { "taskStatus" : { "count" : 4.0 , "taskStatus" : "Finished"}} , { "taskStatus" : { "count" : 3.0 , "taskStatus" : "Received"}} , { "taskStatus" : { "count" : 2.0 , "taskStatus" : "UnReceive"}}]MongoDB 的详细介绍：请点这里
MongoDB 的下载地址：请点这里推荐阅读：Java实现MongoDB中自增长字段 http://www.linuxidc.com/Linux/2012-05/61552.htmCentOS编译安装MongoDB http://www.linuxidc.com/Linux/2012-02/53834.htmCentOS 编译安装 MongoDB与mongoDB的php扩展 http://www.linuxidc.com/Linux/2012-02/53833.htmCentOS 6 使用 yum 安装MongoDB及服务器端配置 http://www.linuxidc.com/Linux/2012-08/68196.htmUbuntu 13.04下安装MongoDB2.4.3 http://www.linuxidc.com/Linux/2013-05/84227.htm如何在MongoDB中建立新数据库和集合 http://www.linuxidc.com/Linux/2013-06/85749.htmMongoDB入门必读（概念与实战并重） http://www.linuxidc.com/Linux/2013-07/87105.htm《MongoDB 权威指南》（MongoDB: The Definitive Guide）英文文字版[PDF] http://www.linuxidc.com/Linux/2012-07/66735.htmLinux下的pg_dump周期性备份MySQL之InnoDB之更换表空间相关资讯      MongoDB  MongoDB Group 
  • MongoDB 3.3.0 发布下载  （01月14日）
  • MongoDB 3.2版WiredTiger存储引擎  （01月02日）
  • 进程监控工具Supervisor 启动  （12/26/2015 10:49:57）
  • MongoDB使用aggregate、group、  （01月05日）
  • 使用MongoDB C#官方驱动操作  （12/31/2015 16:27:56）
  • CentOS 6.6下安装MongoDB 3.0.1  （12/21/2015 19:29:02）
本文评论 查看全部评论 （0）
表情： 姓名： 字数