123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246 |
- import Query = require('./protocol/sequences/Query');
- import {OkPacket, FieldPacket, RowDataPacket, ResultSetHeader} from './protocol/packets/index';
- import {EventEmitter} from 'events';
- declare namespace Connection {
- export interface ConnectionOptions {
- /**
- * The MySQL user to authenticate as
- */
- user?: string;
- /**
- * The password of that MySQL user
- */
- password?: string;
- /**
- * Name of the database to use for this connection
- */
- database?: string;
- /**
- * The charset for the connection. This is called 'collation' in the SQL-level of MySQL (like utf8_general_ci).
- * If a SQL-level charset is specified (like utf8mb4) then the default collation for that charset is used.
- * (Default: 'UTF8_GENERAL_CI')
- */
- charset?: string;
- /**
- * The hostname of the database you are connecting to. (Default: localhost)
- */
- host?: string;
- /**
- * The port number to connect to. (Default: 3306)
- */
- port?: number;
- /**
- * The source IP address to use for TCP connection
- */
- localAddress?: string;
- /**
- * The path to a unix domain socket to connect to. When used host and port are ignored
- */
- socketPath?: string;
- /**
- * The timezone used to store local dates. (Default: 'local')
- */
- timezone?: string | 'local';
- /**
- * The milliseconds before a timeout occurs during the initial connection to the MySQL server. (Default: 10 seconds)
- */
- connectTimeout?: number;
- /**
- * Stringify objects instead of converting to values. (Default: 'false')
- */
- stringifyObjects?: boolean;
- /**
- * Allow connecting to MySQL instances that ask for the old (insecure) authentication method. (Default: false)
- */
- insecureAuth?: boolean;
- /**
- * Determines if column values should be converted to native JavaScript types. It is not recommended (and may go away / change in the future)
- * to disable type casting, but you can currently do so on either the connection or query level. (Default: true)
- *
- * You can also specify a function (field: any, next: () => void) => {} to do the type casting yourself.
- *
- * WARNING: YOU MUST INVOKE the parser using one of these three field functions in your custom typeCast callback. They can only be called once.
- *
- * field.string()
- * field.buffer()
- * field.geometry()
- *
- * are aliases for
- *
- * parser.parseLengthCodedString()
- * parser.parseLengthCodedBuffer()
- * parser.parseGeometryValue()
- *
- * You can find which field function you need to use by looking at: RowDataPacket.prototype._typeCast
- */
- typeCast?: boolean | ((field: any, next: () => void) => any);
- /**
- * A custom query format function
- */
- queryFormat?: (query: string, values: any) => void;
- /**
- * When dealing with big numbers (BIGINT and DECIMAL columns) in the database, you should enable this option
- * (Default: false)
- */
- supportBigNumbers?: boolean;
- /**
- * Enabling both supportBigNumbers and bigNumberStrings forces big numbers (BIGINT and DECIMAL columns) to be
- * always returned as JavaScript String objects (Default: false). Enabling supportBigNumbers but leaving
- * bigNumberStrings disabled will return big numbers as String objects only when they cannot be accurately
- * represented with [JavaScript Number objects] (http://ecma262-5.com/ELS5_HTML.htm#Section_8.5)
- * (which happens when they exceed the [-2^53, +2^53] range), otherwise they will be returned as Number objects.
- * This option is ignored if supportBigNumbers is disabled.
- */
- bigNumberStrings?: boolean;
- /**
- * Force date types (TIMESTAMP, DATETIME, DATE) to be returned as strings rather then inflated into JavaScript Date
- * objects. Can be true/false or an array of type names to keep as strings.
- *
- * (Default: false)
- */
- dateStrings?: boolean | Array<'TIMESTAMP' | 'DATETIME' | 'DATE'>;
- /**
- * This will print all incoming and outgoing packets on stdout.
- * You can also restrict debugging to packet types by passing an array of types (strings) to debug;
- *
- * (Default: false)
- */
- debug?: any;
- /**
- * Generates stack traces on Error to include call site of library entrance ('long stack traces'). Slight
- * performance penalty for most calls. (Default: true)
- */
- trace?: boolean;
- /**
- * Allow multiple mysql statements per query. Be careful with this, it exposes you to SQL injection attacks. (Default: false)
- */
- multipleStatements?: boolean;
- /**
- * List of connection flags to use other than the default ones. It is also possible to blacklist default ones
- */
- flags?: Array<string>;
- /**
- * object with ssl parameters or a string containing name of ssl profile
- */
- ssl?: string | SslOptions;
- /**
- * Return each row as an array, not as an object.
- * This is useful when you have duplicate column names.
- * This can also be set in the `QueryOption` object to be applied per-query.
- */
- rowsAsArray?: boolean
- }
- export interface SslOptions {
- /**
- * A string or buffer holding the PFX or PKCS12 encoded private key, certificate and CA certificates
- */
- pfx?: string;
- /**
- * A string holding the PEM encoded private key
- */
- key?: string;
- /**
- * A string of passphrase for the private key or pfx
- */
- passphrase?: string;
- /**
- * A string holding the PEM encoded certificate
- */
- cert?: string;
- /**
- * Either a string or list of strings of PEM encoded CA certificates to trust.
- */
- ca?: string | string[];
- /**
- * Either a string or list of strings of PEM encoded CRLs (Certificate Revocation List)
- */
- crl?: string | string[];
- /**
- * A string describing the ciphers to use or exclude
- */
- ciphers?: string;
- /**
- * You can also connect to a MySQL server without properly providing the appropriate CA to trust. You should not do this.
- */
- rejectUnauthorized?: boolean;
- }
- }
- declare class Connection extends EventEmitter {
- config: Connection.ConnectionOptions;
- threadId: number;
- authorized: boolean;
- static createQuery<T extends RowDataPacket[][] | RowDataPacket[] | OkPacket | OkPacket[] | ResultSetHeader>(sql: string, callback?: (err: Query.QueryError | null, result: T, fields: FieldPacket[]) => any): Query;
- static createQuery<T extends RowDataPacket[][] | RowDataPacket[] | OkPacket | OkPacket[] | ResultSetHeader>(sql: string, values: any | any[] | { [param: string]: any }, callback?: (err: Query.QueryError | null, result: T, fields: FieldPacket[]) => any): Query;
- beginTransaction(callback: (err: Query.QueryError | null) => void): void;
- connect(callback?: (err: Query.QueryError | null) => void): void;
- commit(callback?: (err: Query.QueryError | null) => void): void;
- changeUser(options: Connection.ConnectionOptions, callback?: (err: Query.QueryError | null) => void): void;
- query<T extends RowDataPacket[][] | RowDataPacket[] | OkPacket | OkPacket[] | ResultSetHeader>(sql: string, callback?: (err: Query.QueryError | null, result: T, fields: FieldPacket[]) => any): Query;
- query<T extends RowDataPacket[][] | RowDataPacket[] | OkPacket | OkPacket[] | ResultSetHeader>(sql: string, values: any | any[] | { [param: string]: any }, callback?: (err: Query.QueryError | null, result: T, fields: FieldPacket[]) => any): Query;
- query<T extends RowDataPacket[][] | RowDataPacket[] | OkPacket | OkPacket[] | ResultSetHeader>(options: Query.QueryOptions, callback?: (err: Query.QueryError | null, result: T, fields?: FieldPacket[]) => any): Query;
- query<T extends RowDataPacket[][] | RowDataPacket[] | OkPacket | OkPacket[] | ResultSetHeader>(options: Query.QueryOptions, values: any | any[] | { [param: string]: any }, callback?: (err: Query.QueryError | null, result: T, fields: FieldPacket[]) => any): Query;
- end(callback?: (err: Query.QueryError | null) => void): void;
- end(options: any, callback?: (err: Query.QueryError | null) => void): void;
- destroy(): void;
- pause(): void;
- resume(): void;
- escape(value: any): string;
- escapeId(value: string): string;
- escapeId(values: string[]): string;
- format(sql: string, values?: any | any[] | { [param: string]: any }): string;
- on(event: string, listener: Function): this;
- rollback(callback: () => void): void;
- }
- export = Connection;
|