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 38547f3d151 Generalize SQL statement handling in UnavailableProxyState
(#35401)
38547f3d151 is described below
commit 38547f3d1519bc5a175cff67ffba8b05095cc9b1
Author: Liang Zhang <[email protected]>
AuthorDate: Wed May 14 12:38:32 2025 +0800
Generalize SQL statement handling in UnavailableProxyState (#35401)
- Replace MySQL-specific statements with core statements
- Update import statements and adjust SQL statement lists accordingly
---
.../proxy/backend/state/impl/UnavailableProxyState.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/state/impl/UnavailableProxyState.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/state/impl/UnavailableProxyState.java
index e49496eba22..a9ab9b17e39 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/state/impl/UnavailableProxyState.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/state/impl/UnavailableProxyState.java
@@ -26,9 +26,9 @@ import
org.apache.shardingsphere.mode.exception.ShardingSphereStateException;
import org.apache.shardingsphere.proxy.backend.state.ProxyClusterState;
import org.apache.shardingsphere.proxy.backend.state.SQLSupportedJudgeEngine;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.SQLStatement;
+import
org.apache.shardingsphere.sql.parser.statement.core.statement.dal.ShowDatabasesStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dal.ShowStatement;
-import
org.apache.shardingsphere.sql.parser.statement.mysql.dal.MySQLShowDatabasesStatement;
-import
org.apache.shardingsphere.sql.parser.statement.mysql.dal.MySQLUseStatement;
+import
org.apache.shardingsphere.sql.parser.statement.core.statement.dal.UseStatement;
import java.util.Arrays;
import java.util.Collection;
@@ -41,7 +41,7 @@ public final class UnavailableProxyState implements
ProxyClusterState {
private static final Collection<Class<? extends SQLStatement>>
SUPPORTED_SQL_STATEMENTS = Arrays.asList(
ImportMetaDataStatement.class, ShowStatement.class,
QueryableRALStatement.class,
- RQLStatement.class, UnlockClusterStatement.class,
MySQLShowDatabasesStatement.class, MySQLUseStatement.class);
+ RQLStatement.class, UnlockClusterStatement.class,
ShowDatabasesStatement.class, UseStatement.class);
private static final Collection<Class<? extends SQLStatement>>
UNSUPPORTED_SQL_STATEMENTS = Collections.singleton(SQLStatement.class);