Mybatis-Plus使用(二)操作语法

Mybatis-Plus使用(二)操作语法

木子李 237 2021-11-24

1. 插入测试及雪花算法

CRUD扩展

Insert插入

@Test
void testInsert(){
    User user = new User();
    user.setName("levnli").setAge(23).setEmail("levnliservice@126.com");
    // 自动生成id
    int result = userMapper.insert(user);
    // 受影响的行数
    System.out.println(result);
    // 发现 id 会自动回填
    System.out.println(user);
}

数据库插入的id的默认值为:全局唯一的

主键生成策略:雪花算法

  • id自增策略是:ID_WORKER

  • snowflake是Twitter开源的分布式ID生成算法,结果是一个long型的ID,其核心思想是:使用41bit作为毫秒数,10bit作为机器的ID(5个bit是数据中心,5个bit的机器ID),12bit作为毫秒内的流水号(意味着每个节点在每毫秒可以产生4096个ID),最后还有一个符号位,永远是0。可以保证几乎全球唯一

2. 不同主键策略测试

/**
 * 数据库ID自增
 */
AUTO(0),
/**
 * 该类型为未设置主键类型
 */
NONE(1),
/**
 * 用户输入ID
 * 该类型可以通过自己注册自动填充插件进行填充
 */
INPUT(2),

/* 以下3种类型、只有当插入对象ID 为空,才自动填充。 */
/**
 * 全局唯一ID (idWorker)
 */
ID_WORKER(3),
/**
 * 全局唯一ID (UUID)
 */
UUID(4),
/**
 * 字符串全局唯一ID (idWorker 的字符串表示)
 */
ID_WORKER_STR(5);
  • 如果想选用策略为:AUTO
    • 实体类字段上添加@TableId(type = IdType.AUTO)
    • 数据库字段一定要是自增!
  • 再次测试插入

3. 更新操作

@Test
void testUpdate(){
    User user = new User().setId(1336837066142076930L).setName("test");
    int i = userMapper.updateById(user);
    System.out.println(i);
}
  • 所有的sql都是自动拼接,动态配置的

自动装填

  • 创建时间、修改时间!这些操作都是自动化完成的,不希望手动更新
  • 所有的数据库表:gmt_create、gmt_modified,几乎所以的表都要配置上,而且需要自动填充

4. 自动填充处理

方式一:数据库级别(工作中不允许修改数据库)

  • 在表中新增字段create_time,update_time

    ALTER TABLE `mybatis_plus`.`user` 
    ADD COLUMN `create_time` datetime NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间' AFTER `email`,
    ADD COLUMN `update_time` datetime NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间' AFTER `create_time`;
    
  • 再次测试插入方法,先把实体类同步

    • private Date createTime;
      private Date updateTime;
      
  • 再次更新查看即可

方式二:代码级别

  • 删除数据库的默认值、更新操作!

    • 去掉时间配置
    • ALTER TABLE mybatis_plus.user
      MODIFY COLUMN create_time datetime(0) NULL COMMENT '创建时间' AFTER email,
      MODIFY COLUMN update_time datetime(0) NOT NULL COMMENT '更新时间' AFTER create_time;
  • 实体类的字段属性上需要增加注解

    • // 字段添加填充内容
      @TableField(fill = FieldFill.INSERT)
      private Date createTime;
      @TableField(fill = FieldFill.INSERT_UPDATE)
      private Date updateTime;
      
  • 编写处理器,来处理这个注解即可

    @Slf4j
    @Component
    public class MyMetaObjectHandler implements MetaObjectHandler {
    
        /**
         * 插入时的填充策略
         * @param metaObject
         */
        @Override
        public void insertFill(MetaObject metaObject) {
            log.info("start insert fill....");
            this.setFieldValByName("createTime",new Date(),metaObject);
            this.setFieldValByName("updateTime",new Date(),metaObject);
        }
    
        /**
         * 更新时的填充策略
         * @param metaObject
         */
        @Override
        public void updateFill(MetaObject metaObject) {
            log.info("start updateTime fill....");
            this.setFieldValByName("updateTime",new Date(),metaObject);
        }
    }
    
  • 测试插入、更新

    • 观察时间即可

5. 乐观锁处理详解

  • 在面试过程中,经常被问到乐观锁、悲观锁

  • 乐观锁

    • 十分乐观,不会认为出现问题
    • 无论干什么都不会上锁
    • 如果出现了问题,再次更新值测试
    • version、new version
  • 悲观锁

    • 十分悲观,总是认为都会出现问题
    • 无论干什么都会上锁!再去操作
  • 主要讲解乐观锁机制

  • 乐观锁实现方式:

    • 取出记录时,获取当前version
    • 更新时,带上这个version
    • 执行更新时, set version = newVersion where version = oldVersion
    • 如果version不对,就更新失败
    乐观锁:先查询,获得版本号version = 1
    -- A线程
    update user set name = "test" , version = version + 1
    where id = 2 and version = 1
    
    -- B线程
    update user set name = "test" , version = version + 1
    where id = 2 and version = 1
    结果B线程抢先完成,这时候version = 2,导致A线程修改失败
    

