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);