SpringCloud——MybatisPlus

一、快速入门

1.引入相干依赖

2.界说Mapper接口并继承BaseMapper

 二、常见注解

1.MyBatisPlus通过扫描实体类，并基于反射获取实体类信息作为数据库表信息

2.@TableName:用来指定表名

3.@TableId:用来指定表中的关键字段信息

4.@TableField:用来指定表中的平凡字段信息

    

三、常见设置

四、条件构造器

注意：
1.QueryWrapper和LambdaQueryWrapper通常用来构建select、delete、update的where条件部分
2.UpdateWrapper和LambdaUpdateWrapper通常只有在set语句比较特殊才使用
3.尽量使用LambdaQueryWrapper和LambdaUpdateWrapper，制止硬编码
五、自界说SQL

利用MyBatisPlus的Wrapper来构建复杂的where条件，然后本身界说SQL语句中剩下的部分
1.基于Wrapper构建where条件

2.在mapper方法参数用Param注解声明Wrapper变量名称，必须是ew

3.自界说SQL，并实用Wrapper条件

 六、IService接口

1、继承实现结构

2、Lambda

查询相干操作：

1. @Override
2.     public  List<User> complexSearch(String name, Integer status, Integer minBalance, Integer maxBalance) {
3.        return lambdaQuery().like(name != null, User::getUsername, name)
4.                 .eq(status != null, User::getStatus, status)
5.                 .ge(minBalance != null, User::getBalance, minBalance)
6.                 .le(maxBalance != null, User::getBalance, maxBalance).list();
8.     }

复制代码

更新相干操作：

1. @Override
2.     public void minusMoneyById(Long id, Long money) {
3.         //通过id查找用户
4.         User userById = this.getById(id);
5.         if (userById == null) {
6.             throw new RuntimeException("扣减失败，用户不存在");
7.         }
8.         //判断用户状态
9.         if (userById.getStatus() == 2) {
10.             throw new RuntimeException("扣减失败，用户被冻结");
11.         }
12.         //判断账户余额
13.         if (userById.getBalance() == 0 || userById.getBalance() < money) {
14.             throw new RuntimeException("扣减失败，余额不足");
15.         }
16.         long updateBalance = userById.getBalance() - money;
17.         //baseMapper.minusMoneyById(id, money);
18.         lambdaUpdate().set(User::getBalance, updateBalance).set(updateBalance==0,User::getStatus,2).eq(User::getId,id).update();
19.     }

复制代码

批量新增相干操作：
开启rewriteBatchedStatements=true

1. spring:
2.   datasource:
3.     url: jdbc:mysql://127.0.0.1:3306/mp?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai&rewriteBatchedStatements=true

复制代码

3、静态工具

相干依赖：

1.         <dependency>
2.             <groupId>com.baomidou</groupId>
3.             <artifactId>mybatis-plus-boot-starter</artifactId>
4.             <version>3.5.6</version>
5.         </dependency>

复制代码

相干代码：

1. @Override
2.     public UserVO selectUserAndAddress(Long id) {
3.         //根据id查询用户
4.         UserVO userVO = new UserVO();
5.         User selectUserById = this.lambdaQuery().eq(User::getId, id).one();
6.         if (selectUserById == null||selectUserById.getStatus() == 2) {
7.             throw new RuntimeException("用户状态异常");
8.         }
9.         BeanUtils.copyProperties(selectUserById, userVO);
10.         //根据用户id查询地址
11.         List<Address> adressList = Db.lambdaQuery(Address.class).eq(Address::getUserId, id).list();
12.         if (adressList != null && adressList.size() > 0) {
13.             ArrayList<AddressVO> addressVOS = new ArrayList<>();
14.             for (Address address : adressList) {
15.                 AddressVO addressVO = new AddressVO();
16.                 BeanUtils.copyProperties(address, addressVO);
17.                 addressVOS.add(addressVO);
18.             }
19.             userVO.setAddresses(addressVOS);
20.         }
22.         return userVO;
23.     }

复制代码

4、逻辑删除

逻辑删除就是基于代码逻辑模拟删除效果，但并不会真正删除数据

缺点：使用逻辑删除后，会导致数据库表垃圾数据越来越多，SQL中全都需要对逻辑删除字段做判断，影响查询效率
5、枚举处置惩罚器

mybatisPlus提供了一个处置惩罚枚举的类型转换器，可以帮我们把枚举类型与数据库类型自动转换。
界说枚举：

