test5

xinyiZzz · Mar 1, 2024 · c2094c0 · c2094c0
1 parent 8037bda
commit c2094c0
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/plsql/Exec.java b/fe/fe-core/src/main/java/org/apache/doris/plsql/Exec.java
@@ -1169,6 +1169,7 @@ public Integer visitStmt(StmtContext ctx) {
     @Override
     public Integer visitDoris_statement(Doris_statementContext ctx) {
         Integer rc = exec.stmt.statement(ctx);
+        console.printError("test3");
         // Sometimes the query results are not returned to the mysql client,
         // such as declare result; select … into result;
         resultListener.onFinalize();

diff --git a/fe/fe-core/src/main/java/org/apache/doris/plsql/executor/PlsqlResult.java b/fe/fe-core/src/main/java/org/apache/doris/plsql/executor/PlsqlResult.java
@@ -120,6 +120,7 @@ public void onEof() {
 
     @Override
     public void onFinalize() {
+        // If metadata not null, it means that mysql channel sent query results.
         if (metadata == null) {
             return;
         }
@@ -195,7 +196,7 @@ public void flushConsole() {
         ConnectContext ctx = processor != null ? processor.getConnectContext() : ConnectContext.get();
         boolean needSend = false;
         if (error.length() > 0) {
-            ctx.getState().setError(getLastErrorCode().toString() + ", " + error.toString());
+            ctx.getState().setError(getLastErrorCode(), error.toString());
             needSend = true;
         } else if (msg.length() > 0) {
             ctx.getState().setOk(0, 0, msg.toString());