ExecuteCallback => SQLExecuteCallback

 * 

 * @param <T> class type of return value

 */

public interface JDBCExecuteCallback<T> {

public interface JDBCExecutor<T> {

    /**

     * execute JDBC.

 * @param <T> class type of return value

 */

@RequiredArgsConstructor

public final class ExecuteCallback<T> implements ShardingExecuteCallback<BaseStatementUnit, T> {

public final class SQLExecuteCallback<T> implements ShardingExecuteCallback<BaseStatementUnit, T> {

    @Getter

    private final SQLType sqlType;

    private final Map<String, Object> dataMap;

    private final JDBCExecuteCallback<T> jdbcCallback;

    private final JDBCExecutor<T> jdbcCallback;

    private final EventBus shardingEventBus = ShardingEventBusInstance.getInstance();

 * @author maxiaoguang

 * @author panjuan

 */

public final class ExecutorEngine implements AutoCloseable {

public final class SQLExecutorEngine implements AutoCloseable {

    @Getter

    private final ShardingExecuteEngine shardingExecuteEngine;

    private final ConnectionMode connectionMode;

    public ExecutorEngine(final int executorSize, final ConnectionMode connectionMode) {

    public SQLExecutorEngine(final int executorSize, final ConnectionMode connectionMode) {

        shardingExecuteEngine = new ShardingExecuteEngine(executorSize);

        this.connectionMode = connectionMode;

    }

     * @return execute result

     * @throws SQLException SQL exception

     */

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

    public <T> List<T> execute(final Collection<? extends BaseStatementUnit> baseStatementUnits, final SQLExecuteCallback<T> executeCallback) throws SQLException {

        OverallExecutionEvent event = new OverallExecutionEvent(executeCallback.getSqlType(), baseStatementUnits.size() > 1);

        ShardingEventBusInstance.getInstance().post(event);

        try {

import io.shardingsphere.core.constant.DatabaseType;

import io.shardingsphere.core.constant.SQLType;

import io.shardingsphere.core.executor.BaseStatementUnit;

import io.shardingsphere.core.executor.ExecuteCallback;

import io.shardingsphere.core.executor.ExecutorEngine;

import io.shardingsphere.core.executor.JDBCExecuteCallback;

import io.shardingsphere.core.executor.SQLExecuteCallback;

import io.shardingsphere.core.executor.SQLExecutorEngine;

import io.shardingsphere.core.executor.JDBCExecutor;

import io.shardingsphere.core.executor.threadlocal.ExecutorDataMap;

import io.shardingsphere.core.executor.threadlocal.ExecutorExceptionHandler;

import lombok.RequiredArgsConstructor;

@RequiredArgsConstructor

public final class BatchPreparedStatementExecutor {

    private final ExecutorEngine executorEngine;

    private final SQLExecutorEngine executorEngine;

    private final DatabaseType dbType;

    public int[] executeBatch() throws SQLException {

        final boolean isExceptionThrown = ExecutorExceptionHandler.isExceptionThrown();

        final Map<String, Object> dataMap = ExecutorDataMap.getDataMap();

        ExecuteCallback<int[]> executeCallback = new ExecuteCallback<>(sqlType, isExceptionThrown, dataMap, new JDBCExecuteCallback<int[]>() {

        SQLExecuteCallback<int[]> executeCallback = new SQLExecuteCallback<>(sqlType, isExceptionThrown, dataMap, new JDBCExecutor<int[]>() {

            @Override

            public int[] execute(final BaseStatementUnit baseStatementUnit) throws SQLException {

import io.shardingsphere.core.constant.SQLType;

import io.shardingsphere.core.executor.BaseStatementUnit;

import io.shardingsphere.core.executor.ExecuteCallback;

import io.shardingsphere.core.executor.ExecutorEngine;

import io.shardingsphere.core.executor.JDBCExecuteCallback;

import io.shardingsphere.core.executor.SQLExecuteCallback;

import io.shardingsphere.core.executor.SQLExecutorEngine;

import io.shardingsphere.core.executor.JDBCExecutor;

import io.shardingsphere.core.executor.threadlocal.ExecutorDataMap;

import io.shardingsphere.core.executor.threadlocal.ExecutorExceptionHandler;

import lombok.RequiredArgsConstructor;

@RequiredArgsConstructor

public final class PreparedStatementExecutor {

    private final ExecutorEngine executorEngine;

    private final SQLExecutorEngine executorEngine;

    private final SQLType sqlType;

    public List<ResultSet> executeQuery() throws SQLException {

        final boolean isExceptionThrown = ExecutorExceptionHandler.isExceptionThrown();

        final Map<String, Object> dataMap = ExecutorDataMap.getDataMap();

        ExecuteCallback<ResultSet> executeCallback = new ExecuteCallback<>(sqlType, isExceptionThrown, dataMap, new JDBCExecuteCallback<ResultSet>() {

        SQLExecuteCallback<ResultSet> executeCallback = new SQLExecuteCallback<>(sqlType, isExceptionThrown, dataMap, new JDBCExecutor<ResultSet>() {

            @Override

            public ResultSet execute(final BaseStatementUnit baseStatementUnit) throws SQLException {

    public int executeUpdate() throws SQLException {

        final boolean isExceptionThrown = ExecutorExceptionHandler.isExceptionThrown();

        final Map<String, Object> dataMap = ExecutorDataMap.getDataMap();

        ExecuteCallback<Integer> executeCallback = new ExecuteCallback<>(sqlType, isExceptionThrown, dataMap, new JDBCExecuteCallback<Integer>() {

        SQLExecuteCallback<Integer> executeCallback = new SQLExecuteCallback<>(sqlType, isExceptionThrown, dataMap, new JDBCExecutor<Integer>() {

            @Override

            public Integer execute(final BaseStatementUnit baseStatementUnit) throws SQLException {

    public boolean execute() throws SQLException {

        boolean isExceptionThrown = ExecutorExceptionHandler.isExceptionThrown();

        Map<String, Object> dataMap = ExecutorDataMap.getDataMap();

        ExecuteCallback<Boolean> executeCallback = new ExecuteCallback<>(sqlType, isExceptionThrown, dataMap, new JDBCExecuteCallback<Boolean>() {

        SQLExecuteCallback<Boolean> executeCallback = new SQLExecuteCallback<>(sqlType, isExceptionThrown, dataMap, new JDBCExecutor<Boolean>() {

            @Override

            public Boolean execute(final BaseStatementUnit baseStatementUnit) throws SQLException {