This is an automated email from the ASF dual-hosted git repository.
zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 1322799c4fb Refactor mode.metadata.refresher's package structure
(#34443)
1322799c4fb is described below
commit 1322799c4fb1d97226b8325e55fbe803fa3bc2da
Author: Liang Zhang <[email protected]>
AuthorDate: Thu Jan 23 19:55:59 2025 +0800
Refactor mode.metadata.refresher's package structure (#34443)
---
.../executor/engine/DriverExecuteExecutor.java | 2 +-
.../jdbc/DriverJDBCPushDownExecuteExecutor.java | 2 +-
.../DriverJDBCPushDownExecuteUpdateExecutor.java | 2 +-
.../statistics/collect/StatisticsCollectJob.java | 4 +--
.../metadata/manager/SchemaMetaDataManager.java | 2 +-
.../FederationMetaDataRefresher.java | 2 +-
.../AlterViewFederationMetaDataRefresher.java | 6 ++---
.../CreateViewFederationMetaDataRefresher.java | 6 ++---
.../type}/DropViewFederationMetaDataRefresher.java | 4 +--
.../{ => metadata}/MetaDataRefreshEngine.java | 3 ++-
.../{ => metadata}/MetaDataRefresher.java | 2 +-
.../index/AlterIndexStatementSchemaRefresher.java | 4 +--
.../index/CreateIndexStatementSchemaRefresher.java | 4 +--
.../index/DropIndexStatementSchemaRefresher.java | 4 +--
.../AlterSchemaStatementSchemaRefresher.java | 4 +--
.../CreateSchemaStatementSchemaRefresher.java | 4 +--
.../schema/DropSchemaStatementSchemaRefresher.java | 4 +--
.../table/AlterTableStatementSchemaRefresher.java | 6 ++---
.../table/CreateTableStatementSchemaRefresher.java | 6 ++---
.../table/DropTableStatementSchemaRefresher.java | 6 ++---
.../table/RenameTableStatementSchemaRefresher.java | 6 ++---
.../view/AlterViewStatementSchemaRefresher.java | 6 ++---
.../view/CreateViewStatementSchemaRefresher.java | 6 ++---
.../view/DropViewStatementSchemaRefresher.java | 4 +--
.../{ => metadata}/util/TableRefreshUtils.java | 2 +-
.../{lock => statistics}/StatisticsLock.java | 2 +-
.../StatisticsRefreshEngine.java} | 9 +++----
...phere.mode.metadata.refresher.MetaDataRefresher | 30 ----------------------
...fresher.federation.FederationMetaDataRefresher} | 6 ++---
...e.metadata.refresher.metadata.MetaDataRefresher | 30 ++++++++++++++++++++++
...eTest.java => StatisticsRefreshEngineTest.java} | 5 ++--
.../database/metadata/SchemaChangedHandler.java | 6 ++---
.../database/metadata/TableChangedHandler.java | 6 ++---
.../database/metadata/ViewChangedHandler.java | 6 ++---
.../global/ListenerAssistedChangedHandler.java | 4 +--
.../StandaloneMetaDataManagerPersistService.java | 2 +-
.../connector/StandardDatabaseConnector.java | 2 +-
37 files changed, 105 insertions(+), 104 deletions(-)
diff --git
a/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/DriverExecuteExecutor.java
b/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/DriverExecuteExecutor.java
index 3ee2c70fc3d..7d7c20cbd36 100644
---
a/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/DriverExecuteExecutor.java
+++
b/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/DriverExecuteExecutor.java
@@ -37,7 +37,7 @@ import
org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData;
import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import
org.apache.shardingsphere.infra.rule.attribute.raw.RawExecutionRuleAttribute;
import org.apache.shardingsphere.infra.session.query.QueryContext;
-import org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefreshEngine;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefreshEngine;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.tcl.TCLStatement;
import org.apache.shardingsphere.sqlfederation.engine.SQLFederationEngine;
import
org.apache.shardingsphere.sqlfederation.executor.context.SQLFederationContext;
diff --git
a/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/pushdown/jdbc/DriverJDBCPushDownExecuteExecutor.java
b/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/pushdown/jdbc/DriverJDBCPushDownExecuteExecutor.java
index bc384be2e74..23581b492e2 100644
---
a/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/pushdown/jdbc/DriverJDBCPushDownExecuteExecutor.java
+++
b/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/pushdown/jdbc/DriverJDBCPushDownExecuteExecutor.java
@@ -44,7 +44,7 @@ import org.apache.shardingsphere.infra.merge.MergeEngine;
import org.apache.shardingsphere.infra.merge.result.MergedResult;
import org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData;
import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
-import org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefreshEngine;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefreshEngine;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dal.DALStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DDLStatement;
diff --git
a/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/pushdown/jdbc/DriverJDBCPushDownExecuteUpdateExecutor.java
b/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/pushdown/jdbc/DriverJDBCPushDownExecuteUpdateExecutor.java
index fc9de04fca4..cd87cca94ca 100644
---
a/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/pushdown/jdbc/DriverJDBCPushDownExecuteUpdateExecutor.java
+++
b/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/pushdown/jdbc/DriverJDBCPushDownExecuteUpdateExecutor.java
@@ -42,7 +42,7 @@ import
org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData;
import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import org.apache.shardingsphere.infra.rule.ShardingSphereRule;
import
org.apache.shardingsphere.infra.rule.attribute.datanode.DataNodeRuleAttribute;
-import org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefreshEngine;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefreshEngine;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DDLStatement;
import java.sql.Connection;
diff --git
a/kernel/schedule/core/src/main/java/org/apache/shardingsphere/schedule/core/job/statistics/collect/StatisticsCollectJob.java
b/kernel/schedule/core/src/main/java/org/apache/shardingsphere/schedule/core/job/statistics/collect/StatisticsCollectJob.java
index ecd3d64cd2c..75c7f07f183 100644
---
a/kernel/schedule/core/src/main/java/org/apache/shardingsphere/schedule/core/job/statistics/collect/StatisticsCollectJob.java
+++
b/kernel/schedule/core/src/main/java/org/apache/shardingsphere/schedule/core/job/statistics/collect/StatisticsCollectJob.java
@@ -21,7 +21,7 @@ import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.elasticjob.api.ShardingContext;
import org.apache.shardingsphere.elasticjob.simple.job.SimpleJob;
import org.apache.shardingsphere.mode.manager.ContextManager;
-import
org.apache.shardingsphere.mode.metadata.refresher.ShardingSphereStatisticsRefreshEngine;
+import
org.apache.shardingsphere.mode.metadata.refresher.statistics.StatisticsRefreshEngine;
/**
* Statistics collect job.
@@ -34,7 +34,7 @@ public final class StatisticsCollectJob implements SimpleJob {
@Override
public void execute(final ShardingContext shardingContext) {
if
(contextManager.getComputeNodeInstanceContext().getModeConfiguration().isCluster())
{
- new
ShardingSphereStatisticsRefreshEngine(contextManager).refresh();
+ new StatisticsRefreshEngine(contextManager).refresh();
}
}
}
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/manager/SchemaMetaDataManager.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/manager/SchemaMetaDataManager.java
index 50237dd386c..5e2f86d6a8a 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/manager/SchemaMetaDataManager.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/manager/SchemaMetaDataManager.java
@@ -31,7 +31,7 @@ import org.apache.shardingsphere.infra.rule.scope.GlobalRule;
import
org.apache.shardingsphere.infra.rule.scope.GlobalRule.GlobalRuleChangedType;
import org.apache.shardingsphere.mode.metadata.MetaDataContexts;
import org.apache.shardingsphere.mode.metadata.persist.MetaDataPersistService;
-import
org.apache.shardingsphere.mode.metadata.refresher.util.TableRefreshUtils;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.util.TableRefreshUtils;
import java.util.Collections;
import java.util.Optional;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/FederationMetaDataRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/federation/FederationMetaDataRefresher.java
similarity index 96%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/FederationMetaDataRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/federation/FederationMetaDataRefresher.java
index fffbf7d12e3..4c49c90eef5 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/FederationMetaDataRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/federation/FederationMetaDataRefresher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher;
+package org.apache.shardingsphere.mode.metadata.refresher.federation;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/view/federation/AlterViewFederationMetaDataRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/federation/type/AlterViewFederationMetaDataRefresher.java
similarity index 92%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/view/federation/AlterViewFederationMetaDataRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/federation/type/AlterViewFederationMetaDataRefresher.java
index 8fd97e5fe20..4148bc161c8 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/view/federation/AlterViewFederationMetaDataRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/federation/type/AlterViewFederationMetaDataRefresher.java
@@ -15,14 +15,14 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.type.view.federation;
+package org.apache.shardingsphere.mode.metadata.refresher.federation.type;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereView;
import
org.apache.shardingsphere.infra.metadata.database.schema.pojo.AlterSchemaMetaDataPOJO;
-import
org.apache.shardingsphere.mode.metadata.refresher.FederationMetaDataRefresher;
-import
org.apache.shardingsphere.mode.metadata.refresher.util.TableRefreshUtils;
+import
org.apache.shardingsphere.mode.metadata.refresher.federation.FederationMetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.util.TableRefreshUtils;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.SimpleTableSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterViewStatement;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/view/federation/CreateViewFederationMetaDataRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/federation/type/CreateViewFederationMetaDataRefresher.java
similarity index 89%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/view/federation/CreateViewFederationMetaDataRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/federation/type/CreateViewFederationMetaDataRefresher.java
index 306f7e38434..d91bd67a6dc 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/view/federation/CreateViewFederationMetaDataRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/federation/type/CreateViewFederationMetaDataRefresher.java
@@ -15,14 +15,14 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.type.view.federation;
+package org.apache.shardingsphere.mode.metadata.refresher.federation.type;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereView;
import
org.apache.shardingsphere.infra.metadata.database.schema.pojo.AlterSchemaMetaDataPOJO;
-import
org.apache.shardingsphere.mode.metadata.refresher.FederationMetaDataRefresher;
-import
org.apache.shardingsphere.mode.metadata.refresher.util.TableRefreshUtils;
+import
org.apache.shardingsphere.mode.metadata.refresher.federation.FederationMetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.util.TableRefreshUtils;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateViewStatement;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/view/federation/DropViewFederationMetaDataRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/federation/type/DropViewFederationMetaDataRefresher.java
similarity index 92%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/view/federation/DropViewFederationMetaDataRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/federation/type/DropViewFederationMetaDataRefresher.java
index 2238f726ba5..f1e34b0c1aa 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/view/federation/DropViewFederationMetaDataRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/federation/type/DropViewFederationMetaDataRefresher.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.type.view.federation;
+package org.apache.shardingsphere.mode.metadata.refresher.federation.type;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import
org.apache.shardingsphere.infra.metadata.database.schema.pojo.AlterSchemaMetaDataPOJO;
-import
org.apache.shardingsphere.mode.metadata.refresher.FederationMetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.federation.FederationMetaDataRefresher;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DropViewStatement;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/MetaDataRefreshEngine.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/MetaDataRefreshEngine.java
similarity index 97%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/MetaDataRefreshEngine.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/MetaDataRefreshEngine.java
index 59e623ba918..ad519d82b9c 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/MetaDataRefreshEngine.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/MetaDataRefreshEngine.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher;
+package org.apache.shardingsphere.mode.metadata.refresher.metadata;
import lombok.RequiredArgsConstructor;
import
org.apache.shardingsphere.infra.binder.context.statement.SQLStatementContext;
@@ -27,6 +27,7 @@ import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import
org.apache.shardingsphere.infra.metadata.database.resource.unit.StorageUnit;
import org.apache.shardingsphere.infra.route.context.RouteUnit;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
+import
org.apache.shardingsphere.mode.metadata.refresher.federation.FederationMetaDataRefresher;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterIndexStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterSchemaStatement;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/MetaDataRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/MetaDataRefresher.java
similarity index 97%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/MetaDataRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/MetaDataRefresher.java
index 6756535bf5f..436bc630926 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/MetaDataRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/MetaDataRefresher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher;
+package org.apache.shardingsphere.mode.metadata.refresher.metadata;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/index/AlterIndexStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/index/AlterIndexStatementSchemaRefresher.java
similarity index 96%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/index/AlterIndexStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/index/AlterIndexStatementSchemaRefresher.java
index 812a1417f2b..3d3a4f0df26 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/index/AlterIndexStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/index/AlterIndexStatementSchemaRefresher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.type.index;
+package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.index;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
@@ -28,7 +28,7 @@ import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSp
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereSchema;
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereTable;
import
org.apache.shardingsphere.infra.metadata.database.schema.pojo.AlterSchemaMetaDataPOJO;
-import org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefresher;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.segment.ddl.index.IndexSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterIndexStatement;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/index/CreateIndexStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/index/CreateIndexStatementSchemaRefresher.java
similarity index 95%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/index/CreateIndexStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/index/CreateIndexStatementSchemaRefresher.java
index fce62478ddf..96088ef7d6c 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/index/CreateIndexStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/index/CreateIndexStatementSchemaRefresher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.type.index;
+package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.index;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
@@ -28,7 +28,7 @@ import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSp
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereTable;
import
org.apache.shardingsphere.infra.metadata.database.schema.pojo.AlterSchemaMetaDataPOJO;
import
org.apache.shardingsphere.infra.metadata.database.schema.util.IndexMetaDataUtils;
-import org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefresher;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateIndexStatement;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/index/DropIndexStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/index/DropIndexStatementSchemaRefresher.java
similarity index 96%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/index/DropIndexStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/index/DropIndexStatementSchemaRefresher.java
index 6006b26c8f3..3298e221a46 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/index/DropIndexStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/index/DropIndexStatementSchemaRefresher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.type.index;
+package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.index;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
@@ -28,7 +28,7 @@ import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSp
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereTable;
import
org.apache.shardingsphere.infra.metadata.database.schema.pojo.AlterSchemaMetaDataPOJO;
import
org.apache.shardingsphere.infra.metadata.database.schema.util.IndexMetaDataUtils;
-import org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefresher;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.segment.ddl.index.IndexSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.SimpleTableSegment;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/schema/AlterSchemaStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/schema/AlterSchemaStatementSchemaRefresher.java
similarity index 93%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/schema/AlterSchemaStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/schema/AlterSchemaStatementSchemaRefresher.java
index adbedc37060..ebf8d831025 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/schema/AlterSchemaStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/schema/AlterSchemaStatementSchemaRefresher.java
@@ -15,14 +15,14 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.type.schema;
+package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.schema;
import com.google.common.base.Preconditions;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import
org.apache.shardingsphere.infra.metadata.database.schema.pojo.AlterSchemaPOJO;
-import org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefresher;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterSchemaStatement;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/schema/CreateSchemaStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/schema/CreateSchemaStatementSchemaRefresher.java
similarity index 92%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/schema/CreateSchemaStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/schema/CreateSchemaStatementSchemaRefresher.java
index 5f8c49cf8fe..e1f72cd1747 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/schema/CreateSchemaStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/schema/CreateSchemaStatementSchemaRefresher.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.type.schema;
+package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.schema;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
-import org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefresher;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateSchemaStatement;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/schema/DropSchemaStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/schema/DropSchemaStatementSchemaRefresher.java
similarity index 93%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/schema/DropSchemaStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/schema/DropSchemaStatementSchemaRefresher.java
index 13a2c515b48..57066c57a68 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/schema/DropSchemaStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/schema/DropSchemaStatementSchemaRefresher.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.type.schema;
+package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.schema;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
-import org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefresher;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DropSchemaStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/table/AlterTableStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/AlterTableStatementSchemaRefresher.java
similarity index 94%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/table/AlterTableStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/AlterTableStatementSchemaRefresher.java
index d296cd3c67e..17ec469b819 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/table/AlterTableStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/AlterTableStatementSchemaRefresher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.type.table;
+package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.table;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
@@ -27,8 +27,8 @@ import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSp
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereTable;
import
org.apache.shardingsphere.infra.metadata.database.schema.pojo.AlterSchemaMetaDataPOJO;
import
org.apache.shardingsphere.infra.rule.attribute.datanode.MutableDataNodeRuleAttribute;
-import org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefresher;
-import
org.apache.shardingsphere.mode.metadata.refresher.util.TableRefreshUtils;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.util.TableRefreshUtils;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterTableStatement;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/table/CreateTableStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/CreateTableStatementSchemaRefresher.java
similarity index 94%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/table/CreateTableStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/CreateTableStatementSchemaRefresher.java
index 2cf7f2d14c3..305e4c944c8 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/table/CreateTableStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/CreateTableStatementSchemaRefresher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.type.table;
+package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.table;
import com.google.common.base.Preconditions;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
@@ -27,8 +27,8 @@ import
org.apache.shardingsphere.infra.metadata.database.schema.builder.GenericS
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereSchema;
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereTable;
import
org.apache.shardingsphere.infra.rule.attribute.datanode.MutableDataNodeRuleAttribute;
-import org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefresher;
-import
org.apache.shardingsphere.mode.metadata.refresher.util.TableRefreshUtils;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.util.TableRefreshUtils;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateTableStatement;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/table/DropTableStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/DropTableStatementSchemaRefresher.java
similarity index 91%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/table/DropTableStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/DropTableStatementSchemaRefresher.java
index bc387e68fb7..2668e5b1751 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/table/DropTableStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/DropTableStatementSchemaRefresher.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.type.table;
+package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.table;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
-import org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefresher;
-import
org.apache.shardingsphere.mode.metadata.refresher.util.TableRefreshUtils;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.util.TableRefreshUtils;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.SimpleTableSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DropTableStatement;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/table/RenameTableStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/RenameTableStatementSchemaRefresher.java
similarity index 94%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/table/RenameTableStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/RenameTableStatementSchemaRefresher.java
index 435143a41f2..b25ca17a03e 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/table/RenameTableStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/RenameTableStatementSchemaRefresher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.type.table;
+package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.table;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
@@ -27,8 +27,8 @@ import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSp
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereTable;
import
org.apache.shardingsphere.infra.metadata.database.schema.pojo.AlterSchemaMetaDataPOJO;
import
org.apache.shardingsphere.infra.rule.attribute.datanode.MutableDataNodeRuleAttribute;
-import org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefresher;
-import
org.apache.shardingsphere.mode.metadata.refresher.util.TableRefreshUtils;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.util.TableRefreshUtils;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.segment.ddl.table.RenameTableDefinitionSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.RenameTableStatement;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/view/AlterViewStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/view/AlterViewStatementSchemaRefresher.java
similarity index 95%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/view/AlterViewStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/view/AlterViewStatementSchemaRefresher.java
index b1ffa59cedd..5aa2f1b54a1 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/view/AlterViewStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/view/AlterViewStatementSchemaRefresher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.type.view;
+package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.view;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
@@ -28,8 +28,8 @@ import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSp
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereView;
import
org.apache.shardingsphere.infra.metadata.database.schema.pojo.AlterSchemaMetaDataPOJO;
import
org.apache.shardingsphere.infra.rule.attribute.datanode.MutableDataNodeRuleAttribute;
-import org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefresher;
-import
org.apache.shardingsphere.mode.metadata.refresher.util.TableRefreshUtils;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.util.TableRefreshUtils;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.SimpleTableSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterViewStatement;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/view/CreateViewStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/view/CreateViewStatementSchemaRefresher.java
similarity index 94%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/view/CreateViewStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/view/CreateViewStatementSchemaRefresher.java
index 371cfc2daab..049c833026c 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/view/CreateViewStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/view/CreateViewStatementSchemaRefresher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.type.view;
+package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.view;
import com.google.common.base.Preconditions;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
@@ -29,8 +29,8 @@ import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSp
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereView;
import
org.apache.shardingsphere.infra.metadata.database.schema.pojo.AlterSchemaMetaDataPOJO;
import
org.apache.shardingsphere.infra.rule.attribute.datanode.MutableDataNodeRuleAttribute;
-import org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefresher;
-import
org.apache.shardingsphere.mode.metadata.refresher.util.TableRefreshUtils;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.util.TableRefreshUtils;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateViewStatement;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/view/DropViewStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/view/DropViewStatementSchemaRefresher.java
similarity index 93%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/view/DropViewStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/view/DropViewStatementSchemaRefresher.java
index 4e397d83203..f46fd8e83e8 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/type/view/DropViewStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/view/DropViewStatementSchemaRefresher.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.type.view;
+package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.view;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import
org.apache.shardingsphere.infra.metadata.database.schema.pojo.AlterSchemaMetaDataPOJO;
-import org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefresher;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DropViewStatement;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/util/TableRefreshUtils.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/util/TableRefreshUtils.java
similarity index 98%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/util/TableRefreshUtils.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/util/TableRefreshUtils.java
index bd197afa24f..bbdf63dbe54 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/util/TableRefreshUtils.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/util/TableRefreshUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.util;
+package org.apache.shardingsphere.mode.metadata.refresher.metadata.util;
import com.google.common.base.Joiner;
import lombok.AccessLevel;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/lock/StatisticsLock.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/statistics/StatisticsLock.java
similarity index 93%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/lock/StatisticsLock.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/statistics/StatisticsLock.java
index db5d4951027..188343a0540 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/lock/StatisticsLock.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/statistics/StatisticsLock.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.lock;
+package org.apache.shardingsphere.mode.metadata.refresher.statistics;
import org.apache.shardingsphere.mode.lock.global.GlobalLock;
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/ShardingSphereStatisticsRefreshEngine.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/statistics/StatisticsRefreshEngine.java
similarity index 97%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/ShardingSphereStatisticsRefreshEngine.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/statistics/StatisticsRefreshEngine.java
index b7a82f57d77..0fa584b9104 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/ShardingSphereStatisticsRefreshEngine.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/statistics/StatisticsRefreshEngine.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher;
+package org.apache.shardingsphere.mode.metadata.refresher.statistics;
import lombok.extern.slf4j.Slf4j;
import
org.apache.shardingsphere.infra.config.props.temporary.TemporaryConfigurationPropertyKey;
@@ -37,7 +37,6 @@ import
org.apache.shardingsphere.infra.yaml.data.swapper.YamlRowStatisticsSwappe
import
org.apache.shardingsphere.mode.metadata.persist.statistics.AlteredDatabaseStatistics;
import org.apache.shardingsphere.mode.lock.global.GlobalLockDefinition;
import org.apache.shardingsphere.mode.manager.ContextManager;
-import org.apache.shardingsphere.mode.metadata.refresher.lock.StatisticsLock;
import java.util.ArrayList;
import java.util.Map;
@@ -49,10 +48,10 @@ import java.util.function.Function;
import java.util.stream.Collectors;
/**
- * ShardingSphere statistics refresh engine.
+ * Statistics refresh engine.
*/
@Slf4j
-public final class ShardingSphereStatisticsRefreshEngine {
+public final class StatisticsRefreshEngine {
private static final ExecutorService EXECUTOR_SERVICE =
Executors.newSingleThreadScheduledExecutor(ExecutorThreadFactoryBuilder.build("statistics-collect-%d"));
@@ -60,7 +59,7 @@ public final class ShardingSphereStatisticsRefreshEngine {
private final LockContext lockContext;
- public ShardingSphereStatisticsRefreshEngine(final ContextManager
contextManager) {
+ public StatisticsRefreshEngine(final ContextManager contextManager) {
this.contextManager = contextManager;
lockContext =
contextManager.getComputeNodeInstanceContext().getLockContext();
}
diff --git
a/mode/core/src/main/resources/META-INF/services/org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefresher
b/mode/core/src/main/resources/META-INF/services/org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefresher
deleted file mode 100644
index 079d469f2cd..00000000000
---
a/mode/core/src/main/resources/META-INF/services/org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefresher
+++ /dev/null
@@ -1,30 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements. See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#
-
-org.apache.shardingsphere.mode.metadata.refresher.type.schema.CreateSchemaStatementSchemaRefresher
-org.apache.shardingsphere.mode.metadata.refresher.type.schema.AlterSchemaStatementSchemaRefresher
-org.apache.shardingsphere.mode.metadata.refresher.type.schema.DropSchemaStatementSchemaRefresher
-org.apache.shardingsphere.mode.metadata.refresher.type.index.CreateIndexStatementSchemaRefresher
-org.apache.shardingsphere.mode.metadata.refresher.type.index.AlterIndexStatementSchemaRefresher
-org.apache.shardingsphere.mode.metadata.refresher.type.index.DropIndexStatementSchemaRefresher
-org.apache.shardingsphere.mode.metadata.refresher.type.view.CreateViewStatementSchemaRefresher
-org.apache.shardingsphere.mode.metadata.refresher.type.view.AlterViewStatementSchemaRefresher
-org.apache.shardingsphere.mode.metadata.refresher.type.view.DropViewStatementSchemaRefresher
-org.apache.shardingsphere.mode.metadata.refresher.type.table.CreateTableStatementSchemaRefresher
-org.apache.shardingsphere.mode.metadata.refresher.type.table.AlterTableStatementSchemaRefresher
-org.apache.shardingsphere.mode.metadata.refresher.type.table.RenameTableStatementSchemaRefresher
-org.apache.shardingsphere.mode.metadata.refresher.type.table.DropTableStatementSchemaRefresher
diff --git
a/mode/core/src/main/resources/META-INF/services/org.apache.shardingsphere.mode.metadata.refresher.FederationMetaDataRefresher
b/mode/core/src/main/resources/META-INF/services/org.apache.shardingsphere.mode.metadata.refresher.federation.FederationMetaDataRefresher
similarity index 70%
rename from
mode/core/src/main/resources/META-INF/services/org.apache.shardingsphere.mode.metadata.refresher.FederationMetaDataRefresher
rename to
mode/core/src/main/resources/META-INF/services/org.apache.shardingsphere.mode.metadata.refresher.federation.FederationMetaDataRefresher
index 9e296836bfa..094883b5601 100644
---
a/mode/core/src/main/resources/META-INF/services/org.apache.shardingsphere.mode.metadata.refresher.FederationMetaDataRefresher
+++
b/mode/core/src/main/resources/META-INF/services/org.apache.shardingsphere.mode.metadata.refresher.federation.FederationMetaDataRefresher
@@ -15,6 +15,6 @@
# limitations under the License.
#
-org.apache.shardingsphere.mode.metadata.refresher.type.view.federation.CreateViewFederationMetaDataRefresher
-org.apache.shardingsphere.mode.metadata.refresher.type.view.federation.AlterViewFederationMetaDataRefresher
-org.apache.shardingsphere.mode.metadata.refresher.type.view.federation.DropViewFederationMetaDataRefresher
+org.apache.shardingsphere.mode.metadata.refresher.federation.type.CreateViewFederationMetaDataRefresher
+org.apache.shardingsphere.mode.metadata.refresher.federation.type.AlterViewFederationMetaDataRefresher
+org.apache.shardingsphere.mode.metadata.refresher.federation.type.DropViewFederationMetaDataRefresher
diff --git
a/mode/core/src/main/resources/META-INF/services/org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefresher
b/mode/core/src/main/resources/META-INF/services/org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefresher
new file mode 100644
index 00000000000..d315989adbd
--- /dev/null
+++
b/mode/core/src/main/resources/META-INF/services/org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefresher
@@ -0,0 +1,30 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+org.apache.shardingsphere.mode.metadata.refresher.metadata.type.schema.CreateSchemaStatementSchemaRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.type.schema.AlterSchemaStatementSchemaRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.type.schema.DropSchemaStatementSchemaRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.type.index.CreateIndexStatementSchemaRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.type.index.AlterIndexStatementSchemaRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.type.index.DropIndexStatementSchemaRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.type.view.CreateViewStatementSchemaRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.type.view.AlterViewStatementSchemaRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.type.view.DropViewStatementSchemaRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.type.table.CreateTableStatementSchemaRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.type.table.AlterTableStatementSchemaRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.type.table.RenameTableStatementSchemaRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.type.table.DropTableStatementSchemaRefresher
diff --git
a/mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/refresher/ShardingSphereStatisticsRefreshEngineTest.java
b/mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/refresher/StatisticsRefreshEngineTest.java
similarity index 96%
rename from
mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/refresher/ShardingSphereStatisticsRefreshEngineTest.java
rename to
mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/refresher/StatisticsRefreshEngineTest.java
index acead823113..38d62634ffc 100644
---
a/mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/refresher/ShardingSphereStatisticsRefreshEngineTest.java
+++
b/mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/refresher/StatisticsRefreshEngineTest.java
@@ -30,6 +30,7 @@ import
org.apache.shardingsphere.infra.metadata.statistics.SchemaStatistics;
import
org.apache.shardingsphere.infra.metadata.statistics.ShardingSphereStatistics;
import org.apache.shardingsphere.infra.metadata.statistics.TableStatistics;
import org.apache.shardingsphere.mode.manager.ContextManager;
+import
org.apache.shardingsphere.mode.metadata.refresher.statistics.StatisticsRefreshEngine;
import org.apache.shardingsphere.test.util.PropertiesBuilder;
import org.apache.shardingsphere.test.util.PropertiesBuilder.Property;
import org.junit.jupiter.api.Test;
@@ -46,7 +47,7 @@ import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;
-class ShardingSphereStatisticsRefreshEngineTest {
+class StatisticsRefreshEngineTest {
@Test
void assertRefresh() {
@@ -59,7 +60,7 @@ class ShardingSphereStatisticsRefreshEngineTest {
when(contextManager.getMetaDataContexts().getMetaData().getTemporaryProps()).thenReturn(new
TemporaryConfigurationProperties(
PropertiesBuilder.build(new
Property(TemporaryConfigurationPropertyKey.PROXY_META_DATA_COLLECTOR_ENABLED.getKey(),
Boolean.TRUE.toString()))));
when(contextManager.getComputeNodeInstanceContext().getLockContext().tryLock(any(),
anyLong())).thenReturn(true);
- new ShardingSphereStatisticsRefreshEngine(contextManager).refresh();
+ new StatisticsRefreshEngine(contextManager).refresh();
verify(contextManager.getPersistServiceFacade().getMetaDataPersistService().getShardingSphereStatisticsPersistService()).update(any());
}
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/SchemaChangedHandler.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/SchemaChangedHandler.java
index 9740d9652ae..bb277c84d03 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/SchemaChangedHandler.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/SchemaChangedHandler.java
@@ -18,7 +18,7 @@
package
org.apache.shardingsphere.mode.manager.cluster.dispatch.handler.database.metadata;
import org.apache.shardingsphere.mode.manager.ContextManager;
-import
org.apache.shardingsphere.mode.metadata.refresher.ShardingSphereStatisticsRefreshEngine;
+import
org.apache.shardingsphere.mode.metadata.refresher.statistics.StatisticsRefreshEngine;
/**
* Schema changed handler.
@@ -27,11 +27,11 @@ public final class SchemaChangedHandler {
private final ContextManager contextManager;
- private final ShardingSphereStatisticsRefreshEngine
statisticsRefreshEngine;
+ private final StatisticsRefreshEngine statisticsRefreshEngine;
public SchemaChangedHandler(final ContextManager contextManager) {
this.contextManager = contextManager;
- statisticsRefreshEngine = new
ShardingSphereStatisticsRefreshEngine(contextManager);
+ statisticsRefreshEngine = new StatisticsRefreshEngine(contextManager);
}
/**
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/TableChangedHandler.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/TableChangedHandler.java
index bf0cffae7ad..90337250be2 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/TableChangedHandler.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/TableChangedHandler.java
@@ -22,7 +22,7 @@ import
org.apache.shardingsphere.mode.node.path.metadata.TableMetaDataNodePath;
import org.apache.shardingsphere.mode.event.DataChangedEvent;
import org.apache.shardingsphere.mode.manager.ContextManager;
import
org.apache.shardingsphere.mode.manager.cluster.dispatch.checker.ActiveVersionChecker;
-import
org.apache.shardingsphere.mode.metadata.refresher.ShardingSphereStatisticsRefreshEngine;
+import
org.apache.shardingsphere.mode.metadata.refresher.statistics.StatisticsRefreshEngine;
/**
* Table changed handler.
@@ -31,11 +31,11 @@ public final class TableChangedHandler {
private final ContextManager contextManager;
- private final ShardingSphereStatisticsRefreshEngine
statisticsRefreshEngine;
+ private final StatisticsRefreshEngine statisticsRefreshEngine;
public TableChangedHandler(final ContextManager contextManager) {
this.contextManager = contextManager;
- statisticsRefreshEngine = new
ShardingSphereStatisticsRefreshEngine(contextManager);
+ statisticsRefreshEngine = new StatisticsRefreshEngine(contextManager);
}
/**
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/ViewChangedHandler.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/ViewChangedHandler.java
index 28f205be57d..294d9f03a73 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/ViewChangedHandler.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/ViewChangedHandler.java
@@ -22,7 +22,7 @@ import
org.apache.shardingsphere.mode.node.path.metadata.ViewMetaDataNodePath;
import org.apache.shardingsphere.mode.event.DataChangedEvent;
import org.apache.shardingsphere.mode.manager.ContextManager;
import
org.apache.shardingsphere.mode.manager.cluster.dispatch.checker.ActiveVersionChecker;
-import
org.apache.shardingsphere.mode.metadata.refresher.ShardingSphereStatisticsRefreshEngine;
+import
org.apache.shardingsphere.mode.metadata.refresher.statistics.StatisticsRefreshEngine;
/**
* View changed handler.
@@ -31,11 +31,11 @@ public final class ViewChangedHandler {
private final ContextManager contextManager;
- private final ShardingSphereStatisticsRefreshEngine
statisticsRefreshEngine;
+ private final StatisticsRefreshEngine statisticsRefreshEngine;
public ViewChangedHandler(final ContextManager contextManager) {
this.contextManager = contextManager;
- statisticsRefreshEngine = new
ShardingSphereStatisticsRefreshEngine(contextManager);
+ statisticsRefreshEngine = new StatisticsRefreshEngine(contextManager);
}
/**
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/global/ListenerAssistedChangedHandler.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/global/ListenerAssistedChangedHandler.java
index 06a43178c2c..e78939f9107 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/global/ListenerAssistedChangedHandler.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/global/ListenerAssistedChangedHandler.java
@@ -25,7 +25,7 @@ import
org.apache.shardingsphere.mode.event.DataChangedEvent.Type;
import org.apache.shardingsphere.mode.manager.ContextManager;
import
org.apache.shardingsphere.mode.manager.cluster.dispatch.handler.DataChangedEventHandler;
import
org.apache.shardingsphere.mode.manager.cluster.dispatch.listener.type.DatabaseMetaDataChangedListener;
-import
org.apache.shardingsphere.mode.metadata.refresher.ShardingSphereStatisticsRefreshEngine;
+import
org.apache.shardingsphere.mode.metadata.refresher.statistics.StatisticsRefreshEngine;
import org.apache.shardingsphere.mode.state.database.ListenerAssistedType;
import
org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;
@@ -63,7 +63,7 @@ public final class ListenerAssistedChangedHandler implements
DataChangedEventHan
}
contextManager.getPersistServiceFacade().getListenerAssistedPersistService().deleteDatabaseNameListenerAssisted(databaseName);
if (InstanceType.PROXY ==
contextManager.getComputeNodeInstanceContext().getInstance().getMetaData().getType())
{
- new
ShardingSphereStatisticsRefreshEngine(contextManager).asyncRefresh();
+ new StatisticsRefreshEngine(contextManager).asyncRefresh();
}
}
}
diff --git
a/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/persist/service/StandaloneMetaDataManagerPersistService.java
b/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/persist/service/StandaloneMetaDataManagerPersistService.java
index 32846374289..3a5e89fecf3 100644
---
a/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/persist/service/StandaloneMetaDataManagerPersistService.java
+++
b/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/persist/service/StandaloneMetaDataManagerPersistService.java
@@ -40,7 +40,7 @@ import
org.apache.shardingsphere.mode.metadata.manager.RuleItemChangedBuilder;
import org.apache.shardingsphere.mode.metadata.manager.SwitchingResource;
import org.apache.shardingsphere.mode.metadata.persist.MetaDataPersistService;
import
org.apache.shardingsphere.mode.metadata.persist.config.database.DataSourceUnitPersistService;
-import
org.apache.shardingsphere.mode.metadata.refresher.util.TableRefreshUtils;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.util.TableRefreshUtils;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import org.apache.shardingsphere.mode.spi.rule.item.RuleChangedItem;
import org.apache.shardingsphere.mode.spi.rule.item.alter.AlterRuleItem;
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/connector/StandardDatabaseConnector.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/connector/StandardDatabaseConnector.java
index 920ec10526c..1fa6068d1c5 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/connector/StandardDatabaseConnector.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/connector/StandardDatabaseConnector.java
@@ -54,7 +54,7 @@ import
org.apache.shardingsphere.infra.session.query.QueryContext;
import org.apache.shardingsphere.infra.spi.ShardingSphereServiceLoader;
import org.apache.shardingsphere.mode.manager.ContextManager;
import org.apache.shardingsphere.mode.metadata.MetaDataContexts;
-import org.apache.shardingsphere.mode.metadata.refresher.MetaDataRefreshEngine;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefreshEngine;
import
org.apache.shardingsphere.proxy.backend.connector.jdbc.executor.callback.ProxyJDBCExecutorCallback;
import
org.apache.shardingsphere.proxy.backend.connector.jdbc.executor.callback.ProxyJDBCExecutorCallbackFactory;
import
org.apache.shardingsphere.proxy.backend.connector.jdbc.statement.JDBCBackendStatement;
