diff --git a/src/connection.js b/src/connection.js
index 578a6a02..8ec37bb5 100644
--- a/src/connection.js
+++ b/src/connection.js
@@ -956,14 +956,14 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
   function Execute(portal = '', rows = 0) {
     return Buffer.concat([
       b().E().str(portal + b.N).i32(rows).end(),
-      Flush
+      rows === 0 ? Sync : Flush
     ])
   }
 
   function Close(portal = '') {
     return Buffer.concat([
       b().C().str('P').str(portal + b.N).end(),
-      b().S().end()
+      Sync
     ])
   }