.png)
接着上一篇:Java Fluent Mybatis 项目工程化与常规操作详解流程篇 上
仓库地址:GitHub仓库
定义查询请求体
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 | packagecom.hy.fmp.dto.req; importlombok.AllArgsConstructor;importlombok.Builder;importlombok.Data;importlombok.NoArgsConstructor; /** @Author huyi @Date 2021/10/20 19:37 @Description: 查询条件 */@Data@AllArgsConstructor@NoArgsConstructor@BuilderpublicclassTestFluentMybatisQueryReq {  privateString age;  privateString name;} | 
查询接口方法定义
| 1 2 3 4 5 6 7 | /** * 查询接口1 * * @param queryReq 查询请求 * @return 列表 */List<TestFluentMybatisEntity> query1(TestFluentMybatisQueryReq queryReq); | 
方法实现,这里我们改用了mapper来实现一下官方给出的查询语法模式。
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 | packagecom.hy.fmp.service.Impl; importcn.hutool.core.util.StrUtil;importcom.hy.fmp.dto.req.TestFluentMybatisQueryReq;importcom.hy.fmp.fluent.dao.intf.TestFluentMybatisDao;importcom.hy.fmp.fluent.entity.TestFluentMybatisEntity;importcom.hy.fmp.fluent.helper.TestFluentMybatisMapping;importcom.hy.fmp.fluent.mapper.TestFluentMybatisMapper;importcom.hy.fmp.fluent.wrapper.TestFluentMybatisQuery;importcom.hy.fmp.service.IBaseService;importlombok.extern.slf4j.Slf4j;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.stereotype.Service; importjava.util.HashMap;importjava.util.List; /** @Author huyi @Date 2021/10/20 17:10 @Description: 基础操作接口实现 */@Slf4j@ServicepublicclassBaseServiceImpl implementsIBaseService {   @AutowiredprivateTestFluentMybatisDao testFluentMybatisDao;  @AutowiredprivateTestFluentMybatisMapper testFluentMybatisMapper;   @Override  publicTestFluentMybatisEntity insertOrUpdate(TestFluentMybatisEntity param) {    testFluentMybatisDao.saveOrUpdate(param);    returnparam;  }   @Override  publicList<TestFluentMybatisEntity> query1(TestFluentMybatisQueryReq queryReq) {    returntestFluentMybatisMapper.listEntity(        newTestFluentMybatisQuery()            .selectAll()            .where            .age()            .eq(queryReq.getAge())            .and            .name()            .eq(queryReq.getName())            .end());  } } | 
control层方法定义
| 1 2 3 4 5 6 7 8 9 10 11 | @ApiOperation(value = "查询数据1", notes = "查询数据1")@RequestMapping(value = "/query1", method = RequestMethod.POST)@ResponseBodypublicResult<List<TestFluentMybatisEntity>> query1(    @RequestBodyTestFluentMybatisQueryReq queryReq) {  try{    returnResult.ok(baseService.query1(queryReq));  } catch(Exception exception) {    returnResult.error(ErrorCode.BASE_ERROR_CODE.getCode(), exception.getMessage(), null);  }} | 
调试一下接口

一眼望去貌似没问题,但是长期后端开发的朋友应该能看出来,这个实现方式如果一旦age或者name参数为空的话,那么肯定查不出结果。因为按照语句的写法,会强制比较age和name两个参数。
我们将其中一个参数设置为空字符串试试看。

不出意料。现在我可以就该方法做调整,参数判断然后替换select语句,为了更优雅的实现,我去官方文档再找找。
查询方法2
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 | packagecom.hy.fmp.service.Impl; importcn.hutool.core.util.StrUtil;importcom.hy.fmp.dto.req.TestFluentMybatisQueryReq;importcom.hy.fmp.fluent.dao.intf.TestFluentMybatisDao;importcom.hy.fmp.fluent.entity.TestFluentMybatisEntity;importcom.hy.fmp.fluent.helper.TestFluentMybatisMapping;importcom.hy.fmp.fluent.mapper.TestFluentMybatisMapper;importcom.hy.fmp.fluent.wrapper.TestFluentMybatisQuery;importcom.hy.fmp.service.IBaseService;importlombok.extern.slf4j.Slf4j;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.stereotype.Service; importjava.util.HashMap;importjava.util.List; /** @Author huyi @Date 2021/10/20 17:10 @Description: 基础操作接口实现 */@Slf4j@ServicepublicclassBaseServiceImpl implementsIBaseService {   @AutowiredprivateTestFluentMybatisDao testFluentMybatisDao;  @AutowiredprivateTestFluentMybatisMapper testFluentMybatisMapper;   @Override  publicTestFluentMybatisEntity insertOrUpdate(TestFluentMybatisEntity param) {    testFluentMybatisDao.saveOrUpdate(param);    returnparam;  }   @Override  publicList<TestFluentMybatisEntity> query1(TestFluentMybatisQueryReq queryReq) {    returntestFluentMybatisMapper.listEntity(        newTestFluentMybatisQuery()            .selectAll()            .where            .age()            .eq(queryReq.getAge())            .and            .name()            .eq(queryReq.getName())            .end());  }   @Override  publicList<TestFluentMybatisEntity> query2(TestFluentMybatisQueryReq queryReq) {    returntestFluentMybatisMapper.listByMap(        true,        newHashMap<String, Object>() {          {            if(!StrUtil.hasEmpty(queryReq.getAge())) {              this.put(TestFluentMybatisMapping.age.column, queryReq.getAge());            }            if(!StrUtil.hasEmpty(queryReq.getName())) {              this.put(TestFluentMybatisMapping.name.column, queryReq.getName());            }          }        });  }} | 
我对比了一下官方文档的写法,发现我这个版本的fm该listByMap方法多一个isColumn的布尔型参数。所以我追了一下源码。

