import { type kysely } from "https://deno.land/x/kysely_postgrs_js_dialect@v0.27.4/deps.ts";
const { Streamable } = kysely;
Methods
stream(chunkSize?: number): AsyncIterableIterator<O>
Executes the query and streams the rows.
The optional argument chunkSize
defines how many rows to fetch from the database
at a time. It only affects some dialects like PostgreSQL that support it.
Examples
const stream = db.
.selectFrom('person')
.select(['first_name', 'last_name'])
.where('gender', '=', 'other')
.stream()
for await (const person of stream) {
console.log(person.first_name)
if (person.last_name === 'Something') {
// Breaking or returning before the stream has ended will release
// the database connection and invalidate the stream.
break
}
}