MyBatisPlus乐观锁和悲观锁的实现示例

本文主要是介绍MyBatisPlus乐观锁和悲观锁的实现示例，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

《MyBatisPlus乐观锁和悲观锁的实现示例》本文主要介绍了MyBatisPlus乐观锁和悲观锁,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小...

1.场景

一件商品，成本价是80元，售价是100元。老板先是通知小李，说你去把商品价格增加50元。小李正在玩游戏，耽搁了一个小时。正好一个小时后，老板觉得商品价格增加到150元，价格太高，可能会影响销量。又通知小王，你把商品价格降低30元。

此时，小李和小王同时操作商品后台系统。小李操作的时候，系统先取出商品价格100元；小王也在操作，取出的商品价格也是100元。小李将价格加了50元，并将100+50=150元存入了数据库；小王将商品减了30元，并将100-30=70元存入了数据库。是的，如果没有锁，小李的操作就完全被小王的覆盖了。

现在商品价格是70元，比成本价低10元。几分钟后，这个商品很快出售了1千多件商品，老板亏1 万多。

2.乐观锁和悲观锁

上面的故事，如果是乐观锁，小王保存价格前，会检查下价格是否被人修改过了。如果被修改过了，则重新取出的被修改后的价格， 150元，这样他会将120元存入数据库。

如果是悲观锁，小李取出数据后，小王只能等小李操作完之后，才能对价格进行操作，也会保证最终的价格是120元。

3.乐观锁实现

添加插件：

    @Bean
    public MyBATisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        // 添加分页插件
        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.mysql));

        // 添加乐观锁插件
        interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
        return interceptor;
    }

创建表：

CREATE TABLE t_product
(
    id BIGINT(20) NOT NULL COMMENT '主键ID',
    NAME VARCHAR(30) NULL DEFAULT NULL COMMENT '商品名称 ',
    price INT(11) DEFAULT 0 COMMENT '价格 ',
    VERSION INT(11) DEFAULT 0 COMMENT '乐观锁版本号 ',
    PRIMARY KEY (id)
);

添加数据：

INSERT INTO t_product (id, NAME, price) VALUES (1, '外星人笔记本 ', 100);

如图：

MyBatisPlus乐观锁和悲观锁的实现示例

编写实体类：

package com.qcby.entity;

import com.baomidou.mybatisplus.annotation.Version;
import lombok.Data;

@Data
public class Product {
    private Long id;
    private String name;
    private Integer price;

    @Version
    private Integer version;
}

mapper：

package com.qcby.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.qcby.entity.Product;
import org.springframework.stereotype.Repository;

@Repository
public interface ProductMapper extends BaseMapper<Product> {
}

测试：

package com.qcby;

import com.qcby.entity.Product;
import com.qcby.mapper.ProductMapper;
import org.junit.jupitpythoner.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
public class MybatisTestOptimisticLock {

    @Autowired
    private ProductMapper productMapper;

    @Test
    public void testOptimisticLock() {
        // 小李查询商品信息
        Product productLi = productMapper.selectById(1L);
        Systjavascriptem.out.println("小李查询价格: " + productLi.getPrice() + ", 版本: " + productLi.getVersion());

        // 小王查询商品信息
        Product productWang = productMapper.selectById(1L);
        System.out.println("小王查询价格: " + productWang.getPrice() + ", 版本: " + productWang.getVersion());

        // 小李修改价格 +50
        productLi.setPrice(productLi.getPrice() + 50);
        int resultLi = productMapper.updateById(productLi);
   China编程     System.out.println("小李修改结果: " + resultLi);

        if (resultLi > 0) {
            Product afterLi = productMapper.selectById(1L);
            System.out.println("小李修改后价格: " + afterLi.getPrice() + ", 版本: " + afterLi.getVersion());
        }

        // 小王修改价格 -30
        productWang.setPrice(productWang.getPrice() - 30);
        int resultWang = productMapper.updateByIdjavascript(productWang);
        System.out.println("小王修改结果: " + resultWang);

        if (resultWang == 0) {
            // 小王修改失败，需要重新尝试
            System.out.println("小王修改失败，版本已变更，需要重新操作");
            Product newproductWang = productMapper.selectById(1L);
            newProductWang.setPrice(newProductWang.getPrice() - 30);
            resultWang = productMapper.updateById(newProductWang);
            System.out.println("小王重试结果: " + resultWang);
        }

        // 最终价格
        Product finalProduct = productMapper.selectById(1L);
        System.out.println("最终价格: " + finalProduct.getPrice() + ", 版本: " + finalProduct.getVersion());
    }
}

MyBatisPlus乐观锁和悲观锁的实现示例

实际编程China编程流程：

1. 小李查询: SELECT id,name,price,version FROM t_product WHERE id=1
结果: price=100, version=0

2. 小王查询: SELECT id,name,price,version FROM t_product WHERE id=1
结果: price=100, version=0

3. 小李更新: UPDATE t_product SET name=?, price=150, version=1
WHERE id=1 AND version=0
成功: version变为1

4. 小王更新: UPDATE t_product SET name=?, price=70, version=1
WHERE id=1 AND version=0
失败: version条件不匹配

5. 小王重试: 重新查询 price=150, version=1
更新: SET price=120, version=2 WHERE id=1 AND version=1
成功

6. 最终价格: 120元 (正确的价格)