美文网首页
关系型数据库锁机制的运用和实战

关系型数据库锁机制的运用和实战

作者: 程序猿峰岑 | 来源:发表于2022-07-04 21:55 被阅读0次

悲观锁

维基百科悲观锁的解释
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>

相关文章

网友评论

      本文标题:关系型数据库锁机制的运用和实战

      本文链接:https://www.haomeiwen.com/subject/udrpvrtx.html