mybatis-plus QueryWrapper自定义查询条件的实现

mybatis-plus框架功能很强大，把很多功能都集成了，比如自动生成代码结构，mybatis crud封装，分页，动态数据源等等，附上官网链接https://mp.baomidou.com/，github上有代码例子，国内小伙伴推荐码云https://gitee.com/baomidou/mybatis-plus。
 但是，其中还是有些小坑，文档也没有涉及的很全面，碰到问题，百度或者发issue，能力强的还是直接看源码好，一切答案都在源码中。

版本推荐用3.1.0，3.1.1及以上版本有bug，访问mapper接口的时候，会把数据库date类型转换为localDateTime，报错java.sql.SQLFeatureNotSupportedException

解决方案可以参考 https://www.jb51.net/article/193995.htm

  com.baomidou
  mybatis-plus-boot-starter
  3.1.0

mybatis-plus里有个类QueryWrapper，封装sql对象，包括where条件，order by排序，select哪些字段等等。该类的具体用法，网上教程很多。

这里有个需求，通过前端提交查询条件，后台动态拼接成where的sql语句，用于查询。常规做法是前端提交一堆查询参数，controller层用一个对象接收，然后在mybatis的xml里对该对象里的各种属性做判断

 select * from test
 
 
  and name=#{name}
 
 ...
 



这有个问题是具体字段连接类型就有很多，like,=,>,<等等。当然要实现功能有很多种方式，mybatis-plus的QueryWrapper很强大，可以通过对象的方式进行查询操作，但是不同的页面都自己管自己，效率低下，会存在大量重复代码。所以我就想自己封装一套，从前端的查询条件传固定格式的参数，到后台进行转换，自动拼接成对应的where sql语句，再传到mybatis xml里进行动态查询。这样所有页面就可以统一，便于操作。下面进入正题：
前端
前端用的技术是html+jquery，jquery操作dom做各种操作。html就仅仅是样式展现，不涉及任何的逻辑代码，没有使用vue之类的mvvm框架，也没有使用thymeleaf之类的模板引擎，其实这些都会在html嵌入污染代码，导致美工修改页面样式的时候一脸蒙蔽。html就是纯的html+css，通过jquery来完成剩余的工作。


index.html






jquery发起post请求，拼接的参数如下：



var searchParam = [
 {column: "COLUMN_NAME",type: "like", value: "tim"},
 {column: "COLUMN_AGE",type: "eq", value: "22"},
 {column: "COLUMN_DATE",type: "ge", value: "2019-08-16 00:00:00"},
 {column: "COLUMN_DATE",type: "le", value: "2019-08-16 23:59:59"}
];


其中column值 为数据表的字段名；type值为sql字段拼接的方式，规则可自己定制；value就是字段值了；目标拼接成的sql语句如下：



COLUMN_NAME like '%tim%' and COLUMN_AGE=22 and COLUMN_DATE>='2019-08-16 00:00:00' and COLUMN_DATE<='2019-08-16 23:59:59'


 jquery发起post请求：



$.ajax({
 url: "list",
 type: "post",
 data: {pageNum:1,pageSize:20,condition:JSON.stringify(searchParam),...(根据需要自己加请求参数)}
 success: function(result){...}
});


说明：请求参数condition为什么要传json字符串后续有介绍。
后端
Controller
controller接收前端发过来的参数，碰到一个问题，在有多个请求参数的情况下，如何接收 集合对象 请求参数？使用了很多方法都不行，后续有空再研究下，目前使用的方法简单粗暴，就上传json字符串，后端转换成对象。


Controller：



import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
@RequestMapping(value = "/list", method = RequestMethod.POST)
public Object getTestList(@RequestParam(name = "pageNum", required = false, defaultValue = "1") int pageNum,
      @RequestParam(name = "pageSize", required = false, defaultValue = "15") int pageSize,
      @RequestParam(name = "condition",required = false) String conditionJson) {
 QueryWrapper queryWrapper = SearchUtil.parseWhereSql(conditionJson);
   queryWrapper.orderByDesc("CREATE_DATE");
   return service.getPageTestList(queryWrapper,pageNum,pageSize);
}


SearchUtil：



public static QueryWrapper parseWhereSql(String conditionJson){
  QueryWrapper queryWrapper = new QueryWrapper();
  if(StrUtil.isNotEmpty(conditionJson)){
    List conditionList = JSON.parseArray(conditionJson,ConditionVo.class);
    if(CollUtil.isNotEmpty(conditionList)){
      for(ConditionVo conditionVo : conditionList){
 switch (conditionVo.getType()){
   case "eq": queryWrapper.eq(conditionVo.getColumn(),conditionVo.getValue());break;
   case "ne": queryWrapper.ne(conditionVo.getColumn(),conditionVo.getValue());break;
   case "like": queryWrapper.like(conditionVo.getColumn(),conditionVo.getValue());break;
   case "leftlike": queryWrapper.likeLeft(conditionVo.getColumn(),conditionVo.getValue());break;
   case "rightlike": queryWrapper.likeRight(conditionVo.getColumn(),conditionVo.getValue());break;
   case "notlike": queryWrapper.notLike(conditionVo.getColumn(),conditionVo.getValue());break;
   case "gt": queryWrapper.gt(conditionVo.getColumn(),conditionVo.getValue());break;
   case "lt": queryWrapper.lt(conditionVo.getColumn(),conditionVo.getValue());break;
   case "ge": queryWrapper.ge(conditionVo.getColumn(),conditionVo.getValue());break;
   case "le": queryWrapper.le(conditionVo.getColumn(),conditionVo.getValue());break;
 }
      }
    }
  }
  return queryWrapper;
}

