create package for jdbc backend

 * </p>

 */

package io.shardingsphere.proxy.backend.common;

package io.shardingsphere.proxy.backend.common.jdbc;

import io.shardingsphere.core.constant.DatabaseType;

import io.shardingsphere.core.constant.SQLType;

import io.shardingsphere.core.routing.SQLRouteResult;

import io.shardingsphere.core.routing.SQLUnit;

import io.shardingsphere.core.routing.router.masterslave.MasterSlaveRouter;

import io.shardingsphere.proxy.backend.common.BackendHandler;

import io.shardingsphere.proxy.backend.common.ProxyConnectionHolder;

import io.shardingsphere.proxy.backend.common.ProxyMode;

import io.shardingsphere.proxy.backend.common.ResultList;

import io.shardingsphere.proxy.backend.resource.BaseJDBCResource;

import io.shardingsphere.proxy.config.RuleRegistry;

import io.shardingsphere.proxy.metadata.ProxyShardingRefreshHandler;

import java.util.concurrent.Future;

/**

 * Abstract ExecuteBackendHandler for SQL or PrepareStatement.

 * Backend handler via JDBC to connect databases.

 *

 * @author zhaojun

 */

@Getter

@Slf4j

public abstract class ExecuteBackendHandler implements BackendHandler {

public abstract class JDBCBackendHandler implements BackendHandler {

    private final String sql;

    private final List<ResultList> resultLists = new CopyOnWriteArrayList<>();

