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 aaefd69bef9 Rename PushDownMetaDataRefresher (#34454)
aaefd69bef9 is described below
commit aaefd69bef97540a60a80592fa21292d4e6d7605
Author: Liang Zhang <[email protected]>
AuthorDate: Thu Jan 23 22:47:18 2025 +0800
Rename PushDownMetaDataRefresher (#34454)
* Add SchemaRefreshUtils
* Add SchemaRefreshUtils
* Rename PushDownMetaDataRefresher
* Rename PushDownMetaDataRefresher
---
.../jdbc/DriverJDBCPushDownExecuteExecutor.java | 4 +--
.../DriverJDBCPushDownExecuteUpdateExecutor.java | 9 ++++---
.../type/AlterViewFederationMetaDataRefresher.java | 2 +-
.../CreateViewFederationMetaDataRefresher.java | 2 +-
.../type/DropViewFederationMetaDataRefresher.java | 2 +-
.../PushDownMetaDataRefreshEngine.java} | 10 ++++----
.../PushDownMetaDataRefresher.java} | 6 ++---
.../AlterIndexPushDownMetaDataRefresher.java} | 8 +++---
.../CreateIndexPushDownMetaDataRefresher.java} | 8 +++---
.../index/DropIndexPushDownMetaDataRefresher.java} | 8 +++---
.../AlterSchemaPushDownMetaDataRefresher.java} | 8 +++---
.../CreateSchemaPushDownMetaDataRefresher.java} | 8 +++---
.../DropSchemaPushDownMetaDataRefresher.java} | 8 +++---
.../AlterTablePushDownMetaDataRefresher.java} | 8 +++---
.../CreateTablePushDownMetaDataRefresher.java} | 8 +++---
.../table/DropTablePushDownMetaDataRefresher.java} | 8 +++---
.../RenameTablePushDownMetaDataRefresher.java} | 8 +++---
.../view/AlterViewPushDownMetaDataRefresher.java} | 8 +++---
.../view/CreateViewPushDownMetaDataRefresher.java} | 8 +++---
.../view/DropViewPushDownMetaDataRefresher.java} | 8 +++---
...e.metadata.refresher.metadata.MetaDataRefresher | 30 ----------------------
...her.metadata.pushdown.PushDownMetaDataRefresher | 30 ++++++++++++++++++++++
.../StatisticsRefreshEngineTest.java | 3 +--
.../connector/StandardDatabaseConnector.java | 8 +++---
24 files changed, 105 insertions(+), 105 deletions(-)
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 171ef59380e..3c757c02243 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.metadata.MetaDataRefreshEngine;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.PushDownMetaDataRefreshEngine;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dal.DALStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DDLStatement;
@@ -107,7 +107,7 @@ public final class DriverJDBCPushDownExecuteExecutor {
if
(isNeedImplicitCommit(executionContext.getSqlStatementContext())) {
connection.commit();
}
- new
MetaDataRefreshEngine(connection.getContextManager().getPersistServiceFacade().getMetaDataManagerPersistService(),
database, metaData.getProps())
+ new
PushDownMetaDataRefreshEngine(connection.getContextManager().getPersistServiceFacade().getMetaDataManagerPersistService(),
database, metaData.getProps())
.refresh(executionContext.getSqlStatementContext(),
executionContext.getRouteContext().getRouteUnits());
return null != results && !results.isEmpty() && null !=
results.get(0) && results.get(0);
} finally {
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 7a0eeb82eb3..a53e9aabe6d 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.metadata.MetaDataRefreshEngine;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.PushDownMetaDataRefreshEngine;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DDLStatement;
import java.sql.Connection;
@@ -108,12 +108,13 @@ public final class
DriverJDBCPushDownExecuteUpdateExecutor {
JDBCExecutorCallback<Integer> callback = new
ExecuteUpdateCallbackFactory(prepareEngine.getType())
.newInstance(database,
executionContext.getSqlStatementContext().getSqlStatement(), updateCallback);
List<Integer> updateCounts =
jdbcExecutor.execute(executionGroupContext, callback);
- MetaDataRefreshEngine metaDataRefreshEngine = new
MetaDataRefreshEngine(connection.getContextManager().getPersistServiceFacade().getMetaDataManagerPersistService(),
database, props);
- if
(metaDataRefreshEngine.isNeedRefresh(executionContext.getSqlStatementContext()))
{
+ PushDownMetaDataRefreshEngine pushDownMetaDataRefreshEngine =
+ new
PushDownMetaDataRefreshEngine(connection.getContextManager().getPersistServiceFacade().getMetaDataManagerPersistService(),
database, props);
+ if
(pushDownMetaDataRefreshEngine.isNeedRefresh(executionContext.getSqlStatementContext()))
{
if
(isNeedImplicitCommit(executionContext.getSqlStatementContext())) {
connection.commit();
}
-
metaDataRefreshEngine.refresh(executionContext.getSqlStatementContext(),
executionContext.getRouteContext().getRouteUnits());
+
pushDownMetaDataRefreshEngine.refresh(executionContext.getSqlStatementContext(),
executionContext.getRouteContext().getRouteUnits());
}
return isNeedAccumulate(database.getRuleMetaData().getRules(),
executionContext.getSqlStatementContext()) ? accumulate(updateCounts) :
updateCounts.get(0);
} finally {
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/federation/type/AlterViewFederationMetaDataRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/federation/type/AlterViewFederationMetaDataRefresher.java
index db8f4cabaf9..f8c7b82dd7b 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/federation/type/AlterViewFederationMetaDataRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/federation/type/AlterViewFederationMetaDataRefresher.java
@@ -29,7 +29,7 @@ import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterVi
import java.util.Optional;
/**
- * Meta data refresher for alter view statement.
+ * Alter view federation meta data refresher.
*/
public final class AlterViewFederationMetaDataRefresher implements
FederationMetaDataRefresher<AlterViewStatement> {
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/federation/type/CreateViewFederationMetaDataRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/federation/type/CreateViewFederationMetaDataRefresher.java
index 15e63137e3c..4ac24f5df44 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/federation/type/CreateViewFederationMetaDataRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/federation/type/CreateViewFederationMetaDataRefresher.java
@@ -26,7 +26,7 @@ import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistServ
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateViewStatement;
/**
- * Meta data refresher for create view statement.
+ * Create view federation meta data refresher.
*/
public final class CreateViewFederationMetaDataRefresher implements
FederationMetaDataRefresher<CreateViewStatement> {
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/federation/type/DropViewFederationMetaDataRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/federation/type/DropViewFederationMetaDataRefresher.java
index e2d2878b57a..988271db4df 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/federation/type/DropViewFederationMetaDataRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/federation/type/DropViewFederationMetaDataRefresher.java
@@ -25,7 +25,7 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DropViewStatement;
/**
- * Meta data refresher for drop view statement.
+ * Drop view federation meta data refresher.
*/
public final class DropViewFederationMetaDataRefresher implements
FederationMetaDataRefresher<DropViewStatement> {
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/MetaDataRefreshEngine.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/PushDownMetaDataRefreshEngine.java
similarity index 91%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/MetaDataRefreshEngine.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/PushDownMetaDataRefreshEngine.java
index 6e69265d5c6..1ade5a772c8 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/MetaDataRefreshEngine.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/PushDownMetaDataRefreshEngine.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.metadata;
+package org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown;
import lombok.RequiredArgsConstructor;
import
org.apache.shardingsphere.infra.binder.context.statement.SQLStatementContext;
@@ -36,10 +36,10 @@ import java.util.Optional;
import java.util.stream.Collectors;
/**
- * Meta data refresh engine.
+ * Push down meta data refresh engine.
*/
@RequiredArgsConstructor
-public final class MetaDataRefreshEngine {
+public final class PushDownMetaDataRefreshEngine {
private final MetaDataManagerPersistService metaDataManagerPersistService;
@@ -55,7 +55,7 @@ public final class MetaDataRefreshEngine {
*/
public boolean isNeedRefresh(final SQLStatementContext
sqlStatementContext) {
Class<?> sqlStatementClass =
sqlStatementContext.getSqlStatement().getClass().getSuperclass();
- return TypedSPILoader.findService(MetaDataRefresher.class,
sqlStatementClass).isPresent();
+ return TypedSPILoader.findService(PushDownMetaDataRefresher.class,
sqlStatementClass).isPresent();
}
/**
@@ -68,7 +68,7 @@ public final class MetaDataRefreshEngine {
@SuppressWarnings({"unchecked", "rawtypes"})
public void refresh(final SQLStatementContext sqlStatementContext, final
Collection<RouteUnit> routeUnits) throws SQLException {
Class<?> sqlStatementClass =
sqlStatementContext.getSqlStatement().getClass().getSuperclass();
- Optional<MetaDataRefresher> metaDataRefresher =
TypedSPILoader.findService(MetaDataRefresher.class, sqlStatementClass);
+ Optional<PushDownMetaDataRefresher> metaDataRefresher =
TypedSPILoader.findService(PushDownMetaDataRefresher.class, sqlStatementClass);
if (!metaDataRefresher.isPresent()) {
return;
}
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/MetaDataRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/PushDownMetaDataRefresher.java
similarity index 94%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/MetaDataRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/PushDownMetaDataRefresher.java
index 436bc630926..a0549931d57 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/MetaDataRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/PushDownMetaDataRefresher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.metadata;
+package org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
@@ -29,12 +29,12 @@ import java.sql.SQLException;
import java.util.Collection;
/**
- * Meta data refresher.
+ * Push down meta data refresher.
*
* @param <T> type of SQL statement
*/
@SingletonSPI
-public interface MetaDataRefresher<T extends SQLStatement> extends TypedSPI {
+public interface PushDownMetaDataRefresher<T extends SQLStatement> extends
TypedSPI {
/**
* Refresh schema.
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/index/AlterIndexStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/index/AlterIndexPushDownMetaDataRefresher.java
similarity index 95%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/index/AlterIndexStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/index/AlterIndexPushDownMetaDataRefresher.java
index 3d3a4f0df26..b3e967c23ff 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/index/AlterIndexStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/index/AlterIndexPushDownMetaDataRefresher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.index;
+package
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.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.metadata.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.PushDownMetaDataRefresher;
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;
@@ -38,9 +38,9 @@ import java.util.LinkedList;
import java.util.Optional;
/**
- * Schema refresher for alter index statement.
+ * Alter index push down meta data refresher.
*/
-public final class AlterIndexStatementSchemaRefresher implements
MetaDataRefresher<AlterIndexStatement> {
+public final class AlterIndexPushDownMetaDataRefresher implements
PushDownMetaDataRefresher<AlterIndexStatement> {
@Override
public void refresh(final MetaDataManagerPersistService
metaDataManagerPersistService, final ShardingSphereDatabase database, final
Collection<String> logicDataSourceNames,
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/index/CreateIndexStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/index/CreateIndexPushDownMetaDataRefresher.java
similarity index 94%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/index/CreateIndexStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/index/CreateIndexPushDownMetaDataRefresher.java
index 96088ef7d6c..e8b9d4503cd 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/index/CreateIndexStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/index/CreateIndexPushDownMetaDataRefresher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.index;
+package
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.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.metadata.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.PushDownMetaDataRefresher;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateIndexStatement;
@@ -36,9 +36,9 @@ import java.util.Collection;
import java.util.LinkedList;
/**
- * Schema refresher for create index statement.
+ * Create index push down meta data refresher.
*/
-public final class CreateIndexStatementSchemaRefresher implements
MetaDataRefresher<CreateIndexStatement> {
+public final class CreateIndexPushDownMetaDataRefresher implements
PushDownMetaDataRefresher<CreateIndexStatement> {
@Override
public void refresh(final MetaDataManagerPersistService
metaDataManagerPersistService, final ShardingSphereDatabase database, final
Collection<String> logicDataSourceNames,
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/index/DropIndexStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/index/DropIndexPushDownMetaDataRefresher.java
similarity index 95%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/index/DropIndexStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/index/DropIndexPushDownMetaDataRefresher.java
index 3298e221a46..bd181eb5fc0 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/index/DropIndexStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/index/DropIndexPushDownMetaDataRefresher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.index;
+package
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.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.metadata.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.PushDownMetaDataRefresher;
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;
@@ -39,9 +39,9 @@ import java.util.Collections;
import java.util.Optional;
/**
- * Schema refresher for drop index statement.
+ * Drop index push down meta data refresher.
*/
-public final class DropIndexStatementSchemaRefresher implements
MetaDataRefresher<DropIndexStatement> {
+public final class DropIndexPushDownMetaDataRefresher implements
PushDownMetaDataRefresher<DropIndexStatement> {
@Override
public void refresh(final MetaDataManagerPersistService
metaDataManagerPersistService, final ShardingSphereDatabase database, final
Collection<String> logicDataSourceNames,
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/schema/AlterSchemaStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/schema/AlterSchemaPushDownMetaDataRefresher.java
similarity index 91%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/schema/AlterSchemaStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/schema/AlterSchemaPushDownMetaDataRefresher.java
index ebf8d831025..5ff9832acf0 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/schema/AlterSchemaStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/schema/AlterSchemaPushDownMetaDataRefresher.java
@@ -15,14 +15,14 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.schema;
+package
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.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.metadata.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.PushDownMetaDataRefresher;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterSchemaStatement;
@@ -31,9 +31,9 @@ import java.util.Collection;
import java.util.Optional;
/**
- * Schema refresher for alter schema statement.
+ * Alter schema push down meta data refresher.
*/
-public final class AlterSchemaStatementSchemaRefresher implements
MetaDataRefresher<AlterSchemaStatement> {
+public final class AlterSchemaPushDownMetaDataRefresher implements
PushDownMetaDataRefresher<AlterSchemaStatement> {
@Override
public void refresh(final MetaDataManagerPersistService
metaDataManagerPersistService, final ShardingSphereDatabase database, final
Collection<String> logicDataSourceNames,
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/schema/CreateSchemaStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/schema/CreateSchemaPushDownMetaDataRefresher.java
similarity index 90%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/schema/CreateSchemaStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/schema/CreateSchemaPushDownMetaDataRefresher.java
index e1f72cd1747..cb2f9dd8103 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/schema/CreateSchemaStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/schema/CreateSchemaPushDownMetaDataRefresher.java
@@ -15,21 +15,21 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.schema;
+package
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.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.metadata.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.PushDownMetaDataRefresher;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateSchemaStatement;
import java.util.Collection;
/**
- * Schema refresher for create schema statement.
+ * Create schema push down meta data refresher.
*/
-public final class CreateSchemaStatementSchemaRefresher implements
MetaDataRefresher<CreateSchemaStatement> {
+public final class CreateSchemaPushDownMetaDataRefresher implements
PushDownMetaDataRefresher<CreateSchemaStatement> {
@Override
public void refresh(final MetaDataManagerPersistService
metaDataManagerPersistService, final ShardingSphereDatabase database, final
Collection<String> logicDataSourceNames,
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/schema/DropSchemaStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/schema/DropSchemaPushDownMetaDataRefresher.java
similarity index 91%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/schema/DropSchemaStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/schema/DropSchemaPushDownMetaDataRefresher.java
index 57066c57a68..7d0b452de2a 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/schema/DropSchemaStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/schema/DropSchemaPushDownMetaDataRefresher.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.schema;
+package
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.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.metadata.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.PushDownMetaDataRefresher;
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;
@@ -29,9 +29,9 @@ import java.util.Collection;
import java.util.LinkedList;
/**
- * Schema refresher for drop schema statement.
+ * Drop schema push down meta data refresher.
*/
-public final class DropSchemaStatementSchemaRefresher implements
MetaDataRefresher<DropSchemaStatement> {
+public final class DropSchemaPushDownMetaDataRefresher implements
PushDownMetaDataRefresher<DropSchemaStatement> {
@Override
public void refresh(final MetaDataManagerPersistService
metaDataManagerPersistService, final ShardingSphereDatabase database, final
Collection<String> logicDataSourceNames,
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/AlterTableStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/table/AlterTablePushDownMetaDataRefresher.java
similarity index 95%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/AlterTableStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/table/AlterTablePushDownMetaDataRefresher.java
index 17ec469b819..113727da68d 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/AlterTableStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/table/AlterTablePushDownMetaDataRefresher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.table;
+package
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.type.table;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
@@ -27,7 +27,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.rule.attribute.datanode.MutableDataNodeRuleAttribute;
-import
org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.PushDownMetaDataRefresher;
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;
@@ -40,9 +40,9 @@ import java.util.Map;
import java.util.Optional;
/**
- * Schema refresher for alter table statement.
+ * Alter table push down meta data refresher.
*/
-public final class AlterTableStatementSchemaRefresher implements
MetaDataRefresher<AlterTableStatement> {
+public final class AlterTablePushDownMetaDataRefresher implements
PushDownMetaDataRefresher<AlterTableStatement> {
@Override
public void refresh(final MetaDataManagerPersistService
metaDataManagerPersistService, final ShardingSphereDatabase database, final
Collection<String> logicDataSourceNames,
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/CreateTableStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/table/CreateTablePushDownMetaDataRefresher.java
similarity index 94%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/CreateTableStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/table/CreateTablePushDownMetaDataRefresher.java
index 305e4c944c8..f11ba0d74e9 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/CreateTableStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/table/CreateTablePushDownMetaDataRefresher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.table;
+package
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.type.table;
import com.google.common.base.Preconditions;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
@@ -27,7 +27,7 @@ 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.metadata.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.PushDownMetaDataRefresher;
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;
@@ -40,9 +40,9 @@ import java.util.Map;
import java.util.Optional;
/**
- * Schema refresher for create table statement.
+ * Create table push down meta data refresher.
*/
-public final class CreateTableStatementSchemaRefresher implements
MetaDataRefresher<CreateTableStatement> {
+public final class CreateTablePushDownMetaDataRefresher implements
PushDownMetaDataRefresher<CreateTableStatement> {
@Override
public void refresh(final MetaDataManagerPersistService
metaDataManagerPersistService, final ShardingSphereDatabase database, final
Collection<String> logicDataSourceNames,
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/DropTableStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/table/DropTablePushDownMetaDataRefresher.java
similarity index 93%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/DropTableStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/table/DropTablePushDownMetaDataRefresher.java
index 2668e5b1751..72d4aa1e634 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/DropTableStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/table/DropTablePushDownMetaDataRefresher.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.table;
+package
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.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.metadata.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.PushDownMetaDataRefresher;
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;
@@ -31,9 +31,9 @@ import java.util.Collection;
import java.util.stream.Collectors;
/**
- * Schema refresher for drop table statement.
+ * Drop table push down meta data refresher.
*/
-public final class DropTableStatementSchemaRefresher implements
MetaDataRefresher<DropTableStatement> {
+public final class DropTablePushDownMetaDataRefresher implements
PushDownMetaDataRefresher<DropTableStatement> {
@Override
public void refresh(final MetaDataManagerPersistService
metaDataManagerPersistService, final ShardingSphereDatabase database, final
Collection<String> logicDataSourceNames,
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/RenameTableStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/table/RenameTablePushDownMetaDataRefresher.java
similarity index 95%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/RenameTableStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/table/RenameTablePushDownMetaDataRefresher.java
index b25ca17a03e..54153230ed5 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/table/RenameTableStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/table/RenameTablePushDownMetaDataRefresher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.table;
+package
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.type.table;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
@@ -27,7 +27,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.rule.attribute.datanode.MutableDataNodeRuleAttribute;
-import
org.apache.shardingsphere.mode.metadata.refresher.metadata.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.PushDownMetaDataRefresher;
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;
@@ -41,9 +41,9 @@ import java.util.Map;
import java.util.Optional;
/**
- * Schema refresher for rename table statement.
+ * Rename table push down meta data refresher.
*/
-public final class RenameTableStatementSchemaRefresher implements
MetaDataRefresher<RenameTableStatement> {
+public final class RenameTablePushDownMetaDataRefresher implements
PushDownMetaDataRefresher<RenameTableStatement> {
@Override
public void refresh(final MetaDataManagerPersistService
metaDataManagerPersistService, final ShardingSphereDatabase database, final
Collection<String> logicDataSourceNames,
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/view/AlterViewStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/view/AlterViewPushDownMetaDataRefresher.java
similarity index 96%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/view/AlterViewStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/view/AlterViewPushDownMetaDataRefresher.java
index 5aa2f1b54a1..88832be117d 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/view/AlterViewStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/view/AlterViewPushDownMetaDataRefresher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.view;
+package
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.type.view;
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.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.metadata.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.PushDownMetaDataRefresher;
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;
@@ -42,9 +42,9 @@ import java.util.Map;
import java.util.Optional;
/**
- * Schema refresher for alter view statement.
+ * Alter view push down meta data refresher.
*/
-public final class AlterViewStatementSchemaRefresher implements
MetaDataRefresher<AlterViewStatement> {
+public final class AlterViewPushDownMetaDataRefresher implements
PushDownMetaDataRefresher<AlterViewStatement> {
@Override
public void refresh(final MetaDataManagerPersistService
metaDataManagerPersistService, final ShardingSphereDatabase database, final
Collection<String> logicDataSourceNames,
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/view/CreateViewStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/view/CreateViewPushDownMetaDataRefresher.java
similarity index 95%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/view/CreateViewStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/view/CreateViewPushDownMetaDataRefresher.java
index 049c833026c..cb11d24a297 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/view/CreateViewStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/view/CreateViewPushDownMetaDataRefresher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.view;
+package
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.type.view;
import com.google.common.base.Preconditions;
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
@@ -29,7 +29,7 @@ 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.metadata.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.PushDownMetaDataRefresher;
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;
@@ -42,9 +42,9 @@ import java.util.Map;
import java.util.Optional;
/**
- * Schema refresher for create view statement.
+ * Create view push down meta data refresher.
*/
-public final class CreateViewStatementSchemaRefresher implements
MetaDataRefresher<CreateViewStatement> {
+public final class CreateViewPushDownMetaDataRefresher implements
PushDownMetaDataRefresher<CreateViewStatement> {
@Override
public void refresh(final MetaDataManagerPersistService
metaDataManagerPersistService, final ShardingSphereDatabase database, final
Collection<String> logicDataSourceNames,
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/view/DropViewStatementSchemaRefresher.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/view/DropViewPushDownMetaDataRefresher.java
similarity index 91%
rename from
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/view/DropViewStatementSchemaRefresher.java
rename to
mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/view/DropViewPushDownMetaDataRefresher.java
index f46fd8e83e8..e4719776b35 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/type/view/DropViewStatementSchemaRefresher.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/view/DropViewPushDownMetaDataRefresher.java
@@ -15,22 +15,22 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.metadata.refresher.metadata.type.view;
+package
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.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.metadata.MetaDataRefresher;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.PushDownMetaDataRefresher;
import
org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DropViewStatement;
import java.util.Collection;
/**
- * Schema refresher for drop view statement.
+ * Drop view push down meta data refresher.
*/
-public final class DropViewStatementSchemaRefresher implements
MetaDataRefresher<DropViewStatement> {
+public final class DropViewPushDownMetaDataRefresher implements
PushDownMetaDataRefresher<DropViewStatement> {
@Override
public void refresh(final MetaDataManagerPersistService
metaDataManagerPersistService, final ShardingSphereDatabase database, final
Collection<String> logicDataSourceNames,
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
deleted file mode 100644
index d315989adbd..00000000000
---
a/mode/core/src/main/resources/META-INF/services/org.apache.shardingsphere.mode.metadata.refresher.metadata.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.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/main/resources/META-INF/services/org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.PushDownMetaDataRefresher
b/mode/core/src/main/resources/META-INF/services/org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.PushDownMetaDataRefresher
new file mode 100644
index 00000000000..d6ecdc9058a
--- /dev/null
+++
b/mode/core/src/main/resources/META-INF/services/org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.PushDownMetaDataRefresher
@@ -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.pushdown.type.schema.CreateSchemaPushDownMetaDataRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.type.schema.AlterSchemaPushDownMetaDataRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.type.schema.DropSchemaPushDownMetaDataRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.type.index.CreateIndexPushDownMetaDataRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.type.index.AlterIndexPushDownMetaDataRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.type.index.DropIndexPushDownMetaDataRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.type.view.CreateViewPushDownMetaDataRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.type.view.AlterViewPushDownMetaDataRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.type.view.DropViewPushDownMetaDataRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.type.table.CreateTablePushDownMetaDataRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.type.table.AlterTablePushDownMetaDataRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.type.table.RenameTablePushDownMetaDataRefresher
+org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.type.table.DropTablePushDownMetaDataRefresher
diff --git
a/mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/refresher/StatisticsRefreshEngineTest.java
b/mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/refresher/statistics/StatisticsRefreshEngineTest.java
similarity index 97%
rename from
mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/refresher/StatisticsRefreshEngineTest.java
rename to
mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/refresher/statistics/StatisticsRefreshEngineTest.java
index 44c2a5395a8..0ebc74a455c 100644
---
a/mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/refresher/StatisticsRefreshEngineTest.java
+++
b/mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/refresher/statistics/StatisticsRefreshEngineTest.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 org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
import
org.apache.shardingsphere.infra.config.props.temporary.TemporaryConfigurationProperties;
@@ -30,7 +30,6 @@ 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;
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 5e52556d9dc..69084d1c646 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.metadata.MetaDataRefreshEngine;
+import
org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.PushDownMetaDataRefreshEngine;
import
org.apache.shardingsphere.mode.metadata.refresher.metadata.federation.FederationMetaDataRefreshEngine;
import
org.apache.shardingsphere.proxy.backend.connector.jdbc.executor.callback.ProxyJDBCExecutorCallback;
import
org.apache.shardingsphere.proxy.backend.connector.jdbc.executor.callback.ProxyJDBCExecutorCallbackFactory;
@@ -111,7 +111,7 @@ public final class StandardDatabaseConnector implements
DatabaseConnector {
private final ProxySQLExecutor proxySQLExecutor;
- private final MetaDataRefreshEngine metaDataRefreshEngine;
+ private final PushDownMetaDataRefreshEngine pushDownMetaDataRefreshEngine;
private final FederationMetaDataRefreshEngine
federationMetaDataRefreshEngine;
@@ -136,7 +136,7 @@ public final class StandardDatabaseConnector implements
DatabaseConnector {
prepareCursorStatementContext((CursorAvailable)
sqlStatementContext);
}
proxySQLExecutor = new ProxySQLExecutor(driverType,
databaseConnectionManager, this, queryContext);
- metaDataRefreshEngine = new MetaDataRefreshEngine(
+ pushDownMetaDataRefreshEngine = new PushDownMetaDataRefreshEngine(
contextManager.getPersistServiceFacade().getMetaDataManagerPersistService(),
database, contextManager.getMetaDataContexts().getMetaData().getProps());
federationMetaDataRefreshEngine = new
FederationMetaDataRefreshEngine(contextManager.getPersistServiceFacade().getMetaDataManagerPersistService(),
database);
}
@@ -240,7 +240,7 @@ public final class StandardDatabaseConnector implements
DatabaseConnector {
List<ExecuteResult> executeResults = advancedExecutors.isEmpty()
? proxySQLExecutor.execute(executionContext)
:
advancedExecutors.iterator().next().execute(executionContext, contextManager,
database, this);
- metaDataRefreshEngine.refresh(queryContext.getSqlStatementContext(),
executionContext.getRouteContext().getRouteUnits());
+
pushDownMetaDataRefreshEngine.refresh(queryContext.getSqlStatementContext(),
executionContext.getRouteContext().getRouteUnits());
Object executeResultSample = executeResults.iterator().next();
return executeResultSample instanceof QueryResult
? processExecuteQuery(queryContext.getSqlStatementContext(),
executeResults.stream().map(QueryResult.class::cast).collect(Collectors.toList()),
(QueryResult) executeResultSample)
