org.apache.shardingsphere.shardingjdbc.executor

Class StatementExecutor

java.lang.Object

org.apache.shardingsphere.shardingjdbc.executor.AbstractStatementExecutor

org.apache.shardingsphere.shardingjdbc.executor.StatementExecutor

public final class StatementExecutor
extends AbstractStatementExecutor

Statement executor.

Author:

gaohongtao, caohao, zhangliang, maxiaoguang, panjuan

Constructor Summary

Constructors

Constructor and Description
StatementExecutor(int resultSetType, int resultSetConcurrency, int resultSetHoldability, ShardingConnection shardingConnection)

Method Summary

Modifier and Type	Method and Description
boolean	execute() Execute SQL.
boolean	execute(int autoGeneratedKeys) Execute SQL with auto generated keys.
boolean	execute(int[] columnIndexes) Execute SQL with column indexes.
boolean	execute(String[] columnNames) Execute SQL with column names.
List<org.apache.shardingsphere.core.execute.sql.execute.result.QueryResult>	executeQuery() Execute query.
int	executeUpdate() Execute update.
int	executeUpdate(int autoGeneratedKeys) Execute update with auto generated keys.
int	executeUpdate(int[] columnIndexes) Execute update with column indexes.
int	executeUpdate(String[] columnNames) Execute update with column names.
void	init(org.apache.shardingsphere.core.route.SQLRouteResult routeResult) Initialize executor.

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

cacheStatements, clear, executeCallback, isAccumulate

Methods inherited from class java.lang.Object

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

Constructor Detail

StatementExecutor

public StatementExecutor(int resultSetType,
                         int resultSetConcurrency,
                         int resultSetHoldability,
                         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

executeQuery

public List<org.apache.shardingsphere.core.execute.sql.execute.result.QueryResult> executeQuery()
                                                                                         throws SQLException

Execute query.

Returns:

result set list

Throws:

SQLException - SQL exception

executeUpdate

public int executeUpdate()
                  throws SQLException

Execute update.

Returns:

effected records count

Throws:

SQLException - SQL exception

executeUpdate

public int executeUpdate(int autoGeneratedKeys)
                  throws SQLException

Execute update with auto generated keys.

Parameters:

autoGeneratedKeys - auto generated keys' flag

Returns:

effected records count

Throws:

SQLException - SQL exception

executeUpdate

public int executeUpdate(int[] columnIndexes)
                  throws SQLException

Execute update with column indexes.

Parameters:

columnIndexes - column indexes

Returns:

effected records count

Throws:

SQLException - SQL exception

executeUpdate

public int executeUpdate(String[] columnNames)
                  throws SQLException

Execute update with column names.

Parameters:

columnNames - column names

Returns:

effected records count

Throws:

SQLException - SQL exception

execute

public boolean execute()
                throws SQLException

Execute SQL.

Returns:

return true if is DQL, false if is DML

Throws:

SQLException - SQL exception

execute

public boolean execute(int autoGeneratedKeys)
                throws SQLException

Execute SQL with auto generated keys.

Parameters:

autoGeneratedKeys - auto generated keys' flag

Returns:

return true if is DQL, false if is DML

Throws:

SQLException - SQL exception

execute

public boolean execute(int[] columnIndexes)
                throws SQLException

Execute SQL with column indexes.

Parameters:

columnIndexes - column indexes

Returns:

return true if is DQL, false if is DML

Throws:

SQLException - SQL exception

execute

public boolean execute(String[] columnNames)
                throws SQLException

Execute SQL with column names.

Parameters:

columnNames - column names

Returns:

return true if is DQL, false if is DML

Throws:

SQLException - SQL exception