123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869 |
- import { EventEmitter } from 'events';
- import { PrepareStatementInfo } from './protocol/sequences/Prepare.js';
- import { ConnectionOptions } from './Connection.js';
- import { PoolConnection } from './PoolConnection.js';
- import {
- Pool as PromisePool,
- PoolConnection as PromisePoolConnection,
- } from '../../../promise.js';
- import { QueryableBase } from './protocol/sequences/QueryableBase.js';
- import { ExecutableBase } from './protocol/sequences/ExecutableBase.js';
- export interface PoolOptions extends ConnectionOptions {
- /**
- * Determines the pool's action when no connections are available and the limit has been reached. If true, the pool will queue
- * the connection request and call it when one becomes available. If false, the pool will immediately call back with an error.
- * (Default: true)
- */
- waitForConnections?: boolean;
- /**
- * The maximum number of connections to create at once. (Default: 10)
- */
- connectionLimit?: number;
- /**
- * The maximum number of idle connections. (Default: same as `connectionLimit`)
- */
- maxIdle?: number;
- /**
- * The idle connections timeout, in milliseconds. (Default: 60000)
- */
- idleTimeout?: number;
- /**
- * The maximum number of connection requests the pool will queue before returning an error from getConnection. If set to 0, there
- * is no limit to the number of queued connection requests. (Default: 0)
- */
- queueLimit?: number;
- }
- declare class Pool extends QueryableBase(ExecutableBase(EventEmitter)) {
- getConnection(
- callback: (
- err: NodeJS.ErrnoException | null,
- connection: PoolConnection,
- ) => any,
- ): void;
- releaseConnection(connection: PoolConnection | PromisePoolConnection): void;
- end(
- callback?: (err: NodeJS.ErrnoException | null, ...args: any[]) => any,
- ): void;
- on(event: string, listener: (...args: any[]) => void): this;
- 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): PrepareStatementInfo;
- promise(promiseImpl?: PromiseConstructor): PromisePool;
- config: PoolOptions;
- }
- export { Pool };
|