org.apache.shardingsphere.shardingjdbc.executor.batch

类 BatchPreparedStatementExecutor

java.lang.Object

org.apache.shardingsphere.shardingjdbc.executor.AbstractStatementExecutor

org.apache.shardingsphere.shardingjdbc.executor.batch.BatchPreparedStatementExecutor

public final class BatchPreparedStatementExecutor
extends AbstractStatementExecutor

Prepared statement executor to process add batch.

构造器概要

构造器

构造器和说明
BatchPreparedStatementExecutor(int resultSetType, int resultSetConcurrency, int resultSetHoldability, boolean returnGeneratedKeys, ShardingConnection shardingConnection)

方法概要

限定符和类型	方法和说明
void	addBatchForRouteUnits(org.apache.shardingsphere.underlying.executor.context.ExecutionContext executionContext) Add batch for route units.
void	clear() Clear data.
int[]	executeBatch() Execute batch.
List<List<Object>>	getParameterSet(Statement statement) Get parameter sets.
List<Statement>	getStatements() Get statements.
void	init(org.apache.shardingsphere.sql.parser.binder.statement.SQLStatementContext sqlStatementContext) Initialize executor.

从类继承的方法 org.apache.shardingsphere.shardingjdbc.executor.AbstractStatementExecutor

cacheStatements, executeCallback, isAccumulate

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

BatchPreparedStatementExecutor

public BatchPreparedStatementExecutor(int resultSetType,
                                      int resultSetConcurrency,
                                      int resultSetHoldability,
                                      boolean returnGeneratedKeys,
                                      ShardingConnection shardingConnection)

方法详细资料

init

public void init(org.apache.shardingsphere.sql.parser.binder.statement.SQLStatementContext sqlStatementContext)
          throws SQLException

Initialize executor.

参数:

sqlStatementContext - SQL statement context

抛出:

SQLException - SQL exception

addBatchForRouteUnits

public void addBatchForRouteUnits(org.apache.shardingsphere.underlying.executor.context.ExecutionContext executionContext)

Add batch for route units.

参数:

executionContext - execution context

executeBatch

public int[] executeBatch()
                   throws SQLException

Execute batch.

返回:

execute results

抛出:

SQLException - SQL exception

getStatements

public List<Statement> getStatements()

Get statements.

返回:

statements

getParameterSet

public List<List<Object>> getParameterSet(Statement statement)

Get parameter sets.

参数:

statement - statement

返回:

parameter sets

clear

public void clear()
           throws SQLException

从类复制的说明: AbstractStatementExecutor

Clear data.

覆盖:

clear 在类中 AbstractStatementExecutor

抛出:

SQLException - SQL exception