Commit 6138029f authored by terrymanu's avatar terrymanu
Browse files

move executor to core module

parent ec1da2fb

sharding-jdbc/src/main/java/io/shardingsphere/core/executor/SQLExecuteCallback.java→sharding-core/src/main/java/io/shardingsphere/core/executor/sql/SQLExecuteCallback.java

+7 −5
Original line number Diff line number Diff line
@@ -15,15 +15,17 @@ 
 * </p>

 */



package io.shardingsphere.core.executor;

package io.shardingsphere.core.executor.sql;



import com.google.common.eventbus.EventBus;

import io.shardingsphere.core.constant.SQLType;

import io.shardingsphere.core.event.ShardingEventBusInstance;

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

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

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

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

import io.shardingsphere.core.executor.ShardingExecuteCallback;

import io.shardingsphere.core.executor.ShardingGroupExecuteCallback;

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

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

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

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

import lombok.RequiredArgsConstructor;



import java.sql.SQLException;

sharding-jdbc/src/main/java/io/shardingsphere/core/executor/SQLExecuteTemplate.java→sharding-core/src/main/java/io/shardingsphere/core/executor/sql/SQLExecuteTemplate.java

+4 −3
Original line number Diff line number Diff line
@@ -15,12 +15,13 @@ 
 * </p>

 */



package io.shardingsphere.core.executor;

package io.shardingsphere.core.executor.sql;



import io.shardingsphere.core.constant.ConnectionMode;

import io.shardingsphere.core.event.ShardingEventBusInstance;

import io.shardingsphere.core.executor.event.overall.OverallExecutionEvent;

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

import io.shardingsphere.core.executor.ShardingExecuteEngine;

import io.shardingsphere.core.executor.sql.event.overall.OverallExecutionEvent;

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

import lombok.RequiredArgsConstructor;



import java.sql.SQLException;

sharding-core/src/main/java/io/shardingsphere/core/executor/StatementExecuteUnit.java→sharding-core/src/main/java/io/shardingsphere/core/executor/sql/StatementExecuteUnit.java

+1 −1
Original line number Diff line number Diff line
@@ -15,7 +15,7 @@ 
 * </p>

 */



package io.shardingsphere.core.executor;

package io.shardingsphere.core.executor.sql;



import io.shardingsphere.core.routing.SQLExecutionUnit;

sharding-jdbc/src/main/java/io/shardingsphere/core/executor/event/overall/OverallExecutionEvent.java→sharding-core/src/main/java/io/shardingsphere/core/executor/sql/event/overall/OverallExecutionEvent.java

+1 −1
Original line number Diff line number Diff line
@@ -15,7 +15,7 @@ 
 * </p>

 */



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

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



import io.shardingsphere.core.event.ShardingEvent;

import lombok.Getter;

sharding-jdbc/src/main/java/io/shardingsphere/core/executor/event/sql/DMLExecutionEvent.java→sharding-core/src/main/java/io/shardingsphere/core/executor/sql/event/sql/DMLExecutionEvent.java

+1 −1
Original line number Diff line number Diff line
@@ -15,7 +15,7 @@ 
 * </p>

 */



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

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



import io.shardingsphere.core.routing.SQLUnit;