当我想返回 ResultSet 时在哪里关闭 JDBC 连接

Question

当我关闭Connection时，ResultSet似乎会自动关闭。 但我想返回ResultSet并在另一个方法中使用它，然后我不知道在哪里关闭Connection和PreparedStatement。

public ResultSet executeQuery(String sql, String[] getValue)
{
    Connection conn = null;
    PreparedStatement pstmt = null;
    ResultSet rs = null;
    try
    {
        conn = getConn();
        pstmt = conn.prepareStatement(sql);
        if (getValue != null)
        {
            for (int i = 0; i < getValue.length; i++)
            {
                pstmt.setString(i + 1, getValue[i]);
            }
        }
        rs = pstmt.executeQuery();
    } catch (Exception e)
    {
        e.printStackTrace();
        closeAll(conn, pstmt, rs);
    }
    return rs;
}

我已将 closeAll(conn, pstmt, null); 移至 catch 块中，因为我发现如果将其放入 finally 块中，我会在之前立即丢失我的 rs它返回。 现在，当我想关闭rs时，我无法关闭conn和pstmt。有什么解决办法吗？

Answer 1

使用 CachedRowSet 在断开连接后保存信息

Connection con = ...
ResultSet rs = ...

CachedRowSet rowset = new CachedRowSetImpl();
rowset.populate(rs);

con.close()

Answer 2

一种干净的编码方法是传入一个对象，该对象具有接受结果集的回调方法。

您的其他方法使用回调方法及其 resultSet 处理代码创建对象，并将其传递给执行 SQL 的方法。

这样，您的 SQL 和DB 代码保留在其所属位置，您的结果集处理逻辑更接近您使用数据的位置，并且您的 SQL 代码会在需要时进行清理。

  interface ResultSetCallBack{
    void handleResultSet(ResultSet r);
  }

  void executeQuery(..., ResultSetCallBack cb){
    //get resultSet r ...
    cb.handleResultSet(r);
    //close connection
  }

  void printReport(){
    executeQuery(..., new ResultSetCallBack(){
      public void handleResultSet(ResultSet r) {
        //do stuff with r here
      }
    });
  }

Answer 3

您不应该永远将 ResultSet （或 Statement 或 Connection）传递到它们所在的方法块之外的 public 中被收购并关闭以避免资源泄漏。常见的做法是将 ResultSet 映射到 List，其中 Data 只是表示感兴趣数据的 javabean 对象。

这是一个基本示例：

public class Data {
    private Long id;
    private String name;
    private Integer value;
    // Add/generate public getters + setters.
}

这是一个如何正确处理它的基本示例：

public List<Data> list() throws SQLException {
    Connection connection = null;
    PreparedStatement statement = null;
    ResultSet resultSet = null;
    List<Data> list = new ArrayList<Data>();

    try {
        connection = database.getConnection();
        statement = connection.prepareStatement("SELECT id, name, value FROM data");
        resultSet = statement.executeQuery();
        while (resultSet.next()) {
            Data data = new Data();
            data.setId(resultSet.getLong("id"));
            data.setName(resultSet.getString("name"));
            data.setValue(resultSet.getInt("value"));
            list.add(data);
        }
    } finally {
        if (resultSet != null) try { resultSet.close(); } catch (SQLException logOrIgnore) {}
        if (statement != null) try { statement.close(); } catch (SQLException logOrIgnore) {}
        if (connection != null) try { connection.close(); } catch (SQLException logOrIgnore) {}
    }

    return list;
}

您可以按如下方式使用它：

List<Data> list = dataDAO.list();

要了解有关 JDBC 最佳实践的更多信息，您可以找到 这篇基本的启动文章也很有用。

Answer 4

按照您现在的方式，连接永远不会关闭，这会在以后（如果不是立即）给您的程序和 RDBMS 带来问题。最好创建一个 Java 类来保存 ResultSet 中的字段并返回该字段。 ResultSet 链接到连接，因此无法返回它并关闭连接。

Answer 5

关闭 Connection 和/或 PreparedStatement 后，您将无法使用 ResultSet。
因此，您需要将一个要对其进行回调的对象传递到此方法中。

所有清理工作都应该在finally 块中完成。

像这样重写它

