const mysql = require('mysql2');
const logger = require('./logger');

const pool = mysql.createPool({
  host: process.env.DB_HOST,
  user: process.env.DB_USER,
  password: process.env.DB_PASSWORD,
  database: process.env.DB_NAME,
  waitForConnections: true,
  connectionLimit: 10,
  queueLimit: 0
});

const promisePool = pool.promise();

const originalExecute = promisePool.execute;
promisePool.execute = function(sql, params) {
  logger.info('Executing SQL', { sql, params });
  return originalExecute.call(this, sql, params);
};

const originalQuery = promisePool.query;
promisePool.query = function(sql, params) {
  logger.info('Executing SQL', { sql, params });
  return originalQuery.call(this, sql, params);
};

module.exports = promisePool;