123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222
import { TableConstraint, CreateColumnDef, StatementLocation } from './parser/syntax/ast.ts';
export type nil = undefined | null;
export type Schema = {    name: string;    fields: SchemaField[];    constraints?: TableConstraint[];}

export interface SchemaField extends Omit<CreateColumnDef, 'dataType'> {    type: IType;    serial?: boolean;}
export interface IType {    /** Data type */    readonly primary: DataType;    toString(): string;}
// todo support all types https://www.postgresql.org/docs/9.5/datatype.htmlexport enum DataType {    text = 'text',    array = 'array',    long = 'long',    float = 'float',    decimal = 'decimal',    int = 'int',    jsonb = 'jsonb',    regtype = 'regtype',    json = 'json',    blob = 'blob',    timestamp = 'timestamp',    date = 'date',    null = 'null',    bool = 'bool',}
export interface MemoryDbOptions {    /**     * When set to true, this will auto create an index on foreign table when adding a foreign key.     * 👉 Recommanded when using Typeorm .synchronize(), which creates foreign keys but not indices !     **/    readonly autoCreateForeignKeyIndices?: boolean;}
export interface IMemoryDb {    /**     * Adapters to create wrappers of this db compatible with known libraries     */    readonly adapters: LibAdapters;    /**     * The default 'public' schema     */    readonly public: ISchema;    /**     * Get an existing schema     */    getSchema(db?: string | null): ISchema;    /**     * Create a schema in this database     */    createSchema(name: string): ISchema;    /**     * Get a table to inspect it     */    getTable(table: string): IMemoryTable;    /** Subscribe to a global event */    on(event: 'query', handler: (query: string) => any): ISubscription;    on(event: GlobalEvent, handler: () => any): ISubscription;    /** Subscribe to an event on all tables */    on(event: TableEvent, handler: (table: string) => any): ISubscription;
    /**     * Creates a restore point.     * 👉 This operation is O(1) (instantaneous, even with millions of records).     * */    backup(): IBackup;}
export interface IBackup {    /**     * Restores data to the state when this backup has been performed.     * 👉 This operation is O(1).     * 👉 Schema must not have been changed since then !     **/    restore(): void;}
export interface LibAdapters {    /** Create a PG module that will be equivalent to require('pg') */    createPg(queryLatency?: number): { Pool: any; Client: any };
    /** Create a pg-promise instance bound to this db */    createPgPromise(queryLatency?: number): any;
    /** Create a slonik pool bound to this db */    createSlonik(queryLatency?: number): any;
    /** Create a pg-native instance bound to this db */    createPgNative(queryLatency?: number): any;
    /** Create a Typeorm connection bound to this db */    createTypeormConnection(typeOrmConnection: any, queryLatency?: number): any;}
export interface ISchema {    /**     * Execute a query and return many results     */    many(query: string): any[];    /**     * Execute a query without results     */    none(query: string): void;    /**     * Execute a query with a single result     */    one(query: string): any;    /**     * Another way to create tables (equivalent to "create table" queries")     */    declareTable(table: Schema): IMemoryTable;    /**     * Execute a query     */    query(text: string): QueryResult;

    /**     * Progressively executes a query, yielding results until the end of enumeration (or an exception)     */    queries(text: string): Iterable<QueryResult>}
export interface QueryResult {    /** Last command that has been executed */    command: string;    rowCount: number;    fields: Array<FieldInfo>;    rows: any[];
    /** Ignored (because of an "if not exists" or equivalent) */    ignored?: boolean;    /** Location of the last ";" prior to this statement */    location: StatementLocation;}
export interface FieldInfo {    name: string;}


export type TableEvent = 'seq-scan';export type GlobalEvent = 'query' | 'query-failed' | 'catastrophic-join-optimization' | 'schema-change';
export interface IMemoryTable {    /** Subscribe to an event on this table */    on(event: TableEvent, handler: () => any): ISubscription;    /** List existing indices defined on this table */    listIndices(): IndexDef[];}
export interface ISubscription {    unsubscribe(): void;}
export interface IndexDef {    name: string;    expressions: string[];}
export class CastError extends Error {    constructor(from: DataType, to: DataType, inWhat?: string) {        super(`failed to cast ${from} to ${to}` + (inWhat ? ' in ' + inWhat : ''));    }}export class ColumnNotFound extends Error {    constructor(columnName: string) {        super(`column "${columnName}" does not exist`);    }}
export class AmbiguousColumn extends Error {    constructor(columnName: string) {        super(`column "${columnName}" is ambiguous`);    }}
export class TableNotFound extends Error {    constructor(tableName: string) {        super('Table not found: ' + tableName);    }}
export class QueryError extends Error {}

export class RecordExists extends Error {    constructor() {        super('Records already exists');    }}
export class NotSupported extends Error {    constructor(what?: string) {        super('Not supported' + (what ? ': ' + what : ''));    }
    static never(value: never, msg?: string) {        return new NotSupported(`${msg ?? ''} ${JSON.stringify(value)}`);    }}export class ReadOnlyError extends Error {    constructor(what?: string) {        super('You cannot modify ' + (what ? ': ' + what : 'this'));    }}