1. package com.itheima.mp.enums;
3. import com.baomidou.mybatisplus.annotation.EnumValue;
4. import com.fasterxml.jackson.annotation.JsonValue;
6. public enum UserStatus {
7.     Normal(1,"正常"),
8.     FROZON(2,"冻结"),
9.     ;
10.     @EnumValue
11.     private final int value;
12.     @JsonValue
13.     private final String desc;
15.     UserStatus(int value, String desc) {
16.         this.value = value;
17.         this.desc = desc;
18.     }
19. }

复制代码

设置枚举处置惩罚器：

1. mybatis-plus:
2.   configuration:
3.     default-enum-type-handler: com.baomidou.mybatisplus.core.handlers.MybatisEnumTypeHandler

复制代码

6、Json处置惩罚器

将数据库中字符串的数据转换为实体对象
界说实体类：

1. package com.itheima.mp.domain.po;
3. import lombok.Data;
5. @Data
6. public class UserInfo {
7.     private Integer age;
8.     private String intro;
9.     private String gender;
10. }

复制代码

使用处置惩罚器：

1. package com.itheima.mp.domain.po;
3. import com.baomidou.mybatisplus.annotation.*;
4. import com.baomidou.mybatisplus.extension.handlers.JacksonTypeHandler;
5. import com.itheima.mp.enums.UserStatus;
6. import lombok.Data;
8. import java.time.LocalDateTime;
10. @Data
11. // @TableName(value = "myuser")
12. @TableName( autoResultMap = true)
13. public class User {
15.     /**
16.      * 用户id
17.      */
18.     @TableId(type = IdType.AUTO)
19.     private Long id;
21.     /**
22.      * 用户名
23.      */
24.     private String username;
26.     /**
27.      * 密码
28.      */
29.     private String password;
31.     /**
32.      * 注册手机号
33.      */
34.     private String phone;
36.     /**
37.      * 详细信息
38.      */
39.     //private String info;
40.     @TableField(typeHandler = JacksonTypeHandler.class)
41.     private UserInfo info;
43.     /**
44.      * 使用状态（1正常 2冻结）
45.      */
46.     //@TableField(value = "status")
47.     private UserStatus status;
49.     /**
50.      * 账户余额
51.      */
52.     //@TableField(exist = false)
53.     private Integer balance;
55.     /**
56.      * 创建时间
57.      */
58.     private LocalDateTime createTime;
60.     /**
61.      * 更新时间
62.      */
63.     private LocalDateTime updateTime;
64. }

复制代码

7、分页插件

设置插件：

1. package com.itheima.mp.domain.config;
3. import com.baomidou.mybatisplus.annotation.DbType;
4. import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
5. import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
6. import org.springframework.context.annotation.Bean;
7. import org.springframework.context.annotation.Configuration;
9. @Configuration
10. public class MybatisConfig {
12.     @Bean
13.     public MybatisPlusInterceptor mybatisPlusInterceptor(){
14.         // 初始化核心插件
15.         MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
16.         // 添加分页插件
17.         interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
18.         return interceptor;
19.     }
21. }

复制代码

分页API：

1. @Test
2.     void testPage(){
3.         Page<User> myPage = Page.of(3, 2);
4.         Page<User> pageFromDatabase = userServiceImpl.page(myPage);
5.         for (User user : pageFromDatabase.getRecords()) {
6.             System.out.println(user);
7.         }
8.     }

复制代码

分页参数实体：

