数据库乐观锁
两个线程同时操作数据库时,希望可以实现,一个线程在修改数据库的时候,另外一个线程不能对同一条数据进行修改。
sql语句
UPDATE money SET money = money+1, version = version+1
WHERE id = #{id} and version = #{version}
测试类
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(5);
fixedThreadPool.execute(()-> {
try {
update();
}catch (Exception e){
log.info(e.toString());
}
});
fixedThreadPool.execute(()->{
try {
update();
}catch (Exception e){
log.info(e.toString());
}
});
fixedThreadPool.execute(()->{
try {
update();
}catch (Exception e){
log.info(e.toString());
}
});
Thread.sleep(1000);
}
public void update(){
Money money = moneyMapper.selectMoney(1);
log.info("获取当前版本" + money.getVersion());
int i = moneyMapper.update(money);
log.info("更新结果为" + i);
}
执行结果
这里遇到一个问题,主线程需要休眠,才能在测试类中获得数据库连接,操作数据库,如果不休眠主线程,就会报错数据库连接池关闭。这是因为数据库连接池是运行test主线程的时候创建的,主线程执行完毕,关闭数据库连接池。此时子线程并未执行完毕,因此在子线程获取数据库连接的时候报错,程序执行失败。