db.js

var mysql = require('mysql'),
    async = require('async')

var PRODUCTION_DB = 'finalAppProd',
    TEST_DB = 'finalAppTest'

exports.MODE_TEST = 'mode_test'
exports.MODE_PRODUCTION = 'mode_production'

var state = {
    pool: null,
    mode: null,
}

exports.connect = function(mode, done) {
    if (mode === exports.MODE_PRODUCTION) {
        state.pool = mysql.createPoolCluster()

        state.pool.add('WRITE', {
            connectionLimit: 100,
            host: 'localhost',
            user: 'root',
            password: 'pass',
            database: PRODUCTION_DB
        })

        state.pool.add('READ1', {
            connectionLimit: 100,
            host: 'localhost',
            user: 'root',
            password: 'pass',
            database: PRODUCTION_DB
        })

        state.pool.add('READ2', {
            connectionLimit: 100,
            host: 'localhost',
            user: 'root',
            password: 'pass',
            database: PRODUCTION_DB
        })
    } else {
        state.pool = mysql.createPool({
            connectionLimit: 100,
            host: 'localhost',
            user: 'root',
            password: 'pass',
            database: TEST_DB
        })
    }

    state.mode = mode
    done()
}

exports.READ = 'read'
exports.WRITE = 'write'

exports.get = function(type, done) {
    var pool = state.pool
    if (!pool) return done(new Error('Missing database connection.'))

    if (type === exports.WRITE) {
        state.pool.getConnection('WRITE', function(err, connection) {
            if (err) return done(err)
            done(null, connection)
        })
    } else {
        state.pool.getConnection('READ*', function(err, connection) {
            if (err) return done(err)
            done(null, connection)
        })
    }
}

//TODO:needs debugging
exports.fixtures = function(data, done) {
    var connection = state.pool
    if (!pool) return done(new Error('Missing database connection.'))
    console.log("storing data");
    var names = Object.keys(data.tables)
    async.each(names, function(name, cb) {
        async.each(data.tables[name], function(row, cb) {
            var keys = Object.keys(row),
                values = keys.map(function(key) {
                    return "'" + row[key] + "'"
                })

            pool.query('INSERT INTO ' + name + ' (' + keys.join(',') + ') VALUES (' + values.join(',') + ')', cb)
        }, cb)
    }, done)
}

exports.drop = function(tables, done) {
    var pool = state.pool
    if (!pool) return done(new Error('Missing database connection.'))

    async.each(tables, function(name, cb) {
        pool.query('DELETE * FROM ' + name, cb)
    }, done)
}