如何在数据库连接中正确使用 try-with-resources?
How to properly use try-with-resources in Database connection?
我环顾四周,但似乎找不到问题的答案。
这是上下文:我必须在我的 Java 程序中连接到数据库并执行我无法控制的 SQL 请求并且事先不知道。为此,我使用下面的代码。
public Collection<HashMap<String, String>> runQuery(String request, int maxRows) {
List<HashMap<String, String>> resultList = new ArrayList<>();
DataSource datasource = null;
try {
Context initContext = new InitialContext();
datasource = (DataSource) initContext.lookup("java:jboss/datasources/xxxxDS");
} catch (NamingException ex) {
// throw something.
}
try (Connection conn = datasource.getConnection();
Statement statement = conn.createStatement();
ResultSet rs = statement.executeQuery(request); ) {
while (rs.next())
{
HashMap<String, String> map = new HashMap<>();
for (int i = 1; i <= rs.getMetaData().getColumnCount(); i++) {
map.put(rs.getMetaData().getColumnName(i).toUpperCase(), rs.getString(i));
}
resultList.add(map);
}
} catch (SQLException ex) {
// throw something.
}
return resultList;
}
我面临的问题是: 如您所见,还有另一个参数 maxRows
我没有使用。我需要将此指定到 statement
,但不能在 try-with-resources
中指定。
我想通过在第一个方法中嵌套另一个 try-with-resources
来指定最大行数(就像在这个代码示例中一样),从而避免增加这种方法的认知复杂性。
try (Connection conn = datasource.getConnection();
Statement statement = conn.createStatement(); ) {
statement.setMaxRows(maxRows);
try (ResultSet rs = statement.executeQuery(request); ) {
while (rs.next())
{
HashMap<String, String> map = new HashMap<>();
for (int i = 1; i <= rs.getMetaData().getColumnCount(); i++) {
map.put(rs.getMetaData().getColumnName(i).toUpperCase(), rs.getString(i));
}
resultList.add(map);
}
}
} catch (SQLException ex) {
// throw something.
}
有没有办法只用一个try-with-resources
?
如果您可以使用其他方法,那么只使用一个 try-resources 是可能的
而不是Statement statement = conn.createStatement();
Statement statement = createStatement(conn, maxRows);
在该新方法中,创建 Statement 对象并设置 maxRows 和 return 语句对象。
您可以添加一个辅助方法来在单个 try-with-resources 块中执行此操作:
private static <T, E extends Exception> T configured(T resource, ThrowingConsumer<? super T, E> configuration) throws E {
configuration.accept(resource);
return resource;
}
private interface ThrowingConsumer<T, E extends Exception> {
void accept(T value) throws E;
}
并像这样使用它:
try (Connection conn = null
; Statement statement = configured(conn.createStatement(), stmt -> stmt.setMaxRows(maxRows))
; ResultSet rs = statement.executeQuery(request)) {
}
我环顾四周,但似乎找不到问题的答案。
这是上下文:我必须在我的 Java 程序中连接到数据库并执行我无法控制的 SQL 请求并且事先不知道。为此,我使用下面的代码。
public Collection<HashMap<String, String>> runQuery(String request, int maxRows) {
List<HashMap<String, String>> resultList = new ArrayList<>();
DataSource datasource = null;
try {
Context initContext = new InitialContext();
datasource = (DataSource) initContext.lookup("java:jboss/datasources/xxxxDS");
} catch (NamingException ex) {
// throw something.
}
try (Connection conn = datasource.getConnection();
Statement statement = conn.createStatement();
ResultSet rs = statement.executeQuery(request); ) {
while (rs.next())
{
HashMap<String, String> map = new HashMap<>();
for (int i = 1; i <= rs.getMetaData().getColumnCount(); i++) {
map.put(rs.getMetaData().getColumnName(i).toUpperCase(), rs.getString(i));
}
resultList.add(map);
}
} catch (SQLException ex) {
// throw something.
}
return resultList;
}
我面临的问题是: 如您所见,还有另一个参数 maxRows
我没有使用。我需要将此指定到 statement
,但不能在 try-with-resources
中指定。
我想通过在第一个方法中嵌套另一个 try-with-resources
来指定最大行数(就像在这个代码示例中一样),从而避免增加这种方法的认知复杂性。
try (Connection conn = datasource.getConnection();
Statement statement = conn.createStatement(); ) {
statement.setMaxRows(maxRows);
try (ResultSet rs = statement.executeQuery(request); ) {
while (rs.next())
{
HashMap<String, String> map = new HashMap<>();
for (int i = 1; i <= rs.getMetaData().getColumnCount(); i++) {
map.put(rs.getMetaData().getColumnName(i).toUpperCase(), rs.getString(i));
}
resultList.add(map);
}
}
} catch (SQLException ex) {
// throw something.
}
有没有办法只用一个try-with-resources
?
如果您可以使用其他方法,那么只使用一个 try-resources 是可能的
而不是Statement statement = conn.createStatement();
Statement statement = createStatement(conn, maxRows);
在该新方法中,创建 Statement 对象并设置 maxRows 和 return 语句对象。
您可以添加一个辅助方法来在单个 try-with-resources 块中执行此操作:
private static <T, E extends Exception> T configured(T resource, ThrowingConsumer<? super T, E> configuration) throws E {
configuration.accept(resource);
return resource;
}
private interface ThrowingConsumer<T, E extends Exception> {
void accept(T value) throws E;
}
并像这样使用它:
try (Connection conn = null
; Statement statement = configured(conn.createStatement(), stmt -> stmt.setMaxRows(maxRows))
; ResultSet rs = statement.executeQuery(request)) {
}