LambdaQueryWrapper&QueryWrapper增删改CURD使用教程案例

Posted 2022-06-16 君子志邦

 目录

---

前言：

最近很多新入职的应届生开始进入项目组，可是他们真的是零基础的开发经验，大学过程中也没有好好地历练过怎么样开发一个应用程序，SpringBoot没使用过，​​Mybatis​​还是老套的xml配置化，真让我无语至极，不懂的现在SPringBoot里面的JPa可以注解实现SQL的增删改查，也不知道针对单表查询现在实际项目开发过程中根本不使用原生的Hibernate或者Mybatis了，现在使用的是Mybatis Plus，使用轻便友好，开发代码段少且完美的实现，在这里我需要写一个文档针对这些初级开发者做一个入门的讲解是如何开发使用的！

好处：单表查询的话，可以直接的使用对象操作，其实实现起来极其方便而且简单！

如果多表的查询的话，那就建议使用xml格式的配置化进行关联，文章末尾也进行了案例讲解参考学习！

目前在重构一个项目的时候要针对原有的SQL进行​​重写​​，所以针对一个好用的Mybatis的插件使用。在这里做一些总结，然后通过我们组内人员使用，统一的改用LambdaQueryWrapper&QueryWrapper

简单对象查询方式用起来极为方便！涉及到单表查询的是该该对象查询继承；

推荐使用：LambdaQueryWrapper

查询使用案例增删改查总结如下

1、【大小比较： ( =, <>, >, >=, <, <= )】

    eq(R column, Object val); // 等价于 =，例: eq("name", "媳妇") ---> name = 媳妇
    ne(R column, Object val); // 等价于 <>，例: ne("name", "媳妇") ---> name <> 媳妇
    gt(R column, Object val); // 等价于 >，例: gt("name", "媳妇") ---> name > 媳妇
    ge(R column, Object val); // 等价于 >=，例: ge("name", "媳妇") ---> name >= 媳妇
    lt(R column, Object val); // 等价于 <，例: lt("name", "媳妇") ---> name < 媳妇
    le(R column, Object val); // 等价于 <=，例: le("name", "媳妇") ---> name <= 媳妇

使用上面直接对象的名称，以及入参即可，比如下面java代码实现列表查询

public List<DimDict> listByDictCode(DictCodeEnum dictCodeEnum) 

        LambdaQueryWrapper<DimDict> wrapper = Wrappers.lambdaQuery();

        wrapper.eq(DimDict::getDictCode, dictCodeEnum.getCode())

                .eq(DimDict::getEnabled, DictEnableEnum.VALID.getType());

        return this.list(wrapper);

 2、【范围：（between、not between、in、not in）】

between(R column, Object val1, Object val2); // 等价于 between a and b, 例：                between("age", 18, 30) ---> age between 18 and 30
notBetween(R column, Object val1, Object val2); // 等价于 not between a and b, 例：    notBetween("age", 18, 30) ---> age not between 18 and 30
in(R column, Object... values); // 等价于 字段 IN (v0, v1, ...),例: in("age",1,2,3) ---> age in (1,2,3)
notIn(R column, Object... values); // 等价于 字段 NOT IN (v0, v1, ...), 例: notIn("age",1,2,3) ---> age not in (1,2,3)
inSql(R column, Object... values); // 等价于 字段 IN (sql 语句), 例: inSql("id", "select id from table where id < 3") ---> id in (select id from table where id < 3)
notInSql(R column, Object... values); // 等价于 字段 NOT IN (sql 语句) 

主要实现的java代码如下，实现查询一个页面。里面会带有分页且根据时间排序

public IPage<TbmNewsDupFilter> getInfoListByNewsId(String newsId, Byte position, Date startTime, Date endTime, Integer current, Integer size) 

        IPage<TbmNewsDupFilter> page = new Page<>(current, size);

        LambdaQueryWrapper<TbmNewsDupFilter> lqw = new LambdaQueryWrapper<>();

        lqw.eq(TbmNewsDupFilter::getNewsId, newsId).ne(TbmNewsDupFilter::getPosition, 0)

                .between(TbmNewsDupFilter::getCreateTime, startTime, endTime);

        if (null != position) 

            lqw.eq(TbmNewsDupFilter::getPosition, position);

        lqw.orderByDesc(TbmNewsDupFilter::getCreateTime);

        return tbmNewsDupFilterMapper.selectPage(page, lqw);

3、【模糊匹配：（like）】

like(R column, Object val); // 等价于 LIKE %值%，例: like("name", "媳妇") ---> name like %媳妇%
notLike(R column, Object val); // 等价于 NOT LIKE %值%，例: notLike("name", "媳妇") ---> name not like %媳妇%
likeLeft(R column, Object val); // 等价于 LIKE %值，例: likeLeft("name", "媳妇") ---> name like %媳妇
likeRight(R column, Object val); // 等价于 LIKE 值%，例: likeRight("name", "媳妇") ---> name like 媳妇%

