This is an automated email from the ASF dual-hosted git repository.
duanzhengqiang 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 fcbb474b962 Rename DatabaseRuleRALUpdater (#29760)
fcbb474b962 is described below
commit fcbb474b9626d8bc855cccc905c7793ab9396918
Author: Liang Zhang <[email protected]>
AuthorDate: Thu Jan 18 14:13:39 2024 +0800
Rename DatabaseRuleRALUpdater (#29760)
* Refactor PreviewExecutor
* Rename DatabaseRuleRALUpdater
---
.../type/ral/update/{RALUpdater.java => DatabaseRuleRALUpdater.java} | 4 ++--
.../pipeline/cdc/distsql/handler/update/DropStreamingUpdater.java | 4 ++--
.../migration/distsql/handler/update/CheckMigrationJobUpdater.java | 4 ++--
.../migration/distsql/handler/update/CommitMigrationUpdater.java | 4 ++--
.../migration/distsql/handler/update/DropMigrationCheckUpdater.java | 4 ++--
.../migration/distsql/handler/update/MigrateTableUpdater.java | 4 ++--
.../handler/update/RegisterMigrationSourceStorageUnitUpdater.java | 4 ++--
.../migration/distsql/handler/update/RollbackMigrationUpdater.java | 4 ++--
.../migration/distsql/handler/update/StartMigrationCheckUpdater.java | 4 ++--
.../migration/distsql/handler/update/StartMigrationUpdater.java | 4 ++--
.../migration/distsql/handler/update/StopMigrationCheckUpdater.java | 4 ++--
.../migration/distsql/handler/update/StopMigrationUpdater.java | 4 ++--
.../handler/update/UnregisterMigrationSourceStorageUnitUpdater.java | 4 ++--
...dingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater} | 0
.../proxy/backend/handler/distsql/ral/UpdatableRALBackendHandler.java | 4 ++--
.../AlterReadwriteSplittingStorageUnitStatusStatementUpdater.java | 4 ++--
.../handler/distsql/ral/updatable/AlterTransmissionRuleUpdater.java | 4 ++--
.../distsql/ral/updatable/ImportDatabaseConfigurationUpdater.java | 4 ++--
.../backend/handler/distsql/ral/updatable/ImportMetaDataUpdater.java | 4 ++--
.../handler/distsql/ral/updatable/LabelComputeNodeUpdater.java | 4 ++--
.../backend/handler/distsql/ral/updatable/LockClusterUpdater.java | 4 ++--
.../handler/distsql/ral/updatable/SetInstanceStatusUpdater.java | 4 ++--
.../handler/distsql/ral/updatable/UnlabelComputeNodeUpdater.java | 4 ++--
.../backend/handler/distsql/ral/updatable/UnlockClusterUpdater.java | 4 ++--
.../ral/updatable/updater/ConnectionSessionRequiredRALUpdater.java | 4 ++--
.../proxy/backend/handler/distsql/rul/sql/PreviewExecutor.java | 2 +-
...dingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater} | 0
27 files changed, 49 insertions(+), 49 deletions(-)
diff --git
a/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/type/ral/update/RALUpdater.java
b/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/type/ral/update/DatabaseRuleRALUpdater.java
similarity index 93%
rename from
infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/type/ral/update/RALUpdater.java
rename to
infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/type/ral/update/DatabaseRuleRALUpdater.java
index ed45e53e7a8..77772d61511 100644
---
a/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/type/ral/update/RALUpdater.java
+++
b/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/type/ral/update/DatabaseRuleRALUpdater.java
@@ -24,12 +24,12 @@ import
org.apache.shardingsphere.sql.parser.sql.common.statement.SQLStatement;
import java.sql.SQLException;
/**
- * RAL updater.
+ * Database rule RAL updater.
*
* @param <T> type of updatable RAL statement
*/
@SingletonSPI
-public interface RALUpdater<T extends SQLStatement> extends TypedSPI {
+public interface DatabaseRuleRALUpdater<T extends SQLStatement> extends
TypedSPI {
/**
* Execute update.
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/handler/update/DropStreamingUpdater.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/handler/update/DropStreamingUpdater.java
index d595789f1bd..5bfdbaad6ba 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/handler/update/DropStreamingUpdater.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/handler/update/DropStreamingUpdater.java
@@ -20,7 +20,7 @@ package
org.apache.shardingsphere.data.pipeline.cdc.distsql.handler.update;
import
org.apache.shardingsphere.data.pipeline.cdc.distsql.statement.DropStreamingStatement;
import org.apache.shardingsphere.data.pipeline.cdc.api.CDCJobAPI;
import org.apache.shardingsphere.data.pipeline.core.job.api.TransmissionJobAPI;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
import java.sql.SQLException;
@@ -28,7 +28,7 @@ import java.sql.SQLException;
/**
* Drop streaming updater.
*/
-public final class DropStreamingUpdater implements
RALUpdater<DropStreamingStatement> {
+public final class DropStreamingUpdater implements
DatabaseRuleRALUpdater<DropStreamingStatement> {
private final CDCJobAPI jobAPI = (CDCJobAPI)
TypedSPILoader.getService(TransmissionJobAPI.class, "STREAMING");
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/CheckMigrationJobUpdater.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/CheckMigrationJobUpdater.java
index ba0438b9f7e..c23be522d28 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/CheckMigrationJobUpdater.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/CheckMigrationJobUpdater.java
@@ -27,7 +27,7 @@ import
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.api.Con
import
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.api.CreateConsistencyCheckJobParameter;
import
org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobType;
import
org.apache.shardingsphere.data.pipeline.scenario.migration.config.MigrationJobConfiguration;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import org.apache.shardingsphere.distsql.segment.AlgorithmSegment;
import
org.apache.shardingsphere.infra.exception.core.ShardingSpherePreconditions;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.CheckMigrationStatement;
@@ -38,7 +38,7 @@ import java.util.Properties;
/**
* Check migration job updater.
*/
-public final class CheckMigrationJobUpdater implements
RALUpdater<CheckMigrationStatement> {
+public final class CheckMigrationJobUpdater implements
DatabaseRuleRALUpdater<CheckMigrationStatement> {
private final ConsistencyCheckJobAPI checkJobAPI = new
ConsistencyCheckJobAPI(new ConsistencyCheckJobType());
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/CommitMigrationUpdater.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/CommitMigrationUpdater.java
index 0e161cd43f4..e2965f00491 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/CommitMigrationUpdater.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/CommitMigrationUpdater.java
@@ -18,7 +18,7 @@
package
org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update;
import org.apache.shardingsphere.data.pipeline.core.job.api.TransmissionJobAPI;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.CommitMigrationStatement;
@@ -27,7 +27,7 @@ import java.sql.SQLException;
/**
* Commit migration updater.
*/
-public final class CommitMigrationUpdater implements
RALUpdater<CommitMigrationStatement> {
+public final class CommitMigrationUpdater implements
DatabaseRuleRALUpdater<CommitMigrationStatement> {
@Override
public void executeUpdate(final String databaseName, final
CommitMigrationStatement sqlStatement) throws SQLException {
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/DropMigrationCheckUpdater.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/DropMigrationCheckUpdater.java
index e17aefb6041..1abbc81750b 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/DropMigrationCheckUpdater.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/DropMigrationCheckUpdater.java
@@ -19,13 +19,13 @@ package
org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update
import
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobType;
import
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.api.ConsistencyCheckJobAPI;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.DropMigrationCheckStatement;
/**
* Drop migration check updater.
*/
-public final class DropMigrationCheckUpdater implements
RALUpdater<DropMigrationCheckStatement> {
+public final class DropMigrationCheckUpdater implements
DatabaseRuleRALUpdater<DropMigrationCheckStatement> {
private final ConsistencyCheckJobAPI jobAPI = new
ConsistencyCheckJobAPI(new ConsistencyCheckJobType());
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/MigrateTableUpdater.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/MigrateTableUpdater.java
index e915c88b2ff..519d379598f 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/MigrateTableUpdater.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/MigrateTableUpdater.java
@@ -21,7 +21,7 @@ import
org.apache.shardingsphere.data.pipeline.core.context.PipelineContextKey;
import
org.apache.shardingsphere.data.pipeline.core.exception.job.MissingRequiredTargetDatabaseException;
import org.apache.shardingsphere.data.pipeline.core.job.api.TransmissionJobAPI;
import
org.apache.shardingsphere.data.pipeline.scenario.migration.api.MigrationJobAPI;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import
org.apache.shardingsphere.infra.exception.core.ShardingSpherePreconditions;
import org.apache.shardingsphere.infra.instance.metadata.InstanceType;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
@@ -30,7 +30,7 @@ import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.Migra
/**
* Migrate table updater.
*/
-public final class MigrateTableUpdater implements
RALUpdater<MigrateTableStatement> {
+public final class MigrateTableUpdater implements
DatabaseRuleRALUpdater<MigrateTableStatement> {
@Override
public void executeUpdate(final String databaseName, final
MigrateTableStatement sqlStatement) {
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/RegisterMigrationSourceStorageUnitUpdater.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/RegisterMigrationSourceStorageUnitUpdater.java
index 3cbaac33452..adfcc28cdd5 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/RegisterMigrationSourceStorageUnitUpdater.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/RegisterMigrationSourceStorageUnitUpdater.java
@@ -20,7 +20,7 @@ package
org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update
import org.apache.shardingsphere.data.pipeline.core.context.PipelineContextKey;
import org.apache.shardingsphere.data.pipeline.core.job.api.TransmissionJobAPI;
import
org.apache.shardingsphere.data.pipeline.scenario.migration.api.MigrationJobAPI;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import
org.apache.shardingsphere.distsql.handler.validate.DataSourcePoolPropertiesValidateHandler;
import org.apache.shardingsphere.distsql.segment.DataSourceSegment;
import
org.apache.shardingsphere.distsql.segment.HostnameAndPortBasedDataSourceSegment;
@@ -42,7 +42,7 @@ import java.util.Map;
/**
* Register migration source storage unit updater.
*/
-public final class RegisterMigrationSourceStorageUnitUpdater implements
RALUpdater<RegisterMigrationSourceStorageUnitStatement> {
+public final class RegisterMigrationSourceStorageUnitUpdater implements
DatabaseRuleRALUpdater<RegisterMigrationSourceStorageUnitStatement> {
private final MigrationJobAPI jobAPI = (MigrationJobAPI)
TypedSPILoader.getService(TransmissionJobAPI.class, "MIGRATION");
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/RollbackMigrationUpdater.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/RollbackMigrationUpdater.java
index ad9314f5c8a..bae752a17c5 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/RollbackMigrationUpdater.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/RollbackMigrationUpdater.java
@@ -18,7 +18,7 @@
package
org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update;
import org.apache.shardingsphere.data.pipeline.core.job.api.TransmissionJobAPI;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.RollbackMigrationStatement;
@@ -27,7 +27,7 @@ import java.sql.SQLException;
/**
* Rollback migration updater.
*/
-public final class RollbackMigrationUpdater implements
RALUpdater<RollbackMigrationStatement> {
+public final class RollbackMigrationUpdater implements
DatabaseRuleRALUpdater<RollbackMigrationStatement> {
@Override
public void executeUpdate(final String databaseName, final
RollbackMigrationStatement sqlStatement) throws SQLException {
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/StartMigrationCheckUpdater.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/StartMigrationCheckUpdater.java
index a63d9462f84..1769ac742a8 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/StartMigrationCheckUpdater.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/StartMigrationCheckUpdater.java
@@ -19,13 +19,13 @@ package
org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update
import
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobType;
import
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.api.ConsistencyCheckJobAPI;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.StartMigrationCheckStatement;
/**
* Start migration check updater.
*/
-public final class StartMigrationCheckUpdater implements
RALUpdater<StartMigrationCheckStatement> {
+public final class StartMigrationCheckUpdater implements
DatabaseRuleRALUpdater<StartMigrationCheckStatement> {
private final ConsistencyCheckJobAPI jobAPI = new
ConsistencyCheckJobAPI(new ConsistencyCheckJobType());
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/StartMigrationUpdater.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/StartMigrationUpdater.java
index d6cf7df86b6..4edaa90b888 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/StartMigrationUpdater.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/StartMigrationUpdater.java
@@ -19,13 +19,13 @@ package
org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update
import
org.apache.shardingsphere.data.pipeline.core.job.service.PipelineJobManager;
import
org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobType;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.StartMigrationStatement;
/**
* Start migration updater.
*/
-public final class StartMigrationUpdater implements
RALUpdater<StartMigrationStatement> {
+public final class StartMigrationUpdater implements
DatabaseRuleRALUpdater<StartMigrationStatement> {
private final PipelineJobManager jobManager = new PipelineJobManager(new
MigrationJobType());
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/StopMigrationCheckUpdater.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/StopMigrationCheckUpdater.java
index 7e7a95444b0..5010f024a4e 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/StopMigrationCheckUpdater.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/StopMigrationCheckUpdater.java
@@ -19,13 +19,13 @@ package
org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update
import
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobType;
import
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.api.ConsistencyCheckJobAPI;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.StopMigrationCheckStatement;
/**
* Stop migration check updater.
*/
-public final class StopMigrationCheckUpdater implements
RALUpdater<StopMigrationCheckStatement> {
+public final class StopMigrationCheckUpdater implements
DatabaseRuleRALUpdater<StopMigrationCheckStatement> {
private final ConsistencyCheckJobAPI jobAPI = new
ConsistencyCheckJobAPI(new ConsistencyCheckJobType());
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/StopMigrationUpdater.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/StopMigrationUpdater.java
index 19829f462ab..9114d3ceb61 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/StopMigrationUpdater.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/StopMigrationUpdater.java
@@ -19,13 +19,13 @@ package
org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update
import
org.apache.shardingsphere.data.pipeline.core.job.service.PipelineJobManager;
import
org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobType;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.StopMigrationStatement;
/**
* Stop migration updater.
*/
-public final class StopMigrationUpdater implements
RALUpdater<StopMigrationStatement> {
+public final class StopMigrationUpdater implements
DatabaseRuleRALUpdater<StopMigrationStatement> {
private final PipelineJobManager jobManager = new PipelineJobManager(new
MigrationJobType());
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/UnregisterMigrationSourceStorageUnitUpdater.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/UnregisterMigrationSourceStorageUnitUpdater.java
index c44cdc2d359..c2621903f2a 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/UnregisterMigrationSourceStorageUnitUpdater.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/update/UnregisterMigrationSourceStorageUnitUpdater.java
@@ -20,7 +20,7 @@ package
org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update
import org.apache.shardingsphere.data.pipeline.core.context.PipelineContextKey;
import org.apache.shardingsphere.data.pipeline.core.job.api.TransmissionJobAPI;
import
org.apache.shardingsphere.data.pipeline.scenario.migration.api.MigrationJobAPI;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import org.apache.shardingsphere.infra.instance.metadata.InstanceType;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.UnregisterMigrationSourceStorageUnitStatement;
@@ -28,7 +28,7 @@ import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.Unreg
/**
* Unregister migration source storage unit updater.
*/
-public final class UnregisterMigrationSourceStorageUnitUpdater implements
RALUpdater<UnregisterMigrationSourceStorageUnitStatement> {
+public final class UnregisterMigrationSourceStorageUnitUpdater implements
DatabaseRuleRALUpdater<UnregisterMigrationSourceStorageUnitStatement> {
private final MigrationJobAPI jobAPI = (MigrationJobAPI)
TypedSPILoader.getService(TransmissionJobAPI.class, "MIGRATION");
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater
b/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater
rename to
kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/UpdatableRALBackendHandler.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/UpdatableRALBackendHandler.java
index 8648b1893ff..215b7c5ab04 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/UpdatableRALBackendHandler.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/UpdatableRALBackendHandler.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.proxy.backend.handler.distsql.ral;
import lombok.RequiredArgsConstructor;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import org.apache.shardingsphere.distsql.statement.ral.UpdatableRALStatement;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.updater.ConnectionSessionRequiredRALUpdater;
@@ -43,7 +43,7 @@ public final class UpdatableRALBackendHandler<T extends
UpdatableRALStatement> i
@SuppressWarnings("unchecked")
@Override
public ResponseHeader execute() throws SQLException {
- RALUpdater<T> updater = TypedSPILoader.getService(RALUpdater.class,
sqlStatement.getClass());
+ DatabaseRuleRALUpdater<T> updater =
TypedSPILoader.getService(DatabaseRuleRALUpdater.class,
sqlStatement.getClass());
if (updater instanceof ConnectionSessionRequiredRALUpdater) {
((ConnectionSessionRequiredRALUpdater<T>)
updater).executeUpdate(connectionSession, (T) sqlStatement);
} else {
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/AlterReadwriteSplittingStorageUnitStatusStatementUpdater.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/AlterReadwriteSplittingStorageUnitStatusStatementUpdater.java
index d8025c35e95..2acfc65385f 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/AlterReadwriteSplittingStorageUnitStatusStatementUpdater.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/AlterReadwriteSplittingStorageUnitStatusStatementUpdater.java
@@ -20,7 +20,7 @@ package
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable;
import com.google.common.base.Splitter;
import com.google.common.base.Strings;
import
org.apache.shardingsphere.distsql.handler.exception.storageunit.MissingRequiredStorageUnitsException;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import org.apache.shardingsphere.infra.state.datasource.DataSourceState;
import
org.apache.shardingsphere.infra.exception.core.ShardingSpherePreconditions;
import
org.apache.shardingsphere.infra.exception.core.external.sql.type.generic.UnsupportedSQLOperationException;
@@ -53,7 +53,7 @@ import java.util.stream.Collectors;
/**
* Set readwrite-splitting storage unit status updater.
*/
-public final class AlterReadwriteSplittingStorageUnitStatusStatementUpdater
implements RALUpdater<AlterReadwriteSplittingStorageUnitStatusStatement> {
+public final class AlterReadwriteSplittingStorageUnitStatusStatementUpdater
implements
DatabaseRuleRALUpdater<AlterReadwriteSplittingStorageUnitStatusStatement> {
private static final String DISABLE = "DISABLE";
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/AlterTransmissionRuleUpdater.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/AlterTransmissionRuleUpdater.java
index e2ecfca3d9d..fca40998b0e 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/AlterTransmissionRuleUpdater.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/AlterTransmissionRuleUpdater.java
@@ -21,7 +21,7 @@ import
org.apache.shardingsphere.data.pipeline.core.job.progress.config.Pipeline
import org.apache.shardingsphere.data.pipeline.core.context.PipelineContextKey;
import org.apache.shardingsphere.data.pipeline.core.job.type.PipelineJobType;
import
org.apache.shardingsphere.data.pipeline.core.metadata.PipelineProcessConfigurationPersistService;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import
org.apache.shardingsphere.distsql.statement.ral.updatable.AlterTransmissionRuleStatement;
import org.apache.shardingsphere.infra.instance.metadata.InstanceType;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
@@ -30,7 +30,7 @@ import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.con
/**
* Alter transmission rule updater.
*/
-public final class AlterTransmissionRuleUpdater implements
RALUpdater<AlterTransmissionRuleStatement> {
+public final class AlterTransmissionRuleUpdater implements
DatabaseRuleRALUpdater<AlterTransmissionRuleStatement> {
private final PipelineProcessConfigurationPersistService
processConfigPersistService = new PipelineProcessConfigurationPersistService();
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/ImportDatabaseConfigurationUpdater.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/ImportDatabaseConfigurationUpdater.java
index 87078bc6db0..28f192c2274 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/ImportDatabaseConfigurationUpdater.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/ImportDatabaseConfigurationUpdater.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import
org.apache.shardingsphere.distsql.statement.ral.updatable.ImportDatabaseConfigurationStatement;
import org.apache.shardingsphere.infra.util.yaml.YamlEngine;
import
org.apache.shardingsphere.proxy.backend.config.yaml.YamlProxyDatabaseConfiguration;
@@ -31,7 +31,7 @@ import java.sql.SQLException;
/**
* Import database configuration updater.
*/
-public final class ImportDatabaseConfigurationUpdater implements
RALUpdater<ImportDatabaseConfigurationStatement> {
+public final class ImportDatabaseConfigurationUpdater implements
DatabaseRuleRALUpdater<ImportDatabaseConfigurationStatement> {
private final YamlDatabaseConfigurationImportExecutor
databaseConfigImportExecutor = new YamlDatabaseConfigurationImportExecutor();
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/ImportMetaDataUpdater.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/ImportMetaDataUpdater.java
index 4740683a631..39b864b519b 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/ImportMetaDataUpdater.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/ImportMetaDataUpdater.java
@@ -19,7 +19,7 @@ package
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable;
import org.apache.commons.codec.binary.Base64;
import org.apache.commons.io.FileUtils;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import
org.apache.shardingsphere.distsql.statement.ral.updatable.ImportMetaDataStatement;
import org.apache.shardingsphere.infra.config.rule.RuleConfiguration;
import org.apache.shardingsphere.infra.util.json.JsonUtils;
@@ -42,7 +42,7 @@ import java.util.Collection;
/**
* Import meta data updater.
*/
-public final class ImportMetaDataUpdater implements
RALUpdater<ImportMetaDataStatement> {
+public final class ImportMetaDataUpdater implements
DatabaseRuleRALUpdater<ImportMetaDataStatement> {
private final YamlRuleConfigurationSwapperEngine ruleConfigSwapperEngine =
new YamlRuleConfigurationSwapperEngine();
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/LabelComputeNodeUpdater.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/LabelComputeNodeUpdater.java
index cec8330f1d5..1efc2e28376 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/LabelComputeNodeUpdater.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/LabelComputeNodeUpdater.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import
org.apache.shardingsphere.distsql.statement.ral.updatable.LabelComputeNodeStatement;
import
org.apache.shardingsphere.infra.exception.core.ShardingSpherePreconditions;
import
org.apache.shardingsphere.infra.exception.core.external.sql.type.generic.UnsupportedSQLOperationException;
@@ -37,7 +37,7 @@ import java.util.Optional;
/**
* Label compute node updater.
*/
-public final class LabelComputeNodeUpdater implements
RALUpdater<LabelComputeNodeStatement> {
+public final class LabelComputeNodeUpdater implements
DatabaseRuleRALUpdater<LabelComputeNodeStatement> {
@Override
public void executeUpdate(final String databaseName, final
LabelComputeNodeStatement sqlStatement) throws SQLException {
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/LockClusterUpdater.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/LockClusterUpdater.java
index 07c85a99207..9c23426a298 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/LockClusterUpdater.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/LockClusterUpdater.java
@@ -20,7 +20,7 @@ package
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable;
import lombok.RequiredArgsConstructor;
import lombok.Setter;
import
org.apache.shardingsphere.distsql.handler.exception.algorithm.MissingRequiredAlgorithmException;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import
org.apache.shardingsphere.distsql.statement.ral.updatable.LockClusterStatement;
import
org.apache.shardingsphere.infra.exception.core.ShardingSpherePreconditions;
import
org.apache.shardingsphere.infra.exception.core.external.sql.type.generic.UnsupportedSQLOperationException;
@@ -37,7 +37,7 @@ import
org.apache.shardingsphere.proxy.backend.lock.spi.ClusterLockStrategy;
*/
@RequiredArgsConstructor
@Setter
-public final class LockClusterUpdater implements
RALUpdater<LockClusterStatement> {
+public final class LockClusterUpdater implements
DatabaseRuleRALUpdater<LockClusterStatement> {
@Override
@SuppressWarnings({"unchecked", "rawtypes"})
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/SetInstanceStatusUpdater.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/SetInstanceStatusUpdater.java
index ce86f2d7b8a..4a19b49386d 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/SetInstanceStatusUpdater.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/SetInstanceStatusUpdater.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import
org.apache.shardingsphere.distsql.statement.ral.updatable.SetInstanceStatusStatement;
import
org.apache.shardingsphere.infra.exception.core.ShardingSpherePreconditions;
import
org.apache.shardingsphere.infra.exception.core.external.sql.type.generic.UnsupportedSQLOperationException;
@@ -29,7 +29,7 @@ import
org.apache.shardingsphere.proxy.backend.context.ProxyContext;
/**
* Set instance status updater.
*/
-public final class SetInstanceStatusUpdater implements
RALUpdater<SetInstanceStatusStatement> {
+public final class SetInstanceStatusUpdater implements
DatabaseRuleRALUpdater<SetInstanceStatusStatement> {
@Override
public void executeUpdate(final String databaseName, final
SetInstanceStatusStatement sqlStatement) {
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/UnlabelComputeNodeUpdater.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/UnlabelComputeNodeUpdater.java
index e2daa71a9c5..8d40b09f6fa 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/UnlabelComputeNodeUpdater.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/UnlabelComputeNodeUpdater.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import
org.apache.shardingsphere.distsql.statement.ral.updatable.UnlabelComputeNodeStatement;
import
org.apache.shardingsphere.infra.exception.core.ShardingSpherePreconditions;
import
org.apache.shardingsphere.infra.exception.core.external.sql.type.generic.UnsupportedSQLOperationException;
@@ -37,7 +37,7 @@ import java.util.Optional;
/**
* Unlabel compute node updater.
*/
-public final class UnlabelComputeNodeUpdater implements
RALUpdater<UnlabelComputeNodeStatement> {
+public final class UnlabelComputeNodeUpdater implements
DatabaseRuleRALUpdater<UnlabelComputeNodeStatement> {
@Override
public void executeUpdate(final String databaseName, final
UnlabelComputeNodeStatement sqlStatement) {
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/UnlockClusterUpdater.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/UnlockClusterUpdater.java
index bf85b182b5c..94f9a9f57f9 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/UnlockClusterUpdater.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/UnlockClusterUpdater.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable;
import lombok.RequiredArgsConstructor;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import
org.apache.shardingsphere.distsql.statement.ral.updatable.UnlockClusterStatement;
import
org.apache.shardingsphere.infra.exception.core.ShardingSpherePreconditions;
import
org.apache.shardingsphere.infra.exception.core.external.sql.type.generic.UnsupportedSQLOperationException;
@@ -34,7 +34,7 @@ import
org.apache.shardingsphere.proxy.backend.context.ProxyContext;
* Unlock cluster updater.
*/
@RequiredArgsConstructor
-public final class UnlockClusterUpdater implements
RALUpdater<UnlockClusterStatement> {
+public final class UnlockClusterUpdater implements
DatabaseRuleRALUpdater<UnlockClusterStatement> {
@Override
@SuppressWarnings({"unchecked", "rawtypes"})
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/updater/ConnectionSessionRequiredRALUpdater.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/updater/ConnectionSessionRequiredRALUpdater.java
index 1e29239c264..ed18b21f9eb 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/updater/ConnectionSessionRequiredRALUpdater.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/updater/ConnectionSessionRequiredRALUpdater.java
@@ -17,7 +17,7 @@
package
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.updater;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import
org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater;
import org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
import org.apache.shardingsphere.sql.parser.sql.common.statement.SQLStatement;
@@ -28,7 +28,7 @@ import java.sql.SQLException;
*
* @param <T> type of SQL statement
*/
-public interface ConnectionSessionRequiredRALUpdater<T extends SQLStatement>
extends RALUpdater<T> {
+public interface ConnectionSessionRequiredRALUpdater<T extends SQLStatement>
extends DatabaseRuleRALUpdater<T> {
/**
* Execute update.
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rul/sql/PreviewExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rul/sql/PreviewExecutor.java
index b73ccf3cea3..2a02c3444c4 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rul/sql/PreviewExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rul/sql/PreviewExecutor.java
@@ -96,7 +96,7 @@ public final class PreviewExecutor implements
ConnectionSessionRequiredRULExecut
if (toBePreviewedStatementContext instanceof CursorAvailable &&
toBePreviewedStatementContext instanceof CursorDefinitionAware) {
setUpCursorDefinition(connectionSession,
toBePreviewedStatementContext);
}
- ShardingSpherePreconditions.checkState(database.isComplete(), () ->
new RuleNotExistedException(connectionSession.getDatabaseName()));
+ ShardingSpherePreconditions.checkState(database.isComplete(), () ->
new RuleNotExistedException(database.getName()));
String schemaName =
queryContext.getSqlStatementContext().getTablesContext().getSchemaName()
.orElseGet(() -> new
DatabaseTypeRegistry(database.getProtocolType()).getDefaultSchemaName(database.getName()));
SQLFederationEngine federationEngine = new
SQLFederationEngine(database.getName(), schemaName, metaData,
ProxyContext.getInstance().getContextManager().getMetaDataContexts().getStatistics(),
diff --git
a/proxy/backend/core/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater
b/proxy/backend/core/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater
similarity index 100%
rename from
proxy/backend/core/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater
rename to
proxy/backend/core/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseRuleRALUpdater
