mybatisFlex各种链式sql写法小结

 更新时间:2025年04月25日 11:40:24   作者:小吴先生666  
本文主要介绍了mybatisFlex各种链式sql写法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

1.关联LEFT JOIN

 public List<TocAgentUserRelationVO> selectTocAgentUserRelationByPhones(List<String> phones) {
        QueryWrapper queryWrapper = QueryWrapper.create()
                .select(TOC_AGENT_USER_RELATION.ALL_COLUMNS)
                .select(TOC_USER_INFO.PHONE,TOC_USER_INFO.NICK_NAME)
                .select(TOC_GROUP_PATIENT_RELATIONS.DOCTOR_ID,TOC_GROUP_PATIENT_RELATIONS.CREATE_TIME.as("bindDoctorTime"))
                .from(TOC_AGENT_USER_RELATION)
                .leftJoin(TOC_USER_INFO).on(TOC_USER_INFO.ID.eq(TOC_AGENT_USER_RELATION.USER_ID))
                .leftJoin(TOC_GROUP_PATIENT_RELATIONS).on(TOC_GROUP_PATIENT_RELATIONS.PATIENT_ID.eq(TOC_AGENT_USER_RELATION.USER_ID))
                .where(TOC_USER_INFO.PHONE.in(phones))
                .orderBy(TOC_AGENT_USER_RELATION.CREATE_TIME.desc());
        return tocAgentUserRelationMapper.selectListByQueryAs(queryWrapper,TocAgentUserRelationVO.class);
    }

2.FIND_IN_SET+LEFT JOIN+AND (OR)写法

 public <R> Page<R> dietitianList(DietitianListRequest request, Class<R> asType) {
        QueryWrapper queryWrapper = QueryWrapper.create()
                .select(TOC_USER_INFO.ID,TOC_USER_INFO.NICK_NAME,TOC_USER_INFO.IMG_URL,TOC_USER_INFO.TAG,TOC_USER_INFO.GOOD_AT,TOC_USER_INFO.GOOD_AT_REMARK)
                .select(TOC_NUTRITIONIST_ORDER_NUM.CONSULT_ORDER_NUMBER)
                //计算好评率=好评数目/总订单数目
                .select(TOC_NUTRITIONIST_ORDER_NUM.GOOD_REPUTATION_NUMBER.divide(TOC_NUTRITIONIST_ORDER_NUM.CONSULT_ORDER_NUMBER).as("goodRate"))
                .from(TOC_USER_INFO)
                .leftJoin(TOC_NUTRITIONIST_ORDER_NUM).on(TOC_NUTRITIONIST_ORDER_NUM.USER_ID.eq(TOC_USER_INFO.ID));
        queryWrapper.where(TOC_USER_INFO.PLATFORM.eq(3));
        queryWrapper.where(TOC_USER_INFO.USER_TYPE.eq(UserTypeEnum.TOC_DOCTOR));
        if(request.getIllnessId() != null){
            queryWrapper.and("FIND_IN_SET('" + request.getIllnessId() + "',good_at)");
        }

        if(request.getIllnessIds() != null && !request.getIllnessIds().isEmpty()){
            queryWrapper.and(q -> { for (Long illnessId : request.getIllnessIds()) { q.or("FIND_IN_SET('" + illnessId + "',good_at)"); } });

        }
        queryWrapper.orderBy("goodRate", false);
        PageDomain pageDomain = TableSupport.buildPageRequest();
        return tocUserInfoMapper.paginateAs(pageDomain.getPageNum(), pageDomain.getPageSize(), queryWrapper, asType);
    }

3.修改部分字段写法

   public void updateReservePhone(NutritionistRequest request) {
        UpdateChain.of(TocUserInfo.class)
                .set(TocUserInfo::getReservePhone, request.getReservePhone())
                .where(TocUserInfo::getId).eq(request.getUserId())
                .update();
    }

4.sum+case_().when().then().else_().end()写法

    public StatisticsReturnVo selectRegistrationCodeIncome(StatisticsRequest request) {
        QueryWrapper wrapper = QueryWrapper.create()
                .select(sum(case_().when(SYS_WX_PAY_ORDER.USER_FROM.eq(4)).then(SYS_WX_PAY_ORDER.PAY_MONEY).else_(0.00).end()).as("num1"))
                .select(sum(case_().when(SYS_WX_PAY_ORDER.USER_FROM.eq(5)).then(SYS_WX_PAY_ORDER.PAY_MONEY).else_(0.00).end()).as("num2"))
                .select(sum(case_().when(SYS_WX_PAY_ORDER.USER_FROM.eq(2)).then(SYS_WX_PAY_ORDER.PAY_MONEY).else_(0.00).end()).as("num3"))
                .from(SYS_WX_PAY_ORDER)
                .where(SYS_WX_PAY_ORDER.USER_FROM.in(2,4,5));
        wrapper.eq(SysWxPayOrder::getAgentUserId, request.getAgentId());
        wrapper.between(SysWxPayOrder::getCreateTime, request.getBeginTime(), request.getEndTime());
        wrapper.eq(SysWxPayOrder::getPayState,1);
        return sysWxPayOrderMapper.selectOneByQueryAs(wrapper, StatisticsReturnVo.class);
    }

