三十六、MyBatis-Plus（2）

🌻🌻 目录

• 一、CRUD 扩展（1)
• • 1.1 Insert
  • 1.2 主键生成策略
  • • 1.2.1 源码解释
    • 1.2.2 Twitter的snowflake算法 (雪花算法)
    • 1.2.3 主键自增：AUTO 我们需要配置主键自增
    • 1.2.4 手动输入：INPUT 就需要自己写 id
  • 1.3 Update
  • 1.4 自动填充
  • • 1.4.1 方式一：数据库级别
    • 1.4.2 方式二：代码级别
• 二、 乐观锁&悲观锁

一、CRUD 扩展（1)

1.1 Insert

/* * 增加 * */ @Test //测试插入 public void insertUser(){      User user = new User();      user.setName("xieMax");     user.setAge(22);     user.setEmail("wmsspark@163.com");      int result = userMapper.insert(user);//会帮我们自动生成id      System.out.println(result);//受影响的行数      System.out.println(user);//通过日志发现id会自动回填  } 

运行如下所示：

刷新数据库可以看到成功增加了一条数据：

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

1.2 主键生成策略

1.2.1 源码解释

• (1) 首先看数据库id不是自增的

• (2) 在实体User中增加注解 @TableId(type = IdType.) 点进去细看

