[shardingsphere] branch master updated: Fix incorrect statement for DistSQL handler. (#20760)

[zhonghongsheng]

This is an automated email from the ASF dual-hosted git repository.

zhonghongsheng 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 2dc169f6834 Fix incorrect statement for DistSQL handler. (#20760)
2dc169f6834 is described below

commit 2dc169f68345946901d7a9e6ec03f0a31f2d09a6
Author: Raigor <raigor.ji...@gmail.com>
AuthorDate: Sun Sep 4 12:58:03 2022 +0800

    Fix incorrect statement for DistSQL handler. (#20760)
---
 .../backend/handler/distsql/ral/updatable/ApplyDistSQLHandler.java    | 4 ++--
 .../backend/handler/distsql/ral/updatable/DiscardDistSQLHandler.java  | 4 ++--
 .../backend/handler/distsql/ral/updatable/PrepareDistSQLHandler.java  | 4 ++--
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/ApplyDistSQLHandler.java
 
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/ApplyDistSQLHandler.java
index e28e8e4bf16..1ae1ded4fed 100644
--- 
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/ApplyDistSQLHandler.java
+++ 
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/ApplyDistSQLHandler.java
@@ -17,14 +17,14 @@
 
 package org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable;
 
+import 
org.apache.shardingsphere.distsql.parser.statement.ral.updatable.ApplyDistSQLStatement;
 import org.apache.shardingsphere.mode.manager.ContextManager;
 import 
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.UpdatableRALBackendHandler;
-import 
org.apache.shardingsphere.transaction.distsql.parser.statement.updatable.AlterTransactionRuleStatement;
 
 /**
  * Apply dist SQL statement handler.
  */
-public final class ApplyDistSQLHandler extends 
UpdatableRALBackendHandler<AlterTransactionRuleStatement> {
+public final class ApplyDistSQLHandler extends 
UpdatableRALBackendHandler<ApplyDistSQLStatement> {
     
     @Override
     protected void update(final ContextManager contextManager) {
diff --git 
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/DiscardDistSQLHandler.java
 
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/DiscardDistSQLHandler.java
index 687bfab3f71..dc719ca830b 100644
--- 
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/DiscardDistSQLHandler.java
+++ 
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/DiscardDistSQLHandler.java
@@ -17,14 +17,14 @@
 
 package org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable;
 
+import 
org.apache.shardingsphere.distsql.parser.statement.ral.updatable.DiscardDistSQLStatement;
 import org.apache.shardingsphere.mode.manager.ContextManager;
 import 
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.UpdatableRALBackendHandler;
-import 
org.apache.shardingsphere.transaction.distsql.parser.statement.updatable.AlterTransactionRuleStatement;
 
 /**
  * Discard dist SQL statement handler.
  */
-public final class DiscardDistSQLHandler extends 
UpdatableRALBackendHandler<AlterTransactionRuleStatement> {
+public final class DiscardDistSQLHandler extends 
UpdatableRALBackendHandler<DiscardDistSQLStatement> {
     
     @Override
     protected void update(final ContextManager contextManager) {
diff --git 
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/PrepareDistSQLHandler.java
 
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/PrepareDistSQLHandler.java
index a0ee98e3229..b3cde729f15 100644
--- 
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/PrepareDistSQLHandler.java
+++ 
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/PrepareDistSQLHandler.java
@@ -17,14 +17,14 @@
 
 package org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable;
 
+import 
org.apache.shardingsphere.distsql.parser.statement.ral.updatable.PrepareDistSQLStatement;
 import org.apache.shardingsphere.mode.manager.ContextManager;
 import 
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.UpdatableRALBackendHandler;
-import 
org.apache.shardingsphere.transaction.distsql.parser.statement.updatable.AlterTransactionRuleStatement;
 
 /**
  * Prepare dist SQL statement handler.
  */
-public final class PrepareDistSQLHandler extends 
UpdatableRALBackendHandler<AlterTransactionRuleStatement> {
+public final class PrepareDistSQLHandler extends 
UpdatableRALBackendHandler<PrepareDistSQLStatement> {
     
     @Override
     protected void update(final ContextManager contextManager) {