删除实体时避免 StaleObjectStateException

Question

我有 2 个并发线程，它们同时进入（Spring）事务服务。

使用 Hibernate，服务方法加载一些实体，处理这些实体，找到一个实体并将其从数据库中删除。伪代码如下：

@Transactional
public MyEntity getAndDelete(String prop) {
    List<MyEntity> list = (List<MyEntity>)sessionFactory
        .getCurrentSession()
        .createCriteria(MyEntity.class)
        .add( Restrictions.eq("prop", prop) )
        .list();

    // process the list, and find one entity
    MyEntity entity = findEntity(list);
    if (entity != null) {
        sessionFactory.getCurrentSession().delete(entity);
    }
    return entity;
}

如果两个线程同时传递相同的参数，两个线程都会“找到”相同的实体，并且都会调用delete。当会话关闭时，其中之一将失败并抛出org.hibernate.StaleObjectStateException。

我希望两个线程都会返回实体，不会抛出任何异常。为了实现这一点，我尝试在删除实体之前锁定（使用“select...for update”）实体，如下所示：

@Transactional
public MyEntity getAndDelete(String prop) {
    List<MyEntity> list = (List<MyEntity>)sessionFactory
        .getCurrentSession()
        .createCriteria(MyEntity.class)
        .add( Restrictions.eq("prop", prop) )
        .list();

    // process the list, and find one entity
    MyEntity entity = findEntity(list);
    if (entity != null) {
        // reload the entity with "select ...for update"
        // to ensure the exception is not thrown
        MyEntity locked = (MyEntity)sessionFactory
            .getCurrentSession()
            .load(MyEntity.class, entity.getId(), new LockOptions(LockMode.PESSIMISTIC_WRITE));
        if (locked != null) {
            sessionFactory.getCurrentSession().delete(locked);
        }
    }
    return entity;
}

我使用 load() 而不是 get() 因为根据 hibernate API，如果实体已在会话中，则 get 将返回实体，而 load 应重新读取它。

如果两个线程同时进入上述方法，其中一个线程会阻塞锁定阶段，并且当第一个线程关闭事务时，第二个线程将被唤醒并抛出 org.hibernate.StaleObjectStateException 。为什么？

为什么锁定加载不只是返回 null？我怎样才能做到这一点？

Answer 1

我花了一些时间调查这个问题，终于明白发生了什么。

PESSIMISTIC_WRITE 锁尝试“锁定”已在会话中加载的实体，它不会从数据库重新读取对象。调试调用时，我看到 entity ==locked 返回了 true （用 Java 术语来说）。两个变量都指向同一个实例。

要强制休眠重新加载实体，必须首先将其从会话中删除。

下面的代码可以解决这个问题：

@Transactional
public MyEntity getAndDelete(String prop) {
    List<MyEntity> list = (List<MyEntity>)sessionFactory
        .getCurrentSession()
        .createCriteria(MyEntity.class)
        .add( Restrictions.eq("prop", prop) )
        .list();

    // process the list, and find one entity
    MyEntity entity = findEntity(list);
    if (entity != null) {

        // Remove the entity from the session.
        sessionFactory.getCurrentSession().evict(entity);

        // reload the entity with "select ...for update"
        MyEntity locked = (MyEntity)sessionFactory
            .getCurrentSession()
            .get(MyEntity.class, entity.getId(), new LockOptions(LockMode.PESSIMISTIC_WRITE));
        if (locked != null) {
            sessionFactory.getCurrentSession().delete(locked);
        }
    }
    return entity;
}

PESSIMISTIC_WRITE 必须与 get 一起使用，而不是与 load 一起使用，否则会抛出 org.hibernate.ObjectNotFoundException 。