mybatis-plus2_mybatis-plus 悲观锁

目录

一、乐观锁

二、乐观锁与悲观锁的区别

1.乐观锁和悲观锁的应用场景

三、条件查询构造器

四、分页查询

五、逻辑删除

六、在Mybatis-plus中使用xml配置

---

一、乐观锁

乐观锁插件 | MyBatis-PlusMyBatis-Plus 官方文档https://baomidou.com/pages/0d93c0/

当要更新一条记录的时候，希望这条记录没有被别人更新

乐观锁实现方式（来自官方文档）：

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

配置示例：

1.在数据库表中加入version字段，表示数据版本号

2.修改实体类，在使用类中加入对应的version字段，并使用是乐观锁

//乐观锁
@Version
private Integer version;

3.配置乐观锁

package com.jwj.mplus.config;
 
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.OptimisticLockerInnerInterceptor;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
// Spring Boot 方式
@Configuration
public class MybatisPlusConfig {
 
    /**
     * 新版
     */
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor mybatisPlusInterceptor = new MybatisPlusInterceptor();
        mybatisPlusInterceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
        return mybatisPlusInterceptor;
    }
}

4.测试

//测试乐观锁
@Test
public void testLock01() {
User user01 = userMapper.selectById(66L);
User user02 = userMapper.selectById(66L);
user01.setName("leguansuo01");
userMapper.updateById(user01);
user02.setName("leguansuo02");
userMapper.updateById(user02);
}

效果如下图所示：

二、乐观锁与悲观锁的区别

图解悲观锁和乐观锁 - 知乎这篇文章讲什么这是一篇介绍悲观锁和乐观锁的入门文章。旨在让那些不了解悲观锁和乐观锁的小白们弄清楚什么是悲观锁，什么是乐观锁。不同于其他文章，本文会配上相应的图解让大家更容易理解。通过该文，你会学习到…https://zhuanlan.zhihu.com/p/63714157

1.乐观锁和悲观锁的应用场景

1. 悲观锁
   因为悲观锁会影响系统吞吐的性能，所以适合应用在写为居多的场景下。
2. 乐观锁
   因为乐观锁就是为了避免悲观锁的弊端出现的，所以适合应用在读为居多的场景下。

解释：乐观锁：是所保护的数据绝大多数情况下是安全的。

悲观锁：是认为所保护的数据在绝大多数情况下都是不安全的，容易出现并发问题。

三、条件查询构造器

https://baomidou.com/pages/10c804/#abstractwrapperhttps://baomidou.com/pages/10c804/#abstractwrapper1.批量查询多个对象

  @Test
    public void testSelectList() {
//一次查询多个ID
        List<User> users = userMapper.selectBatchIds(Arrays.asList(1L, 2L, 3L));
        users.forEach(t -> {
            System.out.println(t);
        });
    }
    @Test
    public void testSelectByMap() {
//使用map进行查询
        Map<String, Object> map = new HashMap<>();
        map.put("name", "Tom");
        map.put("age", 28);
        List<User> users = userMapper.selectByMap(map);
        users.forEach(t-> System.out.println(t));
    }
 
 
@Test
    public void testWrapperLike(){
        QueryWrapper<User> wrapper = new QueryWrapper<>();
        wrapper.likeRight("name","T")
                .eq("age",28).apply(" 1=1 ");
        List<User> users = userMapper.selectList(wrapper);
        users.forEach(t-> System.out.println(t));
    }
    @Test
    public void testUpdateWrapper(){
        UpdateWrapper u = new UpdateWrapper();
//        u.set("name","TT");
        u.eq(true,"id",6L);
        User user = userMapper.selectById(6L);
//        user = new User();
        user.setName("TTT");
        userMapper.update(user,u);
    }

四、分页查询

分页插件 | MyBatis-PlusMyBatis-Plus 官方文档https://baomidou.com/pages/97710a/#paginationinnerinterceptor1.分页配置

package com.jwj.mplus.config;
 
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.OptimisticLockerInnerInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
@Configuration
public class MybatisPlusConfig {
 
