import * as common from "@data-heaving/common";
export declare type TSQLRow = ReadonlyArray<unknown> | undefined;
export interface SQLConnectionReaderAbstraction<
  TIntermediateRequest,
  TFinalRequest
> {
  createRequest: (sqlCommand: string) => TIntermediateRequest;
  defaultPrepareRequest: (req: TIntermediateRequest) => TFinalRequest;
  streamQuery: (
    options: QueryExecutionParametersWithRequest<TFinalRequest>,
    controlFlow: common.ControlFlow | undefined,
  ) => Promise<unknown>;
}
export declare type RowTransformer<T, TRow = ReadonlyArray<unknown>> = (
  row: TRow,
  controlFlow: common.ControlFlow | undefined,
) => T;
export interface QueryExecutionParametersBase<
  TResult = unknown,
  TRow = ReadonlyArray<unknown>
> {
  sqlCommand: string;
  onRow: RowTransformer<TResult, TRow>;
  onDone?: (rowsAffected: Array<number>) => unknown;
}
export declare type QueryExecutionParametersWithRequest<
  TFinalRequest
> = QueryExecutionParametersBase & {
  request: TFinalRequest;
};
export declare type QueryExecutionParameters<
  TIntermediateRequest,
  TFinalRequest,
  TResult = unknown,
  TRow = ReadonlyArray<unknown>
> = QueryExecutionParametersBase<TResult, TRow> & {
  connection: SQLConnectionReaderAbstraction<
    TIntermediateRequest,
    TFinalRequest
  >;
  prepareRequest?: (request: TIntermediateRequest) => TFinalRequest;
};
export declare type QueryExecutionParametersSingle<
  TIntermediateRequest,
  TFinalRequest,
  TResult,
  TRow = ReadonlyArray<unknown>
> = QueryExecutionParameters<
  TIntermediateRequest,
  TFinalRequest,
  TResult,
  TRow
> & {
  strict?: boolean;
};
export declare const executeStatementNoResults: <
  TIntermediateRequest,
  TFinalRequest
>(
  opts: Omit<
    QueryExecutionParameters<
      TIntermediateRequest,
      TFinalRequest,
      unknown,
      readonly unknown[]
    >,
    "onRow"
  >,
) => Promise<void>;
export declare const getQuerySingleValue: <
  TIntermediateRequest,
  TFinalRequest,
  TResult
>(
  opts: QueryExecutionParametersBase<TResult, unknown> & {
    connection: SQLConnectionReaderAbstraction<
      TIntermediateRequest,
      TFinalRequest
    >;
    prepareRequest?:
      | ((request: TIntermediateRequest) => TFinalRequest)
      | undefined;
  } & {
    strict?: boolean | undefined;
  } & {
    columnIndex?: number | undefined;
  },
) => Promise<undefined>;
export declare const getQuerySingleRow: <
  TIntermediateRequest,
  TFinalRequest,
  TResult
>(
  opts: QueryExecutionParametersSingle<
    TIntermediateRequest,
    TFinalRequest,
    TResult,
    readonly unknown[]
  >,
) => Promise<undefined>;
export declare const streamQueryResults: <
  TIntermediateRequest,
  TFinalRequest,
  TResult
>(
  opts: QueryExecutionParameters<
    TIntermediateRequest,
    TFinalRequest,
    TResult,
    readonly unknown[]
  >,
) => Promise<TResult[]>;
export declare const streamQuery: <TIntermediateRequest, TFinalRequest>(
  opts: QueryExecutionParameters<
    TIntermediateRequest,
    TFinalRequest,
    unknown,
    readonly unknown[]
  >,
) => Promise<void>;
export declare const streamQueryOnRequest: <TFinalRequest>(
  {
    sqlCommand,
    onRow,
    onDone,
    request,
  }: QueryExecutionParametersWithRequest<TFinalRequest>,
  connectionStreamQuery: (
    options: QueryExecutionParametersWithRequest<TFinalRequest>,
    controlFlow: common.ControlFlow | undefined,
  ) => Promise<unknown>,
) => Promise<void>;
export declare class UnexpectedAmountOfRowsError extends Error {
  readonly tooMany: boolean;
  constructor(tooMany: boolean);
}