org.apache.shardingsphere.shardingjdbc.executor

类 BatchPreparedStatementExecutor

java.lang.Object

org.apache.shardingsphere.shardingjdbc.executor.AbstractStatementExecutor

org.apache.shardingsphere.shardingjdbc.executor.BatchPreparedStatementExecutor

public final class BatchPreparedStatementExecutor
extends AbstractStatementExecutor

Prepared statement executor to process add batch.

作者:

zhangliang, maxiaoguang, panjuan

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
void	addBatchForRouteUnits(org.apache.shardingsphere.core.route.SQLRouteResult routeResult) 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.core.route.SQLRouteResult routeResult) 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.core.route.SQLRouteResult routeResult)
          throws SQLException

Initialize executor.

参数:

routeResult - route result

抛出:

SQLException - SQL exception

addBatchForRouteUnits

public void addBatchForRouteUnits(org.apache.shardingsphere.core.route.SQLRouteResult routeResult)

Add batch for route units.

参数:

routeResult - route result

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