mongoDb的分组聚合查询(转载)
2017-12-13 00:00
453 查看
task 1:统计上海学生平均年龄
从这个需求来讲,要实现功能要有几个步骤: 1. 找出上海的学生. 2. 统计平均年龄 (当然也可以先算出所有省份的平均值再找出上海的)。
Java代码:
输出结果:
2.
task2:统计每个省各科平均成绩
首先更具数据库文档结构,subjects是数组形式,需要先分组,然后再进行统计
主要处理步骤如下:
1.先用$unwind 拆数组 2. 按照 province, subject 分租并求各科目平均分
输出结果:
3.
task3:
将同一省份的科目成绩统计到一起( 即,期望 ‘province’:’xxxxx’, avgscores:[ {‘xxx’:xxx}, ….] 这样的形式)
要做的有一件事,在前面的统计结果的基础上,先用 project将平均分和成绩揉到一起,再按省份group,将各科目的平均分push到一块,使用 group 再次分组.
"result" : [ { "_id" : "辽宁" , "avginfo" : [ { "subjname" : "数学" , "avgscore" : 56.46666666666667} , { "subjname" : "英语" , "avgscore" : 52.093333333333334} , { "subjname" : "语文" , "avgscore" : 50.53333333333333}]} , { "_id" : "四川" , "avginfo" : [ { "subjname" : "数学" , "avgscore" : 52.72727272727273} , { "subjname" : "英语" , "avgscore" : 55.90909090909091} , { "subjname" : "语文" , "avgscore" : 57.59090909090909}]} , { "_id" : "重庆" , "avginfo" : [ { "subjname" : "语文" , "avgscore" : 56.077922077922075} , { "subjname" : "英语" , "avgscore" : 54.84415584415584} , { "subjname" : "数学" , "avgscore" : 55.33766233766234}]} , { "_id" : "安徽" , "avginfo" : [ { "subjname" : "英语" , "avgscore" : 55.458333333333336} , { "subjname" : "数学" , "avgscore" : 54.47222222222222} , { "subjname" : "语文" , "avgscore" : 52.80555555555556}]} . . . ] , "ok" : 1.0}
4.
task4:
从这个需求来讲,要实现功能要有几个步骤: 1. 找出上海的学生. 2. 统计平均年龄 (当然也可以先算出所有省份的平均值再找出上海的)。
select province, avg(age) from student where province = '上海' group by province
Java代码:
/*创建 $match, 作用相当于query*/ DBObject match = new BasicDBObject("$match", new BasicDBObject("province", "上海")); /* Group操作*/ DBObject groupFields = new BasicDBObject("_id", "$province"); groupFields.put("AvgAge", new BasicDBObject("$avg", "$age")); DBObject group = new BasicDBObject("$group", groupFields); /* 查看Group结果 */ AggregationOutput output = connection.aggregate(match, group); // 执行 aggregation命令 System.out.println(output.getCommandResult());
输出结果:
"result" : [ { "_id" : "上海" , "AvgAge" : 32.09375} ] , "ok" : 1.0
2.
task2:统计每个省各科平均成绩
首先更具数据库文档结构,subjects是数组形式,需要先分组,然后再进行统计
主要处理步骤如下:
1.先用$unwind 拆数组 2. 按照 province, subject 分租并求各科目平均分
/* 创建 $unwind 操作, 用于切分数组*/ DBObject unwind = new BasicDBObject("$unwind", "$subjects"); /* Group操作*/ DBObject groupFields = new BasicDBObject("_id", new BasicDBObject("subjname", "$subjects.name").append("province", "$province")); groupFields.put("AvgScore", new BasicDBObject("$avg", "$subjects.scores")); DBObject group = new BasicDBObject("$group", groupFields); /* 查看Group结果 */ AggregationOutput output = connection.aggregate(unwind, group); // 执行 aggregation命令 System.out.println(output.getCommandResult());
输出结果:
"result" : [ { "_id" : { "subjname" : "英语" , "province" : "海南"} , "AvgScore" : 58.1} , { "_id" : { "subjname" : "数学" , "province" : "海南"} , "AvgScore" : 60.485} , { "_id" : { "subjname" : "语文" , "province" : "江西"} , "AvgScore" : 55.538} , { "_id" : { "subjname" : "英语" , "province" : "上海"} , "AvgScore" : 57.65625} , { "_id" : { "subjname" : "数学" , "province" : "广东"} , "AvgScore" : 56.690} , { "_id" : { "subjname" : "数学" , "province" : "上海"} , "AvgScore" : 55.671875} , { "_id" : { "subjname" : "语文" , "province" : "上海"} , "AvgScore" : 56.734375} , { "_id" : { "subjname" : "英语" , "province" : "云南"} , "AvgScore" : 55.7301 } , . . . . "ok" : 1.0
3.
task3:
将同一省份的科目成绩统计到一起( 即,期望 ‘province’:’xxxxx’, avgscores:[ {‘xxx’:xxx}, ….] 这样的形式)
要做的有一件事,在前面的统计结果的基础上,先用 project将平均分和成绩揉到一起,再按省份group,将各科目的平均分push到一块,使用 group 再次分组.
Mongo m = new Mongo("localhost", 27017); DB db = m.getDB("test"); DBCollection coll = db.getCollection("student"); /* 创建 $unwind 操作, 用于切分数组*/ DBObject unwind = new BasicDBObject("$unwind", "$subjects"); /* Group操作*/ DBObject groupFields = new BasicDBObject("_id", new BasicDBObject("subjname", "$subjects.name").append("province", "$province")); groupFields.put("AvgScore", new BasicDBObject("$avg", "$subjects.scores")); DBObject group = new BasicDBObject("$group", groupFields); /* Reshape Group Result*/ DBObject projectFields = new BasicDBObject(); projectFields.put("province", "$_id.province"); projectFields.put("subjinfo", new BasicDBObject("subjname","$_id.subjname").append("avgscore", "$AvgScore")); DBO 7fe0 bject project = new BasicDBObject("$project", projectFields); /* 将结果push到一起*/ DBObject groupAgainFields = new BasicDBObject("_id", "$province"); groupAgainFields.put("avginfo", new BasicDBObject("$push", "$subjinfo")); DBObject reshapeGroup = new BasicDBObject("$group", groupAgainFields); /* 查看Group结果 */ AggregationOutput output = coll.aggregate(unwind, group, project, reshapeGroup); System.out.println(output.getCommandResult());
"result" : [ { "_id" : "辽宁" , "avginfo" : [ { "subjname" : "数学" , "avgscore" : 56.46666666666667} , { "subjname" : "英语" , "avgscore" : 52.093333333333334} , { "subjname" : "语文" , "avgscore" : 50.53333333333333}]} , { "_id" : "四川" , "avginfo" : [ { "subjname" : "数学" , "avgscore" : 52.72727272727273} , { "subjname" : "英语" , "avgscore" : 55.90909090909091} , { "subjname" : "语文" , "avgscore" : 57.59090909090909}]} , { "_id" : "重庆" , "avginfo" : [ { "subjname" : "语文" , "avgscore" : 56.077922077922075} , { "subjname" : "英语" , "avgscore" : 54.84415584415584} , { "subjname" : "数学" , "avgscore" : 55.33766233766234}]} , { "_id" : "安徽" , "avginfo" : [ { "subjname" : "英语" , "avgscore" : 55.458333333333336} , { "subjname" : "数学" , "avgscore" : 54.47222222222222} , { "subjname" : "语文" , "avgscore" : 52.80555555555556}]} . . . ] , "ok" : 1.0}
4.
task4:
DBCollection collection = MongoUtils.getCollection_Database( (String) ServletContextUtils.getSession().getAttribute( "game"), SysConst.TABLE_WAIGUA_RATIO); // query DBObject match = new BasicDBObject("$match", queryParam_n); // 利用$project拼装group需要的数据 DBObject fields = new BasicDBObject("name", 1); fields.put("count", 1); DBObject project = new BasicDBObject("$project", fields); DBObject groupFields = new BasicDBObject("_id", "$name"); groupFields.put("count", new BasicDBObject("$sum", "$count")); DBObject group = new BasicDBObject("$group", groupFields);// group DBObject limit = new BasicDBObject("$limit", Integer.parseInt(n)); DBObject sort = new BasicDBObject("$sort", new BasicDBObject( "count", -1)); AggregationOutput output = collection.aggregate(match, project, group, sort, limit); List<String> nameList = new ArrayList<String>(); for (DBObject obj : output.results()) { BasicDBObject obj2 = (BasicDBObject) obj; nameList.add(obj2.getString("_id")); }
相关文章推荐
- C# MongoDB 查询,分组,聚合,排序,条件,分页
- mongodb[八]聚合查询、统计、分组、平均值、最大值、最小值
- mongodb 分组查询统计去掉重复的记录
- JAVA mongodb 聚合几种查询方式详解
- Elasticsearch分组聚合-查询每个A_logtype下有多少数据
- mongoDB查询、索引与聚合
- mongodb-aggregate聚合日期分组
- Elasticsearch Nest聚合分组取最小值查询
- Mongodb高级查询Aggregation聚合组件分页
- MongoVUE下实现MongoDB的Group分组查询
- crm使用FetchXml分组聚合查询
- MongoDB高级查询[聚合]
- 二、MongoDB的高级查询(聚合、游标、管道、索引)
- MongoDB高级查询[聚合Group]
- C# MongoDB 查询,分组,聚合,排序,条件,分页
- Sequelize中用group by进行分组聚合查询
- Java MongoDB 条件查询及其分组查询
- 【原创】StreamInsight查询系列(六)——基本查询操作之分组聚合
- java mongodb聚合统计查询,比较两个字段
- JAVA - mongodb 聚合查询方式二