import { type Cache } from '../cache/core/cache.js'; import type { WithCacheConfig } from '../cache/core/types.js'; 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; private cache; private queryMetadata; private cacheConfig?; constructor(query: Query, cache: Cache | undefined, queryMetadata: { type: 'select' | 'update' | 'delete' | 'insert'; tables: string[]; } | undefined, cacheConfig?: WithCacheConfig | undefined); protected authToken?: NeonAuthToken | undefined; getQuery(): Query; mapResult(response: unknown, _isFromBatch?: boolean): unknown; /** @internal */ setToken(token?: NeonAuthToken): this; static readonly [entityKind]: string; /** @internal */ joinsNotNullableMap?: Record; /** @internal */ protected queryWithCache(queryString: string, params: any[], query: () => Promise): Promise; abstract execute(placeholderValues?: Record): Promise; /** @internal */ abstract execute(placeholderValues?: Record, token?: NeonAuthToken): Promise; /** @internal */ abstract execute(placeholderValues?: Record, token?: NeonAuthToken): Promise; /** @internal */ abstract all(placeholderValues?: Record): Promise; /** @internal */ abstract isResponseInArrayMode(): boolean; } 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'], queryMetadata?: { type: 'select' | 'update' | 'delete' | 'insert'; tables: string[]; }, cacheConfig?: WithCacheConfig): PgPreparedQuery; execute(query: SQL): Promise; /** @internal */ execute(query: SQL, token?: NeonAuthToken): Promise; all(query: SQL): Promise; count(sql: SQL): Promise; /** @internal */ count(sql: SQL, token?: NeonAuthToken): 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; /** @internal */ getTransactionConfigSQL(config: PgTransactionConfig): SQL; 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']; //# sourceMappingURL=session.d.ts.map