refactor MasterSlaveStatement

sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/jdbc/core/statement/MasterSlaveStatement.java

@@ -91,7 +91,7 @@ public final class MasterSlaveStatement extends AbstractStatementAdapter {
     private Statement getSingleStatement(final String sql) throws SQLException {
         Collection<Connection> connections = connection.getConnection(sql);
         Preconditions.checkState(1 == connections.size());
-        Statement result = connections.iterator().next().createStatement();
+        Statement result = connections.iterator().next().createStatement(resultSetType, resultSetConcurrency, resultSetHoldability);
         routedStatements.add(result);
         return result;
     }
@@ -100,7 +100,7 @@ public final class MasterSlaveStatement extends AbstractStatementAdapter {
     public boolean execute(final String sql) throws SQLException {
         boolean result = false;
         for (Connection each : connection.getConnection(sql)) {
-            Statement statement = each.createStatement();
+            Statement statement = each.createStatement(resultSetType, resultSetConcurrency, resultSetHoldability);
             routedStatements.add(statement);
             result = statement.execute(sql);
         }
@@ -111,7 +111,7 @@ public final class MasterSlaveStatement extends AbstractStatementAdapter {
     public boolean execute(final String sql, final int autoGeneratedKeys) throws SQLException {
         boolean result = false;
         for (Connection each : connection.getConnection(sql)) {
-            Statement statement = each.createStatement();
+            Statement statement = each.createStatement(resultSetType, resultSetConcurrency, resultSetHoldability);
             routedStatements.add(statement);
             result = statement.execute(sql, autoGeneratedKeys);
         }
@@ -122,7 +122,7 @@ public final class MasterSlaveStatement extends AbstractStatementAdapter {
     public boolean execute(final String sql, final int[] columnIndexes) throws SQLException {
         boolean result = false;
         for (Connection each : connection.getConnection(sql)) {
-            Statement statement = each.createStatement();
+            Statement statement = each.createStatement(resultSetType, resultSetConcurrency, resultSetHoldability);
             routedStatements.add(statement);
             result = statement.execute(sql, columnIndexes);
         }
@@ -133,7 +133,7 @@ public final class MasterSlaveStatement extends AbstractStatementAdapter {
     public boolean execute(final String sql, final String[] columnNames) throws SQLException {
         boolean result = false;
         for (Connection each : connection.getConnection(sql)) {
-            Statement statement = each.createStatement();
+            Statement statement = each.createStatement(resultSetType, resultSetConcurrency, resultSetHoldability);
             routedStatements.add(statement);
             result = statement.execute(sql, columnNames);
         }