org.apache.shardingsphere.sharding.execute.sql.prepare

接口 SQLExecutePrepareCallback

public interface SQLExecutePrepareCallback

SQL execute prepare callback.

方法概要

限定符和类型	方法和说明
StatementExecuteUnit	createStatementExecuteUnit(Connection connection, ExecutionUnit executionUnit, ConnectionMode connectionMode) Create SQL execute unit.
List<Connection>	getConnections(ConnectionMode connectionMode, String dataSourceName, int connectionSize) Get connection.

方法详细资料

getConnections

List<Connection> getConnections(ConnectionMode connectionMode,
                                String dataSourceName,
                                int connectionSize)
                         throws SQLException

Get connection.

参数:

connectionMode - connection mode

dataSourceName - data source name

connectionSize - connection size

返回:

connection

抛出:

SQLException - SQL exception

createStatementExecuteUnit

StatementExecuteUnit createStatementExecuteUnit(Connection connection,
                                                ExecutionUnit executionUnit,
                                                ConnectionMode connectionMode)
                                         throws SQLException

Create SQL execute unit.

参数:

connection - connection

executionUnit - execution unit

connectionMode - connection mode

返回:

SQL execute unit

抛出:

SQLException - SQL exception