'use strict'

var mysql = require('mysql');
var config = require('../config');
var pool = mysql.createPool({
  connectionLimit: config.db.connectionLimit,
  host: config.db.host,
  user: config.db.user,
  password: config.db.password,
  database: config.db.database,
  debug: config.db.debug,
  timezone: config.db.timezone,
  socket: '/Applications/MAMP/tmp/mysql/mysql.sock'
});
var debug = require('debug')('xxx-node:server');

function errorHandler(response, error, message, failure) {
  if(failure == null) {
    if (response != null) {
      response.json({
        status: "error",
        message: message,
        error: error
      });
      response.end();
    }
  }
  else{
    failure(error);
  }
}

exports.query = function (response, query, callback, context, failure) {
  var time = new Date().getTime();
  pool.getConnection(function (err, connection) {
    if (err) {
      errorHandler(response, err, err.message, failure);
      return;
    }
    connection.query(query, function (err, rows) {
      connection.release();
      debug('>>SQL  : ' + query);
      debug('++TIME : ' + (new Date().getTime() - time) + ' ms');
      if (!err) {
        callback(rows, context);
      }
      else {
        errorHandler(response, err, err.message, failure);
        return;
      }
    });
    connection.on('error', function (err) {
      errorHandler(response, err, err.message, failure);
      return;
    })
  })
}