public enum IdType {     AUTO, //数据库id自增     INPUT, //手动输入     ID_WORKER, //默认的全局唯一id     UUID, //全局唯一id  uuid     NONE;//未设置主键     ** } 

默认 : ID_WORKER 全局唯一Id

看我高级文章 分布式系统唯一Id生成汇总

1.2.2 Twitter的snowflake算法 (雪花算法)

snowflake是Twitter开源的分布式ID生成算法，结果是一个long型的ID。其核心思想是：使用41bit作为毫秒数，10bit作为机器的ID（5个bit是数据中心（北京、香港···），5个bit的机器ID），12bit作为毫秒内的流水号（意味着每个节点在每毫秒可以产生 4096 个 ID），最后还有一个符号位，永远是0。

具体实现的代码可以参看 https://github.com/twitter/snowflake。

1.2.3 主键自增：AUTO 我们需要配置主键自增

我们需要配置主键自增

①在实体类字段上配置@TableId(type = IdType.AUTO)

② 同时数据库字段一定是自增，保存

③ 再次运行项目测试查看数据库id

1.2.4 手动输入：INPUT 就需要自己写 id

① 在实体类字段上配置@TableId(type = IdType.INPUT)

② 直接运行程序可以看到id为null

③ 手动添加id再次运行，可看效果

1.3 Update

• ① 增加修改方法进行测试

/*  * 修改  * */ @Test //测试修改 public void updateUser(){      User user = new User();     user.setId(6L);//怎么改id？？     //通过条件自动拼接动态Sql     user.setName("关注我的公众号:爪哇知识库");     user.setAge(24);     user.setEmail("psvmspark@163.com");      int result = userMapper.updateById(user);//updateById，但是参数是个user      System.out.println(result);//受影响的行数      System.out.println(user);//通过日志发现id会自动回填 } 

• ② 运行如下所示

1.4 自动填充

• 创建时间、更改时间！ 这些操作一般都是自动化完成，我们不希望手动更新
• 阿里巴巴开发手册︰几乎所有的表都要配置 gmt_create(创建时间)、gmt_modified（更新时间） ！而且需要自动化。

1.4.1 方式一：数据库级别

数据库级别（工作中不允许修改数据库级别）

• ① 更改表，在表中增加字段：create_time,update_time 并保存

• ② 再次测试插入或更新方法，我们需要在实体类中同步！

private Date createTime;//驼峰命名 private Date updateTime; 

• ③ 再次运行更新方法查看结果

1.4.2 方式二：代码级别

1、删除数据库的默认值，更新操作！

2、实体类字段属性上需要增加注解,id修改为自动增加

3、编写处理器来处理这个注解即可！注：参考官网自动填充字段

MyMetaObjectHandler

package com.gansu.handler;  import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler; import lombok.extern.slf4j.Slf4j; import org.apache.ibatis.reflection.MetaObject; import org.springframework.stereotype.Component;  import java.util.Date;  @Slf4j @Component public class MyMetaObjectHandler implements MetaObjectHandler {     @Override//插入时的填充策略     public void insertFill(MetaObject metaObject) {          log.info("==start insert ······==");         //源码：setFieldValByName(java.lang.String fieldName, java.lang.Object fieldVal,         // org.apache.ibatis.reflection.MetaObject metaObject)         this.setFieldValByName("createTime",new Date(),metaObject);         this.setFieldValByName("updateTime",new Date(),metaObject);     }      @Override//更新时的填充策略     public void updateFill(MetaObject metaObject) {          log.info("==start update ······==");         this.setFieldValByName("updateTime",new Date(),metaObject);     } } 

4、测试插入/更新，观察时间

注释id,进行测试：

结果显示：

更新测试：

结果时间更新了：

二、 乐观锁&悲观锁

在面试过程中经常被问到乐观锁/悲观锁，这个其实很简单

• 乐观锁：顾名思义十分乐观,他总是认为不会出现问题,无论干什么都不上锁!如果出现了问题,再次更新值测试
• 悲观锁：顾名思义十分悲观,他总是认为出现问题,无论干什么都会上锁!再去操作!

下面主要总结 乐观锁机制!

乐观锁实现方式:

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

乐观锁：先查询，获得版本号 -- A 线程 update user set name = "wms",version = version+1  where id = 1 and version = 1 -- B  （B线程抢先完成，此时version=2，会导致A线程修改失败！） update user set name = "jhy",version = version+1  where id = 1 and version = 1 

测试一下Mybatis-Plus乐观锁插件官网👉👉[乐观锁插件] (https://baomidou.com/plugins/optimistic-locker/) 👇👇

1、给数据库中增加version字段

2、增加实体字段并在实体类字段上添加 @Version 注解

在实体类中，需要在表示版本号的字段上添加 @Version 注解：

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

3、编写注册组件配置类 MybatisPlusConfig 参考官网

package com.gansu.config;   import com.baomidou.mybatisplus.extension.plugins.OptimisticLockerInterceptor; import org.mybatis.spring.annotation.MapperScan; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.transaction.annotation.EnableTransactionManagement;  //扫描mapper文件夹 @MapperScan("com.gansu.mapper") //交给mybatis做的，可以让这个配置类做扫描 @EnableTransactionManagement//自动管理事务 @Configuration//配置类 public class MybatisPlusConfig {      //注册乐观锁插件     @Bean     public OptimisticLockerInterceptor optimisticLockerInterceptor(){         return new OptimisticLockerInterceptor();     } } 

4、测试一下

• (1) 成功情况

/*  * 乐观锁  * */ @Test //测试乐观锁 public void testOptimisticLocker1(){     //1、查询用户信息     User user = userMapper.selectById(1L);     //2、修改用户信息     user.setId(1L);     //通过条件自动拼接动态Sql     user.setName("关注我的博客:Daniel521-Spark");     user.setAge(28);     user.setEmail("wmsspark@163.com");     //3、执行更新操作     userMapper.updateById(user); } 

运行结果显示：

• (2) 失败情况

@Test //测试乐观锁失败  多线程下 public void testOptimisticLocker2(){     //线程1     User user = userMapper.selectById(1L);     user.setName("关注我的博客:Daniel521-Spark");     user.setAge(88);     user.setEmail("wmsspark@163.com");      //线程2 模拟另外一个线程执行了插队操作     User user1 = userMapper.selectById(1L);     user1.setName("关注我的博客:Daniel521-Spark");     user1.setAge(99);     user1.setEmail("wmsspark@163.com");     userMapper.updateById(user1);      // 自旋锁来多次尝试提交！     userMapper.updateById(user);//如果没有乐观锁就会覆盖插队线程的值 } 

运行结果查看：

运行前：

运行后：

从而线程二被更新，线程一没有更新。

涉及数据库的面试 5.5 面试高频

文章源码

附：查询删除，代码自动生成见下节总结！！！