(shardingsphere) branch master updated: Refactor MySQLComStmtPrepareExecutor (#35389)

[zhangliang]

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 f5dd504e30e Refactor MySQLComStmtPrepareExecutor (#35389)
f5dd504e30e is described below

commit f5dd504e30ee33e2fa56471ebd0a30bb6b18b07f
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Wed May 14 01:06:33 2025 +0800

    Refactor MySQLComStmtPrepareExecutor (#35389)
---
 .../command/query/binary/prepare/MySQLComStmtPrepareExecutor.java     | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/proxy/frontend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/mysql/command/query/binary/prepare/MySQLComStmtPrepareExecutor.java
 
b/proxy/frontend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/mysql/command/query/binary/prepare/MySQLComStmtPrepareExecutor.java
index 854b1eaebe5..af06539203e 100644
--- 
a/proxy/frontend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/mysql/command/query/binary/prepare/MySQLComStmtPrepareExecutor.java
+++ 
b/proxy/frontend/type/mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/mysql/command/query/binary/prepare/MySQLComStmtPrepareExecutor.java
@@ -82,9 +82,7 @@ public final class MySQLComStmtPrepareExecutor implements 
CommandExecutor {
         SQLParserRule sqlParserRule = 
metaDataContexts.getMetaData().getGlobalRuleMetaData().getSingleRule(SQLParserRule.class);
         DatabaseType databaseType = 
TypedSPILoader.getService(DatabaseType.class, "MySQL");
         SQLStatement sqlStatement = 
sqlParserRule.getSQLParserEngine(databaseType).parse(packet.getSQL(), true);
-        if (!MySQLComStmtPrepareChecker.isAllowedStatement(sqlStatement)) {
-            throw new UnsupportedPreparedStatementException();
-        }
+        
ShardingSpherePreconditions.checkState(MySQLComStmtPrepareChecker.isAllowedStatement(sqlStatement),
 UnsupportedPreparedStatementException::new);
         SQLStatementContext sqlStatementContext = new 
SQLBindEngine(ProxyContext.getInstance().getContextManager().getMetaDataContexts().getMetaData(),
                 connectionSession.getCurrentDatabaseName(), 
packet.getHintValueContext()).bind(sqlStatement, Collections.emptyList());
         int statementId = 
MySQLStatementIdGenerator.getInstance().nextStatementId(connectionSession.getConnectionId());