Использование текущего Sesssion после исключения выбрано

Question

В соответствии с Hibernate documentation небезопасно использовать сеанс после того, как исключение вызывается Hibernate.

Если сеанс вызывает исключение, включая любое SQLException, немедленно откат транзакции базы данных, вызовите Session.close() и отмените экземпляр сеанса. Некоторые методы сеанса не оставляют сеанс в согласованном состоянии. Никакое исключение, вызванное Hibernate, не может рассматриваться как подлежащее восстановлению. Убедитесь, что сессия будет закрыта вызовом функции close() в блоке finally.

В моем коде я делаю пакетную вставку. Я использую метод sessionFactory.getCurrentSession() для получения сеанса. Мой код такой.

try { 
    //some code here.... 
    .... 
    Table1Entity table1Entity = ....... 
    List<Table2Entity> table2Entities = ....... 
    Session currentSession = sessionFactory.getCurrentSession(); 
    for (int i = 0; i < table2Entities; i++) { 
     ............. 
     currentSession.save(table2Entities.get(i)); 
     if(i % batchSize == 0 || i + 1 == table2Entities) { 
     currentSession.flush(); 
     currentSession.clear(); 
    } 
    } 
} catch (Exception e) { 
    currentSession.getTransaction().rollback(); 
    //currentSession.close(); //According to documentation Session should be closed here 
    table1Entity.setError(true); 
    currentSession.save(table1Entity);//According to documentation Session should not be used here 
    ....... 
} 

Как указано в документации, сеанс не должен использоваться после исключения исключения. Моя проблема в том, что я использую currentSession, как я могу сохранить table1Entity в блоке catch? Должен ли я открыть новый сеанс с использованием метода openSession() или любым другим способом?

---

Edit: Чтобы быть более ясным, просто то, что я спрашиваю, могу ли я получить новый currentSession после существующего currentSession закрыт.

Answer 1

Это единый блок try..catch. Как вы можете быть уверены, что исключение Hibernate, безусловно, не будет выбрано из любой обработки, выполняемой в таблице1Entity? Если исключение возникает при обработке table1Entity, то попытка сохранить его в текущем сеансе может создать большие проблемы.

Мой совет заключается в том, что вы разделяете обработку таблиц на отдельные блоки try..catch и вызываете сохранение отдельно в каждом блоке. После того, как выбрано исключение, попытка сохранить транзакцию в том же сеансе в блоке catch небезопасна и если предположить, что в таблице нет проблемы, то иногда может быть встречной интуитивностью.

Answer 2

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

В таких ситуациях вы должны проявлять большую осторожность, чтобы ваша партия не выбрала исключение, несмотря ни на что. Таким образом, если исключение происходит, вы можете предположить, что база данных недоступна или в любом случае не будет принимать никаких попыток. Запишите ошибку в другое место (файлы журнала оказались полезными для этого).

Я вижу ситуации, когда кажется, что ваш подход является жизнеспособным (например, я обновляю все те, которые работают, другие, которые я отмечаю. Чтобы распознать «другие», я использую исключение), но рядом с ним нет на самом деле хорошая идея, но вместо этого ситуация «быть остроумной». - Не будь остроумным, он не окупится.

Вместо этого напишите свою партию так, чтобы те, которые не будут работать как предпочтительные, вместо этого вернут правильный результат, который говорит «Я не работал», и обрабатываю его соответствующим образом.

Так что в вашем случае:

try { 
    //some code here.... 
    .... 
    Table1Entity table1Entity = ....... 
    List<Table2Entity> table2Entities = ....... 
    Session currentSession = sessionFactory.getCurrentSession(); 
    for (int i = 0; i < table2Entities; i++) { 
     ............. 

     // HERE you need to make sure that this call would succeed 
     currentSession.save(table2Entities.get(i)); 
     if(i % batchSize == 0 || i + 1 == table2Entities) { 
     currentSession.flush(); 
     currentSession.clear(); 
    } 
    } 
    currentSession.save(table1Entity); 
    currentSession.getTransaction().commit(); 
} catch (Exception e) { 
    currentSession.getTransaction().rollback(); 
    log.warn("Could not do what I wanted", e); 
} 

Это либо работает целиком или не на всех, и дает правильный трассировки стека с сообщениями и все в том месте, где он принадлежит (регистрационного журнала).

Возможно, вы хотите проверить, будет ли вызов успешным, прежде чем делать это.

Если вы считаете, что должны делать то, что хотите, прочитайте комментарии CodeNewbie под его ответом: Создайте таблицу1Entry с setGoingToWriteBatch(true), а затем в конце партии setBatchWritten(true). Таким образом, вы можете найти те, где первая истинна, а вторая - нет.