Java 使用 SQL 执行方法但能够访问结果

Question

我没有在代码中到处使用复杂的 SQL 查询、尝试、捕获和终结，而是使用了一个方法 execute(SQL，最多三个输入) 但是，如果尝试访问 ResultsSet，这会在执行之外产生得到错误：

"Operation not allowed after ResultSet closed"

这是因为当您关闭PreparedStatement时，它会关闭ResultsSetToo（并且似乎没有办法解决它）。

有办法解决这个问题吗？我唯一能想到的就是将其转换为存储的数组

非常感谢您的时间，

Answer 1

我过去也遇到过同样的问题。现在我使用这个方法：

public ArrayList<Map<String, String>> getListOfMapsFromSQL(String sql) throws SQLException {
    con = DriverManager.getConnection(url,user,pass);
    stmt = con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
    ArrayList<Map<String, String>> list = new ArrayList<Map<String, String>>();

    rs = stmt.executeQuery(sql);
    ResultSetMetaData rsmd = rs.getMetaData();

    while(rs.next()){
        Map<String, String> fieldsMap = new HashMap<String, String>();
        for(int i=1; i<=rsmd.getColumnCount(); i++){
            fieldsMap.put(rsmd.getColumnLabel(i), rs.getObject(i).toString());
        }
        list.add(fieldsMap);
    }

    list.trimToSize();
    stmt.close();
    con.close();
    return list;
}

它不返回 ResultSet，而是返回一个 Map 列表（每个 Map 代表 1 行）。第一个字符串是列标签，第二个字符串是列的值。我希望它有帮助。 :-)

Answer 2

当您关闭PreparedStatement时，它也会关闭ResultSetToo

正确。因此在处理完结果之前可能不会关闭PreparedStatement。

我会定义一个接口，例如ResultConsumer或execute()的调用者可以实现的类似接口。然后在您的execute()方法中，您只需将结果集传递给消费者即可。

public Interface ResultConsumer
{
   void processResult(ResultSet rs);
}

然后你的execute()可能看起来像这样

public void execute(String SQL, ResultConsumer consumer, ... other parameters)
{
   PreparedStatement stmt = ...
   ResultSet rs = stmt.executeQuery();
   consumer.processResult(rs);
   rs.close();
   stmt.close();
}

（为了清楚起见，我删除了所有错误检查和异常处理，当然你需要处理它）

Answer 3

一段时间前，我也遇到过同样的问题。经过一番思考后，我们决定按照下面的方式进行设计。

public static Properties execute(String string, String[] columnames) throws Exception {

    Properties resulProperties = er.executeQuery(string, columnames);

    return resulProperties;

}

由于某些特定原因，我在类中创建了一个字段，如下所示

private static ExecuteRequest er = new ExecuteRequest();

在 ExecuteRequest 类中使用了以下代码。

public Properties executeQuery(String sqlstatement, String[] columnNames) throws Exception {
    Properties prop = new Properties();
    try {
        prop = creteProperty(sqlstatement, columnNames);
    } catch (Exception e) {
        mlogger.report("Error executing sql statement");
        throw (e);
    }

    return prop;

}

public Properties creteProperty(String sqlstatement, String[] columnNames) throws Exception {
    Properties prop = new Properties();

    try {
        PreparedStatement stmt = ConnectionManager.getInstance().prepareStatement(sqlstatement);
        ResultSet rs = stmt.executeQuery();
        if (rs.next()) {
            for (int i = 0; i < columnNames.length; i++) {
                String key = columnNames[i];
                if (rs.getObject(key) != null) {
                    String value = (rs.getObject(key).toString());
                    prop.setProperty(key, value);
                } else {
                    String value = "";
                    prop.setProperty(key, value);
                }

            }
        }
        rs.close();
    } catch (Exception e) {
        mlogger.report("Error executing sql statement");
        throw (e);
    }
    return prop;

}

您可以使用此方法作为解决方案。