New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

@databases/mysql

Package Overview
Dependencies
Maintainers
1
Versions
23
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@databases/mysql - npm Package Compare versions

Comparing version 4.0.0 to 5.0.0

2

lib/ConnectionPool.d.ts

@@ -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

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc