Java Fluent Mybatis 聚合查询与apply方法详解流程篇

Java中常用的ORM框架主要是mybatis, hibernate, JPA等框架。国内又以Mybatis用的多，基于mybatis上的增强框架，又有mybatis plus和TK mybatis等。今天我们介绍一个新的mybatis增强框架 fluent mybatis关于聚

Java中常用的ORM框架主要是mybatis, hibernate, JPA等框架。国内又以Mybatis用的多，基于mybatis上的增强框架，又有mybatis plus和TK mybatis等。今天我们介绍一个新的mybatis增强框架 fluent mybatis关于聚合查询、apply方法详解

前言

接着上一篇文章：Java Fluent Mybatis 分页查询与sql日志输出详解流程篇

我把分页已经调整好了，现在实验一下官方给出的聚合查询方法。

GitHub代码仓库：GitHub仓库

数据准备

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

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);
  }
}

调试代码

Java Fluent Mybatis 聚合查询与apply方法详解流程篇

代码说明：

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

Java Fluent Mybatis 聚合查询与apply方法详解流程篇

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

MAX

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

定义返回实体。

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

/** @Author huyi @Date 2021/10/26 14:15 @Description: 聚合最大年龄返回体 */
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public 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);
  }
}

调试代码

Java Fluent Mybatis 聚合查询与apply方法详解流程篇

OK，没什么问题。

代码说明：

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

SUM、AVG、COUNT

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

定义返回体

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

/** @Author huyi @Date 2021/10/26 14:50 @Description: 聚合平均总和返回体 */
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public 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);
  }
}

调试代码

Java Fluent Mybatis 聚合查询与apply方法详解流程篇

OK，完美。

apply方法使用

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

返回体定义

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.util.Date;

/** @Author huyi @Date 2021/10/26 15:10 @Description: 聚合应用返回体 */
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public 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);
  }
}

调试代码

Java Fluent Mybatis 聚合查询与apply方法详解流程篇