Skip to content

Commit 5cd7639

Browse files
authored
fix: move missing options to ConnectionOptions (#2288)
* fix: move `enableKeepAlive` and `keepAliveInitialDelay` options to `ConnectionOptions` * ci(types): enableKeepAlive and keepAliveInitialDelay
1 parent 8831e09 commit 5cd7639

File tree

3 files changed

+59
-16
lines changed

3 files changed

+59
-16
lines changed
Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
import { mysql, mysqlp } from '../index.js';
2+
3+
// Callback
4+
(() => {
5+
const poolOptions: mysql.PoolOptions = {
6+
enableKeepAlive: true,
7+
keepAliveInitialDelay: 0,
8+
}
9+
10+
const connectionOptions: mysql.ConnectionOptions = {
11+
enableKeepAlive: true,
12+
keepAliveInitialDelay: 0,
13+
}
14+
15+
mysql.createConnection(connectionOptions);
16+
mysql.createPool(poolOptions);
17+
mysql.createPoolCluster().add(poolOptions);
18+
})();
19+
20+
// Promise
21+
(() => {
22+
const poolOptions: mysqlp.PoolOptions = {
23+
enableKeepAlive: true,
24+
keepAliveInitialDelay: 0,
25+
}
26+
27+
const connectionOptions: mysqlp.ConnectionOptions = {
28+
enableKeepAlive: true,
29+
keepAliveInitialDelay: 0,
30+
}
31+
32+
mysqlp.createConnection(connectionOptions);
33+
mysqlp.createPool(poolOptions);
34+
mysqlp.createPoolCluster().add(poolOptions);
35+
})();

typings/mysql/lib/Connection.d.ts

Lines changed: 24 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -258,6 +258,16 @@ export interface ConnectionOptions {
258258
*/
259259
rowsAsArray?: boolean;
260260

261+
/**
262+
* Enable keep-alive on the socket. (Default: true)
263+
*/
264+
enableKeepAlive?: boolean;
265+
266+
/**
267+
* If keep-alive is enabled users can supply an initial delay. (Default: 0)
268+
*/
269+
keepAliveInitialDelay?: number;
270+
261271
charsetNumber?: number;
262272

263273
compress?: boolean;
@@ -312,22 +322,30 @@ declare class Connection extends QueryableBase(ExecutableBase(EventEmitter)) {
312322
| RowDataPacket[]
313323
| OkPacket
314324
| OkPacket[]
315-
| ResultSetHeader
325+
| ResultSetHeader,
316326
>(
317327
sql: string,
318-
callback?: (err: QueryError | null, result: T, fields: FieldPacket[]) => any
328+
callback?: (
329+
err: QueryError | null,
330+
result: T,
331+
fields: FieldPacket[],
332+
) => any,
319333
): Query;
320334
static createQuery<
321335
T extends
322336
| RowDataPacket[][]
323337
| RowDataPacket[]
324338
| OkPacket
325339
| OkPacket[]
326-
| ResultSetHeader
340+
| ResultSetHeader,
327341
>(
328342
sql: string,
329343
values: any | any[] | { [param: string]: any },
330-
callback?: (err: QueryError | null, result: T, fields: FieldPacket[]) => any
344+
callback?: (
345+
err: QueryError | null,
346+
result: T,
347+
fields: FieldPacket[],
348+
) => any,
331349
): Query;
332350

333351
beginTransaction(callback: (err: QueryError | null) => void): void;
@@ -338,7 +356,7 @@ declare class Connection extends QueryableBase(ExecutableBase(EventEmitter)) {
338356

339357
changeUser(
340358
options: ConnectionOptions,
341-
callback?: (err: QueryError | null) => void
359+
callback?: (err: QueryError | null) => void,
342360
): void;
343361

344362
end(callback?: (err: QueryError | null) => void): void;
@@ -363,7 +381,7 @@ declare class Connection extends QueryableBase(ExecutableBase(EventEmitter)) {
363381

364382
prepare(
365383
sql: string,
366-
callback?: (err: QueryError | null, statement: PrepareStatementInfo) => any
384+
callback?: (err: QueryError | null, statement: PrepareStatementInfo) => any,
367385
): Prepare;
368386

369387
unprepare(sql: string): PrepareStatementInfo;

typings/mysql/lib/Pool.d.ts

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -37,16 +37,6 @@ export interface PoolOptions extends ConnectionOptions {
3737
* is no limit to the number of queued connection requests. (Default: 0)
3838
*/
3939
queueLimit?: number;
40-
41-
/**
42-
* Enable keep-alive on the socket. (Default: true)
43-
*/
44-
enableKeepAlive?: boolean;
45-
46-
/**
47-
* If keep-alive is enabled users can supply an initial delay. (Default: 0)
48-
*/
49-
keepAliveInitialDelay?: number;
5040
}
5141

5242
declare class Pool extends QueryableBase(ExecutableBase(EventEmitter)) {

0 commit comments

Comments
 (0)