var db = require('./db.js');

console.log(searchAccessToken(name,queryDB));

function searchAccessToken(emailAddress,callback){
    var sql = "SELECT accessToken FROM device WHERE email_address = '" + emailAddress + "'";
    return callback(sql);
}

function queryDB(sql){
    var token = "";
    db(function(err,conn){
        conn.query(sql,function(err,results){
            if(err){
                conn.release();
                return err;
            }else if(results.length){
                token = results[0].accessToken;
            }
            conn.release();
            return token;
        });
    });
}

var mysql = require('mysql');

var pool = mysql.createPool({
  //development
  // host:'localhost',
  // user:'root',
  // password: '',
  // database: 'merchantdev',
  // insecureAuth : true

  //staging
  host:'',
  user: '',
  password: '',
  database: ''
});

var getConnection = function(callback) {
  pool.getConnection(function(err, connection) {
      if(err) {
        return callback(err);
      }
      callback(null, connection);
  });
};

module.exports = getConnection;