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 b548d3e3ac0 Refactor ProxyBackendHandlerFactory (#35399)
b548d3e3ac0 is described below

commit b548d3e3ac028680c5e2c0e41a3da87d3ddb0d30
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Wed May 14 12:18:05 2025 +0800

    Refactor ProxyBackendHandlerFactory (#35399)
---
 .../proxy/backend/handler/ProxyBackendHandlerFactory.java          | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/ProxyBackendHandlerFactory.java
 
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/ProxyBackendHandlerFactory.java
index bd1f49d911a..a67c7c6349c 100644
--- 
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/ProxyBackendHandlerFactory.java
+++ 
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/ProxyBackendHandlerFactory.java
@@ -87,9 +87,10 @@ public final class ProxyBackendHandlerFactory {
         if (sqlStatement instanceof EmptyStatement) {
             return new SkipBackendHandler(sqlStatement);
         }
-        SQLStatementContext sqlStatementContext = sqlStatement instanceof 
DistSQLStatement ? new DistSQLStatementContext((DistSQLStatement) sqlStatement)
-                : new 
SQLBindEngine(ProxyContext.getInstance().getContextManager().getMetaDataContexts().getMetaData(),
 connectionSession.getCurrentDatabaseName(), 
hintValueContext).bind(sqlStatement,
-                        Collections.emptyList());
+        SQLStatementContext sqlStatementContext = sqlStatement instanceof 
DistSQLStatement
+                ? new DistSQLStatementContext((DistSQLStatement) sqlStatement)
+                : new 
SQLBindEngine(ProxyContext.getInstance().getContextManager().getMetaDataContexts().getMetaData(),
+                        connectionSession.getCurrentDatabaseName(), 
hintValueContext).bind(sqlStatement, Collections.emptyList());
         QueryContext queryContext = new QueryContext(sqlStatementContext, sql, 
Collections.emptyList(), hintValueContext, 
connectionSession.getConnectionContext(),
                 
ProxyContext.getInstance().getContextManager().getMetaDataContexts().getMetaData());
         connectionSession.setQueryContext(queryContext);

Reply via email to