This is an automated email from the ASF dual-hosted git repository.
panjuan 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 c366221af75 Refactor QueryableRALExecutor.getType() (#27964)
c366221af75 is described below
commit c366221af75f80fe6bb87e0f6f5c5d5ce5dbec8d
Author: Liang Zhang <[email protected]>
AuthorDate: Mon Aug 7 17:05:21 2023 +0800
Refactor QueryableRALExecutor.getType() (#27964)
---
.../distsql/handler/ral/query/QueryableRALExecutor.java | 3 +++
.../authority/distsql/handler/ShowAuthorityRuleExecutor.java | 4 ++--
.../cdc/distsql/handler/query/ShowStreamingJobStatusExecutor.java | 4 ++--
.../cdc/distsql/handler/query/ShowStreamingListExecutor.java | 4 ++--
.../handler/query/ShowMigrationCheckAlgorithmsExecutor.java | 4 ++--
.../distsql/handler/query/ShowMigrationCheckStatusExecutor.java | 4 ++--
.../distsql/handler/query/ShowMigrationJobStatusExecutor.java | 4 ++--
.../distsql/handler/query/ShowMigrationListExecutor.java | 4 ++--
.../handler/query/ShowMigrationSourceStorageUnitsExecutor.java | 4 ++--
.../distsql/handler/query/ShowGlobalClockRuleExecutor.java | 4 ++--
.../distsql/handler/query/ShowSQLFederationRuleExecutor.java | 4 ++--
.../parser/distsql/handler/query/ShowSQLParserRuleExecutor.java | 4 ++--
.../distsql/handler/ShowSQLTranslatorRuleExecutor.java | 4 ++--
.../traffic/distsql/handler/query/ShowTrafficRuleExecutor.java | 4 ++--
.../distsql/handler/query/ShowTransactionRuleExecutor.java | 4 ++--
.../backend/handler/distsql/ral/QueryableRALBackendHandler.java | 2 +-
.../distsql/ral/queryable/ConvertYamlConfigurationExecutor.java | 4 ++--
.../ral/queryable/ExportDatabaseConfigurationExecutor.java | 4 ++--
.../handler/distsql/ral/queryable/ExportMetaDataExecutor.java | 6 +++---
.../handler/distsql/ral/queryable/ExportStorageNodesExecutor.java | 8 ++++----
.../distsql/ral/queryable/ShowComputeNodeInfoExecutor.java | 4 ++--
.../distsql/ral/queryable/ShowComputeNodeModeExecutor.java | 4 ++--
.../handler/distsql/ral/queryable/ShowComputeNodesExecutor.java | 4 ++--
.../handler/distsql/ral/queryable/ShowDistVariableExecutor.java | 4 ++--
.../handler/distsql/ral/queryable/ShowDistVariablesExecutor.java | 4 ++--
.../handler/distsql/ral/queryable/ShowMigrationRuleExecutor.java | 6 +++---
.../queryable/ShowStatusFromReadwriteSplittingRulesExecutor.java | 6 +++---
.../handler/distsql/ral/queryable/ShowTableMetaDataExecutor.java | 4 ++--
28 files changed, 61 insertions(+), 58 deletions(-)
diff --git
a/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/ral/query/QueryableRALExecutor.java
b/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/ral/query/QueryableRALExecutor.java
index c657d0f5a50..4aa3ee3457f 100644
---
a/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/ral/query/QueryableRALExecutor.java
+++
b/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/ral/query/QueryableRALExecutor.java
@@ -49,4 +49,7 @@ public interface QueryableRALExecutor<T extends
QueryableRALStatement> extends T
default Collection<LocalDataQueryResultRow> getRows(T sqlStatement) {
return Collections.emptyList();
}
+
+ @Override
+ Class<T> getType();
}
diff --git
a/kernel/authority/distsql/handler/src/main/java/org/apache/shardingsphere/authority/distsql/handler/ShowAuthorityRuleExecutor.java
b/kernel/authority/distsql/handler/src/main/java/org/apache/shardingsphere/authority/distsql/handler/ShowAuthorityRuleExecutor.java
index eeb92355676..c3c53c8a734 100644
---
a/kernel/authority/distsql/handler/src/main/java/org/apache/shardingsphere/authority/distsql/handler/ShowAuthorityRuleExecutor.java
+++
b/kernel/authority/distsql/handler/src/main/java/org/apache/shardingsphere/authority/distsql/handler/ShowAuthorityRuleExecutor.java
@@ -48,7 +48,7 @@ public final class ShowAuthorityRuleExecutor implements
MetaDataRequiredQueryabl
}
@Override
- public String getType() {
- return ShowAuthorityRuleStatement.class.getName();
+ public Class<ShowAuthorityRuleStatement> getType() {
+ return ShowAuthorityRuleStatement.class;
}
}
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/cdc/distsql/handler/query/ShowStreamingJobStatusExecutor.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/cdc/distsql/handler/query/ShowStreamingJobStatusExecutor.java
index 6ae93b02ba0..87fab7477a4 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/cdc/distsql/handler/query/ShowStreamingJobStatusExecutor.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/cdc/distsql/handler/query/ShowStreamingJobStatusExecutor.java
@@ -67,7 +67,7 @@ public final class ShowStreamingJobStatusExecutor implements
QueryableRALExecuto
}
@Override
- public String getType() {
- return ShowStreamingStatusStatement.class.getName();
+ public Class<ShowStreamingStatusStatement> getType() {
+ return ShowStreamingStatusStatement.class;
}
}
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/cdc/distsql/handler/query/ShowStreamingListExecutor.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/cdc/distsql/handler/query/ShowStreamingListExecutor.java
index 969c148f64d..8d83b648daa 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/cdc/distsql/handler/query/ShowStreamingListExecutor.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/cdc/distsql/handler/query/ShowStreamingListExecutor.java
@@ -50,7 +50,7 @@ public final class ShowStreamingListExecutor implements
QueryableRALExecutor<Sho
}
@Override
- public String getType() {
- return ShowStreamingListStatement.class.getName();
+ public Class<ShowStreamingListStatement> getType() {
+ return ShowStreamingListStatement.class;
}
}
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationCheckAlgorithmsExecutor.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationCheckAlgorithmsExecutor.java
index 7754150a8e9..5828efe9381 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationCheckAlgorithmsExecutor.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationCheckAlgorithmsExecutor.java
@@ -49,7 +49,7 @@ public final class ShowMigrationCheckAlgorithmsExecutor
implements QueryableRALE
}
@Override
- public String getType() {
- return ShowMigrationCheckAlgorithmsStatement.class.getName();
+ public Class<ShowMigrationCheckAlgorithmsStatement> getType() {
+ return ShowMigrationCheckAlgorithmsStatement.class;
}
}
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationCheckStatusExecutor.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationCheckStatusExecutor.java
index e909fadc718..6b27af0a606 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationCheckStatusExecutor.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationCheckStatusExecutor.java
@@ -60,7 +60,7 @@ public final class ShowMigrationCheckStatusExecutor
implements QueryableRALExecu
}
@Override
- public String getType() {
- return ShowMigrationCheckStatusStatement.class.getName();
+ public Class<ShowMigrationCheckStatusStatement> getType() {
+ return ShowMigrationCheckStatusStatement.class;
}
}
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationJobStatusExecutor.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationJobStatusExecutor.java
index 24e7a9f5419..b92d9efb73e 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationJobStatusExecutor.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationJobStatusExecutor.java
@@ -66,7 +66,7 @@ public final class ShowMigrationJobStatusExecutor implements
QueryableRALExecuto
}
@Override
- public String getType() {
- return ShowMigrationStatusStatement.class.getName();
+ public Class<ShowMigrationStatusStatement> getType() {
+ return ShowMigrationStatusStatement.class;
}
}
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationListExecutor.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationListExecutor.java
index faf72d77d6a..45ed253bdf0 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationListExecutor.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationListExecutor.java
@@ -49,7 +49,7 @@ public final class ShowMigrationListExecutor implements
QueryableRALExecutor<Sho
}
@Override
- public String getType() {
- return ShowMigrationListStatement.class.getName();
+ public Class<ShowMigrationListStatement> getType() {
+ return ShowMigrationListStatement.class;
}
}
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationSourceStorageUnitsExecutor.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationSourceStorageUnitsExecutor.java
index 5340f389515..52d40f5c7c2 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationSourceStorageUnitsExecutor.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationSourceStorageUnitsExecutor.java
@@ -53,7 +53,7 @@ public final class ShowMigrationSourceStorageUnitsExecutor
implements QueryableR
}
@Override
- public String getType() {
- return ShowMigrationSourceStorageUnitsStatement.class.getName();
+ public Class<ShowMigrationSourceStorageUnitsStatement> getType() {
+ return ShowMigrationSourceStorageUnitsStatement.class;
}
}
diff --git
a/kernel/global-clock/distsql/handler/src/main/java/org/apache/shardingsphere/globalclock/distsql/handler/query/ShowGlobalClockRuleExecutor.java
b/kernel/global-clock/distsql/handler/src/main/java/org/apache/shardingsphere/globalclock/distsql/handler/query/ShowGlobalClockRuleExecutor.java
index 90c20704010..ac3b0543594 100644
---
a/kernel/global-clock/distsql/handler/src/main/java/org/apache/shardingsphere/globalclock/distsql/handler/query/ShowGlobalClockRuleExecutor.java
+++
b/kernel/global-clock/distsql/handler/src/main/java/org/apache/shardingsphere/globalclock/distsql/handler/query/ShowGlobalClockRuleExecutor.java
@@ -45,7 +45,7 @@ public final class ShowGlobalClockRuleExecutor implements
MetaDataRequiredQuerya
}
@Override
- public String getType() {
- return ShowGlobalClockRuleStatement.class.getName();
+ public Class<ShowGlobalClockRuleStatement> getType() {
+ return ShowGlobalClockRuleStatement.class;
}
}
diff --git
a/kernel/sql-federation/distsql/handler/src/main/java/org/apache/shardingsphere/sqlfederation/distsql/handler/query/ShowSQLFederationRuleExecutor.java
b/kernel/sql-federation/distsql/handler/src/main/java/org/apache/shardingsphere/sqlfederation/distsql/handler/query/ShowSQLFederationRuleExecutor.java
index ec72d5025da..801d16d3468 100644
---
a/kernel/sql-federation/distsql/handler/src/main/java/org/apache/shardingsphere/sqlfederation/distsql/handler/query/ShowSQLFederationRuleExecutor.java
+++
b/kernel/sql-federation/distsql/handler/src/main/java/org/apache/shardingsphere/sqlfederation/distsql/handler/query/ShowSQLFederationRuleExecutor.java
@@ -46,7 +46,7 @@ public final class ShowSQLFederationRuleExecutor implements
MetaDataRequiredQuer
}
@Override
- public String getType() {
- return ShowSQLFederationRuleStatement.class.getName();
+ public Class<ShowSQLFederationRuleStatement> getType() {
+ return ShowSQLFederationRuleStatement.class;
}
}
diff --git
a/kernel/sql-parser/distsql/handler/src/main/java/org/apache/shardingsphere/parser/distsql/handler/query/ShowSQLParserRuleExecutor.java
b/kernel/sql-parser/distsql/handler/src/main/java/org/apache/shardingsphere/parser/distsql/handler/query/ShowSQLParserRuleExecutor.java
index 3195d7a2508..7e182177cd3 100644
---
a/kernel/sql-parser/distsql/handler/src/main/java/org/apache/shardingsphere/parser/distsql/handler/query/ShowSQLParserRuleExecutor.java
+++
b/kernel/sql-parser/distsql/handler/src/main/java/org/apache/shardingsphere/parser/distsql/handler/query/ShowSQLParserRuleExecutor.java
@@ -47,7 +47,7 @@ public final class ShowSQLParserRuleExecutor implements
MetaDataRequiredQueryabl
}
@Override
- public String getType() {
- return ShowSQLParserRuleStatement.class.getName();
+ public Class<ShowSQLParserRuleStatement> getType() {
+ return ShowSQLParserRuleStatement.class;
}
}
diff --git
a/kernel/sql-translator/distsql/handler/src/main/java/org/apache/shardingsphere/sqltranslator/distsql/handler/ShowSQLTranslatorRuleExecutor.java
b/kernel/sql-translator/distsql/handler/src/main/java/org/apache/shardingsphere/sqltranslator/distsql/handler/ShowSQLTranslatorRuleExecutor.java
index 66747ce7f62..ddb86ee7dc1 100644
---
a/kernel/sql-translator/distsql/handler/src/main/java/org/apache/shardingsphere/sqltranslator/distsql/handler/ShowSQLTranslatorRuleExecutor.java
+++
b/kernel/sql-translator/distsql/handler/src/main/java/org/apache/shardingsphere/sqltranslator/distsql/handler/ShowSQLTranslatorRuleExecutor.java
@@ -49,7 +49,7 @@ public final class ShowSQLTranslatorRuleExecutor implements
MetaDataRequiredQuer
}
@Override
- public String getType() {
- return ShowSQLTranslatorRuleStatement.class.getName();
+ public Class<ShowSQLTranslatorRuleStatement> getType() {
+ return ShowSQLTranslatorRuleStatement.class;
}
}
diff --git
a/kernel/traffic/distsql/handler/src/main/java/org/apache/shardingsphere/traffic/distsql/handler/query/ShowTrafficRuleExecutor.java
b/kernel/traffic/distsql/handler/src/main/java/org/apache/shardingsphere/traffic/distsql/handler/query/ShowTrafficRuleExecutor.java
index f239aab4162..1aa41d11497 100644
---
a/kernel/traffic/distsql/handler/src/main/java/org/apache/shardingsphere/traffic/distsql/handler/query/ShowTrafficRuleExecutor.java
+++
b/kernel/traffic/distsql/handler/src/main/java/org/apache/shardingsphere/traffic/distsql/handler/query/ShowTrafficRuleExecutor.java
@@ -61,7 +61,7 @@ public final class ShowTrafficRuleExecutor implements
MetaDataRequiredQueryableR
}
@Override
- public String getType() {
- return ShowTrafficRulesStatement.class.getName();
+ public Class<ShowTrafficRulesStatement> getType() {
+ return ShowTrafficRulesStatement.class;
}
}
diff --git
a/kernel/transaction/distsql/handler/src/main/java/org/apache/shardingsphere/transaction/distsql/handler/query/ShowTransactionRuleExecutor.java
b/kernel/transaction/distsql/handler/src/main/java/org/apache/shardingsphere/transaction/distsql/handler/query/ShowTransactionRuleExecutor.java
index 71a66cad380..19dbfcf3a75 100644
---
a/kernel/transaction/distsql/handler/src/main/java/org/apache/shardingsphere/transaction/distsql/handler/query/ShowTransactionRuleExecutor.java
+++
b/kernel/transaction/distsql/handler/src/main/java/org/apache/shardingsphere/transaction/distsql/handler/query/ShowTransactionRuleExecutor.java
@@ -46,7 +46,7 @@ public final class ShowTransactionRuleExecutor implements
MetaDataRequiredQuerya
}
@Override
- public String getType() {
- return ShowTransactionRuleStatement.class.getName();
+ public Class<ShowTransactionRuleStatement> getType() {
+ return ShowTransactionRuleStatement.class;
}
}
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/QueryableRALBackendHandler.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/QueryableRALBackendHandler.java
index b18ab752634..198609bad53 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/QueryableRALBackendHandler.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/QueryableRALBackendHandler.java
@@ -72,7 +72,7 @@ public final class QueryableRALBackendHandler<T extends
QueryableRALStatement> i
@SuppressWarnings("unchecked")
@Override
public ResponseHeader execute() {
- QueryableRALExecutor<T> executor =
TypedSPILoader.getService(QueryableRALExecutor.class,
sqlStatement.getClass().getName());
+ QueryableRALExecutor<T> executor =
TypedSPILoader.getService(QueryableRALExecutor.class, sqlStatement.getClass());
mergedResult = getMergedResult(executor);
queryHeaders = createQueryHeader(executor.getColumnNames());
return new QueryResponseHeader(queryHeaders);
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ConvertYamlConfigurationExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ConvertYamlConfigurationExecutor.java
index 5a4306cdd84..88bcca67d59 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ConvertYamlConfigurationExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ConvertYamlConfigurationExecutor.java
@@ -168,7 +168,7 @@ public final class ConvertYamlConfigurationExecutor
implements QueryableRALExecu
}
@Override
- public String getType() {
- return ConvertYamlConfigurationStatement.class.getName();
+ public Class<ConvertYamlConfigurationStatement> getType() {
+ return ConvertYamlConfigurationStatement.class;
}
}
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ExportDatabaseConfigurationExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ExportDatabaseConfigurationExecutor.java
index af4f5e9a748..46e0622635d 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ExportDatabaseConfigurationExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ExportDatabaseConfigurationExecutor.java
@@ -48,7 +48,7 @@ public final class ExportDatabaseConfigurationExecutor
implements DatabaseRequir
}
@Override
- public String getType() {
- return ExportDatabaseConfigurationStatement.class.getName();
+ public Class<ExportDatabaseConfigurationStatement> getType() {
+ return ExportDatabaseConfigurationStatement.class;
}
}
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ExportMetaDataExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ExportMetaDataExecutor.java
index 1e07dfacbcd..a85a5e712fa 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ExportMetaDataExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ExportMetaDataExecutor.java
@@ -28,6 +28,7 @@ import
org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData;
import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import org.apache.shardingsphere.infra.spi.type.ordered.OrderedSPILoader;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
+import org.apache.shardingsphere.infra.util.json.JsonUtils;
import org.apache.shardingsphere.infra.util.yaml.YamlEngine;
import
org.apache.shardingsphere.infra.yaml.config.swapper.rule.YamlRuleConfigurationSwapper;
import org.apache.shardingsphere.proxy.backend.context.ProxyContext;
@@ -35,7 +36,6 @@ import
org.apache.shardingsphere.proxy.backend.distsql.export.ExportedClusterInf
import org.apache.shardingsphere.proxy.backend.distsql.export.ExportedMetaData;
import
org.apache.shardingsphere.proxy.backend.distsql.export.ExportedSnapshotInfo;
import org.apache.shardingsphere.proxy.backend.util.ExportUtils;
-import org.apache.shardingsphere.infra.util.json.JsonUtils;
import java.time.LocalDateTime;
import java.util.Arrays;
@@ -130,7 +130,7 @@ public final class ExportMetaDataExecutor implements
MetaDataRequiredQueryableRA
}
@Override
- public String getType() {
- return ExportMetaDataStatement.class.getName();
+ public Class<ExportMetaDataStatement> getType() {
+ return ExportMetaDataStatement.class;
}
}
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ExportStorageNodesExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ExportStorageNodesExecutor.java
index 6de623ecee5..ddfc2d3ee93 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ExportStorageNodesExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ExportStorageNodesExecutor.java
@@ -21,15 +21,15 @@ import
org.apache.shardingsphere.distsql.handler.ral.query.MetaDataRequiredQuery
import
org.apache.shardingsphere.distsql.parser.statement.ral.queryable.ExportStorageNodesStatement;
import
org.apache.shardingsphere.infra.database.core.connector.ConnectionProperties;
import
org.apache.shardingsphere.infra.datasource.props.DataSourcePropertiesCreator;
+import
org.apache.shardingsphere.infra.exception.core.ShardingSpherePreconditions;
import
org.apache.shardingsphere.infra.merge.result.impl.local.LocalDataQueryResultRow;
import org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData;
import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
-import
org.apache.shardingsphere.infra.exception.core.ShardingSpherePreconditions;
+import org.apache.shardingsphere.infra.util.json.JsonUtils;
import org.apache.shardingsphere.proxy.backend.context.ProxyContext;
import
org.apache.shardingsphere.proxy.backend.distsql.export.ExportedStorageNode;
import
org.apache.shardingsphere.proxy.backend.distsql.export.ExportedStorageNodes;
import org.apache.shardingsphere.proxy.backend.util.ExportUtils;
-import org.apache.shardingsphere.infra.util.json.JsonUtils;
import javax.sql.DataSource;
import java.time.LocalDateTime;
@@ -106,7 +106,7 @@ public final class ExportStorageNodesExecutor implements
MetaDataRequiredQueryab
}
@Override
- public String getType() {
- return ExportStorageNodesStatement.class.getName();
+ public Class<ExportStorageNodesStatement> getType() {
+ return ExportStorageNodesStatement.class;
}
}
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowComputeNodeInfoExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowComputeNodeInfoExecutor.java
index 04d07942e35..8cdd80dc5c7 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowComputeNodeInfoExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowComputeNodeInfoExecutor.java
@@ -51,7 +51,7 @@ public final class ShowComputeNodeInfoExecutor implements
InstanceContextRequire
}
@Override
- public String getType() {
- return ShowComputeNodeInfoStatement.class.getName();
+ public Class<ShowComputeNodeInfoStatement> getType() {
+ return ShowComputeNodeInfoStatement.class;
}
}
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowComputeNodeModeExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowComputeNodeModeExecutor.java
index 582dd5a4d54..dca08d1afda 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowComputeNodeModeExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowComputeNodeModeExecutor.java
@@ -48,7 +48,7 @@ public final class ShowComputeNodeModeExecutor implements
InstanceContextRequire
}
@Override
- public String getType() {
- return ShowComputeNodeModeStatement.class.getName();
+ public Class<ShowComputeNodeModeStatement> getType() {
+ return ShowComputeNodeModeStatement.class;
}
}
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowComputeNodesExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowComputeNodesExecutor.java
index 339e5bf8777..d96f620f9a7 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowComputeNodesExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowComputeNodesExecutor.java
@@ -62,7 +62,7 @@ public final class ShowComputeNodesExecutor implements
InstanceContextRequiredQu
}
@Override
- public String getType() {
- return ShowComputeNodesStatement.class.getName();
+ public Class<ShowComputeNodesStatement> getType() {
+ return ShowComputeNodesStatement.class;
}
}
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowDistVariableExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowDistVariableExecutor.java
index 667f8718871..c0a3c7662e9 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowDistVariableExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowDistVariableExecutor.java
@@ -106,7 +106,7 @@ public final class ShowDistVariableExecutor implements
ConnectionSessionRequired
}
@Override
- public String getType() {
- return ShowDistVariableStatement.class.getName();
+ public Class<ShowDistVariableStatement> getType() {
+ return ShowDistVariableStatement.class;
}
}
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowDistVariablesExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowDistVariablesExecutor.java
index fde0a2e02ab..a42299061ff 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowDistVariablesExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowDistVariablesExecutor.java
@@ -80,7 +80,7 @@ public final class ShowDistVariablesExecutor implements
ConnectionSessionRequire
}
@Override
- public String getType() {
- return ShowDistVariablesStatement.class.getName();
+ public Class<ShowDistVariablesStatement> getType() {
+ return ShowDistVariablesStatement.class;
}
}
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowMigrationRuleExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowMigrationRuleExecutor.java
index 1e847d1e76e..d7aaab03e55 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowMigrationRuleExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowMigrationRuleExecutor.java
@@ -24,8 +24,8 @@ import
org.apache.shardingsphere.data.pipeline.core.job.service.PipelineJobAPI;
import
org.apache.shardingsphere.distsql.handler.ral.query.QueryableRALExecutor;
import
org.apache.shardingsphere.distsql.parser.statement.ral.queryable.ShowMigrationRuleStatement;
import
org.apache.shardingsphere.infra.merge.result.impl.local.LocalDataQueryResultRow;
-import org.apache.shardingsphere.infra.util.json.JsonUtils;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
+import org.apache.shardingsphere.infra.util.json.JsonUtils;
import java.util.Arrays;
import java.util.Collection;
@@ -55,7 +55,7 @@ public final class ShowMigrationRuleExecutor implements
QueryableRALExecutor<Sho
}
@Override
- public String getType() {
- return ShowMigrationRuleStatement.class.getName();
+ public Class<ShowMigrationRuleStatement> getType() {
+ return ShowMigrationRuleStatement.class;
}
}
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowStatusFromReadwriteSplittingRulesExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowStatusFromReadwriteSplittingRulesExecutor.java
index 2f024fecbf8..58851ec3904 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowStatusFromReadwriteSplittingRulesExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowStatusFromReadwriteSplittingRulesExecutor.java
@@ -18,9 +18,9 @@
package org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable;
import com.google.common.base.Strings;
+import org.apache.shardingsphere.infra.datasource.state.DataSourceState;
import
org.apache.shardingsphere.infra.exception.dialect.exception.syntax.database.NoDatabaseSelectedException;
import
org.apache.shardingsphere.infra.exception.dialect.exception.syntax.database.UnknownDatabaseException;
-import org.apache.shardingsphere.infra.datasource.state.DataSourceState;
import
org.apache.shardingsphere.infra.merge.result.impl.local.LocalDataQueryResultRow;
import org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData;
import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
@@ -135,7 +135,7 @@ public final class
ShowStatusFromReadwriteSplittingRulesExecutor implements Conn
}
@Override
- public String getType() {
- return ShowStatusFromReadwriteSplittingRulesStatement.class.getName();
+ public Class<ShowStatusFromReadwriteSplittingRulesStatement> getType() {
+ return ShowStatusFromReadwriteSplittingRulesStatement.class;
}
}
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowTableMetaDataExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowTableMetaDataExecutor.java
index e519d1ecd5b..96d2f86b41a 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowTableMetaDataExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowTableMetaDataExecutor.java
@@ -63,7 +63,7 @@ public final class ShowTableMetaDataExecutor implements
DatabaseRequiredQueryabl
}
@Override
- public String getType() {
- return ShowTableMetaDataStatement.class.getName();
+ public Class<ShowTableMetaDataStatement> getType() {
+ return ShowTableMetaDataStatement.class;
}
}
