Skip to content

Commit bd72c09

Browse files
committed
Remove FLUSH from CF integration
1 parent 428475a commit bd72c09

File tree

1 file changed

+7
-9
lines changed

1 file changed

+7
-9
lines changed

cf/src/connection.js

+7-9
Original file line numberDiff line numberDiff line change
@@ -185,13 +185,11 @@ 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.prepare
189+
? q.prepared
190+
? prepared(q)
191+
: Buffer.concat([describe(q), prepared(q)])
192+
: unnamed(q)
195193
}
196194

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

606604
query.prepare && (statements[query.signature] = query.statement)
607-
query.describeFirst && !query.onlyDescribe && (write(prepared(query)), query.describeFirst = false)
605+
query.describeFirst && !query.onlyDescribe && (query.describeFirst = false)
608606
}
609607

610608
function RowDescription(x) {
@@ -953,7 +951,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
953951
function Execute(portal = '', rows = 0) {
954952
return Buffer.concat([
955953
b().E().str(portal + b.N).i32(rows).end(),
956-
Flush
954+
Sync
957955
])
958956
}
959957

0 commit comments

Comments
 (0)