diff --git a/symmetric-jdbc/src/main/java/org/jumpmind/db/sql/JdbcSqlTemplate.java b/symmetric-jdbc/src/main/java/org/jumpmind/db/sql/JdbcSqlTemplate.java index 8ce21e96a3..1e18aaa085 100644 --- a/symmetric-jdbc/src/main/java/org/jumpmind/db/sql/JdbcSqlTemplate.java +++ b/symmetric-jdbc/src/main/java/org/jumpmind/db/sql/JdbcSqlTemplate.java @@ -285,7 +285,8 @@ public Integer execute(Connection con) throws SQLException { try { stmt = con.createStatement(); stmt.setQueryTimeout(settings.getQueryTimeout()); - return stmt.executeUpdate(sql); + stmt.execute(sql); + return stmt.getUpdateCount(); } finally { close(stmt); } @@ -300,7 +301,8 @@ public Integer execute(Connection con) throws SQLException { } else { setValues(ps, args); } - return ps.executeUpdate(); + ps.execute(); + return ps.getUpdateCount(); } finally { close(ps); }