[大数据]MybatisPlus-CRUD扩展

1.Insert

	@Test
    public void testInsert(){
        User user = new User();
        user.setName("黄凯宇");
        user.setAge(18);
        user.setEmail("1024955508@qq.com");

        int rs = userMapper.insert(user);
        System.out.println(user);
        System.out.println("结果=》"+rs); 
    }

我们实例化对象时并没有设置主键id，但是输出对象时id已经存在

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

主键生成策略

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

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

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

• 数据库字段设置自增

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

? 不设置id为空

2.update

 @Test
    public void testUpdate(){
        User user=new User();
        user.setId(1L);
        user.setName("alibaba");     //通过设置的属性动态拼接sql
        int rs = userMapper.updateById(user);  //byId 但是参数是个user，所以我们要在user里设置被修改属性的id
        System.out.println(user);
        System.out.println("结果=》"+rs);
    }

3.自动填充

创建时间、更改时间！ 这些操作一般都是自动化完成，我们不希望手动更新

阿里巴巴开发手册︰几乎所有的表都要配置 gmt_create、gmt_modified ！而且需要自动化

方式一：数据库级别（工作中一般不允许修改数据库）

1、在表中增加字段：create_time,update_time

2、我们需要在实体类中同步字段名！

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

3.测试并查看结果

方式二：代码级别

1、删除数据库的默认值CURRENT_TIMESTAMP！

2、实体类字段属性上需要增加注解@TableField

//字段  字段添加填充内容
@TableField(fill = FieldFill.INSERT)//value = ("create_time"),
private Date createTime;
@TableField(fill = FieldFill.INSERT_UPDATE)
private Date updateTime;

3、编写处理器来处理这个注解即可！

@Slf4j//日志
@Component//丢到springboot里   一定不要忘记把处理器加到Ioc容器中!
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);
    }
}

插入时，createTIme和updateTime一同更新

更新时，只有updateTime更新

4.乐观锁&悲观锁

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

悲观锁：顾名思义十分悲观,他总是认为出现问题,无论干什么都会上锁!再去操作!

乐观锁实现方式:

• 取出记录时,获取当前version

• 更新时,带上这个version

• 执行更新时,set version = newVersion where version = oldVersion

• 如果version不对,就更新失败

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

测试一下Mybatis-Plus乐观锁插件

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

2、实体类加对应的字段

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

3、注册组件

//扫描mapper文件夹
@MapperScan("com.huang.mapper")//交给mybatis做的，可以让这个配置类做扫描,将主类注解删除
@EnableTransactionManagement//自动管理事务
@Configuration//配置类
public class MyBatisPlusConfig {
    //注册乐观锁插件
    @Bean
    public OptimisticLockerInterceptor optimisticLockerInterceptor(){
        return new OptimisticLockerInterceptor();
    }
}

4、测试

• 成功

 //测试乐观锁成功
    public void  testOpimisticLocker(){

        //1、查询用户信息
        User user = userMapper.selectById(1L);
        //2、修改用户信息
        user.setAge(18);
        user.setEmail("1024955508@qq.com");
        //3、执行更新操作
        userMapper.updateById(user);
    }

• 失败

  //测试乐观锁失败
      @Test//测试乐观锁失败  多线程下
      public void testOptimisticLocker2(){
          //线程1
          User user1 = userMapper.selectById(1L);
          user1.setName("乐观成功");
  
          //模拟另外一个线程执行了插队操作
          User user2 = userMapper.selectById(1L);
          user2.setName("插队");
  
          userMapper.updateById(user2);
          //自旋锁来多次尝试提交！
          userMapper.updateById(user1);//如果没有乐观锁就会覆盖插队线程的值
      }