Optimizing streaming query performance.

jd-opensource · Aug 24, 2023 · 915e72e · 915e72e
1 parent e9d5536
commit 915e72e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main/java/com/jd/jdbc/engine/RouteStream.java b/src/main/java/com/jd/jdbc/engine/RouteStream.java
@@ -143,9 +143,11 @@ private VtRowList fetchOrdered(boolean wantFields) throws SQLException {
         }
 
         VtResultSet vtResultSet = new VtResultSet();
-        if (wantFields && vtResultSet.getFields() == null) {
+        if (wantFields && fields == null) {
             vtResultSet.appendResult(this.routeEngine.getFields(vcursor, bindVariableMap));
             fields = vtResultSet.getFields();
+        } else if (wantFields) {
+            vtResultSet.setFields(fields);
         }
 
         if (sortedValues.isEmpty()) {