其他分享
首页 > 其他分享> > hibernate的锁机制

hibernate的锁机制

作者:互联网

概述

hibernate 可以通过加锁解决并发问题。
hibernate 的锁分为两种:乐观锁和悲观锁。

乐观锁(Optimistic lock):每次访问数据时,都会乐观的认为其它事务此时肯定不会同时修改该数据。但在真正修改时,会在代码中先判断数据是否已经被其它事务修改过。所以锁 是加在代码中的。

悲观锁(Pessimistic lock):每次访问数据时,都会悲观的认为其它事务一定会同时修改该数据。所以其在访问数据时,在数据库中就会先给数据加锁,以防止其它事务同时修改该数据。所以锁是加在数据库中的。

乐观锁

乐观锁是加在代码中的锁机制,一般充当乐观锁的有两类数据:版本号与时间戳。它们的工作原理是相同的。

举例说明,A、B两个事务从数据库中读取数据时都会读出一个数据版本号。当 A 事务将修改过的数据写入到数据库中时,会使版本号增 1。当 B 事务发生回滚或覆盖时,会首先对比自己数据的版本号与数据库中数据的版本号。若它们相等,则说明数据库中数据没有发生变化,B 事务可以将数据回滚到原始状态,或将修改写入到 DB 中。若小于 DB 中的版本号,则说明其它事务已经修改过该数据,将抛出异常。

悲观锁

悲观锁是加在 DB 中的锁机制,又分为两种:

写锁,又称为排他锁。当 A 事务对某数据加上排他锁后,A 事务将独占该数据,可对该数据进行读、写操作。但其他事务是不能再为该数据添加任何锁的,直到 A 事务将排他锁解锁,将数据释放。 在 SQL 语句中,若要为本次操作(事务)添加排他锁,则可在正常的 SQL 语句最后添 加上 for update 即可。例如: select * from student where age <20 for update

读锁,又称为共享锁。当 A 事务对某数据加上共享锁后,只能对数据进行读操作。但其他事务也同时可以为该数据添加共享锁,读取该数据。但不能添加写锁,直到所有事务将其共享锁解锁,将数据释放,才可再对数据添加排他锁。 在 SQL 语句中,若要为本次操作(事务)添加共享锁,则可在正常的 SQL 语句最后添 加上 lock in share mode 即可。例如:select * from student where age <20 lock in share mode

乐观锁实现

在实体类中添加属性 version,并加注解 @Version

@Data  
@Entity  
@Table(name = "t_book", schema = "test", catalog = "")  
public class Book {  
    @Id  
    @GeneratedValue(strategy = GenerationType.IDENTITY)  
    @Column(name = "id")  
    private int id;  
  
    @Version  
    @Column(name="version")  
    private int version;  
  
    @Basic  
    @Column(name = "name")  
    private String name;  
  
    @Basic  
    @Column(name = "author")  
    private String author;  
  
    @Basic  
    @Column(name = "publish_date")  
    private Date publishDate;  
  
    @Basic  
    @Column(name = "price")  
    private BigDecimal price;  
  
    @Transient  
    private Integer catalogId;
}

测试类

@RunWith(SpringRunner.class)  
@SpringBootTest  
public class OptimisticLockTest {  
    @Autowired  
    private SessionFactory sessionFactory;  
  
    private Session session;  
  
    @Before  
    public void setup() {  
        this.session = sessionFactory.getCurrentSession();  
    }  
  
    @Test  
    @Transactional    
    public void test01() {  
        Criteria criteria = this.session.createCriteria(Book.class);  
        Criterion eqNameCr = Restrictions.eq("name", "三体");  
        criteria.add(eqNameCr);  
        Book book = (Book) criteria.uniqueResult();  
  
        book.setPrice(new BigDecimal("150"));  
  
        //在该行打断点,执行到这个地方时,手动修改数据库中“三体”的version字段值,然后继续执行,会抛出  
        // javax.persistence.OptimisticLockException: Row was updated or deleted by another transaction (or unsaved-value mapping was incorrect) : [com.guide.hibernate.domain.Book#1]  
        this.session.update(book);  
        session.flush();  
        System.out.println(book.getName() + "价格:" + book.getPrice());  
    }  
}

this.session.update(book) 的底层 SQL 如下:

update t_book set author=?, catalog_id=?, name=?, price=?, publish_date=?, version=? where id=? and version=?

悲观锁实现

实体类中不用增加任何属性。只需要在通过 get() 加载对象时,为其加锁。使用 的 get()方法原型为:
T get(Class clazz, Serializable num, LockMode lockMode)
排他锁:LockMode.PESSIMISTIC_WRITE
共享锁:LockMode.PESSIMISTIC_READ

排他锁

对于排他锁,其加锁的时间为通过 get()方法执行 select 查询后,解锁时间为当前事务结束
这期间,当前事务是可以修改被其加锁的数据的,但其它事务是无法对该数据进行修改的。

    Criteria criteria = session.createCriteria(Book.class);  
    criteria.setLockMode(LockMode.PESSIMISTIC_WRITE);  
    Criterion eqNameCr = Restrictions.eq("name", "三体");  
    criteria.add(eqNameCr);  
    Book book = (Book) criteria.uniqueResult();  
    //在此处打断点,然后尝试是否可以在数据库中修改 “三体” 这条数据,发现一直卡住了
    System.out.println(book.getName() + "价格:" + book.getPrice());

它的底层SQL如下:

select this_.id as id1_0_0_, this_.author as author2_0_0_, this_.catalog_id as catalog_7_0_0_, this_.name as name3_0_0_, this_.price as price4_0_0_, this_.publish_date as publish_5_0_0_, this_.version as version6_0_0_ 
from t_book this_ 
where this_.name=? for update

共享锁

对于共享锁,其加锁的时间也为通过 get()方法执行 select 查询后,但其解锁时间则是在其查询的数据被检索出来后的瞬间
即从程序运行来看,get()方法开始执行则加上了读锁, get()方法运行结束,则读锁解除。所以,加了读锁的 get()方法后的修改语句,与读锁是没有任何关系的。

    //读锁,共享锁  
    Criteria criteria = session.createCriteria(Book.class);  
    criteria.setLockMode(LockMode.PESSIMISTIC_READ);  
    Criterion eqNameCr = Restrictions.eq("name", "三体");  
    criteria.add(eqNameCr);  
    Book book = (Book) criteria.uniqueResult();  
    System.out.println(book.getName() + "价格:" + book.getPrice());

它的底层SQL如下:

select this_.id as id1_0_0_, this_.author as author2_0_0_, this_.catalog_id as catalog_7_0_0_, this_.name as name3_0_0_, this_.price as price4_0_0_, this_.publish_date as publish_5_0_0_, this_.version as version6_0_0_ 
from t_book this_ 
where this_.name=? for share

标签:事务,hibernate,name,Book,_.,book,机制,数据
来源: https://www.cnblogs.com/haicheng92/p/15970481.html