public void should_close_statement_and_resultset() throws SQLException {
Connection connection = getConnection();
try {
- String sql = "SELECT 1";
- if (Oracle.ID.equals(getDatabase().getDialect().getId())) {
- sql = "SELECT 1 FROM DUAL";
- }
- PreparedStatement statement = connection.prepareStatement(sql);
+ PreparedStatement statement = connection.prepareStatement(selectDual());
ResultSet rs = statement.executeQuery();
DatabaseUtils.closeQuietly(rs);
*/
private boolean isClosed(Connection c) {
try {
- c.createStatement().execute("SELECT 1");
+ c.createStatement().execute(selectDual());
return false;
} catch (Exception e) {
return true;
return true;
}
}
+
+ private String selectDual() {
+ String sql = "SELECT 1";
+ if (Oracle.ID.equals(getDatabase().getDialect().getId())) {
+ sql = "SELECT 1 FROM DUAL";
+ }
+ return sql;
+ }
}