如何取消正在运行的 SQL 查询？

Question

我知道statement.cancel()可以用来取消一个正在运行的SQL查询，但我想知道的是，我将如何在另一个线程中获取这个语句对象。

用例：

• 我请求启动一个运行语句的线程。
• 然后从一个单独的请求（另一个线程）我可能想取消这个线程。

如何在这个新请求中获得调用cancel方法的语句。

在某些情况下，我会运行多个语句。

附加信息，它是一个web应用程序，使用spring框架、hibernate和JPA。现在在 UI 中有 2 个按钮，按钮 1 将触发 SQL 查询，按钮 2 必须取消该查询

我提到了this 示例，但它使用同一个线程来调用新线程，我不能这样做。

这是查询的开始方式：

    Query query = mEntityManager.createNativeQuery(globalQuery.toString());
    List<Object[]> results = query.getResultList();

编辑：

1. 我能想到的一种方法是跟踪所有正在运行的语句，然后找到必须取消 SQL 语句的语句。

Answer 1

有两种不同的课程可以帮助您：

如果您想在来自同一用户的两个请求之间交换类似语句的对象，无论这些请求是并行运行还是一个接一个地运行，您通常将它们存储在HttpSession 的HttpServletRequest 中。

并且可以使用Hibernate的Session取消当前查询：

public void startLongRunningStatement() {
  EntityManager entityManager = ...

  // Aquire session
  Session hibernateSession = ((HibernateEntityManager) em.getDelegate()).getSession();

  // Store the HibernateSession in the HttpSession
  HttpSession httpSession = servletRequest.getSession()
  httpSession.setAttribute("hibernateSession", hibernateSession);

  try {
    // Run your query  
    Query query = mEntityManager.createNativeQuery(globalQuery.toString());
    List<?> results = query.getResultList();

  } finally {
    // Clear the session object, if it is still ours
    if (httpSession.getAttribute("hibernateSession") == hibernateSession) {
      httpSession.removeAttribute("hibernateSession");
    }
  }
}

public void cancel() {
  // Get the Hibernate session from the HTTP session
  HttpSession httpSession = servletRequest.getSession()
  Session hibernateSession = (Session) httpSession.getAttribute("hibernateSession");
  if (hibernateSession != null) {
    // Cancel the previous query
    hibernateSession.cancelQuery();
  }

}