捕获异常流输出

Question

我看过很多关于如何使用StreamingOutput 的例子。就我而言，我想用它从数据库查询中流式传输 ResultSet。

ResultSet rs = (ResultSet) obj;
StreamingOutput stream = new StreamingOutput() {
    @Override
    public void write(OutputStream os) throws IOException,
                                       WebApplicationException {
        ResultSetFormatter.outputAsJSON(os, rs);

        res.close();
    }
};

return Response.ok(stream).build();

在这个意义上，write 方法定义包括一个throws IOException, WebApplicationException。我的问题出现在哪里。我需要正确关闭与数据库、结果集等的连接。如果在执行流式传输时抛出异常，我不知道如何捕获它。

我尝试了以下代码，但它不是有效代码，因为 IOException 不是从 try-catch 块中抛出的。

try {
    ....  launch request to database ...
    ResultSet rs = (ResultSet) obj;
    StreamingOutput stream = new StreamingOutput() {
        @Override
        public void write(OutputStream os) throws IOException,
                                           WebApplicationException {
            if (accept.equals("application/json") {
                ResultSetFormatter.outputAsJSON(os, rs);
            } else {
                ResultSetFormatter.outputAsXML(os, rs);
            }

            res.close();
        }
    };

    return Response.ok(stream).build();
} catch (IOException | WebApplicationException e) {
    // Do cleanup
}

我该如何继续？是否可以正确清理所有内容？我什至认为在 write 方法中包含所有数据处理，但问题是，如果不修复，我无法设置响应的内容类型。

TIA

编辑 1：我使用的是基于 Jena 而不是 SQL 数据库的 SPARQL 语句。根据查询的类型，我得到不同类型的响应（模型、结果集或布尔值）。然后每个都有不同的有效内容类型，所以在执行或分析查询之前我无法设置响应的内容类型。

Answer 1

您可以查看try-with-resources，它会自动为您关闭它。

在 Java SE 7 之前，要走的路是通过 finally。无论try 退出点如何，它都会执行。

Answer 2

user8 是对的，但没有提供详细信息。您希望在 write 方法中使用 try-with-resources 语句：

@Override
public void write(OutputStream os) throws IOException,
                                   WebApplicationException {

    try (Statement statement = rs.getStatement();
         Connection conn = statement.getConnection()) {

        if (accept.equals("application/json") {
            ResultSetFormatter.outputAsJSON(os, rs);
        } else {
            ResultSetFormatter.outputAsXML(os, rs);
        }
    }
}

自动关闭语句也会automatically close the ResultSet。