diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/UpdateService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/UpdateService.java index 49156ba0ad..9ed19a6e43 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/UpdateService.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/UpdateService.java @@ -149,9 +149,9 @@ protected void postDataForVersion(URL url, byte[] postData) throws IOException { conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8"); conn.connect(); - OutputStream os = conn.getOutputStream(); - os.write(postData); - os.close(); + try (OutputStream os = conn.getOutputStream()) { + os.write(postData); + } parseHeaders(conn); parseResponse(conn); diff --git a/symmetric-db/src/main/java/org/jumpmind/db/sql/AbstractSqlTemplate.java b/symmetric-db/src/main/java/org/jumpmind/db/sql/AbstractSqlTemplate.java index 050bcf9e45..ec8bc9b7ba 100644 --- a/symmetric-db/src/main/java/org/jumpmind/db/sql/AbstractSqlTemplate.java +++ b/symmetric-db/src/main/java/org/jumpmind/db/sql/AbstractSqlTemplate.java @@ -114,8 +114,9 @@ public ISqlReadCursor queryForCursor(String sql, ISqlRowMapper mapper, } public ISqlReadCursor queryForCursor(String sql, ISqlRowMapper mapper, boolean returnLobObjects) { - return queryForCursor(sql, mapper, returnLobObjects); + return queryForCursor(sql, mapper); } + public List query(String sql) { return query(sql, (Object[])null, (int[]) null); }