archive-gh-me/node-postgres
1
0
Fork 0
mirror of https://github.com/brianc/node-postgres.git synced 2026-01-18 15:55:05 +00:00
Code Issues Projects Releases Wiki Activity

fix: AWS Redshift requires a portal name to honor fetchSize

Browse Source
This commit is contained in:
John Lindal 2018-10-17 14:30:56 -07:00
parent 91bdbbd3d7
commit 19c68c753e
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
index.js
View File

@ -4,6 +4,8 @@ const prepare = require('./pg').prepareValue
const EventEmitter = require('events').EventEmitter
const util = require('util')
var nextUniqueID = 1; // concept borrowed from org.postgresql.core.v3.QueryExecutorImpl
function Cursor (text, values, config) {
EventEmitter.call(this)
@ -16,12 +18,14 @@ function Cursor (text, values, config) {
this._result = new Result(this._conf.rowMode)
this._cb = null
this._rows = null
this._portal = null;
}
util.inherits(Cursor, EventEmitter)
Cursor.prototype.submit = function (connection) {
this.connection = connection
this._portal = 'C_' + (nextUniqueID++);
const con = connection
@ -30,12 +34,13 @@ Cursor.prototype.submit = function (connection) {
}, true)
con.bind({
portal: this._portal,
values: this.values
}, true)
con.describe({
type: 'P',
name: '' // use unamed portal
name: this._portal // AWS Redshift requires a portal name
}, true)
con.flush()
@ -132,7 +137,7 @@ Cursor.prototype._getRows = function (rows, cb) {
this._cb = cb
this._rows = []
const msg = {
portal: '',
portal: this._portal,
rows: rows
}
this.connection.execute(msg, true)