Mybatis-Plus使用（二）操作语法

Mybatis-Plus使用（二）操作语法

木子李 273 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

  • 测试使用

    • 执行任何一个方法
mybatis-plus