node-pg-query-stream
node-pg-query-stream copied to clipboard
brianc
Query results from node-postgres as a readable (object) stream
This is how I currently consume the stream: ```js const query = new QueryStream('SELECT * FROM foo'); const queryStream = connect.query(query); queryStream.on('data', (row) => { console.log(row); }); ``` However, is...
Receiving the below error sometimes which causes the process to exit. Not able to reproduce always `TypeError: Cannot read property 'sync' of undefined at PostgresQuery.QueryStream.handleError (/opt/cnmaestro-server/deploy/node_modules/pg-query-stream/index.js:105:19) at PostgresQuery.handleError (/opt/cnmaestro-server/deploy/node_modules/any-db-postgres/index.js:84:27) at...
I'm not sure the reason, or if simply `query stream` is not supported by redshift. Any idea? My code: ``` const query = new QueryStream(info.sql); const stream = client.query(query); stream.on('end',...
seems like pg@7 always returns a promise now, and the promise doesn't seem to resolve for me
hi, i create table with `keys`, `body` column and the **body** column have large text data and i wanna read all text value of **body** | Column | Type |...
Version 1.1.0 broke compatibility where it no longer supports [readable](https://nodejs.org/api/stream.html#stream_event_readable) event. The general rule/recommendation for supporting [data] vs [readable] is as follows: * Both should be supported, ideally. * `data`...
I'd like to use this in conjunction with the pg-promise library and one of the things i'm trying to do is stream data from a redshift table to a dynamoDb...
Hello @brianc, According to the node.js documentation on [`readable._read`](https://nodejs.org/api/stream.html#stream_readable_read_size_1): > _read() should continue reading from the resource and pushing data until readable.push() returns false. Only when _read() is called again...
Not sure exactly why, but doing this doesn't work in TypeScript: import * as QueryStream from 'pg-query-stream'; const query = new QueryStream('SELECT true', []); This produces the following errors: file.ts...
It appears that QueryStream cannot handle queries that only return a few rows (less than 100). Here is the full stack trace: ``` TypeError: self.activeQuery.handleEmptyQuery is not a function at...
