[misc] fix closing of prepared statements

mariadb-corporation · Apr 16, 2024 · 78dfc92 · 78dfc92
1 parent 2442249
commit 78dfc92
Showing 1 changed file with 10 additions and 6 deletions.
diff --git a/lib/connection.js b/lib/connection.js
@@ -1083,15 +1083,17 @@ class Connection extends EventEmitter {
    * @param cmd         command
    * @private
    */
-  addCommandEnable(cmd) {
+  addCommandEnable(cmd, skipReceive) {
     cmd.once('end', this._sendNextCmdImmediate.bind(this));
 
     //send immediately only if no current active receiver
     if (this.sendQueue.isEmpty() && this.receiveQueue.isEmpty()) {
-      this.receiveQueue.push(cmd);
+      if (!skipReceive)
+        this.receiveQueue.push(cmd);
       cmd.start(this.streamOut, this.opts, this.info);
     } else {
-      this.receiveQueue.push(cmd);
+      if (!skipReceive)
+        this.receiveQueue.push(cmd);
       this.sendQueue.push(cmd);
     }
   }
@@ -1102,10 +1104,11 @@ class Connection extends EventEmitter {
    * @param cmd         command
    * @private
    */
-  addCommandEnablePipeline(cmd) {
+  addCommandEnablePipeline(cmd, skipReceive) {
     cmd.once('send_end', this._sendNextCmdImmediate.bind(this));
 
-    this.receiveQueue.push(cmd);
+    if (!skipReceive)
+      this.receiveQueue.push(cmd);
     if (this.sendQueue.isEmpty()) {
       cmd.start(this.streamOut, this.opts, this.info);
       if (cmd.sending) {
@@ -1786,7 +1789,8 @@ class Connection extends EventEmitter {
         () => {},
         () => {},
         prepareResultPacket
-      )
+      ),
+      true
     );
   }