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

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

作者: 程序猿峰岑 | 来源:发表于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