文章目录
一、前言
上篇synchronized关键字与ReentrantLock实现扣减库存，单体应用中还可以使用mysql数据库来实现锁。先来简单实现下。
二、mysql数据库实现锁
数据库分为悲观锁和乐观锁
悲观锁：读取数据时就锁住，这样其他线程或者操作必须要等到悲观锁释放后才获取锁进行操作。乐观锁: 读取数据时不进行数据锁，进行更新操作时检查数据是否被操作过，没有操作过才进行更新。
悲观锁
- select … lock in share mode 共享锁
- select … from for update 悲观锁
共享锁容易造车死锁，这里只以for update为例进行讲解。
主要代码：
/**
* 添加事务
* @param productId
* @return
*/
@Transactional
@Override
public String deductStock(Integer productId) {
Stock stock = stockMapper.selecStockForUpdate(productId);
if(stock != null && stock.getStockNum() > 0 ){
stock.setStockNum(stock.getStockNum() -1);
int updateCount = stockMapper.updateById(stock);
if (updateCount > 0 ){
return "扣减库存成功";
}else{
return "扣减失败";
}
}
return "库存库存失败:商品库存不存在或者库存为0";
}
mapper:
@Select("SELECT * FROM test.stock where product_id = #{productId} for update")
Stock selecStockForUpdate(Integer productId);
乐观锁
实现方法：表加为数据库表增加一个数字类型的 “version” 字段来实现。
ALTER TABLE test.stock ADD version INT DEFAULT 0 NULL;
代码实现思路：当读取数据时，将version字段的值一同读出，数据每更新一次，对此version值加一。当我们提交更新的时候，判断数据库表对应记录 的当前版本信息与第一次取出来的version值进行比对，如果数据库表当前版本号与第一次取出来的version值相等，则予以更新。
/**
* 使用版本号实现扣减库存
* @param productId
* @return
*/
@Override
public String deductStockByVersion(Integer productId) {
// 先查询库存是否充足
Stock stock = stockMapper.selectById(productId);
// 再减库存
if (stock != null && stock.getStockNum() > 0) {
// 获取版本号
Integer version = stock.getVersion();
stock.setStockNum(stock.getStockNum() - 1);
// 每次更新 版本号 + 1
stock.setVersion(stock.getVersion() + 1);
// 更新之前先判断是否是之前查询的那个版本，如果不是重试
if (this.stockMapper.update(stock, new UpdateWrapper<Stock>
().eq("product_id", stock.getProductId()).eq("version", version)) == 0) {
//库存失败再重试一次调用
deductStockByVersion(productId);
}
return "扣减库存成功";
}
return "库存库存失败:商品库存不存在或者库存为0";
}
执行的sql:
UPDATE `stock` SET product_id=?, stock_num=?, create_by=?, create_time=?, update_by=?, update_time=?, version=? WHERE (product_id = ? AND version = ?)
三、总结
本篇简单代码实现了单应用单数据库mysql数据库锁扣减库存，现在常用的都是使用版本号进行控制锁。
