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 <zhangli...@apache.org> 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);