66

重要提示：这已被接受为Spring 问题，目标修复版本为 4.1.2。

我的目标是在从 Hibernate 生成 HTTP 响应时实现 O(1) 空间复杂度ScrollableResults。我想保留标准机制，在该机制中MessageConverter分派 a 以处理从 a 返回的对象@Controller。我已经设置了以下内容：

  1. MappingJackson2HttpMessageConverter丰富了JsonSerializer处理 Java 8 的 a Stream；
  2. ScrollableResultSpliterator需要包装ScrollableResults成的自定义Stream；
  3. OpenSessionInViewInterceptor需要保持 Hibernate 会话在MessageConverter;
  4. 设置hibernate.connection.release_mode为ON_CLOSE；
  5. 确保 JDBC 连接具有必要的 ResultSet 可保持性：con.setHoldability(ResultSet.HOLD_CURSORS_OVER_COMMIT).

此外，我需要一个支持这种可保存性的数据库。PostgreSQL 就是这样一个数据库，我对此没有任何问题。

我遇到的最后一个绊脚石是HibernateTransactionManager事务提交时使用的策略：除非底层会话是“休眠管理的”，否则disconnect()它将关闭我的光标以及其他所有内容。这样的策略在一些特殊情况下很有用，特别是“会话范围的会话”，这与我的要求相去甚远。

我已经设法通过一个糟糕的 hack 来解决这个问题：我不得不用一种方法覆盖有问题的方法，该方法实际上是原始方法的复制粘贴，除了已删除的disconnect()调用，但它必须诉诸反射来访问私有 API。

public class NoDisconnectHibernateTransactionManager extends HibernateTransactionManager
{
  private static final Logger logger = LoggerFactory.getLogger(NoDisconnectHibernateTransactionManager.class);

  public NoDisconnectHibernateTransactionManager(SessionFactory sf) { super(sf); }

  @Override
  protected void doCleanupAfterCompletion(Object transaction) {
    final JdbcTransactionObjectSupport txObject = (JdbcTransactionObjectSupport) transaction;
    final Class<?> c = txObject.getClass();
    try {
      // Remove the session holder from the thread.
      if ((Boolean)jailBreak(c.getMethod("isNewSessionHolder")).invoke(txObject))
        TransactionSynchronizationManager.unbindResource(getSessionFactory());

      // Remove the JDBC connection holder from the thread, if exposed.
      if (getDataSource() != null)
        TransactionSynchronizationManager.unbindResource(getDataSource());

      final SessionHolder sessionHolder = (SessionHolder)jailBreak(c.getMethod("getSessionHolder")).invoke(txObject);
      final Session session = sessionHolder.getSession();
      if ((Boolean)jailBreak(HibernateTransactionManager.class.getDeclaredField("prepareConnection")).get(this)
          && session.isConnected() && isSameConnectionForEntireSession(session))
      {
        // We're running with connection release mode "on_close": We're able to reset
        // the isolation level and/or read-only flag of the JDBC Connection here.
        // Else, we need to rely on the connection pool to perform proper cleanup.
        try {
          final Connection con = ((SessionImplementor) session).connection();
          DataSourceUtils.resetConnectionAfterTransaction(con, txObject.getPreviousIsolationLevel());
        }
        catch (HibernateException ex) {
          logger.debug("Could not access JDBC Connection of Hibernate Session", ex);
        }
      }
      if ((Boolean)jailBreak(c.getMethod("isNewSession")).invoke(txObject)) {
        logger.debug("Closing Hibernate Session [{}] after transaction",  session);
        SessionFactoryUtils.closeSession(session);
      }
      else {
        logger.debug("Not closing pre-bound Hibernate Session [{}] after transaction", session);
        if (sessionHolder.getPreviousFlushMode() != null)
          session.setFlushMode(sessionHolder.getPreviousFlushMode());
      }
      sessionHolder.clear();
    }
    catch (ReflectiveOperationException e) { throw new RuntimeException(e); }
  }

  static <T extends AccessibleObject> T jailBreak(T o) { o.setAccessible(true); return o; }
}

由于我认为我的方法是生成 ResultSet 支持的响应的“正确方法”，并且由于 Streams API 使这种方法非常方便，所以我想以受支持的方式解决这个问题。

有没有办法在没有我的黑客的情况下获得相同的行为？如果不是，那么通过 Spring 的 Jira 请求这是一件好事吗？

4

1 回答 1

1

打扫干净。正如 Marko Topolnik 在这里所说

是的，我错过了保持性设置仅在遇到预先存在的会话时应用的部分。这意味着我的“想法”如何完成它已经是它完成的方式。这也意味着我对失败的评论不适用：您要么想要保持性并跳过会话断开 - 要么您不需要。因此，如果您无法获得可保持性，则没有理由在提交时不断开会话，因此在这种情况下没有理由激活“allowResultSetAccessAfterCompletion”。

于 2015-05-18T00:26:49.577 回答