1. package com.itheima.mp.domain.query;
4. import cn.hutool.core.util.StrUtil;
5. import com.baomidou.mybatisplus.core.metadata.OrderItem;
6. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
7. import io.swagger.annotations.ApiModel;
8. import io.swagger.annotations.ApiModelProperty;
9. import lombok.Data;
11. @Data
12. @ApiModel(description = "分页查询相关实体")
13. public class PageQuery {
14.     @ApiModelProperty("页码")
15.     private Integer pageNo=1;
16.     @ApiModelProperty("页码")
17.     private Integer pageSize=5;
18.     @ApiModelProperty("牌序字段")
19.     private String sortBy;
20.     @ApiModelProperty("是否升序")
21.     private Boolean isAsc;
23.     public <T> Page<T> toMpPage(OrderItem ... orderItems) {
24.         //分页条件
25.         Page<T> page = Page.of(pageNo, pageSize);
27.         //排序依靠、排序方式
28.         //排序字段不为空
29.         if  (StrUtil.isNotBlank(sortBy)) {
30.             page.addOrder(new OrderItem().setColumn(sortBy).setAsc(isAsc));
31.         }else {
32.             page.addOrder(orderItems);
33.         }
34.         return page;
35.     }
37.     public <T> Page<T> toMpPageDefaultOrderByCreateTime(){
38.         return toMpPage(new OrderItem().setColumn("create_time").setAsc(false));
39.     }
41.     public <T> Page<T> toMpPageDefaultOrderByUpdateTime(){
42.         return toMpPage(new OrderItem().setColumn("update_time").setAsc(false));
43.     }
45.     public <T> Page<T> toMpPage(String sortBy, Boolean isAsc) {
46.         return toMpPage(new OrderItem().setColumn(sortBy).setAsc(isAsc));
47.     }
48. }

复制代码

实体类继承分页参数实体：

1. package com.itheima.mp.domain.query;
3. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
4. import io.swagger.annotations.ApiModel;
5. import io.swagger.annotations.ApiModelProperty;
6. import lombok.Data;
8. @Data
9. @ApiModel(description = "用户查询条件实体")
10. public class UserQuery extends PageQuery {
11.     @ApiModelProperty("用户名关键字")
12.     private String name;
13.     @ApiModelProperty("用户状态：1-正常，2-冻结")
14.     private Integer status;
15.     @ApiModelProperty("余额最小值")
16.     private Integer minBalance;
17.     @ApiModelProperty("余额最大值")
18.     private Integer maxBalance;
21. }

复制代码

同一响应返回实体：

1. package com.itheima.mp.domain.dto;
3. import cn.hutool.core.bean.BeanUtil;
4. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
5. import lombok.AllArgsConstructor;
6. import lombok.Data;
7. import lombok.NoArgsConstructor;
9. import java.util.Collections;
10. import java.util.List;
11. import java.util.function.Function;
12. import java.util.stream.Collectors;
14. @Data
15. @NoArgsConstructor
16. @AllArgsConstructor
17. public class PageDTO<V> {
18.     private Long total;
19.     private Long pages;
20.     private List<V> list;
22.     /**
23.      * 返回空分页结果
24.      * @param p MybatisPlus的分页结果
25.      * @param <V> 目标VO类型
26.      * @param <P> 原始PO类型
27.      * @return VO的分页对象
28.      */
29.     public static <V, P> PageDTO<V> empty(Page<P> p){
30.         return new PageDTO<>(p.getTotal(), p.getPages(), Collections.emptyList());
31.     }
33.     /**
34.      * 将MybatisPlus分页结果转为 VO分页结果
35.      * @param p MybatisPlus的分页结果
36.      * @param voClass 目标VO类型的字节码
37.      * @param <V> 目标VO类型
38.      * @param <P> 原始PO类型
39.      * @return VO的分页对象
40.      */
41.     public static <V, P> PageDTO<V> of(Page<P> p, Class<V> voClass) {
42.         // 1.非空校验
43.         List<P> records = p.getRecords();
44.         if (records == null || records.size() <= 0) {
45.             // 无数据，返回空结果
46.             return empty(p);
47.         }
48.         // 2.数据转换
49.         List<V> vos = BeanUtil.copyToList(records, voClass);
50.         // 3.封装返回
51.         return new PageDTO<>(p.getTotal(), p.getPages(), vos);
52.     }
54.     /**
55.      * 将MybatisPlus分页结果转为 VO分页结果，允许用户自定义PO到VO的转换方式
56.      * @param p MybatisPlus的分页结果
57.      * @param convertor PO到VO的转换函数
58.      * @param <V> 目标VO类型
59.      * @param <P> 原始PO类型
60.      * @return VO的分页对象
61.      */
62.     public static <V, P> PageDTO<V> of(Page<P> p, Function<P, V> convertor) {
63.         // 1.非空校验
64.         List<P> records = p.getRecords();
65.         if (records == null || records.size() <= 0) {
66.             // 无数据，返回空结果
67.             return empty(p);
68.         }
69.         // 2.数据转换
70.         List<V> vos = records.stream().map(convertor).collect(Collectors.toList());
71.         // 3.封装返回
72.         return new PageDTO<>(p.getTotal(), p.getPages(), vos);
73.     }
74. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。