Java Fluent Mybatis聚合查询与apply方法流程的示例分析

这篇文章将为大家详细讲解有关Java Fluent Mybatis聚合查询与apply方法流程的示例分析，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。

数据准备

为了聚合查询的条件，添加了几条数据。

MIN

我们试着获取最小的年龄。

方法实现

  @Override  public Integer getAgeMin() {    Map<String, Object> result =        testFluentMybatisMapper            .findOneMap(new TestFluentMybatisQuery().select.min.age("minAge").end())            .orElse(null);    return result != null ? Convert.toInt(result.get("minAge"), 0) : 0;  }

控制层代码

  @ApiOperation(value = "获取最小年龄", notes = "获取最小年龄")  @RequestMapping(value = "/getAgeMin", method = RequestMethod.GET)  @ResponseBody  public Result<Integer> getAgeMin() {    try {      return Result.ok(aggregateService.getAgeMin());    } catch (Exception exception) {      return Result.error(ErrorCode.BASE_ERROR_CODE.getCode(), exception.getMessage(), null);    }  }

调试代码

代码说明：

age("minAge")为什么要加一个字符串进去呢？不加可以吗？答案是可以，不过你看到的结果返回时这样的。

没错，括号内的是聚合查询结果别名，不传的话结果比较尴尬，建议还是传一下。

MAX

在做max聚合函数的时候，我来搞复杂一点，加上group by。

定义返回实体。

import lombok.AllArgsConstructor;import lombok.Builder;import lombok.Data;import lombok.NoArgsConstructor; @Data@AllArgsConstructor@NoArgsConstructor@Builderpublic class AggregateMaxAgeRsp {  private String name;  private Integer maxAge;}

方法实现

  @Override  public List<AggregateMaxAgeRsp> getAgeMaxByName() {    List<Map<String, Object>> result =        testFluentMybatisMapper.listMaps(            new TestFluentMybatisQuery()                .select                .name()                .max                .age("maxAge")                .end()                .groupBy                .name()                .end());    if (result != null && result.size() != 0) {      List<AggregateMaxAgeRsp> list = new ArrayList<>();      result.forEach(          x -> list.add(BeanUtil.fillBeanWithMapIgnoreCase(x, new AggregateMaxAgeRsp(), false)));      return list;    } else {      return null;    }  }

控制层代码

  @ApiOperation(value = "根据年龄分组并获取最大年龄", notes = "根据年龄分组并获取最大年龄")  @RequestMapping(value = "/getAgeMaxByName", method = RequestMethod.GET)  @ResponseBody  public Result<List<AggregateMaxAgeRsp>> getAgeMaxByName() {    try {      return Result.ok(aggregateService.getAgeMaxByName());    } catch (Exception exception) {      return Result.error(ErrorCode.BASE_ERROR_CODE.getCode(), exception.getMessage(), null);    }  }

调试代码

OK，没什么问题。

代码说明：

使用了Hutools工具BeanUtil将map的值填充到实体对象中。

SUM、AVG、COUNT

sum、avg、count加一起试试吧。

定义返回体

import lombok.AllArgsConstructor;import lombok.Builder;import lombok.Data;import lombok.NoArgsConstructor; @Data@AllArgsConstructor@NoArgsConstructor@Builderpublic class AggregateAgeSumAvgAndCountRsp {  private String name;  private Integer sum;  private Integer avg;  private Integer count;}

方法实现

  @Override  public List<AggregateAgeSumAvgAndCountRsp> getAgeSumAvgCountByName() {    List<Map<String, Object>> result =        testFluentMybatisMapper.listMaps(            new TestFluentMybatisQuery()                .select                .name()                .sum                .age("sum")                .avg                .age("avg")                .count("count")                .end()                .groupBy                .name()                .end());    if (result != null && result.size() != 0) {      List<AggregateAgeSumAvgAndCountRsp> list = new ArrayList<>();      result.forEach(          x ->              list.add(                  BeanUtil.fillBeanWithMapIgnoreCase(                      x, new AggregateAgeSumAvgAndCountRsp(), false)));      return list;    } else {      return null;    }  }

控制层代码

  @ApiOperation(value = "根据年龄分组并获取年龄和、平均年龄、数量", notes = "根据年龄分组并获取年龄和、平均年龄、数量")  @RequestMapping(value = "/getAgeSumAvgCountByName", method = RequestMethod.GET)  @ResponseBody  public Result<List<AggregateAgeSumAvgAndCountRsp>> getAgeSumAvgCountByName() {    try {      return Result.ok(aggregateService.getAgeSumAvgCountByName());    } catch (Exception exception) {      return Result.error(ErrorCode.BASE_ERROR_CODE.getCode(), exception.getMessage(), null);    }  }

调试代码

OK，完美。

apply方法使用

官方提供了显示自由指定字段.apply语法功能。我们测试一下好不好用。

返回体定义

import lombok.AllArgsConstructor;import lombok.Builder;import lombok.Data;import lombok.NoArgsConstructor; import java.util.Date; @Data@AllArgsConstructor@NoArgsConstructor@Builderpublic class AggregateApplyRsp {  private String name;  private Date createTime;  private Integer minAge;  private Date maxTime;}

方法实现

  @Override  public List<AggregateApplyRsp> getApply() {    List<Map<String, Object>> result =        testFluentMybatisMapper.listMaps(            new TestFluentMybatisQuery()                .select                .apply("name")                .createTime("createTime")                .apply("min(age) as minAge", "max(create_time) as maxTime")                .end()                .groupBy                .name()                .createTime()                .end());    if (result != null && result.size() != 0) {      List<AggregateApplyRsp> list = new ArrayList<>();      result.forEach(          x -> list.add(BeanUtil.fillBeanWithMapIgnoreCase(x, new AggregateApplyRsp(), false)));      return list;    } else {      return null;    }  }

控制层代码

  @ApiOperation(value = "根据名字获取最小年龄，使用语句", notes = "根据名字获取最小年龄，使用语句")  @RequestMapping(value = "/getApply", method = RequestMethod.GET)  @ResponseBody  public Result<List<AggregateApplyRsp>> getApply() {    try {      return Result.ok(aggregateService.getApply());    } catch (Exception exception) {      return Result.error(ErrorCode.BASE_ERROR_CODE.getCode(), exception.getMessage(), null);    }  }

调试代码

OK，完美。

关于“Java Fluent Mybatis聚合查询与apply方法流程的示例分析”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，使各位可以学到更多知识，如果觉得文章不错，请把它分享出去让更多的人看到。