JAVA

2023-08-28 12:47| 来源: 网络整理| 查看: 265

前言

最近项目工作中遇到mongo复杂查询的语句使用，其中使用到数据去重，分组查询。

去重

mongo中去重和sql语句一样都是使用distinct

// 对时间范围内的name字段去重 db.getCollection("table").distinct("name",{"key":"abbe56e057f20f88dd","time" : {"$gte" : ISODate("2020-05-09T06:57:22.855+0000"), "$lte" : ISODate("2020-05-09T06:57:22.855+0000")}}); // 对name字段进行去重 db.getCollection("table").distinct("name"); 聚合

MongoDB中聚合(aggregate)主要用于处理数据(诸如统计平均值,求和等)，并返回计算后的数据结果。有点类似sql语句中的 count(*)。

MongoDB中聚合的方法使用aggregate()。

基本语法

aggregate() 方法的基本语法格式如下所示：

db.COLLECTION_NAME.aggregate(AGGREGATE_OPERATION) 管道的概念

管道在Unix和Linux中一般用于将当前命令的输出结果作为下一个命令的参数。

MongoDB的聚合管道将MongoDB文档在一个管道处理完毕后将结果传递给下一个管道处理。管道操作是可以重复的。

表达式：处理输入文档并输出。表达式是无状态的，只能用于计算当前聚合管道的文档，不能处理其它的文档。

这里我们介绍一下聚合框架中常用的几个操作：

$project：修改输入文档的结构。可以用来重命名、增加或删除域，也可以用于创建计算结果以及嵌套文档。$match：用于过滤数据，只输出符合条件的文档。match使用MongoDB的标准查询操作。$limit：用来限制MongoDB聚合管道返回的文档数。$skip：在聚合管道中跳过指定数量的文档，并返回余下的文档。$unwind：将文档中的某一个数组类型字段拆分成多条，每条包含数组中的一个值。$group：将集合中的文档分组，可用于统计结果。$sort：将输入文档排序后输出。$geoNear：输出接近某一地理位置的有序文档。示例 db.getCollection("table").aggregate([ {$match:{"name":"zhangsan"}}, // 过滤条件 {$unwind:"$books"}, // 拆分多条，每条都是一个新数据 {$group : {_id : "$classType", count : {"$sum" : "$count"}}} // 根据类型分组，并统计count字段的总和 ]) Criteria Query使用示例 regex模糊查询排序，分页操作 // 组装查询条件 Criteria criteria = Criteria.where("nameId").is("zhangsan").and("isCheck").is(false) .and("isMan").is(true); if (StringUtils.isNotBlank(name)) { criteria.and("name").regex(Pattern.quote(name),"i"); } if (StringUtils.isNotBlank(des) ) { criteria.and("description").regex(Pattern.quote(des),"i"); } if(CollectionUtils.isNotEmpty(uuids)){ criteria.and("UUID").in(uuids); }else{ criteria.and("actionPluginUuid").in(""); } Query query = new Query(); query.addCriteria(criteria); String orderBy = param.getOrderBy(); if(StringUtils.isBlank(orderBy)){ orderBy = "modifiedTime"; } String orderType = param.getOrderType(); Sort.Direction direction = Sort.Direction.DESC; if(("1").equals(orderType)){ direction = Sort.Direction.ASC; } // 排序 Sort sort = new Sort(direction,orderBy); query.with(sort); // 分页 query.skip((param.getPageNo()-1)*param.getPageSize()); query.limit(param.getPageSize());

【本文地址】

公司简介

联系我们