123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189 |
- import {
- Connection as PromiseConnection,
- Pool as PromisePool,
- 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;
- promise(promiseImpl?: PromiseConstructor): PromiseConnection;
- }
- export interface PoolConnection extends mysql.PoolConnection, Connection {
- 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;
- promise(promiseImpl?: PromiseConstructor): PromisePool;
- }
- type authPlugins = (pluginMetadata: {
- connection: Connection;
- command: string;
- }) => (
- pluginData: Buffer
- ) => Promise<string> | string | Buffer | Promise<Buffer> | null;
- 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;
- Promise?: any;
- queueLimit?: number;
- waitForConnections?: boolean;
- authPlugins?: {
- [key: string]: authPlugins;
- };
- }
- 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;
|