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;}
备注:其他的写法都比较简单,如果有不会的写法,欢迎留言,我每天会看一遍,我会抽取部分复杂的写法补充进来