org.apache.shardingsphere.shardingjdbc.executor

Class 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.

Author:

zhangliang, maxiaoguang, panjuan

Constructor Summary

Constructors

Constructor and Description
BatchPreparedStatementExecutor(int resultSetType, int resultSetConcurrency, int resultSetHoldability, boolean returnGeneratedKeys, ShardingConnection shardingConnection)

Method Summary

Modifier and Type	Method and Description
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.

Methods inherited from class org.apache.shardingsphere.shardingjdbc.executor.AbstractStatementExecutor

cacheStatements, executeCallback, isAccumulate

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchPreparedStatementExecutor

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

Method Detail

init

public void init(org.apache.shardingsphere.core.route.SQLRouteResult routeResult)
          throws SQLException

Initialize executor.

Parameters:

routeResult - route result

Throws:

SQLException - SQL exception

addBatchForRouteUnits

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

Add batch for route units.

Parameters:

routeResult - route result

executeBatch

public int[] executeBatch()
                   throws SQLException

Execute batch.

Returns:

execute results

Throws:

SQLException - SQL exception

getStatements

public List<Statement> getStatements()

Get statements.

Returns:

statements

getParameterSet

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

Get parameter sets.

Parameters:

statement - statement

Returns:

parameter sets

clear

public void clear()
           throws SQLException

Description copied from class: AbstractStatementExecutor

Clear data.

Overrides:

clear in class AbstractStatementExecutor

Throws:

SQLException - sql exception