/** * Querying * * @since 1.0.0 */ import type * as Schema from "@effect/schema/Schema"; import type * as Effect from "effect/Effect"; import type * as Stream from "effect/Stream"; import type * as pg from "pg"; import type * as PgError from "./PgError.js"; /** * @category models * @since 1.0.0 */ export interface QueryStreamOptions { maxRowsPerRead: number; } /** * @category querying * @since 1.0.0 */ export declare const all: { (sql: string, schema: Schema.Schema): (...values: Array) => Effect.Effect, PgError.PostgresQueryError | PgError.PostgresValidationError, pg.ClientBase | R>; (sql: string): (...values: Array) => Effect.Effect, PgError.PostgresQueryError, pg.ClientBase>; }; /** * @category querying * @since 1.0.0 */ export declare const one: { (sql: string): (...values: Array) => Effect.Effect; (sql: string, schema?: Schema.Schema): (...values: Array) => Effect.Effect; }; /** * @category querying * @since 1.0.0 */ export declare const stream: { (queryText: string, schema: Schema.Schema, options?: Partial): (...values: Array) => Stream.Stream; (queryText: string, options?: Partial): (...values: Array) => Stream.Stream; }; /** * @category transactions * @since 1.0.0 */ export declare const begin: Effect.Effect; /** * @category transactions * @since 1.0.0 */ export declare const commit: Effect.Effect; /** * @category transactions * @since 1.0.0 */ export declare const rollback: Effect.Effect; /** * @category transactions * @since 1.0.0 */ export declare const transaction: (self: Effect.Effect) => Effect.Effect; /** * @category transactions * @since 1.0.0 */ export declare const transactionRollback: (self: Effect.Effect) => Effect.Effect; //# sourceMappingURL=PgQuery.d.ts.map