add io.shardingsphere.core.metadata.table.executor package

azexcy · Aug 1, 2018 · c778526 · c778526
1 parent cff9022
commit c778526
Show file tree

Hide file tree

Showing 11 changed files with 15 additions and 10 deletions.
diff --git a/sharding-core/src/main/java/io/shardingsphere/core/metadata/table/ShardingTableMetaData.java b/sharding-core/src/main/java/io/shardingsphere/core/metadata/table/ShardingTableMetaData.java
@@ -20,6 +20,9 @@
 import com.google.common.base.Optional;
 import com.google.common.util.concurrent.ListeningExecutorService;
 import io.shardingsphere.core.exception.ShardingException;
+import io.shardingsphere.core.metadata.table.executor.TableLoader;
+import io.shardingsphere.core.metadata.table.executor.TableMetaDataExecutorAdapter;
+import io.shardingsphere.core.metadata.table.executor.TableMetaDataLoader;
 import io.shardingsphere.core.rule.ShardingRule;
 import io.shardingsphere.core.rule.TableRule;
 

diff --git a/...here/core/metadata/table/TableLoader.java → .../metadata/table/executor/TableLoader.java b/...here/core/metadata/table/TableLoader.java → .../metadata/table/executor/TableLoader.java
@@ -15,7 +15,7 @@
  * </p>
  */
 
-package io.shardingsphere.core.metadata.table;
+package io.shardingsphere.core.metadata.table.executor;
 
 import lombok.RequiredArgsConstructor;
 

diff --git a/...a/table/TableMetaDataExecutorAdapter.java → ...xecutor/TableMetaDataExecutorAdapter.java b/...a/table/TableMetaDataExecutorAdapter.java → ...xecutor/TableMetaDataExecutorAdapter.java
@@ -15,7 +15,7 @@
  * </p>
  */
 
-package io.shardingsphere.core.metadata.table;
+package io.shardingsphere.core.metadata.table.executor;
 
 import java.sql.Connection;
 import java.sql.SQLException;

diff --git a/...e/metadata/table/TableMetaDataLoader.java → ...a/table/executor/TableMetaDataLoader.java b/...e/metadata/table/TableMetaDataLoader.java → ...a/table/executor/TableMetaDataLoader.java
@@ -15,12 +15,14 @@
  * </p>
  */
 
-package io.shardingsphere.core.metadata.table;
+package io.shardingsphere.core.metadata.table.executor;
 
 import com.google.common.util.concurrent.Futures;
 import com.google.common.util.concurrent.ListenableFuture;
 import com.google.common.util.concurrent.ListeningExecutorService;
 import io.shardingsphere.core.exception.ShardingException;
+import io.shardingsphere.core.metadata.table.ColumnMetaData;
+import io.shardingsphere.core.metadata.table.TableMetaData;
 import io.shardingsphere.core.rule.DataNode;
 import io.shardingsphere.core.rule.ShardingDataSourceNames;
 import io.shardingsphere.core.rule.ShardingRule;

diff --git a/...c/src/main/java/io/shardingsphere/core/jdbc/core/statement/ShardingPreparedStatement.java b/...c/src/main/java/io/shardingsphere/core/jdbc/core/statement/ShardingPreparedStatement.java
@@ -39,7 +39,7 @@
 import io.shardingsphere.core.merger.event.EventMergeType;
 import io.shardingsphere.core.merger.event.ResultSetMergeEvent;
 import io.shardingsphere.core.metadata.table.ShardingTableMetaData;
-import io.shardingsphere.core.metadata.table.TableMetaDataLoader;
+import io.shardingsphere.core.metadata.table.executor.TableMetaDataLoader;
 import io.shardingsphere.core.parsing.parser.sql.dal.DALStatement;
 import io.shardingsphere.core.parsing.parser.sql.dml.insert.InsertStatement;
 import io.shardingsphere.core.parsing.parser.sql.dql.DQLStatement;

diff --git a/...ding-jdbc/src/main/java/io/shardingsphere/core/jdbc/core/statement/ShardingStatement.java b/...ding-jdbc/src/main/java/io/shardingsphere/core/jdbc/core/statement/ShardingStatement.java
@@ -35,7 +35,7 @@
 import io.shardingsphere.core.merger.event.EventMergeType;
 import io.shardingsphere.core.merger.event.ResultSetMergeEvent;
 import io.shardingsphere.core.metadata.table.ShardingTableMetaData;
