MyBatisPlus笔记

MyBatisPlus

快速入门

1.创建数据库mybatisplus

2.创建user表并插入数据

1. DROP TABLE IF EXISTS user;
2. CREATE TABLE user
3. (
4.     id BIGINT(20) NOT NULL COMMENT '主键ID',
5.     name VARCHAR(30) NULL DEFAULT NULL COMMENT '姓名',
6.     age INT(11) NULL DEFAULT NULL COMMENT '年龄',
7.     email VARCHAR(50) NULL DEFAULT NULL COMMENT '邮箱',
8.     PRIMARY KEY (id)
9. );
10. INSERT INTO user (id, name, age, email) VALUES
11. (1, 'Jone', 18, 'test1@baomidou.com'),
12. (2, 'Jack', 20, 'test2@baomidou.com'),
13. (3, 'Tom', 28, 'test3@baomidou.com'),
14. (4, 'Sandy', 21, 'test4@baomidou.com'),
15. (5, 'Billie', 24, 'test5@baomidou.com');
16. -- 真实开发中一般还需要version（乐观锁）、deleted（逻辑删除）、gmt_create、gmt_modified

复制代码

3.初始化SpringBoot项目

4.导入依赖

尽量不要同时导入mybatis和mybatisplus的依赖

1. <dependency>
2.     <groupId>mysql</groupId>
3.     <artifactId>mysql-connector-java</artifactId>
4. </dependency>
6. <dependency>
7.     <groupId>org.projectlombok</groupId>
8.     <artifactId>lombok</artifactId>
9. </dependency>
11. <dependency>
12.     <groupId>com.baomidou</groupId>
13.     <artifactId>mybatis-plus-boot-starter</artifactId>
14.     <version>3.0.5</version>
15. </dependency>

复制代码

5.连接数据库

application.properties

1. # mysql 5 驱动不同 com.mysql.jdbc.Driver
2. # mysql 8 驱动不同com.mysql.cj.jdbc.Driver、需要增加时区的配置serverTimezone=GMT%2B8
3. spring.datasource.username=root
4. spring.datasource.password=123456
5. spring.datasource.url=jdbc:mysql://localhost:3306/mybatis_plus? useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=GMT%2B8
6. spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

复制代码

6.传统方式pojo-dao（连接mybatis,配置mapper.xml文件）-service-controller
6.使用MyBatisPlus

• pojo
  

1. @Data
2. @NoArgsConstructor
3. @AllArgsConstructor
4. public class User {
5.     private Long id;
6.     private String name;
7.     private Integer age;
8.     private String email;
9. }

复制代码

• mapper接口
  

1. @Repository//持久层
2. public interface UserMapper extends BaseMapper<User> {
3. }

复制代码

• 测试类
  

首先在主类中配置mapper扫描@MapperScan("com.xust.mapper")

1. @SpringBootTest
2. class MybatisPlusApplicationTests {
4.     @Autowired
5.     private UserMapper userMapper;
7.     @Test
8.     void contextLoads() {
9.         //参数是一个Wrapper，条件构造器,这里先不用
10.         List<User> users=userMapper.selectList(null);
11.         users.forEach(System.out::println);
12.     }
13. }

复制代码

配置日志

在开发中使用，通过日志查看sql如何执行

applicatiohn.properties

1. mybatis-plus.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl

复制代码

CRUD扩展

插入

1. @SpringBootTest
2. class MybatisPlusApplicationTests {
3.         // 测试插入
4.     @Test
5.     public void testInsert() {
6.         User user = new User();
7.         user.setName("xust");
8.         user.setAge(3);
9.         user.setEmail("24736743@qq.com");
10.         int result = userMapper.insert(user); // 帮我们自动生成id
11.         System.out.println(result); // 受影响的行数
12.         System.out.println(user); // 发现，id会自动回填
13.     }
14. }

复制代码

更新

1. @SpringBootTest
2. class MybatisPlusApplicationTests {
4.     @Autowired
5.     private UserMapper userMapper;
7.     //测试更新
8.     @Test
9.     public void testUpdate(){
10.         User user = new User();
11.         user.setId(1L);
12.         user.setName("xxx");
13.         userMapper.updateById(user);
14.     }
15. }

复制代码

自动填充

创建时间、修改时间！这些个操作一遍都是自动化完成的，我们不希望手动更新
我这里使用的是SQLyog

数据库级别操作


代码级别操作

1.首先恢复清除数据库中默认值和更新效果
2.实体类字段属性上需要增加注解

