Skip to content

Instantly share code, notes, and snippets.

@alik472
Created July 19, 2019 20:11
Show Gist options
  • Save alik472/86d017bc2303531e763d3e7e86b7abf9 to your computer and use it in GitHub Desktop.
Save alik472/86d017bc2303531e763d3e7e86b7abf9 to your computer and use it in GitHub Desktop.
Node mysql promise lib
const util = require('util')
const mysql = require('mysql')
const pool = mysql.createPool({
connectionLimit: 10,
host: 'localhost',
user: 'root',
password: 'password',
database: 'my_database'
})
// Ping database to check for common exception errors.
pool.getConnection((err, connection) => {
if (err) {
if (err.code === 'PROTOCOL_CONNECTION_LOST') {
console.error('Database connection was closed.')
}
if (err.code === 'ER_CON_COUNT_ERROR') {
console.error('Database has too many connections.')
}
if (err.code === 'ECONNREFUSED') {
console.error('Database connection was refused.')
}
}
if (connection) connection.release()
return
})
// Promisify for Node.js async/await.
pool.query = util.promisify(pool.query)
module.exports = pool
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment