createPool

信息

For queries please see the Simple Queries and Prepared Statements examples.

createPool(connectionUri)

createPool(connectionUri: string)

promise.js

import mysql from 'mysql2/promise';

try {
  const pool = mysql.createPool('mysql://root:password@localhost:3306/test');
  const connection = await pool.getConnection();
  // ... some query

  connection.release();
} catch (err) {
  console.log(err);
}

callback.js

const mysql = require('mysql2');

const pool = mysql.createPool('mysql://root:password@localhost:3306/test');

pool.getConnection(function (err, connection) {
  if (err instanceof Error) {
    console.log(err);
    return;
  }

  // ... some query

  connection.release();
});

注意

Don't forget to release the connection when finished by using:

• pool.releaseConnection(connection)
• connection.release()

---

createPool(config)

createPool(config: PoolOptions)

promise.js

import mysql from 'mysql2/promise';

try {
  const pool = mysql.createPool({
    host: 'localhost',
    user: 'root',
    database: 'test',
    // port: 3306,
    // password: '',
  });
  const connection = await pool.getConnection();
  // ... some query

  connection.release();
} catch (err) {
  console.log(err);
}

callback.js

const mysql = require('mysql2');

const pool = mysql.createPool({
  host: 'localhost',
  user: 'root',
  database: 'test',
  // port: 3306,
  // password: '',
});

pool.getConnection(function (err, connection) {
  if (err instanceof Error) {
    console.log(err);
    return;
  }

  // ... some query

  connection.release();
});

注意

Don't forget to release the connection when finished by using:

• pool.releaseConnection(connection)
• connection.release()

---

createPool(config) — SHA1

createPool(config: PoolOptions)

promise.js

import mysql from 'mysql2/promise';

try {
  const pool = mysql.createPool({
    // ...
    passwordSha1: Buffer.from(
      '8bb6118f8fd6935ad0876a3be34a717d32708ffd',
      'hex'
    ),
  });
  const connection = await pool.getConnection();
  // ... some query

  connection.release();
} catch (err) {
  console.log(err);
}

callback.js

const mysql = require('mysql2');

const pool = mysql.createPool({
  // ...
  passwordSha1: Buffer.from('8bb6118f8fd6935ad0876a3be34a717d32708ffd', 'hex'),
});

pool.getConnection(function (err, connection) {
  if (err instanceof Error) {
    console.log(err);
    return;
  }

  // ... some query

  connection.release();
});

注意

Don't forget to release the connection when finished by using:

• pool.releaseConnection(connection)
• connection.release()

---

createPool(config) — SSL

createPool(config: PoolOptions)

promise.js

import mysql from 'mysql2/promise';

try {
  const pool = mysql.createPool({
    // ...
    ssl: {
      // key: fs.readFileSync('./certs/client-key.pem'),
      // cert: fs.readFileSync('./certs/client-cert.pem')
      ca: fs.readFileSync('./certs/ca-cert.pem'),
    },
  });
  const connection = await pool.getConnection();
  // ... some query

  connection.release();
} catch (err) {
  console.log(err);
}

callback.js

const mysql = require('mysql2');

const pool = mysql.createPool({
  // ...
  ssl: {
    // key: fs.readFileSync('./certs/client-key.pem'),
    // cert: fs.readFileSync('./certs/client-cert.pem')
    ca: fs.readFileSync('./certs/ca-cert.pem'),
  },
});

pool.getConnection(function (err, connection) {
  if (err instanceof Error) {
    console.log(err);
    return;
  }

  // ... some query

  connection.release();
});

certs/ca-cert.pem

• See ssl/certs.

注意

Don't forget to release the connection when finished by using:

• pool.releaseConnection(connection)
• connection.release()

---

createPool(config) — RDS SSL

createPool(config: PoolOptions)

You can use Amazon RDS string as value to ssl property to connect to Amazon RDS MySQL over SSL.

In that case https://s3.amazonaws.com/rds-downloads/mysql-ssl-ca-cert.pem CA cert is used:

npm install --save aws-ssl-profiles

promise.js

import mysql from 'mysql2/promise';
import awsCaBundle from 'aws-ssl-profiles';

try {
  const pool = mysql.createPool({
    // ...
    host: 'db.id.ap-southeast-2.rds.amazonaws.com',
    ssl: awsCaBundle,
  });
  const connection = await pool.getConnection();
  // ... some query

  connection.release();
} catch (err) {
  console.log(err);
}

信息

For detailed instructions, please follow the AWS SSL Profiles documentation.

Testing

try {
  const [res] = await connection.query('SHOW `status` LIKE "Ssl_cipher"');
  await pool.end();

  console.log(res);
} catch (err) {
  console.log(err);
}

callback.js

const mysql = require('mysql2');
const awsCaBundle = require('aws-ssl-profiles');

const pool = mysql.createPool({
  // ...
  host: 'db.id.ap-southeast-2.rds.amazonaws.com',
  ssl: awsCaBundle,
});

pool.getConnection(function (err, connection) {
  if (err instanceof Error) {
    console.log(err);
    return;
  }

  // ... some query

  connection.release();
});

信息

For detailed instructions, please follow the AWS SSL Profiles documentation.

Testing

connectionquery('SHOW `status` LIKE "Ssl_cipher"', function (err, res) {
  pool.end();

  if (err instanceof Error) {
    console.log(err);
    return;
  }

  console.log(res);
});

注意

Don't forget to release the connection when finished by using:

• pool.releaseConnection(connection)
• connection.release()

---

createPool(config) — Socks

createPool(config: PoolOptions)

A.js

const mysql = require('mysql2');
const SocksConnection = require('socksjs');

const socksProxy = new SocksConnection({ port: 3306 });
const pool = mysql.createPool({
  stream: socksProxy,
});

B.js

const mysql = require('mysql2');
const SocksConnection = require('socksjs');

const pool = mysql.createPool({
  debug: 1,
  stream: function () {
    return new SocksConnection({ port: 3306 });
  },
});

Testing

pool.execute('SELECT SLEEP(1.1) AS `www`', (err, rows, fields) => {
  if (err instanceof Error) {
    console.log(err);
    return;
  }

  console.log(rows, fields);
});

pool.execute('SELECT SLEEP(1) AS `qqq`', (err, rows, fields) => {
  if (err instanceof Error) {
    console.log(err);
    return;
  }

  console.log(rows, fields);
});

pool.execute('SELECT SLEEP(1) AS `qqq`', (err, rows, fields) => {
  if (err instanceof Error) {
    console.log(err);
    return;
  }

  console.log(rows, fields);
});

---

Glossary

PoolOptions

PoolOptions extends all options from ConnectionOptions:

ConnectionOptions Specification

PoolOptions Specification