Commit c811b6ff authored by yangyi15's avatar yangyi15
Browse files

for #372, clear routedStatements in ShardingPreparedStatement before do execute

parent 81076280

sharding-jdbc/src/main/java/io/shardingsphere/core/jdbc/core/statement/ShardingPreparedStatement.java

+3 −0
Original line number Diff line number Diff line
@@ -129,6 +129,7 @@ public final class ShardingPreparedStatement extends AbstractShardingPreparedSta 
    

    @Override

    public ResultSet executeQuery() throws SQLException {

        routedStatements.clear();

        ResultSet result;

        try {

            Collection<PreparedStatementUnit> preparedStatementUnits = route();
@@ -150,6 +151,7 @@ public final class ShardingPreparedStatement extends AbstractShardingPreparedSta 
    

    @Override

    public int executeUpdate() throws SQLException {

        routedStatements.clear();

        try {

            Collection<PreparedStatementUnit> preparedStatementUnits = route();

            return new PreparedStatementExecutor(
@@ -164,6 +166,7 @@ public final class ShardingPreparedStatement extends AbstractShardingPreparedSta 
    

    @Override

    public boolean execute() throws SQLException {

        routedStatements.clear();

        try {

            Collection<PreparedStatementUnit> preparedStatementUnits = route();

            return new PreparedStatementExecutor(