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

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);

如图：

编写实体类：

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.jupiter.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);
        system.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);
        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.updatebyid(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());
    }
}

实际流程：

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元 (正确的价格)