测试一下MP的乐观锁插件

  • 给数据库中添加version字段

    • ALTER TABLE mybatis_plus.user
      MODIFY COLUMN version int(10) NULL DEFAULT 1 COMMENT '乐观锁' AFTER update_time
      ADD COLUMN version int(10) NULL COMMENT '乐观锁' AFTER update_time;
  • 实体类添加对应的字段

    • /**
       * 乐观锁version注解
       */
      @Version
      private Integer version;
      
  • 注册组件

    @EnableTransactionManagement
    @MapperScan("com.example.mapper")
    @Configuration
    public class MyBatisPlusConfig {
    
        // 注册乐观锁插件
        @Bean
        public OptimisticLockerInterceptor optimisticLockerInterceptor() {
            return new OptimisticLockerInterceptor();
        }
    
    }
    
  • 测试一下

    @Test
    void testOptimisticLocker(){
        // 查询用户信息
        User user = userMapper.selectById(6L);
        // 修改用户信息
        user.setEmail("123@qq.com");
        // 执行更新
        userMapper.updateById(user);
    }
    
    @Test
    void testOptimisticLockerThread(){
        // 模拟乐观锁,多线程并发
        // 线程1
        User user = userMapper.selectById(6L);
        user.setEmail("111@qq.com");
    
        // 线程2,抢先提交
        User user2 = userMapper.selectById(6L);
        user2.setEmail("222@qq.com");
        userMapper.updateById(user2);
    
        userMapper.updateById(user);
    }
    

6. 查询操作

  • 批量查询和条件查询
/**
 * 测试批量查询
 */
@Test
void testSelectByIds(){
    List<User> users = userMapper.selectBatchIds(Arrays.asList(1,2,3));
    users.forEach(System.out::println);
}

/**
 * 条件查询之一使用 map
 */
@Test
void selectByMap(){
    HashMap<String, Object> map = new HashMap<>();
    map.put("name","levnli");
    List<User> users = userMapper.selectByMap(map);
    users.forEach(System.out::println);
}

7. 分页查询实现

  • 分页查询在网站使用十分之多!
    • 原始的limit进行分页
    • pageHelper第三方插件
    • MP其实也内置了分页插件

如何使用

  • 配置拦截器组件即可

    • // 分页插件
      @Bean
      public PaginationInterceptor paginationInterceptor() {
          return new PaginationInterceptor();
      }
      
  • 直接使用Page对象即可

    • @Test
      void testPage(){
          // 参数:当前页、页面大小
          Page<User> page = new Page<>(2,5);
          userMapper.selectPage(page,null);
      
          // 打印查询结果
          page.getRecords().forEach(System.out::println);
          // 当前表总共条数
          System.out.println(page.getTotal());
      }
      

8. 删除操作

  • 根据ID删除记录

    /**
     * 通过ID删除
     */
    @Test
    void testDeleteById(){
        userMapper.deleteById(1336837066142076931L);
    }
    
  • 根据ID批量删除

    /**
     * 通过ID批量删除
     */
    @Test
    void testDeleteBatchIds(){
        userMapper.deleteBatchIds(Arrays.asList(1336837066142076931L));
    }
    
  • 根据条件删除

    /**
     * 通过条件删除
     */
    @Test
    void testDeleteMap(){
        HashMap<String, Object> map = new HashMap<>();
        map.put("name","test2");
        userMapper.deleteByMap(map);
    }
    

9. 逻辑删除

  • 物理删除:从数据库中直接移除
  • 逻辑删除:在数据库中没有被移除,而是通过一个变量来让他失效!
    • deleted = 0 -> deleted = 1
  • 管理员可以查看被删除的记录!防止数据的丢失,类似于回收站

测试一下:

  • 在数据报中增加一个deleted字段

    ALTER TABLE `mybatis_plus`.`user` 
    ADD COLUMN `deleted` int(1) NULL DEFAULT 0 COMMENT '删除标志位' AFTER `version`;
    
  • 在实体类上添加字段

    /**
     * 逻辑删除
     */
    @TableLogic
    private Integer deleted;
    
  • 添加插件

    // 逻辑删除插件
    @Bean
    public ISqlInjector sqlInjector() {
        return new LogicSqlInjector();
    }
    
  • 配置逻辑删除

    mybatis-plus:
      global-config:
        db-config:
          logic-delete-value: 1
          logic-not-delete-value: 0
    

10. 性能分析插件

开发中,会遇到慢sql

MP也提供性能分析插件,如果超过这个时间就是停止运行

  • 导入插件

    // SQL执行效率插件
    @Bean
    @Profile("dev")
    public PerformanceInterceptor performanceInterceptor(){
        PerformanceInterceptor performanceInterceptor = new PerformanceInterceptor();
        // sql最大执行时间,超过不执行
        performanceInterceptor.setMaxTime(100);
        // 输出sql格式化
        performanceInterceptor.setFormat(true);
        return performanceInterceptor;
    }
    
  • 修改application.yml

    spring:
      profiles:
        active: dev
    
  • 测试使用

    • 执行任何一个方法