悲观锁
维基百科悲观锁的解释
image.png悲观锁分为两种锁(数据库提供实现)
- 读锁/共享锁
读锁可被其他线程所共享,如果是读取的话,大家都可以用这把锁读取数据
select * from table lock in share mode (读锁/共享锁) - 写锁/排他锁【用的多】
写锁/排他锁,可以锁一张表或者一行记录
写锁不能共享,只要有人为数据加入了写锁,其他人就不能为数据加任何锁
select * from table for update(写锁、排他锁)
读锁/共享锁实战
第一步:
首先打开两个终端窗口,两个窗口使用cd进入到mysql关系型数据库bin目录下,并使用命令进入到数据库 mysql -u 【数据库登录名称】-p 【密码】
命令:mysql -u root -p 点击回车,输入密码点击回车,进入到如下界面就算成功进入了
image.png
第二步:两个窗口都进入到同一个数据库,使用命令如下:
mysql> use hibernate_day03;
温馨提示:我这里是创建了数据库的 所以我是直接使用数据库,如果您还没有创建数据库还需要创建数据库再使用如上命令。创建数据库的命令:create database 【数据库名称】
第三步:两个窗口分别开启事务,开启事务命令如下
mysql> start transaction;
以上准备工作已完毕,我们分别对两个窗口命名为A和B
A添加读锁或共享锁,其他线程可以用这把锁。添加共享锁的命令如下:
mysql> select * from t_customer lock in share mode;
如果其他线程使用了A的那把锁,没有提交并释放这把锁,B终端执行更新数据的操作是不能成功的,它会一直处在等待的状态。
mysql> update t_customer set name='zhangsan' where id=1;
这时,我们提交A终端的事务,使用命令如下:
mysql> commit;
B终端随即更新数据库
image.png
读锁或共享锁的整个执行流程就是如此了
写锁/排他锁实战
准备工作和读锁/共享锁相同,我这里就不再赘述。
给表添加写锁,其他线程无法读取这个表,当提交后才能读到这个表
在A终端中使用如下命令:
mysql> select * from t_customer for update;
在B终端开启事务读表,添加写锁【读不到数据】
mysql> update t_customer set name='zhangsan' where id=1;
如果长时间读取不到,还会报读取超时错误
image.png
A终端提交,B终端数据也随即更新
image.png
终端和hibernate联动
- 终端开启事务,并执行 select * from t_customer for update;
在hibernate执行如下代码:
Session session = HibernateUtils.openSession();
session.getTransaction().begin();
Query query = session.createQuery("select c from Customer c where id=?");
query.setLockOptions(LockOptions.UPGRADE);
query.setParameter(0,1);
session.getTransaction().commit();
session.close();
只有在终端提交事务,hibernate的更新数据才能成功
乐观锁
维基百科乐观锁的解释
image.png乐观锁就是在表中添加一个version字段来控制数据不一致性
在PO对象中(JavaBean)提供字段,表示版本字段,一般使用Integer
hibernate使用乐观锁案例:
private Integer version;//乐观锁,在PO对象【JavaBean】添加一个整型的version
public Integer getVersion() {
return version;
}
public void setVersion(Integer version) {
this.version = version;
}
然后在Customer.hbm.xml文件中添加如下:
<!-- version的标签位置在id和property之间,根据dtd的约束可以查看-->
<version name="version"></version>
网友评论