node-pg-query-stream

node-pg-query-stream copied to clipboard

Do not emit 'close' event after finish with query

12

We found that one of our apps could not use node11 because of breaking change. I created [bug](https://github.com/nodejs/node/issues/26373) in nodejs repo. And node maintainers said it is bug in this...

btd

Do not emit 'close' event after you finished read rows

5

This fixes https://github.com/brianc/node-pg-query-stream/issues/52

btd

I am using a node module to connect to an sql database, but when I do streaming, it gets the Node blocking by design. I cannot do a simple GET...

spimou

Is there a way to get the total number of rows as soon as the query executor knows the total result size?

1

I am streaming results and I would to cut off the stream after X rows, but I need to know how many rows there are in total. I have tried...

gajus

await:ing in for-await loops short-circuits the stream

1

Hi, I'm trying my luck using async iterators, with the end goal to use `for-await`. However, a peculiar behaviour occurred while awaiting within the loop. I am not sure if...

fl0w

Stream not closed if for:await loop break

1

Considering the [first](https://github.com/jamiemccrindle/axax/blob/master/src/first.ts) utility (that yields the first result and then breaks): ```js import { fist } from 'axax/esnext/first' async function* toAsyncIterable(conn, config) { const stream = conn.query(new QueryStream(config.text, config.values))...

matthieusieben

Have the option to rely on PG's 'row' event rather than polling with cursor

1

I would like to stream large amounts of rows from a database without being powered behind the scenes by having multiple queries with a cursor. Currently using this is super...

flesler

Get number of rows?

5

Would it be difficult to make the library report the number of rows processed, as a parameter of the `end` event? It just seems to be the key information for...

vitaly-t

multiple streams and stream needs to be piped to writable

1

Hi, I am struggling to see, why the below test would not work. Maybe I get something wrong. But right now I assume there is something very quirky during the...

eljefedelrodeodeljefe

Should work with a QueryConfig

2

Hi Brianc, and thx for this great module ! Unlike pg.Client, QueryStream doesn't seem to work when a QueryConfig is passed, ie an object as : ``` { text :...

abenhamdine