public ResultSet executeQuery(
    String sql,
    String[] getValue,
    CallbackObj cbObj
  ) throws SQLException
{
  final Connection conn = getConn( );

  try
  {
    final PreparedStatement pstmt = conn.prepareStatement(sql);

    try
    {
      if (getValue != null)
      {
        for (int i = 0; i < getValue.length; i++)
        {
          pstmt.setString(i + 1, getValue[i]);
        }
      }

      final ResultSet rs = pstmt.executeQuery();

      try
      {
        cbObj.processResultSet( rs );
      }
      finally
      {
        // You may want to handle SQLException
        // declared by close
        rs.close( );
      }
    }
    finally
    {
      // You may want to handle SQLException
      // declared by close
      pstmt.close( );
    }
  }
  finally
  {
    // You may want to handle SQLException
    // declared by close
    conn.close( );
  }
}

Answer 6

当我想返回结果集时在哪里关闭 JDBC 连接

实际上，您自己几乎已经回答了这个问题。在您进行实验时，关闭 Connection将释放与其关联的 JDBC 资源（至少，事情应该是这样工作的）。因此，如果您想返回 ResultSet （我稍后会讨论这一点），您需要“稍后”关闭连接。执行此操作的一种方法显然是传递与您的方法的连接，如下所示：

public ResultSet executeQuery(Connection conn, String sql, String[] getValue);

问题是我真的不知道您的最终目标是什么以及为什么您需要如此低级的东西，所以我不确定这一点是个好建议。除非您正在编写一个低级 JDBC 框架（请不要告诉我您没有这样做），否则我实际上不建议返回 结果集。例如，如果您想提供某些业务类，请按照其他人的建议返回一些独立于 JDBC 的对象或它们的集合，而不是 结果集。另请记住 RowSet是 ResultSet 因此，如果您不应该使用 ResultSet 那么你不应该使用 RowSet。

就我个人而言，我认为您应该使用一些辅助类，而不是重新发明轮子。虽然 Spring 可能有点矫枉过正，并且有一点学习曲线（如果你根本不知道的话，那就太多了），Spring 并不是唯一的方法，我强烈建议看看 Commons DbUtils。更具体地说，请查看 QueryRunner 尤其是这个query() 方法：

public <T> T query(String sql,
                   ResultSetHandler<T> rsh,
                   Object... params)
        throws SQLException

正如你所看到的，这个方法允许传递 ResultSetHandler 公开了一个回调方法，用于将 ResultSets 转换为其他对象，如 z5h 的答案 和 DbUtils 提供了几种实现，只需选择适合您需要的一种即可。另请查看 DbUtils 类，例如您可能会发现可以方便地关闭 JDBC 资源的各种 DbUnit.close()。

真的，除非你有很好的理由这样做（我很想知道它们），否则不要编写另一个 JDBC 框架，使用现有的解决方案，它会为你减轻一些痛苦，更重要的是，避免一些错误您将受益于经过验证的良好设计。即使对于低级别的东西，也有我们所看到的现有（且简单）的解决方案。至少，检查一下。

Answer 7

您可以调用 ResultSet.getStatement 来检索 Statement，并调用 Statement.getConnection 来检索 Connection。

从这些中，您可以编写一个 closeResultSet 实用程序方法，该方法将为您关闭所有 3 个方法，除了 ResultSet 之外什么都没有。

Answer 8

更简洁的方法是使用CachedRowSetImpl。但在 MySQL 5.x+ 上，按名称或标签选择列存在一些错误。

要与 MySQL 一起使用，请使用此版本：
https://stackoverflow.com/a/17399059/1978096

Answer 9

您确实不应该在较低级别处理 JDBC。使用像 spring 这样的框架，它会处理您所需的所有 close() 操作。

Answer 10

我建议你做更多类似这样的事情：

public List<Map> executeQuery(Connection connection, String sql) throws SQLException
{
    List<Map> rows = new ArrayList<Map>();

    PreparedStatement stmt = null;
    ResultSet rs = null;

    try
    {
        pstmt = conn.prepareStatement(sql);
        rs = stmt.execute();
        int numColumns = rs.getMetaData().getColumnCount();

        while (rs.next())
        {
            Map<String, Object> row = new LinkedHashMap<String, Object>();
            for (int i = 0; i < numColumns; ++i)
            {
                String column = rs.getColumnName(i+1);
                Object value = rs.getObject(i+1);
                row.put(column, value);
            }
            rows.add(row);
        }
    } 
    finally
    {
        close(rs);
        close(stmt);
    }

    return rows;
}

public static void close(Statement s)
{
    try
    {
        if (s != null)
        {
            s.close();
        }
    }
    catch (SQLException e)
    {
        e.printStackTrace();
    }
}

public static void close(ResultSet rs)
{
    try
    {
        if (rs != null)
        {
            rs.close();
        }
    }
    catch (SQLException e)
    {
        e.printStackTrace();
    }
}