mybatisFlex各种链式sql写法小结
作者:小吴先生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内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
