Merge pull request #1050 from KomachiSion/dev

for #372, clear routedStatements in ShardingPreparedStatement before …
apache · Jul 25, 2018 · 7807eef · 7807eef
2 parents ae89665 + c811b6f
commit 7807eef
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...c/src/main/java/io/shardingsphere/core/jdbc/core/statement/ShardingPreparedStatement.java b/...c/src/main/java/io/shardingsphere/core/jdbc/core/statement/ShardingPreparedStatement.java
@@ -129,6 +129,7 @@ public ShardingPreparedStatement(final ShardingConnection connection, final Stri
 
     @Override
     public ResultSet executeQuery() throws SQLException {
+        routedStatements.clear();
         ResultSet result;
         try {
             Collection<PreparedStatementUnit> preparedStatementUnits = route();
@@ -150,6 +151,7 @@ public ResultSet executeQuery() throws SQLException {
 
     @Override
     public int executeUpdate() throws SQLException {
+        routedStatements.clear();
         try {
             Collection<PreparedStatementUnit> preparedStatementUnits = route();
             return new PreparedStatementExecutor(
@@ -164,6 +166,7 @@ public int executeUpdate() throws SQLException {
 
     @Override
     public boolean execute() throws SQLException {
+        routedStatements.clear();
         try {
             Collection<PreparedStatementUnit> preparedStatementUnits = route();
             return new PreparedStatementExecutor(