Skip to content

82.spring_boot_2_mongotemplate_statistic_query.md

Latest commit

 

History

History
118 lines (88 loc) · 3.77 KB

82.spring_boot_2_mongotemplate_statistic_query.md

File metadata and controls

118 lines (88 loc) · 3.77 KB

Springboot 2.X MongoTemplate 统计查询以及查询部分指定字段

​
​

1 摘要

MongoDB 作为 NoSQL 文档数据库，其查询的语法区别于传统的关系型数据库。本文将介绍 MongoTemplate 查询部分指定字段以及统计查询功能。

​

2 查询指定字段

./demo-mongodb/src/main/java/com/ljq/demo/springboot/mongodb/service/impl/BlogServiceImpl.java

    /**
     * 查询博客阅读量
     *
     * @param readCountQueryParam
     * @return
     */
    @Override
    public ApiResult queryReadCount(BlogReadCountQueryParam readCountQueryParam) {
        // 查询条件
        Criteria criteria = Criteria.where("id").is(readCountQueryParam.getId());
        // 查询字段
        Query query = Query.query(criteria);
        query.fields().include("id", "title", "countRead", "countLike");
        return ApiResult.success(mongoTemplate.findOne(query, BlogEntity.class));
    }
query.fields().include("id", "title", "countRead", "countLike");

用于指定需要查询的字段

3 统计查询

需求: 查询数据的统计信息，如总数据条数、某个字段的求和、某个字段的平均值等

./demo-mongodb/src/main/java/com/ljq/demo/springboot/mongodb/service/impl/BlogServiceImpl.java

    /**
     * 查询博客阅读量统计
     *
     * @param readCountSummaryParam
     * @return
     */
    @Override
    public ApiResult summaryReadCount(BlogReadCountSummaryParam readCountSummaryParam) {
        // 查询条件
        Criteria criteria = new Criteria();
        if (StrUtil.isNotBlank(readCountSummaryParam.getId())) {
            criteria.and("id").is(readCountSummaryParam.getId());
        }
        if (StrUtil.isNotBlank(readCountSummaryParam.getAuthor())) {
            criteria.and("author").is(readCountSummaryParam.getAuthor());
        }
        // 查询条件
        MatchOperation match = Aggregation.match(criteria);
        // 分组统计
        GroupOperation group = Aggregation.group()
                .count().as("totalBlog")
                .sum("countRead").as("totalRead")
                .avg("countRead").as("aveRead")
                .sum("countLike").as("totalLike")
                .avg("countLike").as("aveLike");
        // 查询结果
        AggregationResults<BlogSummaryVo> results = mongoTemplate.aggregate(Aggregation.newAggregation(BlogEntity.class,
                match, group), BlogSummaryVo.class);
        return ApiResult.success(results.getUniqueMappedResult());
    }

org.springframework.data.mongodb.core.aggregation.Aggregation 用于实现复杂的聚合查询

在本需求中是查询所有数据的总条数、总和等功能，不需要指定分组字段，也不需要通过 ProjectionOperation 来指定查询字段。

(PS: 查遍全网，搜到的资料全是按照字段分组查询，我需要的是查询整个表的数据统计，而不是某一个字段或者按日期的分组，无奈，只能自己来写一个示例了)

​

4 推荐参考资料

springboot使用MongoTemplate分组统计数据

使用mongoTemplate进行Aggregation聚合查询

​

5 本次提交记录

commit 614de38490b4d6a346d052adb47f4dbc3283dfe8 (HEAD -> dev, origin/master, origin/dev, origin/HEAD, master)
Author: lujunqiang <flying9001@gmail.com>
Date:   Mon Nov 15 18:54:50 2021 +0800

    代码-新增 Springboot MongoTemplate 查询指定字段、批量操作、统计查询等功能

版本回退命令:

git reset --soft 614de38490b4d6a346d052adb47f4dbc3283dfe8