    public ExecuteBackendHandler(final String sql, final DatabaseType databaseType, final boolean showSQL) {

    public JDBCBackendHandler(final String sql, final DatabaseType databaseType, final boolean showSQL) {

        this.sql = sql;

        isMerged = false;

        hasMoreResultValueFlag = true;

 * </p>

 */

package io.shardingsphere.proxy.backend.common;

package io.shardingsphere.proxy.backend.common.jdbc;

import io.shardingsphere.core.parsing.parser.sql.SQLStatement;

import io.shardingsphere.core.routing.router.masterslave.MasterVisitedManager;

import java.util.concurrent.Callable;

/**

 * Execute worker.

 * 

 * <p>Include SQL and PreparedStatement implement.</p>

 * Execute worker via JDBC to connect databases.

 * 

 * @author zhaojun

 */

@AllArgsConstructor

@Getter

@Slf4j

public abstract class ExecuteWorker implements Callable<CommandResponsePackets> {

public abstract class JDBCExecuteWorker implements Callable<CommandResponsePackets> {

    private final ExecuteBackendHandler executeBackendHandler;

    private final JDBCBackendHandler executeBackendHandler;

    private final SQLStatement sqlStatement;

 * </p>

 */

package io.shardingsphere.proxy.backend.common;

package io.shardingsphere.proxy.backend.common.jdbc.statement;

import io.shardingsphere.core.constant.DatabaseType;

import io.shardingsphere.core.merger.QueryResult;

import io.shardingsphere.core.parsing.parser.sql.dml.insert.InsertStatement;

import io.shardingsphere.core.routing.PreparedStatementRoutingEngine;

import io.shardingsphere.core.routing.SQLRouteResult;

import io.shardingsphere.proxy.backend.common.ProxyMode;

import io.shardingsphere.proxy.backend.common.jdbc.JDBCBackendHandler;

import io.shardingsphere.proxy.backend.mysql.MySQLPacketStatementExecuteQueryResult;

import io.shardingsphere.proxy.backend.resource.ProxyJDBCResourceFactory;

import io.shardingsphere.proxy.backend.resource.ProxyPrepareJDBCResource;

import java.util.concurrent.CopyOnWriteArrayList;

/**

 * Statement execute backend handler.

 * Statement protocol backend handler via JDBC to connect databases.

 *

 * @author zhangyonglun

 * @author zhaojun

 */

public final class StatementExecuteBackendHandler extends ExecuteBackendHandler implements BackendHandler {

public final class JDBCStatementBackendHandler extends JDBCBackendHandler {

    private final List<PreparedStatementParameter> preparedStatementParameters;

    @Getter

    private final List<ColumnType> columnTypes;

    public StatementExecuteBackendHandler(final List<PreparedStatementParameter> preparedStatementParameters, final int statementId,

    public JDBCStatementBackendHandler(final List<PreparedStatementParameter> preparedStatementParameters, final int statementId,

                                       final DatabaseType databaseType, final boolean showSQL) {

        super(PreparedStatementRegistry.getInstance().getSQL(statementId), databaseType, showSQL);

        super.setJdbcResource(ProxyJDBCResourceFactory.newPrepareResource());

    @Override

    protected Callable<CommandResponsePackets> newSubmitTask(final Statement statement, final SQLStatement sqlStatement, final String unitSql) {

        return new StatementExecuteWorker(this, sqlStatement, (PreparedStatement) statement);

        return new JDBCStatementExecuteWorker(this, sqlStatement, (PreparedStatement) statement);

    }

    @Override

 * </p>

 */

package io.shardingsphere.proxy.backend.common;

package io.shardingsphere.proxy.backend.common.jdbc.statement;

import io.shardingsphere.core.parsing.parser.sql.SQLStatement;

import io.shardingsphere.core.parsing.parser.sql.dml.insert.InsertStatement;

import io.shardingsphere.proxy.backend.common.jdbc.JDBCExecuteWorker;

import io.shardingsphere.proxy.backend.common.ResultList;

import io.shardingsphere.proxy.transport.mysql.constant.ColumnType;

import io.shardingsphere.proxy.transport.mysql.packet.command.CommandResponsePackets;

import io.shardingsphere.proxy.transport.mysql.packet.generic.OKPacket;

 * @author zhangyonglun

 * @author zhaojun

 */

public final class StatementExecuteWorker extends ExecuteWorker implements Callable<CommandResponsePackets> {

public final class JDBCStatementExecuteWorker extends JDBCExecuteWorker implements Callable<CommandResponsePackets> {

    private static final Integer FETCH_ONE_ROW_A_TIME = Integer.MIN_VALUE;

    private final PreparedStatement preparedStatement;

    public StatementExecuteWorker(final StatementExecuteBackendHandler statementExecuteBackendHandler, final SQLStatement sqlStatement, final PreparedStatement preparedStatement) {

    public JDBCStatementExecuteWorker(final JDBCStatementBackendHandler statementExecuteBackendHandler, final SQLStatement sqlStatement, final PreparedStatement preparedStatement) {

        super(statementExecuteBackendHandler, sqlStatement);

        this.preparedStatement = preparedStatement;

    }

    @Override

    protected void setColumnType(final ColumnType columnType) {

        ((StatementExecuteBackendHandler) getExecuteBackendHandler()).getColumnTypes().add(columnType);

        ((JDBCStatementBackendHandler) getExecuteBackendHandler()).getColumnTypes().add(columnType);

    }

    @Override

 * </p>

 */

package io.shardingsphere.proxy.backend.common;

package io.shardingsphere.proxy.backend.common.jdbc.text;

import io.shardingsphere.core.constant.DatabaseType;

import io.shardingsphere.core.merger.QueryResult;

import io.shardingsphere.core.parsing.parser.sql.SQLStatement;

import io.shardingsphere.core.routing.SQLRouteResult;

import io.shardingsphere.core.routing.StatementRoutingEngine;

import io.shardingsphere.proxy.backend.common.ProxyMode;

import io.shardingsphere.proxy.backend.common.jdbc.JDBCBackendHandler;

import io.shardingsphere.proxy.backend.mysql.MySQLPacketQueryResult;

import io.shardingsphere.proxy.backend.resource.ProxyJDBCResource;

import io.shardingsphere.proxy.backend.resource.ProxyJDBCResourceFactory;

import java.util.concurrent.Callable;

/**

 * SQL execute backend handler.

 * Text protocol backend handler via JDBC to connect databases.

 *

 * @author zhangliang

 * @author panjuan

 * @author zhaojun

 */

public final class SQLExecuteBackendHandler extends ExecuteBackendHandler implements BackendHandler {

public final class JDBCTextBackendHandler extends JDBCBackendHandler {

    public SQLExecuteBackendHandler(final String sql, final DatabaseType databaseType, final boolean showSQL) {

    public JDBCTextBackendHandler(final String sql, final DatabaseType databaseType, final boolean showSQL) {

        super(sql, databaseType, showSQL);

        super.setJdbcResource(ProxyJDBCResourceFactory.newResource());

        setJdbcResource(ProxyJDBCResourceFactory.newResource());

    }

    @Override

    @Override

    protected Callable<CommandResponsePackets> newSubmitTask(final Statement statement, final SQLStatement sqlStatement, final String unitSql) {

        return new SQLExecuteWorker(this, sqlStatement, statement, unitSql);

        return new JDBCTextExecuteWorker(this, sqlStatement, statement, unitSql);

    }

    @Override