Commit 5e9ec613 authored by terrymanu's avatar terrymanu
Browse files

for checkstyle

parent 09159efb

sharding-proxy/src/main/java/io/shardingsphere/proxy/backend/common/jdbc/statement/JDBCStatementBackendHandler.java

+8 −8
Original line number Diff line number Diff line
@@ -93,25 +93,25 @@ public final class JDBCStatementBackendHandler extends JDBCBackendHandler { 
    protected PreparedStatement prepareResource(final String dataSourceName, final String unitSql, final SQLStatement sqlStatement) throws SQLException {

        DataSource dataSource = RuleRegistry.getInstance().getDataSourceMap().get(dataSourceName);

        Connection connection = getConnection(dataSource);

        PreparedStatement statement = sqlStatement instanceof InsertStatement ? connection.prepareStatement(unitSql, Statement.RETURN_GENERATED_KEYS) : connection.prepareStatement(unitSql);

        PreparedStatement result = sqlStatement instanceof InsertStatement ? connection.prepareStatement(unitSql, Statement.RETURN_GENERATED_KEYS) : connection.prepareStatement(unitSql);

        for (int i = 0; i < preparedStatementParameters.size(); i++) {

            statement.setObject(i + 1, preparedStatementParameters.get(i).getValue());

            result.setObject(i + 1, preparedStatementParameters.get(i).getValue());

        }

        ProxyPrepareJDBCResource prepareProxyJDBCResource = (ProxyPrepareJDBCResource) getJdbcResource();

        prepareProxyJDBCResource.addConnection(connection);

        prepareProxyJDBCResource.addPrepareStatement(statement);

        return statement;

        prepareProxyJDBCResource.addPrepareStatement(result);

        return result;

    }

    

    @Override

    protected QueryResult newQueryResult(final CommandResponsePackets packet, final int index) {

        MySQLPacketStatementExecuteQueryResult mySQLPacketStatementExecuteQueryResult = new MySQLPacketStatementExecuteQueryResult(packet, columnTypes);

        MySQLPacketStatementExecuteQueryResult result = new MySQLPacketStatementExecuteQueryResult(packet, columnTypes);

        if (ProxyMode.MEMORY_STRICTLY == RuleRegistry.getInstance().getProxyMode()) {

            mySQLPacketStatementExecuteQueryResult.setResultSet(getJdbcResource().getResultSets().get(index));

            result.setResultSet(getJdbcResource().getResultSets().get(index));

        } else {

            mySQLPacketStatementExecuteQueryResult.setResultList(getResultLists().get(index));

            result.setResultList(getResultLists().get(index));

        }

        return mySQLPacketStatementExecuteQueryResult;

        return result;

    }

    

    @Override

sharding-proxy/src/main/java/io/shardingsphere/proxy/backend/common/jdbc/text/JDBCTextBackendHandler.java

+7 −7
Original line number Diff line number Diff line
@@ -64,11 +64,11 @@ public final class JDBCTextBackendHandler extends JDBCBackendHandler { 
    protected Statement prepareResource(final String dataSourceName, final String unitSql, final SQLStatement sqlStatement) throws SQLException {

        DataSource dataSource = RuleRegistry.getInstance().getDataSourceMap().get(dataSourceName);

        Connection connection = getConnection(dataSource);

        Statement statement = connection.createStatement();

        Statement result = connection.createStatement();

        ProxyJDBCResource proxyJDBCResource = (ProxyJDBCResource) getJdbcResource();

        proxyJDBCResource.addConnection(connection);

        proxyJDBCResource.addStatement(statement);

        return statement;

        proxyJDBCResource.addStatement(result);

        return result;

    }

    

    @Override
@@ -78,13 +78,13 @@ public final class JDBCTextBackendHandler extends JDBCBackendHandler { 
    

    @Override

    protected QueryResult newQueryResult(final CommandResponsePackets packet, final int index) {

        MySQLPacketQueryResult mySQLPacketQueryResult = new MySQLPacketQueryResult(packet);

        MySQLPacketQueryResult result = new MySQLPacketQueryResult(packet);

        if (ProxyMode.MEMORY_STRICTLY == RuleRegistry.getInstance().getProxyMode()) {

            mySQLPacketQueryResult.setResultSet(getJdbcResource().getResultSets().get(index));

            result.setResultSet(getJdbcResource().getResultSets().get(index));

        } else {

            mySQLPacketQueryResult.setResultList(getResultLists().get(index));

            result.setResultList(getResultLists().get(index));

        }

        return mySQLPacketQueryResult;

        return result;

    }

    

    @Override