db.js 479 Bytes
var mysql = require('mysql');

function start(db_host, db_user, db_pass, db_name, logger) {
    var connection = mysql.createConnection({
        host: db_host,
        user: db_user,
        password: db_pass,
        database: db_name
    });

    logger.info("Connecting to db");
    connection.connect();

    connection.on('error', function(err) {
        logger.error("DB error: " + err.code); // 'ER_BAD_DB_ERROR'
    });


    return connection;
}

exports.start = start