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

var connection = mysql.createConnection({
    user : config.DB_CONNECTION.user,
    password: config.DB_CONNECTION.pass,
    database: config.DB_CONNECTION.name
});

connection.connect((err) => {
    if (err) throw err;
    console.log('You are now connected...');
});


module.exports = class Mysql {
    constructor(table = null){
        this.table = table;
        this.generateCondition = (condition = '') => {
            if(condition){
                return `WHERE ${condition}`;
            }else{
                return '';
            }
        };
        this.connection = connection;
    };
    findAll (condition = '', params = []) {
        return new Promise((resolve, reject) => {
            this.connection.query(`Select * FROM ${this.table} ${this.generateCondition(condition)}`, params, (err, results) => {
                if (err)
                    return reject( err );
                resolve(results);
            });
        });
    };
    find (condition = '', params = []){
        return new Promise((resolve, reject) => {
            this.connection.query(`Select * FROM ${this.table} ${this.generateCondition(condition)}`, params, (err, results) => {
                if (err)
                    return reject( err );
                resolve(results[0]);
            });
        });
    };
    findByPk (id = 0){
        return new Promise((resolve, reject) => {
            this.connection.query(`Select * FROM ${this.table} WHERE id = ${id}`, params, (err, results) => {
                if (err)
                    return reject( err );
                resolve(results[0]);
            });
        });
    };
    query( sql, args ) {
        return new Promise( ( resolve, reject ) => {
            this.connection.query( sql, args, ( err, rows ) => {
                if ( err )
                    return reject( err );
                resolve( rows );
            } );
        } );
    };
    close() {
        return new Promise( ( resolve, reject ) => {
            this.connection.end( err => {
                if ( err )
                    return reject( err );
                resolve();
            } );
        } );
    };
};