java代码查询右边末尾模糊查询，前端字符串匹配代码实现如下

private Map<String, Double> queryWeight() 

        QueryWrapper<TagWeight> wrapper = new QueryWrapper<>();

        wrapper.lambda().likeRight(TagWeight::getTagType, "101109");

        List<TagWeight> list = tagWeightService.list(wrapper);

        if (CollectionUtils.isEmpty(list)) 

            return Maps.newHashMap();

        return list.stream().collect(Collectors.toMap(TagWeight::getTagType, TagWeight::getWeight));

  4、【空值比较：（isNull、isNotNull）】

    isNull(R column); // 等价于 IS NULL，例: isNull("name") ---> name is null
    isNotNull(R column); // 等价于 IS NOT NULL，例: isNotNull("name") ---> name is not null

java代码使用的案例实现的代码如下可以一共参考，isnotNUll使用上比较多的

private List<HwSecuritiesInfo> getHwSecuritiesInfoList(Long jsid, int limit) 

        LambdaQueryWrapper<HwSecuritiesInfo> lambda = new LambdaQueryWrapper<>();

        lambda.isNotNull(HwSecuritiesInfo::getCompanyCode)

                .ne(HwSecuritiesInfo::getSecuritiesSection, EXCLUDE_SEUCRITIES_SECTION)

                .gt(HwSecuritiesInfo::getJsid, jsid)

                .orderByAsc(HwSecuritiesInfo::getJsid);

        lambda.last("limit " + limit);

        return hwSecuritiesInfoService.list(lambda);

5、【分组、排序：（group、having、order）】

groupBy(R... columns); // 等价于 GROUP BY 字段, ...， 例: groupBy("id", "name") ---> group by id,name
orderByAsc(R... columns); // 等价于 ORDER BY 字段, ... ASC， 例: orderByAsc("id", "name") ---> order by id ASC,name ASC
orderByDesc(R... columns); // 等价于 ORDER BY 字段, ... DESC， 例: orderByDesc("id", "name") ---> order by id DESC,name DESC
having(String sqlHaving, Object... params); // 等价于 HAVING ( sql语句 )， 例: having("sum(age) > 0", 11) ---> having sum(age) > 11

实现的java代码参考如下通过分组来查询分页的使用代码

@DataSource(DataSourceType.HW_BUSINESS)

    public IPage<Ds> selectDistinctDsByPage(DsQueryForm queryForm) 

        Integer currentPage = queryForm.getCurrentPage();

        Integer pageSize = queryForm.getPageSize();

        Page<Ds> page = new Page<>(currentPage, pageSize);

        LambdaQueryWrapper<Ds> lqw = new LambdaQueryWrapper<>();

        //数据源编码， 媒体栏目， 信息来源参数只传了一个

        String dsCode = queryForm.getDsCode();

        String dsSourceName = queryForm.getDsSourceName();

        String dsNewsColumns = queryForm.getDsNewsColumns();

        if (!StringUtil.isEmpty(dsCode)) 

            lqw.likeRight(Ds::getDsCode, SqlUtil.escapeLike(dsCode));

            lqw.groupBy(Ds::getDsCode).having("count (0) >1");

         else if (!StringUtil.isEmpty(dsSourceName)) 

            lqw.like(Ds::getDsSourceName, SqlUtil.escapeLike(dsSourceName));

            lqw.groupBy(Ds::getDsSourceName);

         else if (!StringUtils.isEmpty(dsNewsColumns)) 

            lqw.like(Ds::getDsNewsColumns, SqlUtil.escapeLike(dsNewsColumns));

            lqw.groupBy(Ds::getDsNewsColumns);

        lqw.orderByAsc(Ds::getDsCode);

        return dsMapper.selectPage(page, lqw);

6、【拼接、嵌套 sql：（or、and、nested、apply）】

or(); // 等价于 a or b， 例：eq("id",1).or().eq("name","媳妇") ---> id = 1 or name = 媳妇
or(Consumer<Param> consumer); // 等价于 or(a or/and b)，or 嵌套。例: or(i -> i.eq("name", "李白").ne("status", "活着")) ---> or (name = 李白 and status <> 活着)
and(Consumer<Param> consumer); // 等价于 and(a or/and b)，and 嵌套。例: and(i -> i.eq("name", "李白").ne("status", "活着")) ---> and (name = 李白 and status <> 活着)
nested(Consumer<Param> consumer); // 等价于 (a or/and b)，普通嵌套。例: nested(i -> i.eq("name", "李白").ne("status", "活着")) ---> (name = 李白 and status <> 活着)
apply(String applySql, Object... params); // 拼接sql（若不使用 params 参数，可能存在 sql 注入），例: apply("date_format(dateColumn,%Y-%m-%d) = 0", "2008-08-08") ---> date_format(dateColumn,%Y-%m-%d) = 2008-08-08")
last(String lastSql); // 无视优化规则直接拼接到 sql 的最后，可能存若在 sql 注入。
exists(String existsSql); // 拼接 exists 语句。例: exists("select id from table where age = 1") ---> exists (select id from table where age = 1)
使用案例java实现的代码逻辑last案例