1. @Data
2. @NoArgsConstructor
3. @AllArgsConstructor
4. public class User {
5.     @TableId(type = IdType.INPUT)      //一旦手动输入id后就需要自己配置id了
6.     private Long id;
7.     private String name;
8.     private Integer age;
9.     private String email;
11.     @TableField(fill= FieldFill.INSERT)     //插入时自动填充
12.     private Date createTime;
13.     @TableField(fill= FieldFill.INSERT_UPDATE)      //插入和更新时自动填充
14.     private Date updateTime;
15. }

复制代码

3.编写处理器来处理这个注解

1. @Slf4j
2. @Component  //将处理器加入到IOC容器中
3. public class MyMetaObjectHandler implements MetaObjectHandler {
4.     //插入时的填充策略
5.     @Override
6.     public void insertFill(MetaObject metaObject) {
7.         log.info("start insert fill...........");
8.         this.setFieldValByName("createTime",new Date(),metaObject);
9.         this.setFieldValByName("updateTime",new Date(),metaObject);
10.     }
12.     //更新时的填充策略
13.     @Override
14.     public void updateFill(MetaObject metaObject) {
15.         log.info("start update fill...........");
16.         this.setFieldValByName("updateTime",new Date(),metaObject);
17.     }
18. }

复制代码

乐观锁

意图：

当更新一条数据时，希望这条数据没有被其他人更新。

• 乐观锁：它总是认为不会出现问题，无论干什么不去上锁！如果出现了问题，再次更新值测试
  
• 悲观锁：它总是认为总是出现问题，无论干什么都会上锁！再去操作
  

乐观锁实现方式：

• 取出记录时，获取当前version
  
• 更新时带上version
  
• 执行更新时，set version=newVersion where version=oldVersion
  
• 如果version不对，就更新失败
  

1. 乐观锁：1、先查询，获得版本号 version = 1
2. -- A
3. update user set name = "kuangshen", version = version + 1
4. where id = 2 and version = 1
5. -- B 线程抢先完成，这个时候 version = 2，会导致 A 修改失败！
6. update user set name = "kuangshen", version = version + 1
7. where id = 2 and version = 1

复制代码

测试

1. 数据库添加version字段


2.实体类加对应字段

1. @Version //乐观锁Version注解
2. private Integer version;

复制代码

3.注册组件

1. @EnableTransactionManagement
2. @Configuration // 配置类
3. public class MyBatisPlusConfig { // 注册乐观锁插件
4.     @Bean
5.     public OptimisticLockerInterceptor optimisticLockerInterceptor() {
6.         return new OptimisticLockerInterceptor();
7.     }
8. }

复制代码

4.测试

1. @SpringBootTest
2. class MybatisPlusApplicationTests {
4.     @Autowired
5.     private UserMapper userMapper;
7.     //测试乐观锁成功
8.     @Test
9.     public void testOptimisticLocker(){
10.         //查询用户信息
11.         User user = userMapper.selectById(1L);
12.         //修改用户信息
13.         user.setName("yyy");
14.         user.setEmail("111@qq.com");
15.         //执行更新操作
16.         userMapper.updateById(user);
17.     }
19.     //测试乐观锁失败
20.     @Test
21.     public void testOptimisticLocker2(){
22.         //A
23.         User user = userMapper.selectById(1L);
24.         user.setName("yyy1");
25.         user.setEmail("123@qq.com");
27.         //B，模拟另外一个线程执行了插队操作
28.         User user2 = userMapper.selectById(1L);
29.         user2.setName("yyy2");
30.         user2.setEmail("222@qq.com");
32.         //B执行更新
33.         userMapper.updateById(user2);
34.         //A执行更新，如果没有乐观锁就会更新
35.         userMapper.updateById(user);
36.     }
37. }

复制代码

查询操作

1. @SpringBootTest
2. class MybatisPlusApplicationTests {
4.     @Autowired
5.     private UserMapper userMapper;
7.     // 测试查询
8.     @Test
9.     public void testSelectById() {
10.         User user = userMapper.selectById(1L);
11.         System.out.println(user);
12.     }
14.     // 测试批量查询！
15.     @Test
16.     public void testSelectByBatchId() {
17.         List<User> users = userMapper.selectBatchIds(Arrays.asList(1, 2, 3));
18.         users.forEach(System.out::println);
19.     }
21.     // 按条件查询之使用map操作
22.     @Test
23.     public void testSelectByBatchIds() {
24.         HashMap<String, Object> map = new HashMap<>();
25.         // 自定义要查询
26.         map.put("name", "ccc");
27.         map.put("age", 3);
28.         List<User> users = userMapper.selectByMap(map);
29.         users.forEach(System.out::println);
30.     }
31. }