-import io.shardingsphere.core.metadata.table.TableMetaDataLoader;
+import io.shardingsphere.core.metadata.table.executor.TableMetaDataLoader;
 import io.shardingsphere.core.parsing.parser.sql.dal.DALStatement;
 import io.shardingsphere.core.parsing.parser.sql.dml.insert.InsertStatement;
 import io.shardingsphere.core.parsing.parser.sql.dql.DQLStatement;

diff --git a/.../java/io/shardingsphere/core/jdbc/metadata/DataSourceMapTableMetaDataExecutorAdapter.java b/.../java/io/shardingsphere/core/jdbc/metadata/DataSourceMapTableMetaDataExecutorAdapter.java
@@ -17,7 +17,7 @@
 
 package io.shardingsphere.core.jdbc.metadata;
 
-import io.shardingsphere.core.metadata.table.TableMetaDataExecutorAdapter;
+import io.shardingsphere.core.metadata.table.executor.TableMetaDataExecutorAdapter;
 import lombok.RequiredArgsConstructor;
 
 import javax.sql.DataSource;

diff --git a/.../io/shardingsphere/core/jdbc/metadata/ShardingConnectionTableMetaDataExecutorAdapter.java b/.../io/shardingsphere/core/jdbc/metadata/ShardingConnectionTableMetaDataExecutorAdapter.java
@@ -18,7 +18,7 @@
 package io.shardingsphere.core.jdbc.metadata;
 
 import io.shardingsphere.core.jdbc.core.connection.ShardingConnection;
-import io.shardingsphere.core.metadata.table.TableMetaDataExecutorAdapter;
+import io.shardingsphere.core.metadata.table.executor.TableMetaDataExecutorAdapter;
 import lombok.RequiredArgsConstructor;
 
 import java.sql.Connection;

diff --git a/sharding-proxy/src/main/java/io/shardingsphere/proxy/backend/jdbc/JDBCBackendHandler.java b/sharding-proxy/src/main/java/io/shardingsphere/proxy/backend/jdbc/JDBCBackendHandler.java
@@ -23,7 +23,7 @@
 import io.shardingsphere.core.constant.TransactionType;
 import io.shardingsphere.core.merger.MergeEngineFactory;
 import io.shardingsphere.core.merger.MergedResult;
-import io.shardingsphere.core.metadata.table.TableMetaDataLoader;
+import io.shardingsphere.core.metadata.table.executor.TableMetaDataLoader;
 import io.shardingsphere.core.parsing.parser.sql.SQLStatement;
 import io.shardingsphere.core.parsing.parser.sql.dml.insert.InsertStatement;
 import io.shardingsphere.core.routing.SQLRouteResult;

diff --git a/...g-proxy/src/main/java/io/shardingsphere/proxy/backend/netty/SQLPacketsBackendHandler.java b/...g-proxy/src/main/java/io/shardingsphere/proxy/backend/netty/SQLPacketsBackendHandler.java
@@ -26,7 +26,7 @@
 import io.shardingsphere.core.merger.MergeEngineFactory;
 import io.shardingsphere.core.merger.MergedResult;
 import io.shardingsphere.core.merger.QueryResult;
-import io.shardingsphere.core.metadata.table.TableMetaDataLoader;
+import io.shardingsphere.core.metadata.table.executor.TableMetaDataLoader;
 import io.shardingsphere.core.parsing.SQLJudgeEngine;
 import io.shardingsphere.core.parsing.parser.sql.SQLStatement;
 import io.shardingsphere.core.routing.SQLExecutionUnit;

diff --git a/...oxy/src/main/java/io/shardingsphere/proxy/metadata/ProxyTableMetaDataExecutorAdapter.java b/...oxy/src/main/java/io/shardingsphere/proxy/metadata/ProxyTableMetaDataExecutorAdapter.java
@@ -17,7 +17,7 @@
 
 package io.shardingsphere.proxy.metadata;
 
-import io.shardingsphere.core.metadata.table.TableMetaDataExecutorAdapter;
+import io.shardingsphere.core.metadata.table.executor.TableMetaDataExecutorAdapter;
 import io.shardingsphere.proxy.backend.jdbc.datasource.JDBCBackendDataSource;
 import lombok.RequiredArgsConstructor;