perfect the executeUpdate

apache · Dec 13, 2019 · 4cd3ce5 · 4cd3ce5
1 parent 26b9790
commit 4cd3ce5
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/...a/org/apache/shardingsphere/shardingjdbc/jdbc/core/statement/ShadowPreparedStatement.java b/...a/org/apache/shardingsphere/shardingjdbc/jdbc/core/statement/ShadowPreparedStatement.java
@@ -110,7 +110,15 @@ public ResultSet executeQuery() throws SQLException {
 
     @Override
     public int executeUpdate() throws SQLException {
-        return 0;
+        try {
+            SQLUnit sqlUnit = getSQLUnit(sql);
+            preparedStatement = preparedStatementGenerator.createPreparedStatement(sqlUnit.getSql());
+            replayMethodsInvocation(preparedStatement);
+            replaySetParameter(preparedStatement, sqlUnit.getParameters());
+            return preparedStatement.executeUpdate();
+        } finally {
+            clearParameters();
+        }
     }
 
     @Override