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 fb4ddc4f1e6 Integrate with create/alter/show ProcessConfiguration
DistSQL (#20320)
fb4ddc4f1e6 is described below
commit fb4ddc4f1e60fafe85b01e8e1159d4250d177f21
Author: Hongsheng Zhong <[email protected]>
AuthorDate: Sat Aug 20 18:20:22 2022 +0800
Integrate with create/alter/show ProcessConfiguration DistSQL (#20320)
* Integrate with create/alter/show ProcessConfiguration DistSQL
* Improve alter ProcessConfiguration
* Rename
* Set streamChannel default algorithm properties
---
...ShowMigrationProcessConfigurationStatement.java | 4 +-
...lterMigrationProcessConfigurationStatement.java | 4 +-
...eateMigrationProcessConfigurationStatement.java | 4 +-
.../pipeline/YamlPipelineProcessConfiguration.java | 26 +++++--
.../pipeline/YamlPipelineReadConfiguration.java | 30 +++++---
.../pipeline/YamlPipelineWriteConfiguration.java | 23 +++++--
.../data/pipeline/api/PipelineJobPublicAPI.java | 2 +-
.../core/api/impl/AbstractPipelineJobAPIImpl.java | 1 +
.../memory/MemoryPipelineChannelCreator.java | 6 +-
.../util/PipelineProcessConfigurationUtils.java | 4 +-
.../distsql/ral/RALBackendHandlerFactory.java | 9 ---
.../ShowMigrationProcessConfigurationHandler.java | 44 ------------
...igrationProcessConfigurationQueryResultSet.java | 79 ++++++++++++++++++++++
.../AlterMigrationProcessConfigurationHandler.java | 34 ----------
.../AlterMigrationProcessConfigurationUpdater.java | 44 ++++++++++++
...CreateMigrationProcessConfigurationHandler.java | 34 ----------
...CreateMigrationProcessConfigurationUpdater.java | 44 ++++++++++++
...rationProcessConfigurationSegmentConverter.java | 69 +++++++++++++++++++
...dingsphere.infra.distsql.query.DistSQLResultSet | 1 +
...shardingsphere.infra.distsql.update.RALUpdater} | 9 +--
20 files changed, 315 insertions(+), 156 deletions(-)
diff --git
a/shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/queryable/ShowMigrationProcessConfigurationStatement.java
b/shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/queryable/ShowMigrationProcessConfigurationStatement.java
index 6e8eef9f7a8..8cffebac261 100644
---
a/shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/queryable/ShowMigrationProcessConfigurationStatement.java
+++
b/shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/queryable/ShowMigrationProcessConfigurationStatement.java
@@ -17,10 +17,10 @@
package org.apache.shardingsphere.distsql.parser.statement.ral.queryable;
-import
org.apache.shardingsphere.distsql.parser.statement.ral.QueryableRALStatement;
+import
org.apache.shardingsphere.distsql.parser.statement.ral.scaling.QueryableScalingRALStatement;
/**
* Show migration process configuration statement.
*/
-public final class ShowMigrationProcessConfigurationStatement extends
QueryableRALStatement {
+public final class ShowMigrationProcessConfigurationStatement extends
QueryableScalingRALStatement {
}
diff --git
a/shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/updatable/AlterMigrationProcessConfigurationStatement.java
b/shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/updatable/AlterMigrationProcessConfigurationStatement.java
index 7611747d3e1..06bca682ec4 100644
---
a/shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/updatable/AlterMigrationProcessConfigurationStatement.java
+++
b/shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/updatable/AlterMigrationProcessConfigurationStatement.java
@@ -20,14 +20,14 @@ package
org.apache.shardingsphere.distsql.parser.statement.ral.updatable;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import
org.apache.shardingsphere.distsql.parser.segment.MigrationProcessConfigurationSegment;
-import
org.apache.shardingsphere.distsql.parser.statement.ral.UpdatableRALStatement;
+import
org.apache.shardingsphere.distsql.parser.statement.ral.scaling.UpdatableScalingRALStatement;
/**
* Alter migration process configuration statement.
*/
@RequiredArgsConstructor
@Getter
-public final class AlterMigrationProcessConfigurationStatement extends
UpdatableRALStatement {
+public final class AlterMigrationProcessConfigurationStatement extends
UpdatableScalingRALStatement {
private final MigrationProcessConfigurationSegment
migrationProcessConfigurationSegment;
}
diff --git
a/shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/updatable/CreateMigrationProcessConfigurationStatement.java
b/shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/updatable/CreateMigrationProcessConfigurationStatement.java
index 3ddf7ebd124..025b1dc6303 100644
---
a/shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/updatable/CreateMigrationProcessConfigurationStatement.java
+++
b/shardingsphere-distsql/shardingsphere-distsql-statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/updatable/CreateMigrationProcessConfigurationStatement.java
@@ -20,14 +20,14 @@ package
org.apache.shardingsphere.distsql.parser.statement.ral.updatable;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import
org.apache.shardingsphere.distsql.parser.segment.MigrationProcessConfigurationSegment;
-import
org.apache.shardingsphere.distsql.parser.statement.ral.UpdatableRALStatement;
+import
org.apache.shardingsphere.distsql.parser.statement.ral.scaling.UpdatableScalingRALStatement;
/**
* Create migration process configuration statement.
*/
@RequiredArgsConstructor
@Getter
-public final class CreateMigrationProcessConfigurationStatement extends
UpdatableRALStatement {
+public final class CreateMigrationProcessConfigurationStatement extends
UpdatableScalingRALStatement {
private final MigrationProcessConfigurationSegment
migrationProcessConfigurationSegment;
}
diff --git
a/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/yaml/config/pojo/data/pipeline/YamlPipelineProcessConfiguration.java
b/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/yaml/config/pojo/data/pipeline/YamlPipelineProcessConfiguration.java
index 07e1d1f20ca..e3aed9371f0 100644
---
a/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/yaml/config/pojo/data/pipeline/YamlPipelineProcessConfiguration.java
+++
b/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/yaml/config/pojo/data/pipeline/YamlPipelineProcessConfiguration.java
@@ -44,18 +44,34 @@ public final class YamlPipelineProcessConfiguration
implements YamlConfiguration
*/
// TODO add unit test
public void copyNonNullFields(final YamlPipelineProcessConfiguration
another) {
+ if (null == another) {
+ return;
+ }
+ if (isAllFieldsNull(another)) {
+ setAllFieldsNull(this);
+ }
if (null == read) {
- read = another.getRead();
+ read = another.read;
} else {
- read.copyNonNullFields(another.getRead());
+ read.copyNonNullFields(another.read);
}
if (null == write) {
- write = another.getWrite();
+ write = another.write;
} else {
- write.copyNonNullFields(another.getWrite());
+ write.copyNonNullFields(another.write);
}
if (null == streamChannel) {
- streamChannel = another.getStreamChannel();
+ streamChannel = another.streamChannel;
}
}
+
+ private boolean isAllFieldsNull(final YamlPipelineProcessConfiguration
config) {
+ return null == config.read && null == config.write && null ==
config.streamChannel;
+ }
+
+ private void setAllFieldsNull(final YamlPipelineProcessConfiguration
config) {
+ config.read = null;
+ config.write = null;
+ config.streamChannel = null;
+ }
}
diff --git
a/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/yaml/config/pojo/data/pipeline/YamlPipelineReadConfiguration.java
b/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/yaml/config/pojo/data/pipeline/YamlPipelineReadConfiguration.java
index 7f392856597..38a29f9f8f3 100644
---
a/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/yaml/config/pojo/data/pipeline/YamlPipelineReadConfiguration.java
+++
b/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/yaml/config/pojo/data/pipeline/YamlPipelineReadConfiguration.java
@@ -74,17 +74,31 @@ public final class YamlPipelineReadConfiguration implements
YamlConfiguration {
if (null == another) {
return;
}
- if (null != another.getWorkerThread()) {
- workerThread = another.getWorkerThread();
+ if (isAllFieldsNull(another)) {
+ setAllFieldsNull(this);
}
- if (null != another.getBatchSize()) {
- batchSize = another.getBatchSize();
+ if (null != another.workerThread) {
+ workerThread = another.workerThread;
}
- if (null != another.getShardingSize()) {
- shardingSize = another.getShardingSize();
+ if (null != another.batchSize) {
+ batchSize = another.batchSize;
}
- if (null != another.getRateLimiter()) {
- rateLimiter = another.getRateLimiter();
+ if (null != another.shardingSize) {
+ shardingSize = another.shardingSize;
}
+ if (null != another.rateLimiter) {
+ rateLimiter = another.rateLimiter;
+ }
+ }
+
+ private boolean isAllFieldsNull(final YamlPipelineReadConfiguration
config) {
+ return null == config.workerThread && null == config.batchSize && null
== config.shardingSize && null == config.rateLimiter;
+ }
+
+ private void setAllFieldsNull(final YamlPipelineReadConfiguration config) {
+ config.workerThread = null;
+ config.batchSize = null;
+ config.shardingSize = null;
+ config.rateLimiter = null;
}
}
diff --git
a/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/yaml/config/pojo/data/pipeline/YamlPipelineWriteConfiguration.java
b/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/yaml/config/pojo/data/pipeline/YamlPipelineWriteConfiguration.java
index ef0d488826c..b01eab1c6e8 100644
---
a/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/yaml/config/pojo/data/pipeline/YamlPipelineWriteConfiguration.java
+++
b/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/yaml/config/pojo/data/pipeline/YamlPipelineWriteConfiguration.java
@@ -67,14 +67,27 @@ public final class YamlPipelineWriteConfiguration
implements YamlConfiguration {
if (null == another) {
return;
}
- if (null != another.getWorkerThread()) {
+ if (isAllFieldsNull(another)) {
+ setAllFieldsNull(this);
+ }
+ if (null != another.workerThread) {
workerThread = another.workerThread;
}
- if (null != another.getBatchSize()) {
- batchSize = another.getBatchSize();
+ if (null != another.batchSize) {
+ batchSize = another.batchSize;
}
- if (null != another.getRateLimiter()) {
- rateLimiter = another.getRateLimiter();
+ if (null != another.rateLimiter) {
+ rateLimiter = another.rateLimiter;
}
}
+
+ private boolean isAllFieldsNull(final YamlPipelineWriteConfiguration
config) {
+ return null == config.workerThread && null == config.batchSize && null
== config.rateLimiter;
+ }
+
+ private void setAllFieldsNull(final YamlPipelineWriteConfiguration config)
{
+ config.workerThread = null;
+ config.batchSize = null;
+ config.rateLimiter = null;
+ }
}
diff --git
a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-api/src/main/java/org/apache/shardingsphere/data/pipeline/api/PipelineJobPublicAPI.java
b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-api/src/main/java/org/apache/shardingsphere/data/pipeline/api/PipelineJobPublicAPI.java
index 1d7903a9a24..fd8815797ed 100644
---
a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-api/src/main/java/org/apache/shardingsphere/data/pipeline/api/PipelineJobPublicAPI.java
+++
b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-api/src/main/java/org/apache/shardingsphere/data/pipeline/api/PipelineJobPublicAPI.java
@@ -45,7 +45,7 @@ public interface PipelineJobPublicAPI extends TypedSPI {
/**
* Show process configuration.
*
- * @return process configuration
+ * @return process configuration, non-null
*/
PipelineProcessConfiguration showProcessConfiguration();
diff --git
a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/api/impl/AbstractPipelineJobAPIImpl.java
b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/api/impl/AbstractPipelineJobAPIImpl.java
index d1a3b38da4e..f83b6fb95fe 100644
---
a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/api/impl/AbstractPipelineJobAPIImpl.java
+++
b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/api/impl/AbstractPipelineJobAPIImpl.java
@@ -84,6 +84,7 @@ public abstract class AbstractPipelineJobAPIImpl implements
PipelineJobAPI {
if (null == existingProcessConfig) {
throw new PipelineMetaDataException("Process configuration does
not exists");
}
+ // TODO check rateLimiter type match or not
YamlPipelineProcessConfiguration targetYamlProcessConfig =
PROCESS_CONFIG_SWAPPER.swapToYamlConfiguration(existingProcessConfig);
targetYamlProcessConfig.copyNonNullFields(PROCESS_CONFIG_SWAPPER.swapToYamlConfiguration(processConfig));
processConfigPersistService.persist(getJobType(),
PROCESS_CONFIG_SWAPPER.swapToObject(targetYamlProcessConfig));
diff --git
a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/memory/MemoryPipelineChannelCreator.java
b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/memory/MemoryPipelineChannelCreator.java
index 068a1caa8ab..650ee113813 100644
---
a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/memory/MemoryPipelineChannelCreator.java
+++
b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/memory/MemoryPipelineChannelCreator.java
@@ -32,12 +32,14 @@ public final class MemoryPipelineChannelCreator implements
PipelineChannelCreato
public static final String TYPE = "MEMORY";
- private static final String BLOCK_QUEUE_SIZE_KEY = "block-queue-size";
+ public static final int BLOCK_QUEUE_SIZE_DEFAULT_VALUE = 10000;
+
+ public static final String BLOCK_QUEUE_SIZE_KEY = "block-queue-size";
@Getter
private Properties props;
- private int blockQueueSize = 10000;
+ private int blockQueueSize = BLOCK_QUEUE_SIZE_DEFAULT_VALUE;
@Override
public void init(final Properties props) {
diff --git
a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/util/PipelineProcessConfigurationUtils.java
b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/util/PipelineProcessConfigurationUtils.java
index b267cfea044..0f8f0e1f7a2 100644
---
a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/util/PipelineProcessConfigurationUtils.java
+++
b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/util/PipelineProcessConfigurationUtils.java
@@ -56,7 +56,9 @@ public final class PipelineProcessConfigurationUtils {
yamlConfig.getWrite().fillInNullFieldsWithDefaultValue();
}
if (null == yamlConfig.getStreamChannel()) {
- yamlConfig.setStreamChannel(new
YamlAlgorithmConfiguration(MemoryPipelineChannelCreator.TYPE, new
Properties()));
+ Properties props = new Properties();
+ props.put(MemoryPipelineChannelCreator.BLOCK_QUEUE_SIZE_KEY,
MemoryPipelineChannelCreator.BLOCK_QUEUE_SIZE_DEFAULT_VALUE);
+ yamlConfig.setStreamChannel(new
YamlAlgorithmConfiguration(MemoryPipelineChannelCreator.TYPE, props));
}
return SWAPPER.swapToObject(yamlConfig);
}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/RALBackendHandlerFactory.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/RALBackendHandlerFactory.java
index 5f3a5f2348b..0dbac6a9967 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/RALBackendHandlerFactory.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/RALBackendHandlerFactory.java
@@ -27,7 +27,6 @@ import
org.apache.shardingsphere.distsql.parser.statement.ral.queryable.ExportDa
import
org.apache.shardingsphere.distsql.parser.statement.ral.queryable.ShowAllVariableStatement;
import
org.apache.shardingsphere.distsql.parser.statement.ral.queryable.ShowInstanceInfoStatement;
import
org.apache.shardingsphere.distsql.parser.statement.ral.queryable.ShowInstanceListStatement;
-import
org.apache.shardingsphere.distsql.parser.statement.ral.queryable.ShowMigrationProcessConfigurationStatement;
import
org.apache.shardingsphere.distsql.parser.statement.ral.queryable.ShowModeInfoStatement;
import
org.apache.shardingsphere.distsql.parser.statement.ral.queryable.ShowSQLParserRuleStatement;
import
org.apache.shardingsphere.distsql.parser.statement.ral.queryable.ShowSQLTranslatorRuleStatement;
@@ -36,12 +35,10 @@ import
org.apache.shardingsphere.distsql.parser.statement.ral.queryable.ShowTran
import
org.apache.shardingsphere.distsql.parser.statement.ral.queryable.ShowVariableStatement;
import
org.apache.shardingsphere.distsql.parser.statement.ral.scaling.QueryableScalingRALStatement;
import
org.apache.shardingsphere.distsql.parser.statement.ral.scaling.UpdatableScalingRALStatement;
-import
org.apache.shardingsphere.distsql.parser.statement.ral.updatable.AlterMigrationProcessConfigurationStatement;
import
org.apache.shardingsphere.distsql.parser.statement.ral.updatable.AlterSQLParserRuleStatement;
import
org.apache.shardingsphere.distsql.parser.statement.ral.updatable.AlterTrafficRuleStatement;
import
org.apache.shardingsphere.distsql.parser.statement.ral.updatable.AlterTransactionRuleStatement;
import
org.apache.shardingsphere.distsql.parser.statement.ral.updatable.ApplyDistSQLStatement;
-import
org.apache.shardingsphere.distsql.parser.statement.ral.updatable.CreateMigrationProcessConfigurationStatement;
import
org.apache.shardingsphere.distsql.parser.statement.ral.updatable.CreateTrafficRuleStatement;
import
org.apache.shardingsphere.distsql.parser.statement.ral.updatable.DiscardDistSQLStatement;
import
org.apache.shardingsphere.distsql.parser.statement.ral.updatable.DropTrafficRuleStatement;
@@ -64,7 +61,6 @@ import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable.Exp
import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable.ShowAllVariableHandler;
import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable.ShowInstanceInfoHandler;
import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable.ShowInstanceListHandler;
-import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable.ShowMigrationProcessConfigurationHandler;
import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable.ShowModeInfoHandler;
import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable.ShowReadwriteSplittingReadResourcesHandler;
import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable.ShowSQLParserRuleHandler;
@@ -72,12 +68,10 @@ import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable.Sho
import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable.ShowTableMetadataHandler;
import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable.ShowTransactionRuleHandler;
import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable.ShowVariableHandler;
-import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.AlterMigrationProcessConfigurationHandler;
import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.AlterSQLParserRuleHandler;
import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.AlterTrafficRuleHandler;
import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.AlterTransactionRuleHandler;
import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.ApplyDistSQLHandler;
-import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.CreateMigrationProcessConfigurationHandler;
import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.CreateTrafficRuleHandler;
import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.DiscardDistSQLHandler;
import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.DropTrafficRuleHandler;
@@ -133,9 +127,6 @@ public final class RALBackendHandlerFactory {
HANDLERS.put(ShowSQLTranslatorRuleStatement.class,
ShowSQLTranslatorRuleHandler.class);
HANDLERS.put(ShowInstanceInfoStatement.class,
ShowInstanceInfoHandler.class);
HANDLERS.put(ShowModeInfoStatement.class, ShowModeInfoHandler.class);
- HANDLERS.put(ShowMigrationProcessConfigurationStatement.class,
ShowMigrationProcessConfigurationHandler.class);
- HANDLERS.put(CreateMigrationProcessConfigurationStatement.class,
CreateMigrationProcessConfigurationHandler.class);
- HANDLERS.put(AlterMigrationProcessConfigurationStatement.class,
AlterMigrationProcessConfigurationHandler.class);
}
/**
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowMigrationProcessConfigurationHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowMigrationProcessConfigurationHandler.java
deleted file mode 100644
index 4d149dbf511..00000000000
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowMigrationProcessConfigurationHandler.java
+++ /dev/null
@@ -1,44 +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.
- */
-
-package org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable;
-
-import
org.apache.shardingsphere.distsql.parser.statement.ral.queryable.ShowMigrationProcessConfigurationStatement;
-import
org.apache.shardingsphere.infra.merge.result.impl.local.LocalDataQueryResultRow;
-import org.apache.shardingsphere.mode.manager.ContextManager;
-import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.QueryableRALBackendHandler;
-
-import java.util.Arrays;
-import java.util.Collection;
-import java.util.Collections;
-
-/**
- * Show migration process configuration handler.
- */
-public final class ShowMigrationProcessConfigurationHandler extends
QueryableRALBackendHandler<ShowMigrationProcessConfigurationStatement> {
-
- @Override
- protected Collection<String> getColumnNames() {
- return Arrays.asList("read", "write", "stream_channel");
- }
-
- @Override
- protected Collection<LocalDataQueryResultRow> getRows(final ContextManager
contextManager) {
- // TODO
- return Collections.emptyList();
- }
-}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowMigrationProcessConfigurationQueryResultSet.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowMigrationProcessConfigurationQueryResultSet.java
new file mode 100644
index 00000000000..c6457d9863e
--- /dev/null
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowMigrationProcessConfigurationQueryResultSet.java
@@ -0,0 +1,79 @@
+/*
+ * 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.
+ */
+
+package org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable;
+
+import com.google.gson.Gson;
+import org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI;
+import org.apache.shardingsphere.data.pipeline.api.PipelineJobPublicAPIFactory;
+import
org.apache.shardingsphere.distsql.parser.statement.ral.queryable.ShowMigrationProcessConfigurationStatement;
+import
org.apache.shardingsphere.infra.config.rule.data.pipeline.PipelineProcessConfiguration;
+import org.apache.shardingsphere.infra.distsql.query.DatabaseDistSQLResultSet;
+import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
+import org.apache.shardingsphere.sql.parser.sql.common.statement.SQLStatement;
+
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.Iterator;
+import java.util.LinkedList;
+
+/**
+ * Show migration process configuration query result set.
+ */
+public final class ShowMigrationProcessConfigurationQueryResultSet implements
DatabaseDistSQLResultSet {
+
+ private static final MigrationJobPublicAPI JOB_API =
PipelineJobPublicAPIFactory.getMigrationJobPublicAPI();
+
+ private static final Gson GSON = new Gson();
+
+ private Iterator<Collection<Object>> data;
+
+ @Override
+ public void init(final ShardingSphereDatabase database, final SQLStatement
sqlStatement) {
+ PipelineProcessConfiguration processConfig =
JOB_API.showProcessConfiguration();
+ Collection<Object> row = new LinkedList<>();
+ row.add(getString(processConfig.getRead()));
+ row.add(getString(processConfig.getWrite()));
+ row.add(getString(processConfig.getStreamChannel()));
+ data = Collections.singletonList(row).iterator();
+ }
+
+ private String getString(final Object obj) {
+ return null == obj ? "" : GSON.toJson(obj);
+ }
+
+ @Override
+ public Collection<String> getColumnNames() {
+ return Arrays.asList("read", "write", "stream_channel");
+ }
+
+ @Override
+ public boolean next() {
+ return data.hasNext();
+ }
+
+ @Override
+ public Collection<Object> getRowData() {
+ return data.next();
+ }
+
+ @Override
+ public String getType() {
+ return ShowMigrationProcessConfigurationStatement.class.getName();
+ }
+}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/AlterMigrationProcessConfigurationHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/AlterMigrationProcessConfigurationHandler.java
deleted file mode 100644
index 86d59d5613a..00000000000
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/AlterMigrationProcessConfigurationHandler.java
+++ /dev/null
@@ -1,34 +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.
- */
-
-package org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable;
-
-import
org.apache.shardingsphere.distsql.parser.statement.ral.updatable.AlterMigrationProcessConfigurationStatement;
-import org.apache.shardingsphere.infra.distsql.exception.DistSQLException;
-import org.apache.shardingsphere.mode.manager.ContextManager;
-import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.UpdatableRALBackendHandler;
-
-/**
- * Alter migration process configuration handler.
- */
-public final class AlterMigrationProcessConfigurationHandler extends
UpdatableRALBackendHandler<AlterMigrationProcessConfigurationStatement> {
-
- @Override
- protected void update(final ContextManager contextManager) throws
DistSQLException {
- // TODO
- }
-}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/AlterMigrationProcessConfigurationUpdater.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/AlterMigrationProcessConfigurationUpdater.java
new file mode 100644
index 00000000000..03815ad3cad
--- /dev/null
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/AlterMigrationProcessConfigurationUpdater.java
@@ -0,0 +1,44 @@
+/*
+ * 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.
+ */
+
+package org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable;
+
+import org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI;
+import org.apache.shardingsphere.data.pipeline.api.PipelineJobPublicAPIFactory;
+import
org.apache.shardingsphere.distsql.parser.statement.ral.updatable.AlterMigrationProcessConfigurationStatement;
+import
org.apache.shardingsphere.infra.config.rule.data.pipeline.PipelineProcessConfiguration;
+import org.apache.shardingsphere.infra.distsql.update.RALUpdater;
+import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.converter.MigrationProcessConfigurationSegmentConverter;
+
+/**
+ * Alter migration process configuration updater.
+ */
+public final class AlterMigrationProcessConfigurationUpdater implements
RALUpdater<AlterMigrationProcessConfigurationStatement> {
+
+ private static final MigrationJobPublicAPI JOB_API =
PipelineJobPublicAPIFactory.getMigrationJobPublicAPI();
+
+ @Override
+ public void executeUpdate(final String databaseName, final
AlterMigrationProcessConfigurationStatement sqlStatement) {
+ PipelineProcessConfiguration processConfig =
MigrationProcessConfigurationSegmentConverter.convert(sqlStatement.getMigrationProcessConfigurationSegment());
+ JOB_API.alterProcessConfiguration(processConfig);
+ }
+
+ @Override
+ public String getType() {
+ return AlterMigrationProcessConfigurationStatement.class.getName();
+ }
+}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/CreateMigrationProcessConfigurationHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/CreateMigrationProcessConfigurationHandler.java
deleted file mode 100644
index 4586071279a..00000000000
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/CreateMigrationProcessConfigurationHandler.java
+++ /dev/null
@@ -1,34 +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.
- */
-
-package org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable;
-
-import
org.apache.shardingsphere.distsql.parser.statement.ral.updatable.CreateMigrationProcessConfigurationStatement;
-import org.apache.shardingsphere.infra.distsql.exception.DistSQLException;
-import org.apache.shardingsphere.mode.manager.ContextManager;
-import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.UpdatableRALBackendHandler;
-
-/**
- * Create migration process configuration handler.
- */
-public final class CreateMigrationProcessConfigurationHandler extends
UpdatableRALBackendHandler<CreateMigrationProcessConfigurationStatement> {
-
- @Override
- protected void update(final ContextManager contextManager) throws
DistSQLException {
- // TODO
- }
-}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/CreateMigrationProcessConfigurationUpdater.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/CreateMigrationProcessConfigurationUpdater.java
new file mode 100644
index 00000000000..e96c0f615c6
--- /dev/null
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/CreateMigrationProcessConfigurationUpdater.java
@@ -0,0 +1,44 @@
+/*
+ * 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.
+ */
+
+package org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable;
+
+import org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI;
+import org.apache.shardingsphere.data.pipeline.api.PipelineJobPublicAPIFactory;
+import
org.apache.shardingsphere.distsql.parser.statement.ral.updatable.CreateMigrationProcessConfigurationStatement;
+import
org.apache.shardingsphere.infra.config.rule.data.pipeline.PipelineProcessConfiguration;
+import org.apache.shardingsphere.infra.distsql.update.RALUpdater;
+import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.converter.MigrationProcessConfigurationSegmentConverter;
+
+/**
+ * Create migration process configuration updater.
+ */
+public final class CreateMigrationProcessConfigurationUpdater implements
RALUpdater<CreateMigrationProcessConfigurationStatement> {
+
+ private static final MigrationJobPublicAPI JOB_API =
PipelineJobPublicAPIFactory.getMigrationJobPublicAPI();
+
+ @Override
+ public void executeUpdate(final String databaseName, final
CreateMigrationProcessConfigurationStatement sqlStatement) {
+ PipelineProcessConfiguration processConfig =
MigrationProcessConfigurationSegmentConverter.convert(sqlStatement.getMigrationProcessConfigurationSegment());
+ JOB_API.createProcessConfiguration(processConfig);
+ }
+
+ @Override
+ public String getType() {
+ return CreateMigrationProcessConfigurationStatement.class.getName();
+ }
+}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/converter/MigrationProcessConfigurationSegmentConverter.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/converter/MigrationProcessConfigurationSegmentConverter.java
new file mode 100644
index 00000000000..62c5a065118
--- /dev/null
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/converter/MigrationProcessConfigurationSegmentConverter.java
@@ -0,0 +1,69 @@
+/*
+ * 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.
+ */
+
+package
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.converter;
+
+import lombok.AccessLevel;
+import lombok.NoArgsConstructor;
+import org.apache.shardingsphere.distsql.parser.segment.AlgorithmSegment;
+import
org.apache.shardingsphere.distsql.parser.segment.MigrationProcessConfigurationSegment;
+import org.apache.shardingsphere.distsql.parser.segment.ReadOrWriteSegment;
+import org.apache.shardingsphere.infra.config.algorithm.AlgorithmConfiguration;
+import
org.apache.shardingsphere.infra.config.rule.data.pipeline.PipelineProcessConfiguration;
+import
org.apache.shardingsphere.infra.config.rule.data.pipeline.PipelineReadConfiguration;
+import
org.apache.shardingsphere.infra.config.rule.data.pipeline.PipelineWriteConfiguration;
+
+/**
+ * Migration process configuration segment converter.
+ */
+@NoArgsConstructor(access = AccessLevel.PRIVATE)
+public final class MigrationProcessConfigurationSegmentConverter {
+
+ /**
+ * Convert to pipeline process configuration.
+ *
+ * @param segment migration process configuration segment
+ * @return pipeline process configuration
+ */
+ public static PipelineProcessConfiguration convert(final
MigrationProcessConfigurationSegment segment) {
+ PipelineReadConfiguration readConfig =
convertToReadConfiguration(segment.getReadSegment());
+ PipelineWriteConfiguration writeConfig =
convertToWriteConfiguration(segment.getWriteSegment());
+ AlgorithmConfiguration streamChannel =
convertToAlgorithm(segment.getStreamChannel());
+ return new PipelineProcessConfiguration(readConfig, writeConfig,
streamChannel);
+ }
+
+ private static PipelineReadConfiguration convertToReadConfiguration(final
ReadOrWriteSegment readSegment) {
+ if (null == readSegment) {
+ return null;
+ }
+ return new PipelineReadConfiguration(readSegment.getWorkerThread(),
readSegment.getBatchSize(), readSegment.getShardingSize(),
convertToAlgorithm(readSegment.getRateLimiter()));
+ }
+
+ private static PipelineWriteConfiguration
convertToWriteConfiguration(final ReadOrWriteSegment writeSegment) {
+ if (null == writeSegment) {
+ return null;
+ }
+ return new PipelineWriteConfiguration(writeSegment.getWorkerThread(),
writeSegment.getBatchSize(), convertToAlgorithm(writeSegment.getRateLimiter()));
+ }
+
+ private static AlgorithmConfiguration convertToAlgorithm(final
AlgorithmSegment segment) {
+ if (null == segment) {
+ return null;
+ }
+ return new AlgorithmConfiguration(segment.getName(),
segment.getProps());
+ }
+}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet
index 239fefc4ea8..a0fb80c2b70 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet
@@ -22,3 +22,4 @@
org.apache.shardingsphere.proxy.backend.handler.distsql.rql.rule.SingleTableRule
org.apache.shardingsphere.proxy.backend.handler.distsql.rql.rule.DatabaseRulesCountResultSet
org.apache.shardingsphere.proxy.backend.handler.distsql.rql.rule.RulesUsedResourceQueryResultSet
org.apache.shardingsphere.proxy.backend.handler.distsql.rql.rule.CountSingleTableRuleQueryResultSet
+org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable.ShowMigrationProcessConfigurationQueryResultSet
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.update.RALUpdater
similarity index 53%
copy from
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet
copy to
shardingsphere-proxy/shardingsphere-proxy-backend/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.update.RALUpdater
index 239fefc4ea8..cd9c763c7a0 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.update.RALUpdater
@@ -15,10 +15,5 @@
# limitations under the License.
#
-org.apache.shardingsphere.proxy.backend.handler.distsql.rql.resource.DataSourceQueryResultSet
-org.apache.shardingsphere.proxy.backend.handler.distsql.rql.resource.UnusedDataSourceQueryResultSet
-org.apache.shardingsphere.proxy.backend.handler.distsql.rql.rule.SingleTableQueryResultSet
-org.apache.shardingsphere.proxy.backend.handler.distsql.rql.rule.SingleTableRulesQueryResultSet
-org.apache.shardingsphere.proxy.backend.handler.distsql.rql.rule.DatabaseRulesCountResultSet
-org.apache.shardingsphere.proxy.backend.handler.distsql.rql.rule.RulesUsedResourceQueryResultSet
-org.apache.shardingsphere.proxy.backend.handler.distsql.rql.rule.CountSingleTableRuleQueryResultSet
+org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.CreateMigrationProcessConfigurationUpdater
+org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.AlterMigrationProcessConfigurationUpdater
