import { entityKind } from "../entity.js"; import type { TablesRelationalConfig } from "../relations.js"; import type { PreparedQuery } from "../session.js"; import { type Query, type SQL } from "../sql/index.js"; import type { NeonAuthToken } from "../utils.js"; import { PgDatabase } from "./db.js"; import type { PgDialect } from "./dialect.js"; import type { SelectedFieldsOrdered } from "./query-builders/select.types.js"; export interface PreparedQueryConfig { execute: unknown; all: unknown; values: unknown; } export declare abstract class PgPreparedQuery implements PreparedQuery { protected query: Query; constructor(query: Query); protected authToken?: NeonAuthToken; getQuery(): Query; mapResult(response: unknown, _isFromBatch?: boolean): unknown; static readonly [entityKind]: string; abstract execute(placeholderValues?: Record): Promise; } export interface PgTransactionConfig { isolationLevel?: 'read uncommitted' | 'read committed' | 'repeatable read' | 'serializable'; accessMode?: 'read only' | 'read write'; deferrable?: boolean; } export declare abstract class PgSession = Record, TSchema extends TablesRelationalConfig = Record> { protected dialect: PgDialect; static readonly [entityKind]: string; constructor(dialect: PgDialect); abstract prepareQuery(query: Query, fields: SelectedFieldsOrdered | undefined, name: string | undefined, isResponseInArrayMode: boolean, customResultMapper?: (rows: unknown[][], mapColumnValue?: (value: unknown) => unknown) => T['execute']): PgPreparedQuery; execute(query: SQL): Promise; all(query: SQL): Promise; count(sql: SQL): Promise; abstract transaction(transaction: (tx: PgTransaction) => Promise, config?: PgTransactionConfig): Promise; } export declare abstract class PgTransaction = Record, TSchema extends TablesRelationalConfig = Record> extends PgDatabase { protected schema: { fullSchema: Record; schema: TSchema; tableNamesMap: Record; } | undefined; protected readonly nestedIndex: number; static readonly [entityKind]: string; constructor(dialect: PgDialect, session: PgSession, schema: { fullSchema: Record; schema: TSchema; tableNamesMap: Record; } | undefined, nestedIndex?: number); rollback(): never; setTransaction(config: PgTransactionConfig): Promise; abstract transaction(transaction: (tx: PgTransaction) => Promise): Promise; } export interface PgQueryResultHKT { readonly $brand: 'PgQueryResultHKT'; readonly row: unknown; readonly type: unknown; } export type PgQueryResultKind = (TKind & { readonly row: TRow; })['type'];