123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201
// deno-lint-ignore-file no-explicit-anyimport type { ErrnoException, Buffer } from "./deps.ts";import {  Connection as PromiseConnection,  Pool as PromisePool,  PoolConnection as PromisePoolConnection} from './promise.d.ts';
import * as mysql from './typings/mysql/index.d.ts';export * from './typings/mysql/index.d.ts';export * from "./deps.ts";
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: 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 ConnectionConfig extends ConnectionOptions {  // static mergeFlags(defaultFlags: string[], userFlags: string[] | string): number;  // static getDefaultFlags(options?: ConnectionOptions): string[];  // static getCharsetNumber(charset: string): number;  // static getSSLProfile(name: string): { ca: string[] };  // static 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;