MyBatis-Plus+mysql5.7 動態拼接sql語句 分頁查詢 自定義sql 查詢條件 分組 排序

在使用srpingboot2.x+mybatis-plus框架是遇到特殊需求時研究mybatis-plus的條件構造器動態拼接sql查詢，這個查詢接口涉及到了自定義sql，動態拼接sql，分頁，求和，分組，排序。

可以直接看業務實現方法

首先說一下接口的需求：

入參JSON：

{
    "from": "2020-5-29",
    "limit": 10,
    "offset": 0,
    "order": "hitCount",
    "page": 1,
    "search": "",
    "sort": "desc",
    "sortDirection": "",
    "to": "2020-6-10"
}

入參注釋說明：

{
    "from": "開始查詢時間",
    "limit": 條數,
    "offset": 0,
    "order": "需要排序的字段",
    "page": 頁碼,
    "search": "查詢條件",
    "sort": "排序規則",
    "sortDirection": "",
    "to": "結束查詢時間"
}

然后先寫接口實現：

    @PostMapping("categoryList")
    public R getCategoryList(@Validated @RequestBody QaDetailSearchVo vo){
        RobotPage pageHelper = new RobotPage(vo.getPage(),vo.getLimit());
        return R.ok(iStatQaService.findQaStatCategory(pageHelper, vo));
    }

解釋：POST請求，R 是自定義的返回類型，RobotPage是為了實現一些特殊返回值 繼承於mybatsi-plus分頁的Ipage:

public class RobotPage<T> extends Page<T> implements Serializable {}

重點是業務實現類和mapper層：

對於一般的查詢mybatis-plus的條件構造器已經可以滿足了，例如：

SysUser sysUser = baseMapper.selectOne(Wrappers.<SysUser>lambdaQuery()
                .select(SysUser::getUserId, SysUser::getUsername, SysUser::getPhone, SysUser::getEmail, SysUser::getPassword, SysUser::getDeptId, SysUser::getJobId, SysUser::getAvatar)
                .eq(SysUser::getUsername, username));

但是對於一些需要復雜的或者多表的操作就需要自定義sql語句了，示例：

首先是mapper自定義分頁查詢接口：

@Select("SELECT s.category_id as id, s.category_name as category, SUM(s.hit_count) as hitCount, SUM(s.solve_count) as resolvedCount, SUM(s.not_solve_count) as unresolvedCount " +
            "FROM core_stat_qa as s ${ew.customSqlSegment}")
    IPage<QaDetailCategoryListVo> findCategoryListByParams(IPage<QaDetailCategoryListVo> page, @Param(Constants.WRAPPER) QueryWrapper<StatQa> wrappers);

這部分官網給的有示例：https://mybatis.plus/guide/wrapper.html#%E4%BD%BF%E7%94%A8-wrapper-%E8%87%AA%E5%AE%9A%E4%B9%89sql

業務接口不用看 直接是實現類：

@Override
    public Grid findQaStatCategory(Page<QaDetailCategoryListVo> page, QaDetailSearchVo vo) {
        //聲明返回
        Grid grid = new Grid();
        //組裝查詢語句
        QueryWrapper<StatQa> qaQueryWrapper = new QueryWrapper<>();
        //模糊查詢
        qaQueryWrapper.like(StringUtils.isNotBlank(vo.getSearch()),"category_name",vo.getSearch());
        //where條件
        qaQueryWrapper.ge("create_time", DateUtil.parse(vo.getFrom(),"yyyy-MM-dd"));
        qaQueryWrapper.lt("create_time",DateUtil.parse(vo.getTo(), "yyyy-MM-dd"));
        //分組
        qaQueryWrapper.groupBy("category_id","category_name");
        //排序
        qaQueryWrapper.orderBy(true, !"desc".equals(vo.getSort()),vo.getOrder());
        //調用自定義sql語句
        IPage<QaDetailCategoryListVo> statQaIPage = baseMapper.findCategoryListByParams(page, qaQueryWrapper);
        //抽取list
        List<QaDetailCategoryListVo> statQaList = statQaIPage.getRecords();
        grid.setList(statQaList);
        grid.setTotal(statQaIPage.getTotal());
        return grid;
    }

需要解釋的：

排序orderBy方法中的第一個true官網上也是給出解釋的：表示該條件是否加入最后生成的sql中。

!"desc".equals(vo.getSort())  是排序規則 asc和desc

調用mapper自定義sql就是：

baseMapper.findCategoryListByParams(page, qaQueryWrapper);

接口完成。