Избегайте StaleObjectStateException при удалении объекта - PullRequest
Новая
       33

Избегайте StaleObjectStateException при удалении объекта

1 голос
/ 19 октября 2011

У меня есть 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.Почему?

Почему заблокированная загрузка не просто возвращает ноль?Как мне этого добиться?

1 Ответ

1 голос
/ 20 октября 2011

Я потратил некоторое время на изучение этой проблемы и наконец понял, что происходит.

Блокировка PESSIMISTIC_WRITE пытается «заблокировать» сущность, которая уже загружена в сеансе, она не перечитывает объект из БД. Отлаживая вызов, я увидел, что entity == locked вернул true (в терминах Java). Обе переменные указывали на один и тот же экземпляр.

Чтобы заставить 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) {

        // 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.

...