org.apache.shardingsphere.core.execute.sql.execute

Class SQLExecuteCallback<T>

java.lang.Object

org.apache.shardingsphere.core.execute.sql.execute.SQLExecuteCallback<T>

Type Parameters:

T - class type of return value

All Implemented Interfaces:

ShardingGroupExecuteCallback<StatementExecuteUnit,T>

public abstract class SQLExecuteCallback<T>
extends Object
implements ShardingGroupExecuteCallback<StatementExecuteUnit,T>

Statement execute callback interface.

Author:

gaohongtao, zhangliang

Constructor Summary

Constructors

Constructor and Description
SQLExecuteCallback()

Method Summary

Modifier and Type	Method and Description
Collection<T>	execute(Collection<StatementExecuteUnit> statementExecuteUnits, boolean isTrunkThread, Map<String,Object> shardingExecuteDataMap) Execute callback.
protected abstract T	executeSQL(RouteUnit routeUnit, Statement statement, org.apache.shardingsphere.core.constant.ConnectionMode connectionMode)

Methods inherited from class java.lang.Object

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

Constructor Detail

SQLExecuteCallback

public SQLExecuteCallback()

Method Detail

execute

public final Collection<T> execute(Collection<StatementExecuteUnit> statementExecuteUnits,
                                   boolean isTrunkThread,
                                   Map<String,Object> shardingExecuteDataMap)
                            throws SQLException

Description copied from interface: ShardingGroupExecuteCallback

Execute callback.

Specified by:

execute in interface ShardingGroupExecuteCallback<StatementExecuteUnit,T>

Parameters:

statementExecuteUnits - input values

isTrunkThread - is execution in trunk thread

shardingExecuteDataMap - sharding execute data map

Returns:

execute result

Throws:

SQLException - throw when execute failure

executeSQL

protected abstract T executeSQL(RouteUnit routeUnit,
                                Statement statement,
                                org.apache.shardingsphere.core.constant.ConnectionMode connectionMode)
                         throws SQLException

Throws:

SQLException