JAVA mongodb 聚合几种查询方式详解

2023-09-14 22:01:04 66

一、BasicDBObject

整个聚合查询是统计用户的各种状态下的用户数量为场景：

1.筛选条件：

date为查询日期：

BasicDBObjectQuery=newBasicDBObject();
Query.put("time",newBasicDBObject("$gte",date+"00:00:00")
.append("$lte",date+"23:59:59"));

如果有多个条件：直接加Query.put("status",0);

如果有OR筛选：

BasicDBListvalues=newBasicDBList();
values.add(newBasicDBObject("status",newBasicDBObject("$exists",false)));
values.add(newBasicDBObject("status",0));
Query.put("$or",values);

其中newBasicDBObject("$exists",false))就是“status”不存在（mongodb文档可不等于实体的字段）

2.拼接match

DBObjectMatch=newBasicDBObject("$match",Query);

将上一步的Query放入macth筛选中

3.拼接分组条件

此步相当于SQL的GroupBy

BasicDBObjectGroupBy=newBasicDBObject();//分组条件
GroupBy.put("userId","$userId");//根据用户ID来分组

同第一步的筛选一样，如果有多个分组可直接添加在后面：GroupBy.put("status","$status");

4.分组后查询

首先把分组拼接上：

DBObjectSelect=newBasicDBObject("_id",GroupBy);

如果我们要对分组后的数据进行操作：（这里是用户的统计数量）

Select.put("count",newBasicDBObject("$sum",1));

5.拼接$group

DBObjectGroup=newBasicDBObject("$group",Select);

至此。我们拼接，mongodb的语句到此结束

下面我们开始查询操作：

importcom.mongodb.AggregationOutput;
importorg.springframework.data.mongodb.core.MongoTemplate;
AggregationOutputOutput=mongoTemplate.getCollection("这里是mongodb的数据表名")
.aggregate(Match,Group);

读取查询结果：

Iterablemap=Output.results();
//遍历map
for(DBObjectdbObject:map){
//这里读取到的map为{"_id":{"userId":1,"status"0}}...
MapresultMap=(Map)dbObject.get("_id");

//这里截取掉.0
IntegeruserId=Integer.parseInt(CommUtil.toString(ausgMap.get("userId")).replace(".0",""));

//在这里我们就可以对我们的数据进行操作了；
Integercount=Integer.parseInt(CommUtil.toString(dbObject.get("count")));

}

二、DBObject

不多说，如果大家觉得第一种方法特别长篇大论，那么下面我给大家带来一种代码更简洁的聚合查询：

直接上代码吧。

1.注意导入的包:

importcom.mongodb.DBObject;importcom.mongodb.util.JSON;

2.$macth:

(beginDay-查询开始日期；endDay-查询结束日期)

DBObjectmatch=(DBObject)JSON.parse("{$match:{'status':'1','time':
{$gte:'"+beginDay+"',$lte:'"+endDay+"'}}}");

3.$group:

（以userId分组，统计用户数量，累加amout字段值，取amout字段最大值）

DBObjectgroup=(DBObject)JSON.parse("{$group:{_id:'$userId',
count:{$sum:1},total:{$sum:'$amount'},maxSigle:{$max:'$amount'}}}");

条件拼接完，开始查询：

Listlist=newArrayList();
list.add(match);list.add(group);
AggregationOutputOutput=mongoTemplate.getCollection("表名").aggregate(list);

遍历结果就不用在说了。上面已经详细描述了

第二种方法是不是比一种方式简单多了。但是比较考验自身对mongodb语句熟悉性。

【扩展】

接着上面的方法进行扩展

//status为0或者为1;type不为11；time在beginDay~endDay时间段内
DBObjectmatch=(DBObject)JSON.parse("{$match:{'status':{$in:['0','1']},
type:{$ne:11},'time':{$gte:'"+beginDay+"',$lte:'"+endDay+"'}}}");

//以用户Id分组，统计查询次数，取最后一次time的时间
DBObjectgroup=(DBObject)JSON.parse("{$group:{_id:'$userId',
count:{$sum:1},lastTime:{$max:'$time'}}}");

//在上一步统计出的结果中筛选次数大于100的数据
DBObjectgroupMatch=(DBObject)JSON.parse("{$match:{count:{$gte:100}}}");

//$project----查询结果中需要显示哪些字段，显示则设置为1。如下需要不显示_id域（字段），则需如下指定：
//db.集合名.aggregate([{$project:{_id:0,count:1,lastSuccTime:1}}])
DBObjectproject=(DBObject)JSON.parse("{$project:{_id:1,count:1,lastSuccTime:1}}");

DBObjectsort=(DBObject)JSON.parse("{$sort:{'count':-1}}");//排序

Listlist=newArrayList();
list.add(match);
list.add(group);
list.add(groupMatch);
list.add(project);
list.add(sort);
AggregationOutputcatchOutPut=mongoTemplate.getCollection("表名")
.aggregate(list);//查询结果

三、BasicDBObject+脚本语句

BasicDBObjectgroupIndex=newBasicDBObject();
BasicDBObjectdistinctQuery=newBasicDBObject();
distinctQuery.put("userId",newBasicDBObject("$in",userIds));//UserIds数组
BasicDBObjectinitIndex=newBasicDBObject();
initIndex.put("count",0);//给count赋初值

//脚本（doc代表数据库的数据.prev代表查询结果//prev.count这里的count就是上一步initIndex的count）
Stringreduce="function(doc,prev){if(doc.status==0){prev.count+=1;};}";
List>basicDBList=(List>)mongoTemplate.
getCollection("Collection").group(groupIndex,distinctQuery,initIndex,reduce,null);

最后循环遍历List即可得到结果【PS：group这种聚合方式有个限制条件--->超过20000数据就会报错】

以上就是我在普通业务处理中用到mongodb聚合处理。如果有更好的方法或是有需要改进的地方，欢迎大家给我留言~

JAVA mongodb 聚合几种查询方式详解

热门推荐

随机推荐