参考文档

dependencygroupIdcom.baomidou/groupIdartifactIdmybatis-plus-boot-starter/artifactIdversion3.5.3.1/version/dependencyMapper

public

userMapper.selectList(wrapper);//3.

遍历打印users.forEach(System.out::println);}Testvoid

user

User();user.setBalance(2000);//

wrapper

QueryWrapperUser().eq(username,jack);//

执行更新userMapper.update(user,wrapper);}Testvoid

ids

UpdateWrapperUser().setSql(balance

balance

200).in(id,ids);userMapper.update(null,wrapper);}

Testvoid

testLambdaQueryWrapper(){LambdaQueryWrapperUser

wrapper

LambdaQueryWrapperUser().select(User::getId,User::getUsername,User::getInfo,User::getBalance).like(User::getUsername,o).ge(User::getBalance,1000);ListUser

users

userMapper.selectList(wrapper);users.forEach(System.out::println);}自定义SQL

Service接口

我们的自定义接口UserService需要去继承IService接口我们的实现类UserServiceImpl也要继承他的实现类ServiceImpl

package

com.baomidou.mybatisplus.extension.service.IService;

import

com.i***ima.mp.domain.po.User;public

interface

com.i***ima.mp.service.impl;import

com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

import

com.i***ima.mp.mapper.UserMapper;

import

com.i***ima.mp.service.IUserService;

import

org.springframework.stereotype.Service;Service

public

org.springframework.beans.factory.annotation.Autowired;

import

org.springframework.boot.test.context.SpringBootTest;import

import

org.junit.jupiter.api.Assertions.*;SpringBootTest

class

user.setId(5L);user.setUsername(Lilei);user.setPassword(123);user.setPhone(18688990011);user.setBalance(200);user.setInfo({\age\:

24,

\female\});user.setCreateTime(LocalDateTime.now());user.setUpdateTime(LocalDateTime.now());userService.save(user);}Testvoid

testQuery(){ListUser

userService.listByIds(Arrays.asList(1L,

2L,

3L));users.forEach(System.out::println);}

}package

com.i***ima.mp.controller;import

import

com.i***ima.mp.domain.dto.UserFormDTO;

import

com.i***ima.mp.domain.query.UserQuery;

import

com.i***ima.mp.domain.vo.UserVO;

import

com.i***ima.mp.service.IUserService;

import

io.swagger.annotations.ApiOperation;

import

io.swagger.annotations.ApiParam;

import

lombok.RequiredArgsConstructor;

import

org.springframework.beans.factory.annotation.Autowired;

import

org.springframework.web.bind.annotation.*;import

用户管理接口)

final搭配lombok的RequiredArgsConstructor注解//

实现根据需要自动注入不需要注入的不加lombok注解就行了private

final

userService;ApiOperation(新增用户接口)PostMappingpublic

void

BeanUtil.copyProperties(userDto,

User.class);//

新增userService.save(user);}ApiOperation(删除用户接口)DeleteMapping({id})public

void

id){userService.removeById(id);}ApiOperation(根据id查询用户)GetMapping({id})public

UserVO

BeanUtil.copyProperties(user,UserVO.class);}ApiOperation(根据id批量查询用户)GetMappingpublic

ListUserVO

userService.listByIds(ids);return

BeanUtil.copyToList(users,UserVO.class);}ApiOperation(扣减用户余额接口)DeleteMapping({id}/deduction/{money})public

void

money){userService.deductBalance(id,

money);}

ApiOperation(根据复杂条件查询用户)GetMapping(/list)public

ListUserVO

userService.queryUsers(query.getName(),query.getStatus(),query.getMinBalance(),query.getMaxBalance());//

把PO拷贝到VOreturn

maxBalance).list();}OverrideTransactionalpublic

void

我们继承了ServiceImpl爸爸的就是我的已经有UserService了不用注入this一下看看哦//

校验用户状态if(usernull

baseMapper.deductBalance(id,money);int

remainBalance

money;lambdaUpdate().set(User::getBalance,remainBalance).set(remainBalance

0,User::getStatus,0).eq(User::getId,id).eq(User::getBalance,user.getBalance())

乐观锁.update();

ApiOperation(根据id查询用户)GetMapping({id})public

UserVO

BeanUtil.copyProperties(user,UserVO.class);return

userService.queryUserAndAddressById(id);}实现方法

Overridepublic

Db.lambdaQuery(Address.class).eq(Address::getUserId,

id).list();//

