io.shardingsphere.core.executor

Class ExecutorEngine

java.lang.Object

io.shardingsphere.core.executor.ExecutorEngine

All Implemented Interfaces:

AutoCloseable

public final class ExecutorEngine
extends Object
implements AutoCloseable

SQL execute engine.

Author:

gaohongtao, zhangliang, maxiaoguang

Constructor Summary

Constructors

Constructor and Description
ExecutorEngine(int executorSize)

Method Summary

Modifier and Type	Method and Description
void	close()
<T> List<T>	execute(SQLType sqlType, Collection<? extends BaseStatementUnit> baseStatementUnits, ExecuteCallback<T> executeCallback) Execute.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutorEngine

public ExecutorEngine(int executorSize)

Method Detail

execute

public <T> List<T> execute(SQLType sqlType,
                           Collection<? extends BaseStatementUnit> baseStatementUnits,
                           ExecuteCallback<T> executeCallback)
                    throws SQLException

Execute.

Type Parameters:

T - class type of return value

Parameters:

sqlType - SQL type

baseStatementUnits - statement execute unitS

executeCallback - prepared statement execute callback

Returns:

execute result

Throws:

SQLException - SQL exception

close

public void close()

Specified by:

close in interface AutoCloseable