AK-21/Graphite-Industrial-Intelligence
0
1import type { OPSQLiteConnection, QueryResult } from '@op-engineering/op-sqlite';2import { type Cache } from "../cache/core/index.js";3import type { WithCacheConfig } from "../cache/core/types.js";4import { entityKind } from "../entity.js";5import type { Logger } from "../logger.js";6import type { RelationalSchemaConfig, TablesRelationalConfig } from "../relations.js";7import { type Query } from "../sql/sql.js";8import type { SQLiteAsyncDialect } from "../sqlite-core/dialect.js";9import { SQLiteTransaction } from "../sqlite-core/index.js";10import type { SelectedFieldsOrdered } from "../sqlite-core/query-builders/select.types.js";11import { type PreparedQueryConfig as PreparedQueryConfigBase, type SQLiteExecuteMethod, SQLitePreparedQuery, SQLiteSession, type SQLiteTransactionConfig } from "../sqlite-core/session.js";12export interface OPSQLiteSessionOptions {13 logger?: Logger;14 cache?: Cache;15}16type PreparedQueryConfig = Omit<PreparedQueryConfigBase, 'statement' | 'run'>;17export declare class OPSQLiteSession<TFullSchema extends Record<string, unknown>, TSchema extends TablesRelationalConfig> extends SQLiteSession<'async', QueryResult, TFullSchema, TSchema> {18 private client;19 private schema;20 static readonly [entityKind]: string;21 private logger;22 private cache;23 constructor(client: OPSQLiteConnection, dialect: SQLiteAsyncDialect, schema: RelationalSchemaConfig<TSchema> | undefined, options?: OPSQLiteSessionOptions);24 prepareQuery<T extends Omit<PreparedQueryConfig, 'run'>>(query: Query, fields: SelectedFieldsOrdered | undefined, executeMethod: SQLiteExecuteMethod, isResponseInArrayMode: boolean, customResultMapper?: (rows: unknown[][]) => unknown, queryMetadata?: {25 type: 'select' | 'update' | 'delete' | 'insert';26 tables: string[];27 }, cacheConfig?: WithCacheConfig): OPSQLitePreparedQuery<T>;28 transaction<T>(transaction: (tx: OPSQLiteTransaction<TFullSchema, TSchema>) => T, config?: SQLiteTransactionConfig): T;29}30export declare class OPSQLiteTransaction<TFullSchema extends Record<string, unknown>, TSchema extends TablesRelationalConfig> extends SQLiteTransaction<'async', QueryResult, TFullSchema, TSchema> {31 static readonly [entityKind]: string;32 transaction<T>(transaction: (tx: OPSQLiteTransaction<TFullSchema, TSchema>) => T): T;33}34export declare class OPSQLitePreparedQuery<T extends PreparedQueryConfig = PreparedQueryConfig> extends SQLitePreparedQuery<{35 type: 'async';36 run: QueryResult;37 all: T['all'];38 get: T['get'];39 values: T['values'];40 execute: T['execute'];41}> {42 private client;43 private logger;44 private fields;45 private _isResponseInArrayMode;46 private customResultMapper?;47 static readonly [entityKind]: string;48 constructor(client: OPSQLiteConnection, query: Query, logger: Logger, cache: Cache, queryMetadata: {49 type: 'select' | 'update' | 'delete' | 'insert';50 tables: string[];51 } | undefined, cacheConfig: WithCacheConfig | undefined, fields: SelectedFieldsOrdered | undefined, executeMethod: SQLiteExecuteMethod, _isResponseInArrayMode: boolean, customResultMapper?: ((rows: unknown[][]) => unknown) | undefined);52 run(placeholderValues?: Record<string, unknown>): Promise<QueryResult>;53 all(placeholderValues?: Record<string, unknown>): Promise<T['all']>;54 get(placeholderValues?: Record<string, unknown>): Promise<T['get']>;55 values(placeholderValues?: Record<string, unknown>): Promise<T['values']>;56}57export {};58 