package cn.dzp.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;

@Component
@Slf4j
 public class MyMetaObjectHandler implements MetaObjectHandler {
//    插入时候的填充策略
    @Override
    public void insertFill(MetaObject metaObject) {
        log.info("start insert fill......");
//        String fieldName, Object fieldVal, MetaObject metaObject
        this.setFieldValByName("createTime",new Date(),metaObject);
        this.setFieldValByName("updateTime",new Date(),metaObject);
    }

    @Override
    public void updateFill(MetaObject metaObject) {
        log.info("start update fill......");
        this.setFieldValByName("updateTime",new Date(),metaObject);
    }
}

测试插入

查看数据库

测试更新

查看数据库,只更新了更新的时间

4.5 乐观锁

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

这里主要讲解:乐观锁机制
乐观锁实现方式:

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

测试一下MP(MybatisPlus简写)的乐观锁插件

1.给数据库加上version字段

2.我们实体类增加对应的字段

@Version//代表这是一个乐观锁的注解
   private Integer version;

package cn.dzp.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;

@MapperScan("cn.dzp.mapper")
@EnableTransactionManagement
@Configuration//配置类
public class MybatisPlusConfig {
//    注册乐观锁插件
    @Bean
    public OptimisticLockerInterceptor optimisticLockerInterceptor(){
        return new OptimisticLockerInterceptor();
    }
}

//    测试乐观锁成功
    @Test
    public void testOptimisticLocker(){
//        1.查询用户信息
        User user = userMapper.selectById(1L);
//        2.修改用户信息
        user.setName("乐观锁");
        user.setEmail("leguansuo.com");
//        3.更新操作
        userMapper.updateById(user);
    }

//    测试乐观锁失败!多线程下
@Test
public void testOptimisticLocker2(){
//        线程1
    User user1 = userMapper.selectById(1L);
    user1.setName("乐观锁111");
    user1.setEmail("leguansuo111.com");

//    模拟线程2执行了插队操作
    User user2 = userMapper.selectById(1L);
    user2.setName("乐观锁222");
    user2.setEmail("leguansuo222.com");
    userMapper.updateById(user2);


    userMapper.updateById(user1);//没有乐观锁就会覆盖插队线程的值
}

//测试查询
    @Test
    public void testSelectById(){
        User user = userMapper.selectById(1L);
        System.out.println(user);
    }
//    测试批量查询
    @Test
    public void testSelectBatchId(){
        List<User> users = userMapper.selectBatchIds(Arrays.asList(1, 2, 3, 4, 5));
        users.forEach(System.out::println);
    }
    @Test
//    条件查询之一 map
    public void testSelectByBatchIds(){
        HashMap<String, Object> map = new HashMap<>();
//        自定义查询
        map.put("name","邓疯子");
        List<User> users = userMapper.selectByMap(map);
        users.forEach(System.out::println);
    }

// 旧版分页插件
    @Bean
    public PaginationInterceptor paginationInterceptor() {
        return new PaginationInterceptor();
    }

//    测试分页查询
    @Test
    public void testPage(){
//        参数一:当前页
//        参数二:页面大小
        Page<User> page = new Page<>(1,5);
        userMapper.selectPage(page,null);

        page.getRecords().forEach(System.out::println);
    }

    @TableLogic//逻辑删除
    private Integer deleted;

//注册逻辑删除
    @Bean
    public ISqlInjector sqlInjector(){
        return new LogicSqlInjector();
    }

#设置开发环境
spring.profiles.active=dev

@Bean
    @Profile({"dev","test"}) //设置dev 和 test环境开启,保证效率
    public PerformanceInterceptor performanceInterceptor(){
        PerformanceInterceptor performanceInterceptor = new PerformanceInterceptor();
        performanceInterceptor.setMaxTime(100);//ms 设置sql执行的最大时间,如果超过了则不执行
        performanceInterceptor.setFormat(true);//是否格式化
        return performanceInterceptor;
    }

 @Test
    void contextLoads() {
//        参数是Wrapper,条件构造器,暂时先不用
        List<User> users = userMapper.selectList(null);
        users.forEach(System.out::println);
//        for (User user : users) {
//            System.out.println(user);
//        }
    }