复制代码

分页查询

1.配置拦截器组件

MyBatisPlusConfig.java

1. @Bean
2. public PaginationInterceptor paginationInterceptor() {
3.     return new PaginationInterceptor();
4. }

复制代码

2.直接使用Page对象

1. @SpringBootTest
2. class MybatisPlusApplicationTests {
4.     @Autowired
5.     private UserMapper userMapper;
7.     //测试分页查询
8.     @Test
9.     public void testPage(){
10.         //参数一：当前页
11.         //参数二：显示条数
12.         Page<User> page=new Page<>(1,3);
13.         userMapper.selectPage(page,null);
15.         //打印当前页
16.         page.getRecords().forEach(System.out::println);
17.         //打印总数
18.         System.out.println(page.getTotal());
19.     }
20. }

复制代码

删除操作

根据id删除

1. @SpringBootTest
2. class MybatisPlusApplicationTests {
4.     @Autowired
5.     private UserMapper userMapper;
7.     //测试删除
8.     @Test
9.     public void testDeleteById() {
10.         userMapper.deleteById(1579436224978829314L);
11.     }
13.     //批量删除
14.     @Test
15.     public void testDeleteBatchId() {
16.         userMapper.deleteBatchIds(Arrays.asList(1579459015811768322L, 1579459015811768324L));
17.     }
19.     //条件删除map操作
20.     @Test
21.     public void testDeleteMap() {
22.         HashMap<String, Object> map = new HashMap<>();
23.         map.put("name", "ccc");
24.         userMapper.deleteByMap(map);
25.     }
26. }

复制代码

逻辑删除

物理删除:从数据库中直接移除
逻辑删除:在数据库中没有直接移除，通过一个变量使其失效

1.在数据库表中增加一个deleted字段,为0表示没删


2.实体类中增加属性

1. @TableLogic //逻辑删除
2. private Integer deleted;

复制代码

3.配置

MyBatisPlusConfig.java

1. // 逻辑删除组件！
2. @Bean
3. public ISqlInjector sqlInjector() {
4.     return new LogicSqlInjector();
5. }

复制代码

application.properties

1. # 配置逻辑删除
2. mybatis-plus.global-config.db-config.logic-delete-value=1
3. mybatis-plus.global-config.db-config.logic-not-delete-value=0

复制代码

4.测试

执行之前的删除操作，实际上进行的是update操作

性能分析插件

平时开发时会遇到一些慢SQL
作用：性能分析拦截器，用于输出每条 SQL 语句及其执行时间
在测试和开发环境下使用

1.设置开发环境

application.properties

1. spring.profiles.active=dev

复制代码

2.导入插件

MyBatisPlusConfig.java

1. @Bean
2. @Profile({"dev","test"})    //设置在dev、test环境开启，保证效率
3. public PerformanceInterceptor performanceInterceptor(){
4.     PerformanceInterceptor performanceInterceptor=new PerformanceInterceptor();
5.     performanceInterceptor.setMaxTime(100);    //设置SQL执行的最大时间，超过则不执行
6.     performanceInterceptor.setFormat(true); //是否开启格式化，让SQL查看起来更方便
7.     return performanceInterceptor;
8. }

复制代码

条件构造器(Wrapper)

比较重要，写复杂的SQL可以用它来代替

[code]@SpringBootTestpublic class WrapperTest {    @Autowired    private UserMapper userMapper;    @Test    void contextLoads() {        //查询name不为空，email不为空，且年龄大于等于12的        QueryWrapper wrapper=new QueryWrapper();        wrapper.isNotNull("name")                .isNotNull("email")                .ge("age",12);        userMapper.selectList(wrapper);    }    @Test    void test2() {        //查询name为Tom的        QueryWrapper wrapper=new QueryWrapper();        wrapper.eq("name","Tom");        User user = userMapper.selectOne(wrapper);        System.out.println(user);    }    @Test    void test3() {        //查询年龄20~30的人        QueryWrapper wrapper=new QueryWrapper();        wrapper.between("age",20,30);        Integer count= userMapper.selectCount(wrapper);//查询结果数        System.out.println(count);    }    //模糊查询    @Test    void test4() {        //name中不包含o，且email以t开头        QueryWrapper wrapper=new QueryWrapper();        wrapper.notLike("name","o")                .likeRight("email","t");    //相当于t%        List maps= userMapper.selectMaps(wrapper);        maps.forEach(System.out::println);    }    @Test    void test5() {        QueryWrapper wrapper=new QueryWrapper();        //id在子查询中查出来        wrapper.inSql("id","select id from user where id