由于刚刚接触mongodb,很多语法还不是很了解,写的不好的地方请大佬指出
查询的demo数据
{ "_id":Object("xxxxxxxx"), "contentList":[ "id":"xxxx", "type":2 ], [ "id":"xxxx", "type":2 ] }
查询方法,使用聚合aggregate查询
match:将查询的contentList的size大于2的查出来
unwind:将集合根据contentList分组
match:再查出所有contentList的type为2的结果
group:再根据_id和total分组,total根据_id计算总数
match:过滤掉contentList的type小于3条的数据
project:结果集过滤,我只要id字段
db.getCollection(‘momPublishRecently‘).aggregate([ {"$match": {"contentList.2": {"$exists": 1}}}, {"$unwind": "$contentList"}, {"$match": {"contentList.type": 2}}, {"$group": {"_id":"$_id", "total": {"$sum":1}}}, {"$match": {"total": {"$gte": 3}}}, {"$project": {"total":0}} ]);
下面是springboot中的写法
Aggregation agg = Aggregation.newAggregation( Aggregation.match(Criteria.where("contentList.2").exists(true)), Aggregation.unwind("contentList"), Aggregation.match(Criteria.where("contentList.type").is(2)), Aggregation.group("_id").count().as("total"), Aggregation.match(Criteria.where("total").gte(3)), Aggregation.project("_id") ); AggregationResults<IdDTO> results = getMongoTemplate().aggregate(agg, "表名", IdDTO.class); List<IdDTO> list = results.getMappedResults(); List<ObjectId> idList = new ArrayList<>(); //这里转成object类型 if (!list.isEmpty()) { list.stream().forEach(idDTO -> { idList.add(new ObjectId(idDTO.getId())); }); }
刚刚接触就要求写这样的,还是有点吃力的,花了不少时间,踩了不少mongo的坑
感谢以下资料:
https://www.cnblogs.com/zhoujie/p/mongo1.html
https://docs.spring.io/spring-data/mongodb/docs/2.0.5.RELEASE/reference/html/#mongo.aggregation
原文地址:https://www.cnblogs.com/oldboyooxx/p/12041524.html
时间: 2024-11-18 12:38:34