remove SQL type from OverallExecutionEvent

import io.shardingsphere.core.executor.event.sql.SQLExecutionEventFactory;

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

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

import lombok.Getter;

import lombok.RequiredArgsConstructor;

import java.sql.SQLException;

 * @param <T> class type of return value

 */

@RequiredArgsConstructor

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

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

    @Getter

    private final SQLType sqlType;

    private final boolean isExceptionThrown;

     * @throws SQLException SQL exception

     */

    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);

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

        ShardingEventBusInstance.getInstance().post(event);

        try {

            List<T> result = ConnectionMode.MEMORY_STRICTLY == connectionMode ? shardingExecuteEngine.execute(new LinkedList<>(baseStatementUnits), executeCallback)

package io.shardingsphere.core.executor.event.overall;

import io.shardingsphere.core.constant.SQLType;

import io.shardingsphere.core.event.ShardingEvent;

import lombok.Getter;

import lombok.RequiredArgsConstructor;

@Getter

public final class OverallExecutionEvent extends ShardingEvent {

    private final SQLType sqlType;

    private final boolean parallelExecute;

}

     * @param event overall execution event

     */

    public static void listen(final EventCaller eventCaller, final OverallExecutionEvent event) {

        eventCaller.verifySQLType(event.getSqlType());

        eventCaller.verifyIsParallelExecute(event.isParallelExecute());

        if (ShardingEventType.EXECUTE_FAILURE == event.getEventType()) {

            eventCaller.verifyException(event.getException());

    @Override

    protected void beforeExecute(final OverallExecutionEvent event) {

        ActiveSpan activeSpan = ShardingTracer.get().buildSpan(OPERATION_NAME_PREFIX + event.getSqlType().name()).withTag(Tags.COMPONENT.getKey(), ShardingTags.COMPONENT_NAME).startActive();

        ActiveSpan activeSpan = ShardingTracer.get().buildSpan(OPERATION_NAME_PREFIX).withTag(Tags.COMPONENT.getKey(), ShardingTags.COMPONENT_NAME).startActive();

        SPAN.set(activeSpan);

        if (event.isParallelExecute()) {

            ExecutorDataMap.getDataMap().put(SNAPSHOT_DATA_KEY, activeSpan.capture());