Socket
Socket
Sign inDemoInstall

@goodware/mysql

Package Overview
Dependencies
5
Maintainers
1
Versions
43
Alerts
File Explorer

Advanced tools

Install Socket

Detect and block malicious and high-risk dependencies

Install

    @goodware/mysql

A mysql2-based connection helper


Version published
Weekly downloads
9
decreased by-57.14%
Maintainers
1
Created
Weekly downloads
 

Readme

Source

@goodware/mysql: A mysql2-promise helper

  • Release History
  • npm
  • git
  • API

Requirements

  • NodeJS 8+

Features

  • Creates database connections via mysql2-promise, optionally from a pool, with exponential backoff retry
  • Handles AWS RDS IAM passwordless connections
  • Optionally manages database transactions by wrapping begin end transaction commands around a function invocation, with an exception handler that executes rollback
  • Same API whether using connection pooling or individual connections
  • Same API whether using explicit or implicit transactions

Installation

npm i --save @goodware/mysql

Usage

  1. Create an instance of the MySqlConnection class (it is the default export)
  2. Call execute() or transaction() which accept a function that accepts a mysql2-promise Connection.
  3. If you're using connection pooling, call stop() to close the connections in the pool. This is necessary if:
  • The app instantiates multiple instances to access the same database server. It is recommended to use a single global instance to avoid this issue.
  • The app hangs instead of terminating

Logger

The options provided by the constructor and all other methods accept an optional 'logger' function or object. If an object is provided, it must have the method log().

interface Logger {
  /**
   * @param tags Typically includes a logging level name, like info or debug.
   * @param message An object with at least a message property
   */
  log(tags: string[] | string, message: Record<string, unknown>): void;
}

Example

The following program outputs 'success' to the console.

const mysql = require('@goodware/mysql');

const config = {
  // host: '0.0.0.0', // This is the default
  // port: 3306, // This is the default
  // user: 'root', // This is the default
  // database: 'mysql', // This is the default
  password: 'password',
  usePool: true, // Defaults to 10 connections (see connectionLimit in constructor options)
};

async () => {
  const connector = new mysql(config, console.log); // The second parameter is a logger function
  // Acquire a database connection
  const result = await connector.execute( async (connection) => {
    // Perform database operations
    const [results] = await connection.query(`select 'success' AS status`);
    // The Promise resolves to 'success'
    return results[0].status;
  });
  // Close all database connections in the pool
  await connector.stop();
  // The Promise resolves to 'success'
  return result;
}().then(console.info, console.error);

Keywords

FAQs

Last updated on 16 May 2023

Did you know?

Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.

Install

Related posts

SocketSocket SOC 2 Logo

Product

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

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc