diff --git a/cjs/src/connection.js b/cjs/src/connection.js index 10184ca3..15fad8ee 100644 --- a/cjs/src/connection.js +++ b/cjs/src/connection.js @@ -956,7 +956,7 @@ 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 ]) } diff --git a/deno/src/connection.js b/deno/src/connection.js index 81f26c08..6af94604 100644 --- a/deno/src/connection.js +++ b/deno/src/connection.js @@ -959,7 +959,7 @@ 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 ]) } diff --git a/src/connection.js b/src/connection.js index 578a6a02..1f4d9604 100644 --- a/src/connection.js +++ b/src/connection.js @@ -956,7 +956,7 @@ 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 ]) }