We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e413124 commit d994000Copy full SHA for d994000
2 files changed
packages/pg/lib/connection.js
@@ -178,6 +178,11 @@ class Connection extends EventEmitter {
178
this._send(syncBuffer)
179
}
180
181
+ pipelineSync() {
182
+ // Send sync without marking connection as ending (for pipeline mode)
183
+ this._send(syncBuffer)
184
+ }
185
+
186
ref() {
187
this.stream.ref()
188
packages/pg/lib/query.js
@@ -281,7 +281,7 @@ class Query extends EventEmitter {
281
})
282
283
if (!this.rows) {
284
- connection.sync()
+ connection.pipelineSync()
285
} else {
286
connection.flush()
287
0 commit comments