mybatisFlex各种链式sql写法小结

目录

• 1.关联LEFT JOIN
• 2.FIND_IN_SET+LEFT JOIN+AND (OR)写法
• 3.修改部分字段写法
• 4.sum+case_().when().then().else_().end()写法
• 4.count+case_().when().then().else_().end()写法
• 5.字段加减乘除写法
• 6. AND +(字段 or 字段写法)
• 7.批量修改写法

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));
        querypythonWrapper.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())
python                .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(D编程客栈ietitianListRequest 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<http://www.devze.comLong> relationIds) {
        //每次执行1000条
        Db.executeBatch(relationIds, 1000, TocGroupPatientRelationsMapper.class
                , (mapper, relationId) -> {
                    //下面是具体的执行sql写法
                    Update编程客栈Chain.of(mapper)
                            .set(TocGroupPatientRelations::getGroupId, null)
                            .set(TocGroupPatientRelations::getGroupName, "")
                            .where(TocGroupPatientRelations::getRelationId).eq(relationId)
                            .update();
                });
        return Constants.SUCCESS_CODE;
    }

到此这篇关于mybatisFlex各种链式sql写法小结的文章就介绍到这了,更多相关mybatisFlex链式sql内容请搜索编程客栈(www.devze.com)以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程客栈(www.devze.com)！