抛出异常后使用当前会话

Question

根据Hibernate documentation，Hibernate 抛出异常后使用 Session 是不安全的。

如果 Session 抛出异常，包括任何 SQLException，立即回滚数据库事务，调用 Session.close() 并丢弃 Session 实例。 Session 的某些方法不会使会话保持一致状态。 Hibernate 抛出的任何异常都不能被视为可恢复的。通过在 finally 块中调用 close() 确保 Session 将被关闭。

在我的代码中，我正在执行批量插入。我正在使用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() 方法还是任何其他方式打开一个新会话？

---

编辑： 更清楚地说，我要问的是我是否可以在现有的 currentSession 关闭后检索新的 currentSession。

Answer 1

这是一个单独的 try..catch 块。您如何确定在 table1Entity 上进行的任何处理都不会引发 Hibernate 异常？如果在处理 table1Entity 时确实出现异常，那么尝试将其保存在当前会话中可能会产生更大的问题。

我的建议是将表上的处理分成单独的 try..catch 块，并在每个块中分别调用 save。抛出异常后，尝试在 catch 块内的同一会话中保存事务是不安全的，并且假设 table1Entity 中没有问题有时可能是违反直觉的。

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 在他的回答下的 cmets：使用setGoingToWriteBatch(true) 创建 table1Entry 然后在批处理的末尾setBatchWritten(true)。这样您就可以找到第一个为真但第二个不为真的那些。