4.count+case_().when().then().else_().end()写法

public List<TocReserveTimeVo> getReserveTimeSlotRule(TocReserveQuery query) {
        QueryWrapper queryWrapper = QueryWrapper.create()
                .select(TOC_RESERVE_TIME_SLOT_RULE.ID.as("slotId"),
                        TOC_RESERVE_TIME_SLOT_RULE.TIME_SLOT,
                        TOC_RESERVE_TIME_SLOT_RULE.MAX_CAPACITY.as("totalAvailable"))
                .select(count(case_().when(TOC_RESERVE_DETAIL.STATUS.eq(1)).then(TOC_RESERVE_DETAIL.ID).else_(null).end()).as("reservedCount"))
                .select(TOC_RESERVE_TIME_SLOT_RULE.MAX_CAPACITY.subtract(count(TOC_RESERVE_DETAIL.ID)) .as("remainingSlots"))
                .from(TOC_RESERVE_TIME_SLOT_RULE)
                .leftJoin(TOC_RESERVE_DETAIL).on(TOC_RESERVE_DETAIL.SLOT_ID.eq(TOC_RESERVE_TIME_SLOT_RULE.ID))
                .where(TOC_RESERVE_TIME_SLOT_RULE.DATE_RULE_ID.eq(query.getId()))
                .groupBy(TOC_RESERVE_TIME_SLOT_RULE.ID, TOC_RESERVE_TIME_SLOT_RULE.TIME_SLOT, TOC_RESERVE_TIME_SLOT_RULE.MAX_CAPACITY);
        return tocReserveTimeSlotRuleMapper.selectListByQueryAs(queryWrapper,TocReserveTimeVo.class);
    }

5.字段加减乘除写法

 public <R> Page<R> dietitianList(DietitianListRequest request, Class<R> asType) {
        QueryWrapper queryWrapper = QueryWrapper.create()
                .select(TOC_USER_INFO.ID,TOC_USER_INFO.NICK_NAME,TOC_USER_INFO.IMG_URL,TOC_USER_INFO.TAG,TOC_USER_INFO.GOOD_AT,TOC_USER_INFO.GOOD_AT_REMARK)
                .select(TOC_NUTRITIONIST_ORDER_NUM.CONSULT_ORDER_NUMBER)
                //计算好评率=好评数目/总订单数目
                .select(TOC_NUTRITIONIST_ORDER_NUM.GOOD_REPUTATION_NUMBER.divide(TOC_NUTRITIONIST_ORDER_NUM.CONSULT_ORDER_NUMBER).as("goodRate1"))
                .select(TOC_NUTRITIONIST_ORDER_NUM.GOOD_REPUTATION_NUMBER.multiply(TOC_NUTRITIONIST_ORDER_NUM.CONSULT_ORDER_NUMBER).as("goodRate2"))
                .select(TOC_NUTRITIONIST_ORDER_NUM.GOOD_REPUTATION_NUMBER.subtract(TOC_NUTRITIONIST_ORDER_NUM.CONSULT_ORDER_NUMBER).as("goodRate3"))
                .select(TOC_NUTRITIONIST_ORDER_NUM.GOOD_REPUTATION_NUMBER.add(TOC_NUTRITIONIST_ORDER_NUM.CONSULT_ORDER_NUMBER).as("goodRate4"))
                .from(TOC_USER_INFO)
                .leftJoin(TOC_NUTRITIONIST_ORDER_NUM).on(TOC_NUTRITIONIST_ORDER_NUM.USER_ID.eq(TOC_USER_INFO.ID));
        queryWrapper.where(TOC_USER_INFO.PLATFORM.eq(3));
        queryWrapper.where(TOC_USER_INFO.USER_TYPE.eq(UserTypeEnum.TOC_DOCTOR));
        PageDomain pageDomain = TableSupport.buildPageRequest();
        return tocUserInfoMapper.paginateAs(pageDomain.getPageNum(), pageDomain.getPageSize(), queryWrapper, asType);
    }

