import stream from "node:stream"; import pg from 'pg'; import { PgDb, PgSchema } from "./index.js"; import { PgDbLogger } from "./pgDbLogger.js"; import { IQueryAble, PgRowResult, SqlQueryOptions } from "./queryAbleInterface.js"; export declare abstract class QueryAble implements IQueryAble { db: PgDb & QueryAble; schema: PgSchema; logger: PgDbLogger; static connectionErrorListener: () => void; setLogger(logger: PgDbLogger): void; getLogger(useConsoleAsDefault?: boolean): PgDbLogger; run(sql: string, params?: any[] | {}, options?: SqlQueryOptions): Promise; query(sql: string, params?: any[] | {} | null, options?: SqlQueryOptions): Promise; protected internalQuery(options: { connection: pg.PoolClient | null; sql: string; params?: any; logger?: PgDbLogger; }): Promise; protected internalQuery(options: { connection: pg.PoolClient | null; sql: string; params?: any; logger?: PgDbLogger; rowMode: true; }): Promise; queryAsRows(sql: string, params?: any[] | {}, options?: SqlQueryOptions): Promise; queryWithOnCursorCallback(sql: string, params: any[] | Record | null, options: SqlQueryOptions | null, callback: (res: any) => any): Promise; queryAsStream(sql: string, params?: any[] | Record | null, options?: SqlQueryOptions | null): Promise; queryOne(sql: string, params?: any[] | {}, options?: SqlQueryOptions): Promise; queryFirst(sql: string, params?: any[] | {}, options?: SqlQueryOptions): Promise; queryOneField(sql: string, params?: any[] | {}, options?: SqlQueryOptions): Promise; queryOneColumn(sql: string, params?: any[] | {}, options?: SqlQueryOptions): Promise; private postProcessFields; private checkAndFixOids; private hasUnknownOids; }