const mysql = require('mysql');
const vars = require('./vars');

const logcon = mysql.createConnection({
    host: 'db',
    user: 'user',
    password: 'user',
    database: 'users'
});

logcon.connect();

// check_for
module.exports.cv = (table,key,value,callback) => {
    logcon.query(`SELECT * FROM ${table}`, (err, rows, fields) => {
        let log = '';
        if (err) {
            console.log("sql err");
            throw err;
        } 
        rows.forEach(rec => {
            if (rec[key]==value){
                log = rec[key];
                return;
            }
        });
        if (log != ''){
            callback(log);
        }
        else{
            callback(null);
        }
    })
}

// module.exports.ccv = (table,ekey,key,value,callback) => {
//     logcon.query('SELECT * FROM `'+table+'`', (err, rows, fields) => {
//         let log = '';
//         if (err) {
//             console.log("sql err");
//             throw err;
//         } 
//         rows.forEach(rec => {
//             if (rec[key]==value){
//                 log = rec[key];
//                 return;
//             }
//         });
//         if (log != ''){
//             callback(log);
//         }
//         else{
//             callback(null);
//         }
//     })
// }

module.exports.dl = (table,key,value,callback) => {
    // console.log('SELECT * FROM `'+table+'` WHERE `'+key+'` = '+value);
    logcon.query(`DELETE FROM ${table} WHERE ${key} = ${value}`, (err, rows, fields) => {
        if (err) {
            console.log("sql err");
            throw err;
        }else{
            callback(rows);
        }
    })
}

// get_from
module.exports.gv = (table,key,value,callback) => {
    // console.log('SELECT * FROM `'+table+'` WHERE `'+key+'` = '+value);
    logcon.query(`SELECT * FROM ${table} WHERE ${key} = ${value}`, (err, rows, fields) => {
        if (err) {
            console.log("sql err");
            throw err;
        }else{
            callback(rows);
        }
    })
}

module.exports.gav = (table,callback) => {
    // console.log('SELECT * FROM `'+table+'` WHERE `'+key+'` = '+value);
    logcon.query(`SELECT * FROM ${table} WHERE 1`, (err, rows, fields) => {
        if (err) {
            console.log("sql err");
            throw err;
        }else{
            callback(rows);
        }
    })
}


module.exports.ggv = (table,ekey,key,value,callback) => {
    // console.log('SELECT * FROM `'+table+'` WHERE `'+key+'` = '+value);
    logcon.query(`SELECT ${ekey} FROM ${table} WHERE ${key} = ${value}`, (err, rows, fields) => {
        if (err) {
            console.log("sql err");
            throw err;
        }else{
            callback(rows);
        }
    })
}

// set_in
module.exports.sv = (table,key,value,ekey,evalue,callback) => {
    logcon.query(`UPDATE ${table} SET ${key} = '${value}' WHERE ${ekey} = '${evalue}'`, (err , rows) => {
        // console.log("UPDATE `"+table+"` SET `"+key+"` = '"+value+"' WHERE `"+ekey+"` = '"+evalue+"'");
        if (err) {
            console.log("sql err");
            throw err;
        }else{
            callback(rows);
        }
    })
}

module.exports.nr = (table,keys,values) =>{
    // console.log('INSERT INTO `'+table+'`('+keys+') VALUES ('+values+')');
    logcon.query(`INSERT INTO ${table} (${keys}) VALUES (${values})`,(err,res) =>{
        if (err) {
            console.log("sql err");
            throw err;
        }else{
            return true;
        }
    })
}

module.exports.glv = (table,last_value,callback) =>{
    // console.log('INSERT INTO `'+table+'`('+keys+') VALUES ('+values+')');
    logcon.query(`SELECT * FROM ${table} ORDER BY ${last_value} DESC LIMIT 1;`,(err,res) =>{
        if (err) {
            console.log("sql err");
            throw err;
        }else{
            callback(res);
        }
    })
}