Skip to content
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.

Commit 90ad051

Browse files
committedNov 22, 2023
Remove FLUSH from CF integration
1 parent 428475a commit 90ad051

File tree

1 file changed

+3
-9
lines changed

1 file changed

+3
-9
lines changed
 

‎cf/src/connection.js

+3-9
Original file line numberDiff line numberDiff line change
@@ -185,13 +185,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
185185

186186
return q.options.simple
187187
? b().Q().str(q.statement.string + b.N).end()
188-
: q.describeFirst
189-
? Buffer.concat([describe(q), Flush])
190-
: q.prepare
191-
? q.prepared
192-
? prepared(q)
193-
: Buffer.concat([describe(q), prepared(q)])
194-
: unnamed(q)
188+
: q.prepared ? prepared(q) : Buffer.concat([describe(q), prepared(q)])
195189
}
196190

197191
function describe(q) {
@@ -604,7 +598,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
604598
!query.statement.types[i] && (query.statement.types[i] = x.readUInt32BE(7 + i * 4))
605599

606600
query.prepare && (statements[query.signature] = query.statement)
607-
query.describeFirst && !query.onlyDescribe && (write(prepared(query)), query.describeFirst = false)
601+
query.describeFirst && !query.onlyDescribe && (query.describeFirst = false)
608602
}
609603

610604
function RowDescription(x) {
@@ -953,7 +947,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
953947
function Execute(portal = '', rows = 0) {
954948
return Buffer.concat([
955949
b().E().str(portal + b.N).i32(rows).end(),
956-
Flush
950+
Sync
957951
])
958952
}
959953

0 commit comments

Comments
 (0)
Please sign in to comment.