use auto close

GenericPoolAdapter.d.ts

@@ -0,0 +1,63 @@
+// MOST Web Framework 2.0 Codename Blueshift Copyright (c) 2017-2020 THEMOST LP
+
+import { AsyncEventEmitter } from '@themost/events';
+
+declare type GenericPoolAdapterCallback = (err?: Error) => void;
+
+export declare interface GenericPoolOptions {
+    adapter: string;
+    max?: number;
+    min?: number;
+    maxWaitingClients?: number;
+    testOnBorrow?: boolean;
+    acquireTimeoutMillis?: number;
+    fifo?: boolean;
+    priorityRange?: number;
+    autostart?: boolean;
+    evictionRunIntervalMillis?: number;
+    softIdleTimeoutMillis?: number;
+    idleTimeoutMillis?: number;
+}
+
+export declare interface GenericPoolAdapterOptions {
+    name: string;
+    invariantName: string;
+    default?: boolean;
+    options: GenericPoolOptions;
+}
+
+declare interface ApplicationDataConfiguration {
+    adapters: Array<any>;
+    getAdapterType(name: string): any;
+}
+
+export declare interface GenericPool {
+    acquire(): Promise<any>;
+    release(resource: any): Promise<void>;
+}
+
+export declare class GenericPoolAdapter {
+
+    static pool(name: string): GenericPool;
+
+    static acquired: AsyncEventEmitter<{ name: string, target: GenericPool, borrowed?: number, pending?: number }>;
+    static released: AsyncEventEmitter<{ name: string, target: GenericPool, borrowed?: number, pending?: number }>;
+    static created: AsyncEventEmitter<{ target: GenericPool }>;
+
+    constructor(options: GenericPoolAdapterOptions);
+    open(callback: GenericPoolAdapterCallback): void;
+    openAsync(): Promise<void>;
+    close(callback: GenericPoolAdapterCallback): void;
+    closeAsync(): Promise<void>;
+    createView(name: string, query: any, callback: GenericPoolAdapterCallback): void;
+    executeInTransaction(func: any, callback: GenericPoolAdapterCallback): void;
+    executeInTransactionAsync(func: Promise<any>): Promise<any>;
+    migrate(obj: any, callback: GenericPoolAdapterCallback): void;
+    migrateAsync(obj: any): Promise<void>;
+    selectIdentity(entity: string, attribute: string, callback: (err: Error, value: any) => void): void;
+    execute(query: any, values: any, callback: (err: Error, value: any) => void): void;
+    executeAsync(query: any, values: any): Promise<any>;
+
+}
+
+export declare function createInstance(options: any): GenericPoolAdapter;