var mysql      = require('mysql');
var config = require('./config.json');

function getConnection() {
    var params = {
        host     : config.host,
        user     : config.user,
        password : config.password,
        database : config.database
    };

    return mysql.createConnection(params);
};


module.exports = {
    fetchUsers: function(callback) {
        var connection = getConnection();

        connection.query('SELECT * FROM USER', function (error, results, fields) {

            if (error) throw error;
            console.log('Query: ', results);
            callback(results);
        });

        connection.end();
    }
};