(shardingsphere) branch master updated: Refactor DistSQLQueryExecuteEngine (#30089)

[wuweijie]

This is an automated email from the ASF dual-hosted git repository.

wuweijie 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 a9c406e32f6 Refactor DistSQLQueryExecuteEngine (#30089)
a9c406e32f6 is described below

commit a9c406e32f6805ce84361f1be714c1a4cecaae0d
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Sun Feb 11 16:20:53 2024 +0800

    Refactor DistSQLQueryExecuteEngine (#30089)
    
    * Add SQLStatement parameter on DistSQLQueryExecutor.getColumnNames()
    
    * Refactor DistSQLQueryExecuteEngine
---
 .../distsql/handler/engine/query/DistSQLQueryExecuteEngine.java         | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/engine/query/DistSQLQueryExecuteEngine.java
 
b/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/engine/query/DistSQLQueryExecuteEngine.java
index 8cce66e2746..0cb8bf79861 100644
--- 
a/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/engine/query/DistSQLQueryExecuteEngine.java
+++ 
b/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/engine/query/DistSQLQueryExecuteEngine.java
@@ -70,9 +70,11 @@ public final class DistSQLQueryExecuteEngine {
         try {
             new DistSQLExecutorAwareSetter(executor).set(contextManager, null 
== databaseName ? null : contextManager.getDatabase(databaseName), 
distsqlConnectionContext);
         } catch (final UnsupportedSQLOperationException ignored) {
+            columnNames = executor.getColumnNames(sqlStatement);
             rows = Collections.emptyList();
             return;
         }
+        columnNames = executor.getColumnNames(sqlStatement);
         rows = executor.getRows(sqlStatement, contextManager);
     }
 }