@databases/mysql
Advanced tools
Comparing version 4.0.0 to 5.0.0
@@ -26,3 +26,3 @@ /// <reference types="node" /> | ||
export default class ConnectionPool extends BaseConnectionPool<Connection, Transaction, MySqlDriver> implements IConnectionPool { | ||
constructor(srcConfig: MySqlConnectionOptions, poolOptions: Omit<PoolOptions<MySqlDriver>, 'openConnection' | 'closeConnection'>, handlers: EventHandlers, onError: (err: Error) => void, aquireLockTimeoutMilliseconds: number, serverTimeZone: 'local' | 'utc' | undefined); | ||
constructor(srcConfig: MySqlConnectionOptions, poolOptions: Omit<PoolOptions<MySqlDriver>, 'openConnection' | 'closeConnection'>, handlers: EventHandlers, onError: (err: Error) => void, acquireLockTimeoutMilliseconds: number, serverTimeZone: 'local' | 'utc' | undefined); | ||
queryNodeStream(query: SQLQuery, options?: { | ||
@@ -29,0 +29,0 @@ highWaterMark?: number; |
@@ -30,7 +30,7 @@ "use strict"; | ||
const getConnectionPoolOptions = (srcConfig, poolOptions, handlers, onError, aquireLockTimeoutMilliseconds, serverTimeZone) => { | ||
const getConnectionPoolOptions = (srcConfig, poolOptions, handlers, onError, acquireLockTimeoutMilliseconds, serverTimeZone) => { | ||
return { ...poolOptions, | ||
openConnection: async removeFromPool => { | ||
const client = await promise_1.createConnection(srcConfig); | ||
const driver = new MySqlDriver_1.default(client, handlers, aquireLockTimeoutMilliseconds); | ||
const driver = new MySqlDriver_1.default(client, handlers, acquireLockTimeoutMilliseconds); | ||
@@ -80,4 +80,4 @@ try { | ||
class ConnectionPool extends shared_1.BaseConnectionPool { | ||
constructor(srcConfig, poolOptions, handlers, onError, aquireLockTimeoutMilliseconds, serverTimeZone) { | ||
super(getConnectionPoolOptions(srcConfig, poolOptions, handlers, onError, aquireLockTimeoutMilliseconds, serverTimeZone), factories); | ||
constructor(srcConfig, poolOptions, handlers, onError, acquireLockTimeoutMilliseconds, serverTimeZone) { | ||
super(getConnectionPoolOptions(srcConfig, poolOptions, handlers, onError, acquireLockTimeoutMilliseconds, serverTimeZone), factories); | ||
} | ||
@@ -84,0 +84,0 @@ |
@@ -102,5 +102,5 @@ import sql, { SQLQuery, isSqlQuery } from '@databases/sql'; | ||
*/ | ||
aquireLockTimeoutMilliseconds?: number; | ||
acquireLockTimeoutMilliseconds?: number; | ||
onError?: (err: Error) => void; | ||
} | ||
export default function createConnectionPool(connectionConfig?: string | ConnectionPoolConfig | undefined): ConnectionPool; |
@@ -54,3 +54,3 @@ "use strict"; | ||
queueTimeoutMilliseconds = 60000, | ||
aquireLockTimeoutMilliseconds = 60000, | ||
acquireLockTimeoutMilliseconds = 60000, | ||
onConnectionClosed, | ||
@@ -107,3 +107,3 @@ onConnectionOpened, | ||
onQueryError | ||
}, onError, aquireLockTimeoutMilliseconds, serverTimeZone); | ||
}, onError, acquireLockTimeoutMilliseconds, serverTimeZone); | ||
} | ||
@@ -110,0 +110,0 @@ |
@@ -10,3 +10,3 @@ /// <reference types="node" /> | ||
export default class MySqlDriver implements Driver<TransactionOptions, QueryStreamOptions> { | ||
readonly aquireLockTimeoutMilliseconds: number; | ||
readonly acquireLockTimeoutMilliseconds: number; | ||
readonly client: MySqlClient; | ||
@@ -16,3 +16,3 @@ private readonly _handlers; | ||
private readonly _disposed; | ||
constructor(client: MySqlClient, handlers: EventHandlers, aquireLockTimeoutMilliseconds: number); | ||
constructor(client: MySqlClient, handlers: EventHandlers, acquireLockTimeoutMilliseconds: number); | ||
private _removeFromPool; | ||
@@ -19,0 +19,0 @@ private _idleErrorEventHandler; |
@@ -27,3 +27,3 @@ "use strict"; | ||
class MySqlDriver { | ||
constructor(client, handlers, aquireLockTimeoutMilliseconds) { | ||
constructor(client, handlers, acquireLockTimeoutMilliseconds) { | ||
this._endCalled = false; | ||
@@ -47,3 +47,3 @@ | ||
this.aquireLockTimeoutMilliseconds = aquireLockTimeoutMilliseconds; | ||
this.acquireLockTimeoutMilliseconds = acquireLockTimeoutMilliseconds; | ||
this._disposed = new Promise(resolve => { | ||
@@ -50,0 +50,0 @@ client.on('end', resolve); |
{ | ||
"name": "@databases/mysql", | ||
"version": "4.0.0", | ||
"version": "5.0.0", | ||
"description": "", | ||
@@ -12,3 +12,3 @@ "main": "./lib/index.js", | ||
"@databases/push-to-async-iterable": "^3.0.0", | ||
"@databases/shared": "^1.0.0", | ||
"@databases/shared": "^2.0.0", | ||
"@databases/sql": "^3.0.0", | ||
@@ -15,0 +15,0 @@ "@types/mysql": "^2.15.5", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
85829
0
+ Added@databases/lock@2.1.0(transitive)
+ Added@databases/shared@2.0.0(transitive)
- Removed@databases/lock@1.0.0(transitive)
- Removed@databases/shared@1.0.0(transitive)
Updated@databases/shared@^2.0.0