该类是重点，根据type不同的值进行组合，queryWrapper包含了很多拼接方法，可以看文档。这里只写了一些常用的拼接方法。


ConditionVo：



@Data
public class ConditionVo implements Serializable {
  private static final long serialVersionUID = -5099378457111419832L;
  
  private String column;
  
  private String value;
  
  private String type;
}


拿到queryWrapper对象就是重点了，之后就是sql操作了。
Service



import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@Override
public IPage getPageEntityList(QueryWrapper queryWrapper, int pageNum, int pageSize) {
   Page page = new Page<>(pageNum,pageSize);
   IPage list = page(page,queryWrapper);
   return list;
 }
@Override
public IPage getPageTestList(QueryWrapper queryWrapper, int pageNum, int pageSize) {
  Page page = new Page<>(pageNum,pageSize);
  IPage list = mapper.getPageTestList(page,queryWrapper);
  return list;
}


上面的第一个方法getPageEntityList使用的是mybatis-plus自带的page(page,queryWrapper)方法，具体使用方法可以查看官方文档。使用该方法就不需要自己写sql语句了。本篇文章重点是下面那个方法getPageTestList。

mybatis-plus自带了强大的翻页功能，只需往mapper方法里传入一个Page类，该类实现了IPage接口。

 这里有个坑，通过看源码发现，mapper方法的参数有顺序要求：page对象一定要放在第一个参数，否则翻页查询会报错。源码在com.baomidou.mybatisplus.core.override.MybatisMapperMethod中public Object execute(SqlSession sqlSession, Object[] args)方法的case SELECT判断里，因反编译后的行数可能不同，所以贴上具体是哪个方法，我这边反编译后在68行。

ListVo是自己的业务对象。
Mapper



import com.baomidou.mybatisplus.core.toolkit.Constants;
IPage getPageTestList(Page page,@Param(Constants.WRAPPER) Wrapper query);


大家可以进Constans这个接口看下源码都有哪些值，后续xml要用到。
XML




  select * from test
  
    ${ew.customSqlSegment}
  

这里先强调一点，${ew.customSqlSegment}是用美元符号$，而不是#。

这里的ew是啥？其实就是mapper方法里的@Param(Constants.WRAPPER) Wrapper query对象，Constants.WRAPPER的值就是ew。

首先判断ew.emptyOfWhere是否存在where条件，有的话再拼接上去。ew里还有个属性nonEmptyOfWhere，看单词应该跟emptyOfWhere的值相反，但是在xml中使用却提示不存在，不知道为什么，又是一个地雷？

ew.customSqlSegment又是啥，该值是WHERe + sql语句，还有个ew.sqlSegment是不包括WHERe字符串。大家可以在service层输出queryWrapper里面的相关方法：

log.info(queryWrapper.isEmptyOfWhere()+"");
log.info(queryWrapper.getCustomSqlSegment());
log.info(queryWrapper.getSqlSegment());
log.info(queryWrapper.getParamNamevaluePairs().toString());

输出如下：

getCustomSqlSegment()
 WHERe COLUMN_NAME LIKE #{ew.paramNamevaluePairs.MPGENVAL1}
 getSqlSegment()
 COLUMN_NAME LIKE #{ew.paramNamevaluePairs.MPGENVAL1}
 getParamNamevaluePairs()
 {MPGENVAL1=%tim%}

看到这，mybatis框架用的熟练的小伙伴们应该就懂了吧，这样就可以避免sql注入的问题。
 这里又有 一个小坑，就是order by排序。传入了page参数，mybatis-plus底层就会帮你翻页查询，会查询总数量。通过输出的sql日志可以发现，其实框架是在你的sql基础上外面再套一层select count(1) from。这里会有个问题，本人用的数据库是sqlserver，如果在count查询语句里用了order by就会出错，解决方法是调用queryWrapper对象中的排序方法，如：queryWrapper.orderByDesc("CREATE_DATE")，xml中就不要用order by。所以我在controller层用了这个方法，这样mybatis-plus底层会合理地进行查询。

总结

通过上面这种封装方式，就不需要在xml里面做一大堆的where条件if判断来拼接sql。
mybatis-plus框架功能很强大，且还在维护中，有空可以仔细阅读下文档、官方例子，能力强的可以直接看源码，一切答案都在源码中。

到此这篇关于mybatis-plus QueryWrapper自定义查询条件的实现的文章就介绍到这了,更多相关mybatis-plus QueryWrapper查询条件内容请搜索考高分网以前的文章或继续浏览下面的相关文章希望大家以后多多支持考高分网！