    /**
     * 新版
     */
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor mybatisPlusInterceptor = new MybatisPlusInterceptor();
//       乐观锁
        mybatisPlusInterceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
//        分页拦截器
        mybatisPlusInterceptor.addInnerInterceptor(new PaginationInnerInterceptor());
        return mybatisPlusInterceptor;
    }
}

 2.分页演示

@Test
    public void testSelectPage() {
        PageDTO<User> page = new PageDTO<>();
//        当前页第3页
        page.setCurrent(3);
//        一页查询几条
        page.setSize(3);
//        select * from user limit (3-1)*3,3
        PageDTO<User> pageDTO = userMapper.selectPage(page, null);
        System.out.println(pageDTO.getTotal());
        List<User> records = pageDTO.getRecords();
        records.forEach(t-> System.out.println(t));
    }

五、逻辑删除

逻辑删除 | MyBatis-PlusMyBatis-Plus 官方文档https://baomidou.com/pages/6b03c5/#%E4%BD%BF%E7%94%A8%E6%96%B9%E6%B3%95物理删除使用起来比较简单，仿照查询功能即可，不再赘述。

什么是逻辑删除？

即：标记删除，并不是真的从数据库中删除，而是做个删除标记，在查询时，过滤掉标记为删除的记录即可。

1.数据库表结构调整

 2.修改实体类

 //标记该字段为逻辑删除字段
    @TableLogic
    private Integer deleted;

3.在application.properties(或application.yml)中加入如下配置

#逻辑删除字段名
mybatis-plus.global-config.db-config.logic-delete-field=deleted
# 1表示逻辑删除
mybatis-plus.global-config.db-config.logic-delete-value=1
# 0 表示未删除
mybatis-plus.global-config.db-config.logic-not-delete-value=0

4.测试

@Test
public void testDeleteLogic() {
int i = userMapper.deleteById(66L);
System.out.println(i);
}

效果如下图所示：

它在数据库是还在的，查询不出来的。

六、在Mybatis-plus中使用xml配置

mybatis-plus是mybatis的升级版，所以在mybatis-plus中使用xml的配置比较简单

1.在application.properties配置文件中加入以下配置

mybatis-plus.mapper-locations=classpath:/mapper/**/*.xml

2.定义mapper接口

package com.jwj.mplus.config;
 
import com.jwj.mplus.model.User;
import org.springframework.stereotype.Repository;
 
import java.util.List;
 
/**
 * @author 敢敢
 * @site www.javajwj.com
 * @company xxx公司
 * @create  2023-01-30 19:42
 */
@Repository
public interface UserMapperXml {
    List<User> list();
}

3.根据接口生成xml配置文件，IDE一般有辅助的插件，列如IDEA中的Free Mybatis plugin

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.jwj.mplus.config.UserMapperXml">
    <select id="list" resultType="com.jwj.mplus.model.User">
select * from user;
</select>
</mapper>

4.测试

package com.jwj.mplus;
 
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.PageDTO;
import com.jwj.mplus.config.UserMapperXml;
import com.jwj.mplus.mapper.UserMapper;
import com.jwj.mplus.model.User;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
 
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
 
@SpringBootTest
public class SampleTest2 {
 
    @Autowired
    private UserMapperXml userMapperXml;
 
    @Test
    public void test1(){
        List<User> list = userMapperXml.list();
        list.forEach(System.out::println);
    }
 
}

也可以不使用xml配置，使用注解来定义sql语句

package com.jwj.mplus.config;
 
import com.jwj.mplus.model.User;
import org.springframework.stereotype.Repository;
 
import java.util.List;
 
/**
 * @author 敢敢
 * @site www.javajwj.com
 * @company xxx公司
 * @create  2023-01-30 19:42
 */
@Repository
public interface UserMapperXml {
 
    @Select("select * from user")
    List<User> list();
}

一般来说公司不会用，连表就不行了，但有的公司会用，很少。

连表的话是不好调优的，所以不推荐。