数据准备
为了聚合查询的条件，添加了几条数据。
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;
}控制层代码
立即学习“Java免费学习笔记（深入）”；
@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;
}
}控制层代码
立即学习“Java免费学习笔记（深入）”；
@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;
}
}控制层代码
立即学习“Java免费学习笔记（深入）”；
@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;
}
}控制层代码
立即学习“Java免费学习笔记（深入）”；
@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，完美。
