前言
接著上一篇文章：Java Fluent Mybatis 分頁查詢與sql日志輸出詳解流程篇
我把分頁已經調整好了，現在實驗一下官方給出的聚合查詢方法。
GitHub代碼倉庫：GitHub倉庫
數據準備
為了聚合查詢的條件，添加了幾條數據。
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，完美。
總結
在調試完聚合查詢代碼后給我直觀感受是，這和寫sql沒啥區別，十分好理解。只是需要掌握fm的select語法，特別是end方法的理解，可以追一下源碼看一下具體實現過程。
如果文章對你有幫助的話，點個贊吧，點個贊吧，點個贊吧，重要的事情說三遍。
到此這篇關于Java Fluent Mybatis 聚合查詢與apply方法詳解流程篇的文章就介紹到這了,更多相關Java Fluent Mybatis內容請搜索服務器之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持服務器之家！
原文鏈接：https://huyi-aliang.blog.csdn.net/article/details/120973105