public Long calculateFileRealMd5(Long minId, Integer limit) 

        LambdaQueryWrapper<AnncFile> wrapper = new LambdaQueryWrapper<>();

        wrapper.eq(AnncFile::getUploadStatus, UploadStatusEnum.SUCCESS.getCode())

                .isNull(AnncFile::getRealFileMd5)

                .gt(AnncFile::getId, minId)

                .orderByAsc(AnncFile::getId)

                .last("limit " + limit);

        List<AnncFile> list = anncFileService.list(wrapper);

7、【QueryWrapper 条件：】

    select(String... sqlSelect); // 用于定义需要返回的字段。例： select("id", "name", "age") ---> select id, name, age
    select(Predicate<TableFieldInfo> predicate); // ​​​Lambda​​​ 表达式，过滤需要的字段。
    lambda(); // 返回一个 LambdaQueryWrapper
   实际使用的select语句java代码实现案例

private List<HwSecuritiesInfo> query(QueryParam param) 

        QueryWrapper<HwSecuritiesInfo> wrapper = new QueryWrapper<>();

        wrapper.lambda().gt(HwSecuritiesInfo::getId, param.getJsid())

                .orderByAsc(HwSecuritiesInfo::getId);

        wrapper.lambda().select(HwSecuritiesInfo::getId, HwSecuritiesInfo::getBusinessId, HwSecuritiesInfo::getCompanyCode);

        wrapper.last("limit " + param.getCount());

        return hwSecuritiesInfoService.list(wrapper);

8、【UpdateWrapper 条件：】

    set(String column, Object val); // 用于设置 set 字段值。例: set("name", null) ---> set name = null
    etSql(String sql); // 用于设置 set 字段值。例: setSql("name = 老公") ---> set name = 老公
    lambda(); // 返回一个 LambdaUpdateWrapper 

java代码使用案例如下

public List<GelonghuiNews> selectGelonghuiNews(Long lastId) 

        QueryWrapper<GelonghuiNews> wrapper = new QueryWrapper<>();

        if (null == lastId) 

        wrapper.lambda().gt(GelonghuiNews::getJsid, lastId).eq(GelonghuiNews::getImageStatus,OssImageStatus.YES.getStatus());

        return super.baseMapper.selectList(wrapper);

使用功能简单地开发代码截图如下

LambdaQueryWrapper<HwPicture> lambdaQueryWrapper = new LambdaQueryWrapper<>();

9、 LambdaQueryWrapper使用其实更为方便；

因为很多个性化的功能呢都在这里面使用的，所以目前开发组建议使用这个；

java使用案例如下：

public List<TbmNewsPopularFeelings> selectNewsPopularFeelings(Date startTime, Date endTime, Integer limitSize) 

        LambdaQueryWrapper<TbmNewsPopularFeelings> lambdaQueryWrapper = new LambdaQueryWrapper<>();

        lambdaQueryWrapper.ge(startTime != null, TbmNewsPopularFeelings::getCreateTime, startTime);

        lambdaQueryWrapper.le(endTime != null, TbmNewsPopularFeelings::getCreateTime, endTime);

        lambdaQueryWrapper.orderByAsc(TbmNewsPopularFeelings::getCreateTime);

        lambdaQueryWrapper.last("limit " + limitSize);

        return historyNewsEventMapper.selectList(lambdaQueryWrapper);

10，多表查询如何配置使用

代码案例使用

11.pom依赖

目前的Mybatis-Plus版本已经跟新到2.5.2【本篇博客更新2022-06-15】

<mybatis-plus-generator.version>3.5.2</mybatis-plus-generator.version>
<mybatis-plus-boot-starter.version>3.5.2</mybatis-plus-boot-starter.version>
<mybatis-plus-extension.version>3.5.2</mybatis-plus-extension.version>
<mybatis-plus-core.version>3.5.2</mybatis-plus-core.version>

目前如果仅仅只是使用上面的功能的话，下面的俩个依赖已经完全满足需要了！

<groupId>com.baomidou</groupId>

                <artifactId>mybatis-plus-core</artifactId>

                <version>$mybatis-plus-core.version</version>

                <groupId>com.baomidou</groupId>

                <artifactId>mybatis-plus-boot-starter</artifactId>

                <version>$mybatis-plus-boot-starter.version</version>

            </dependency>

本文同步于我的CSDN文章 ​​我的原始文章参考​​