只影响错误打印,主要就是设置的map参数必须要是列名或者实体对象内的参数名。就不管了。
验证一下

没什么问题,还是可以查出来。
但是按照这个查询方法,如果两个值都传空字符串会查出全表数据吗?
验证一下

咳咳,报错了。
所以我还是老老实实先把代码参数判空优化一下。
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 | packagecom.hy.fmp.service.Impl; importcn.hutool.core.util.StrUtil;importcom.hy.fmp.dto.req.TestFluentMybatisQueryReq;importcom.hy.fmp.fluent.dao.intf.TestFluentMybatisDao;importcom.hy.fmp.fluent.entity.TestFluentMybatisEntity;importcom.hy.fmp.fluent.helper.TestFluentMybatisMapping;importcom.hy.fmp.fluent.mapper.TestFluentMybatisMapper;importcom.hy.fmp.fluent.wrapper.TestFluentMybatisQuery;importcom.hy.fmp.service.IBaseService;importlombok.extern.slf4j.Slf4j;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.stereotype.Service; importjava.util.HashMap;importjava.util.List; /** @Author huyi @Date 2021/10/20 17:10 @Description: 基础操作接口实现 */@Slf4j@ServicepublicclassBaseServiceImpl implementsIBaseService {   @AutowiredprivateTestFluentMybatisDao testFluentMybatisDao;  @AutowiredprivateTestFluentMybatisMapper testFluentMybatisMapper;   @Override  publicTestFluentMybatisEntity insertOrUpdate(TestFluentMybatisEntity param) {    testFluentMybatisDao.saveOrUpdate(param);    returnparam;  }   @Override  publicList<TestFluentMybatisEntity> query1(TestFluentMybatisQueryReq queryReq) {    returntestFluentMybatisMapper.listEntity(        newTestFluentMybatisQuery()            .selectAll()            .where            .age()            .eq(queryReq.getAge())            .and            .name()            .eq(queryReq.getName())            .end());  }   @Override  publicList<TestFluentMybatisEntity> query2(TestFluentMybatisQueryReq queryReq) {    if(StrUtil.hasEmpty(queryReq.getAge()) && StrUtil.hasEmpty(queryReq.getName())) {      returntestFluentMybatisMapper.listEntity(newTestFluentMybatisQuery().selectAll());    }    returntestFluentMybatisMapper.listByMap(        true,        newHashMap<String, Object>() {          {            if(!StrUtil.hasEmpty(queryReq.getAge())) {              this.put(TestFluentMybatisMapping.age.column, queryReq.getAge());            }            if(!StrUtil.hasEmpty(queryReq.getName())) {              this.put(TestFluentMybatisMapping.name.column, queryReq.getName());            }          }        });  }} | 
验证一下

添加通过ID删除数据的接口方法
| 1 2 3 4 5 6 | /** * 删除接口 * * @param id id */voiddeleteById(Integer id); | 
实现接口方法
| 1 2 3 4 | @OverridepublicvoiddeleteById(Integer id) {  testFluentMybatisMapper.deleteById(id);} | 
验证一下


删除成功
这两篇文章主要是将之前的项目进行工程化改造,增加了文档、接口等一些列常规化操作。实现了数据库表的基本增删改查功能。其他的功能会在之后慢慢更新,fm融合了很多其他orm框架的东西,需要慢慢摸索摸索。
如果本文对你有帮助,请点个赞支持一下吧。

到此这篇关于Java Fluent Mybatis 项目工程化与常规操作详解流程篇 下的文章就介绍到这了,更多相关Java Fluent Mybatis内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!