| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203 |
- import {
- Connection as PromiseConnection,
- PoolConnection as PromisePoolConnection,
- } from './promise';
- import * as mysql from './typings/mysql';
- export * from './typings/mysql';
- export interface Connection extends mysql.Connection {
- execute<
- T extends
- | mysql.RowDataPacket[][]
- | mysql.RowDataPacket[]
- | mysql.OkPacket
- | mysql.OkPacket[]
- | mysql.ResultSetHeader
- >(
- sql: string,
- callback?: (
- err: mysql.QueryError | null,
- result: T,
- fields: mysql.FieldPacket[]
- ) => any
- ): mysql.Query;
- execute<
- T extends
- | mysql.RowDataPacket[][]
- | mysql.RowDataPacket[]
- | mysql.OkPacket
- | mysql.OkPacket[]
- | mysql.ResultSetHeader
- >(
- sql: string,
- values: any | any[] | { [param: string]: any },
- callback?: (
- err: mysql.QueryError | null,
- result: T,
- fields: mysql.FieldPacket[]
- ) => any
- ): mysql.Query;
- execute<
- T extends
- | mysql.RowDataPacket[][]
- | mysql.RowDataPacket[]
- | mysql.OkPacket
- | mysql.OkPacket[]
- | mysql.ResultSetHeader
- >(
- options: mysql.QueryOptions,
- callback?: (
- err: mysql.QueryError | null,
- result: T,
- fields?: mysql.FieldPacket[]
- ) => any
- ): mysql.Query;
- execute<
- T extends
- | mysql.RowDataPacket[][]
- | mysql.RowDataPacket[]
- | mysql.OkPacket
- | mysql.OkPacket[]
- | mysql.ResultSetHeader
- >(
- options: mysql.QueryOptions,
- values: any | any[] | { [param: string]: any },
- callback?: (
- err: mysql.QueryError | null,
- result: T,
- fields: mysql.FieldPacket[]
- ) => any
- ): mysql.Query;
- ping(callback?: (err: mysql.QueryError | null) => any): void;
- unprepare(sql: string): mysql.PrepareStatementInfo;
- prepare(sql: string, callback?: (err: mysql.QueryError | null, statement: mysql.PrepareStatementInfo) => any): mysql.Prepare;
- serverHandshake(args: any): any;
- writeOk(args?: mysql.OkPacketParams): void;
- writeError(args?: mysql.ErrorPacketParams): void;
- writeEof(warnings?: number, statusFlags?: number): void;
- writeTextResult(rows?: Array<any>, columns?: Array<any>): void;
- writePacket(packet: any): void;
- promise(promiseImpl?: PromiseConstructor): PromiseConnection;
- sequenceId: number;
- }
- export interface PoolConnection extends mysql.PoolConnection {
- promise(promiseImpl?: PromiseConstructor): PromisePoolConnection;
- }
- export interface Pool extends mysql.Connection {
- execute<
- T extends
- | mysql.RowDataPacket[][]
- | mysql.RowDataPacket[]
- | mysql.OkPacket
- | mysql.OkPacket[]
- | mysql.ResultSetHeader
- >(
- sql: string,
- callback?: (
- err: mysql.QueryError | null,
- result: T,
- fields: mysql.FieldPacket[]
- ) => any
- ): mysql.Query;
- execute<
- T extends
- | mysql.RowDataPacket[][]
- | mysql.RowDataPacket[]
- | mysql.OkPacket
- | mysql.OkPacket[]
- | mysql.ResultSetHeader
- >(
- sql: string,
- values: any | any[] | { [param: string]: any },
- callback?: (
- err: mysql.QueryError | null,
- result: T,
- fields: mysql.FieldPacket[]
- ) => any
- ): mysql.Query;
- execute<
- T extends
- | mysql.RowDataPacket[][]
- | mysql.RowDataPacket[]
- | mysql.OkPacket
- | mysql.OkPacket[]
- | mysql.ResultSetHeader
- >(
- options: mysql.QueryOptions,
- callback?: (
- err: mysql.QueryError | null,
- result: T,
- fields?: mysql.FieldPacket[]
- ) => any
- ): mysql.Query;
- execute<
- T extends
- | mysql.RowDataPacket[][]
- | mysql.RowDataPacket[]
- | mysql.OkPacket
- | mysql.OkPacket[]
- | mysql.ResultSetHeader
- >(
- options: mysql.QueryOptions,
- values: any | any[] | { [param: string]: any },
- callback?: (
- err: mysql.QueryError | null,
- result: T,
- fields: mysql.FieldPacket[]
- ) => any
- ): mysql.Query;
- getConnection(
- callback: (err: NodeJS.ErrnoException, connection: PoolConnection) => any
- ): void;
- on(event: 'connection', listener: (connection: PoolConnection) => any): this;
- on(event: 'acquire', listener: (connection: PoolConnection) => any): this;
- on(event: 'release', listener: (connection: PoolConnection) => any): this;
- on(event: 'enqueue', listener: () => any): this;
- unprepare(sql: string): mysql.PrepareStatementInfo;
- prepare(sql: string, callback?: (err: mysql.QueryError | null, statement: mysql.PrepareStatementInfo) => any): mysql.Prepare;
- promise(promiseImpl?: PromiseConstructor): PromisePoolConnection;
- config: mysql.PoolOptions;
- }
- export interface ConnectionOptions extends mysql.ConnectionOptions {
- charsetNumber?: number;
- compress?: boolean;
- authSwitchHandler?: (data: any, callback: () => void) => any;
- connectAttributes?: { [param: string]: any };
- decimalNumbers?: boolean;
- isServer?: boolean;
- maxPreparedStatements?: number;
- namedPlaceholders?: boolean;
- nestTables?: boolean | string;
- passwordSha1?: string;
- pool?: any;
- rowsAsArray?: boolean;
- stream?: any;
- uri?: string;
- connectionLimit?: number;
- maxIdle?: number;
- idleTimeout?: number;
- Promise?: any;
- queueLimit?: number;
- waitForConnections?: boolean;
- authPlugins?: {
- [key: string]: mysql.AuthPlugin;
- };
- }
- export interface ConnectionConfig extends ConnectionOptions {
- mergeFlags(defaultFlags: string[], userFlags: string[] | string): number;
- getDefaultFlags(options?: ConnectionOptions): string[];
- getCharsetNumber(charset: string): number;
- getSSLProfile(name: string): { ca: string[] };
- parseUrl(url: string): { host: string, port: number, database: string, user: string, password: string, [key: string]: any };
- }
- export interface PoolOptions extends mysql.PoolOptions, ConnectionOptions {}
- export function createConnection(connectionUri: string): Connection;
- export function createConnection(config: ConnectionOptions): Connection;
- export function createPool(config: PoolOptions): Pool;
|