转地址VOif(CollUtil.isNotEmpty(addresses)){userVO.setAddresses(BeanUtil.copyToList(addresses,

controller层

ApiOperation(根据id批量查询用户)GetMappingpublic

ListUserVO

BeanUtil.copyToList(users,UserVO.class);return

userService.queryUserAndAddressByIds(ids);}实现

Overridepublic

queryUserAndAddressByIds(ListLong

ids)

listByIds(ids);if(CollUtil.isEmpty(users)){return

2.查询地址//

users.stream().map(User::getId).collect(Collectors.toList());//

2.2

Db.lambdaQuery(Address.class).in(Address::getUserId,

userIds).list();//

用户地址集合分组处理相同的用户放入一个集合组中MapLong,

ListAddressVO

HashMap(0);if(CollUtil.isNotEmpty(addressVOList)){addressMap

addressVOList.stream().collect(Collectors.groupingBy(AddressVO::getUserId));}//

list

转换地址VOvo.setAddresses(addressMap.get(user.getId()));list.add(vo);}return

list;}逻辑删除

com.baomidou.mybatisplus.annotation.EnumValue;

import

com.fasterxml.jackson.annotation.JsonValue;

import

{NORML(1,正常),FROZEN(2,冻结),;EnumValueprivate

final

前端默认返回枚举项的名字不友好设置返回desc由spring控制private

final

com.i***ima.mp.domain.po;import

import

com.i***ima.mp.domain.po;import

com.baomidou.mybatisplus.annotation.IdType;

import

com.baomidou.mybatisplus.annotation.TableField;

import

com.baomidou.mybatisplus.annotation.TableId;

import

com.baomidou.mybatisplus.annotation.TableName;

import

com.baomidou.mybatisplus.extension.handlers.JacksonTypeHandler;

import

com.i***ima.mp.enums.UserStatus;

import

JacksonTypeHandler.class)private

UserInfo

com.i***ima.mp.domain.vo;import

com.i***ima.mp.domain.po.UserInfo;

import

com.i***ima.mp.enums.UserStatus;

import

io.swagger.annotations.ApiModel;

import

io.swagger.annotations.ApiModelProperty;

import

id;ApiModelProperty(用户名)private

String

username;ApiModelProperty(详细信息)private

UserInfo

status;ApiModelProperty(账户余额)private

Integer

balance;ApiModelProperty(用户的收货地址)private

ListAddressVO

com.baomidou.mybatisplus.annotation.DbType;

import

com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;

import

com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;

import

org.springframework.context.annotation.Bean;

import

org.springframework.context.annotation.Configuration;Configuration

public

mybatisPlusInterceptor(){MybatisPlusInterceptor

interceptor

MybatisPlusInterceptor();//创建分页插件PaginationInnerInterceptor

new

PaginationInnerInterceptor(DbType.MYSQL);paginationInnerInterceptor.setMaxLimit(1000L);//

添加分页插件interceptor.addInnerInterceptor(paginationInnerInterceptor);return

interceptor;}}

p.getRecords();records.forEach(System.out::println);}通用分页实体

package

com.i***ima.mp.domain.query;import

io.swagger.annotations.ApiModel;

import

io.swagger.annotations.ApiModelProperty;

import

pageNo;ApiModelProperty(页码)private

Long

pageSize;ApiModelProperty(排序字段)private

String

sortBy;ApiModelProperty(是否升序)private

Boolean

com.i***ima.mp.domain.query;import

io.swagger.annotations.ApiModel;

import

io.swagger.annotations.ApiModelProperty;

import

lombok.EqualsAndHashCode;EqualsAndHashCode(callSuper

true)

PageQuery{ApiModelProperty(用户名关键字)private

String

name;ApiModelProperty(用户状态1-正常2-冻结)private

Integer

status;ApiModelProperty(余额最小值)private

Integer

minBalance;ApiModelProperty(余额最大值)private

Integer

ApiOperation(根据分页查询用户接口)GetMapping(/page)public

PageDtoUserVO

userService.queryUsersPage(query);}service层

Overridepublic

排序条件if(StrUtil.isNotBlank(query.getSortBy())){//

不为空page.addOrder(new

OrderItem(query.getSortBy(),query.getIsAsc()));}else{//

OrderItem(update_time,false));}//

分页查询PageUser

User::getStatus,status).page(page);//

封装VO结果PageDtoUserVO

总条数dto.setTotal(p.getTotal());//

3.2

总页数dto.setPages(p.getPages());//

3.3

p.getRecords();if(CollUtil.isEmpty(records)){dto.setList(Collections.emptyList());return

dto;}//

UserVO.class);dto.setList(vos);//

4返回return

com.i***ima.mp.domain.query;import

import

com.baomidou.mybatisplus.core.metadata.OrderItem;

import

com.baomidou.mybatisplus.extension.plugins.pagination.Page;

import

io.swagger.annotations.ApiModel;

import

io.swagger.annotations.ApiModelProperty;

import

5;ApiModelProperty(排序字段)private

String

sortBy;ApiModelProperty(是否升序)private

Boolean

排序条件if(StrUtil.isNotBlank(sortBy)){//

不为空page.addOrder(new

为空默认排序page.addOrder(items);}return

page;}public

OrderItem(defaultSortBy,defaultAsc));}public

PageT

toMpPageDefaultSortByCreateTime(){return

toMpPage(new

OrderItem(create_time,false));}public

PageT

toMpPageDefaultSortByUpdateTime(){return

toMpPage(new

OrderItem(update_time,false));}}package

com.i***ima.mp.domain.dto;import

import

cn.hutool.core.collection.CollUtil;

import

com.baomidou.mybatisplus.extension.plugins.pagination.Page;

import

io.swagger.annotations.ApiModel;

import

io.swagger.annotations.ApiModelProperty;

import

java.util.stream.Collectors;Data

ApiModel(description

total;ApiModelProperty(总页数)private

Long

pages;ApiModelProperty(集合)private

ListT

总条数dto.setTotal(p.getTotal());//

3.2

总页数dto.setPages(p.getPages());//

3.3

p.getRecords();if(CollUtil.isEmpty(records)){dto.setList(Collections.emptyList());return

dto;}//

拷贝user的VOdto.setList(records.stream().map(convertor).collect(Collectors.toList()));//

4返回return

query.toMpPageDefaultSortByUpdateTime();//

分页查询PageUser

User::getStatus,status).page(page);//

dto

处理特殊逻辑vo.setUsername(vo.getUsername().substring(0,

**);return