6. AND +(字段 or 字段写法)

  public <R> Page<R> dietitianList(DietitianListRequest request, Class<R> asType) {
        QueryWrapper queryWrapper = QueryWrapper.create()
                .select(TOC_USER_INFO.ID,TOC_USER_INFO.NICK_NAME,TOC_USER_INFO.IMG_URL,TOC_USER_INFO.TAG,TOC_USER_INFO.GOOD_AT,TOC_USER_INFO.GOOD_AT_REMARK)
                .select(TOC_NUTRITIONIST_ORDER_NUM.CONSULT_ORDER_NUMBER)
                //计算好评率=好评数目/总订单数目
                .select(TOC_NUTRITIONIST_ORDER_NUM.GOOD_REPUTATION_NUMBER.divide(TOC_NUTRITIONIST_ORDER_NUM.CONSULT_ORDER_NUMBER).as("goodRate"))
                .from(TOC_USER_INFO)
                .leftJoin(TOC_NUTRITIONIST_ORDER_NUM).on(TOC_NUTRITIONIST_ORDER_NUM.USER_ID.eq(TOC_USER_INFO.ID));
        queryWrapper.and(TOC_NUTRITIONIST_ORDER_NUM.GOOD_REPUTATION_NUMBER.eq(1).or(TOC_NUTRITIONIST_ORDER_NUM.GOOD_REPUTATION_NUMBER.gt(1)));

        
        PageDomain pageDomain = TableSupport.buildPageRequest();
        return tocUserInfoMapper.paginateAs(pageDomain.getPageNum(), pageDomain.getPageSize(), queryWrapper, asType);
    }

7.批量修改写法

  public int batchUntieGroup(List<Long> relationIds) {
        //每次执行1000条
        Db.executeBatch(relationIds, 1000, TocGroupPatientRelationsMapper.class
                , (mapper, relationId) -> {
                    //下面是具体的执行sql写法
                    UpdateChain.of(mapper)
                            .set(TocGroupPatientRelations::getGroupId, null)
                            .set(TocGroupPatientRelations::getGroupName, "")
                            .where(TocGroupPatientRelations::getRelationId).eq(relationId)
                            .update();
                });
        return Constants.SUCCESS_CODE;
    }

到此这篇关于mybatisFlex各种链式sql写法小结的文章就介绍到这了,更多相关mybatisFlex链式sql内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Java线程池并发执行多个任务方式

    Java线程池并发执行多个任务方式

    这篇文章主要介绍了Java线程池并发执行多个任务方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-08-08
  • Java如何自定义类数组的创建和初始化

    Java如何自定义类数组的创建和初始化

    这篇文章主要介绍了Java如何自定义类数组的创建和初始化,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-10-10
  • SpringMVC4.3 HandlerExceptionResolver异常处理源码解析

    SpringMVC4.3 HandlerExceptionResolver异常处理源码解析

    这篇文章主要为大家介绍了SpringMVC4.3 HandlerExceptionResolver异常处理源码解析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪<BR>
    2023-09-09
  • 如何创建SpringBoot项目

    如何创建SpringBoot项目

    这篇文章主要介绍了如何创建SpringBoot项目,帮助大家更好的学习和使用springboot框架,感兴趣的朋友可以了解下
    2021-01-01
  • Kafka生产者和消费者高级用法及说明

    Kafka生产者和消费者高级用法及说明

    Kafka生产者和消费者高级用法包括事务支持、多线程处理和自定义序列化与反序列化,事务支持确保消息的原子性,多线程处理提高高吞吐量场景下的效率,自定义序列化和反序列化则增强了灵活性,适用于复杂数据结构
    2025-11-11
  • Maven介绍与配置+IDEA集成Maven+使用Maven命令小结

    Maven介绍与配置+IDEA集成Maven+使用Maven命令小结

    Maven是Apache软件基金会的一个开源项目,是一个优秀的项目构建管理工具,它用来帮助开发者管理项目中的 jar,以及 jar 之间的依赖关系、完成项目的编译、测试、打包和发布等工作,本文给大家介绍Maven介绍与配置+IDEA集成Maven+使用Maven命令,感兴趣的朋友一起看看吧
    2024-01-01
  • java如何反编译jar包并修改class文件重新打包

    java如何反编译jar包并修改class文件重新打包

    这篇文章主要介绍了java如何反编译jar包并修改class文件重新打包,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-03-03
  • Java的函数式接口@FunctionalInterface的使用说明

    Java的函数式接口@FunctionalInterface的使用说明

    这篇文章主要介绍了Java的函数式接口@FunctionalInterface的使用说明,我们常用的一些接口Callable、Runnable、Comparator等在JDK8中都添加了@FunctionalInterface注解,需要的朋友可以参考下
    2024-01-01
  • java ArrayList按照同一属性进行分组

    java ArrayList按照同一属性进行分组

    这篇文章主要介绍了java ArrayList按照同一属性进行分组的相关资料,需要的朋友可以参考下
    2017-02-02
  • minio的原理、部署、操作方法(十分钟精通MinIO)

    minio的原理、部署、操作方法(十分钟精通MinIO)

    MinIO是一个简单易用的云存储服务,可以将文件上传到互联网上,方便在不同地方访问,部署MinIO需要拉取镜像、启动端口、设置账号密码和映射文件地址,在Spring Boot中集成MinIO,需要添加依赖、创建客户端并进行单元测试,感兴趣的朋友一起看看吧
    2025-02-02

最新评论