首页 > 文章列表 > Java Fluent Mybatis的聚合查询与apply方法流程示例分析

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

java mybatis apply
501 2023-04-28

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

    }

  }

调试代码

代码说明:

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

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

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

    }

  }

调试代码

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

    }

  }

调试代码

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

    }

  }

调试代码

OK,完美。