"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.MysqlManager = void 0;
const Database_1 = require("./Database");
var mysql = require('mysql');
class MysqlManager extends Database_1.Database {
    constructor() {
        super();
    }
    Open(callback) {
        this.log.Debug("Calling Open function in MysqlManager");
        if (this.dbase == null || this.dbase == "") {
            this.log.Debug("MySQL database not selected, Error : ");
            return;
        }
        if (this.hostip == null || this.hostip == "") {
            this.log.Debug("MySQL hostname not set, Error : ");
            return;
        }
        if (this.user == null || this.user == "") {
            this.log.Debug("MySQL username not set, Error : ");
            return;
        }
        if (this.pass == null) {
            this.log.Debug("MySQL password not set, Error : ");
            return;
        }
        /* if(this.port==3307 || this.port==3306 || this.port==0 ){
            this.connection = mysql.createConnection({
                host     : this.hostip,
                user     : this.user,
                password : this.pass,
                database : this.dbase,
                charset  : 'utf8mb4',
                port: this.port,


                // custom modification
                multipleStatements: true,
                acquireTimeout: 1000000
            });

            // this.connection.connect((err:any)=>{
            // 	if(callback)
            // 		callback(err);
            // });
        }
        //else
        //	this.connection = mysql.createConnection(this.host+":"+this.port+":"+this.username+":"+this.database+":"+this.password); */
        if (this.port == 3306 || this.port == 0) {
            this.connection = mysql.createConnection({
                host: this.hostip,
                user: this.user,
                password: this.pass,
                database: this.dbase,
                charset: 'utf8mb4',
                /* custom modification */
                multipleStatements: true,
                acquireTimeout: 1000000
            });
        }
        else {
            this.connection = mysql.createConnection({
                host: this.hostip,
                user: this.user,
                password: this.pass,
                database: this.dbase,
                port: this.port,
                charset: 'utf8mb4',
                multipleStatements: true,
                acquireTimeout: 1000000
            });
        }
    }
    Close() {
        this.log.Debug("Calling Close function in MysqlManager");
        try {
            this.connection.end();
        }
        catch (e) {
            console.log(e);
        }
    }
    RawExecute(callback) {
        this.log.Debug("Calling Raw Execute function in MysqlManager");
        this.log.Debug(this._sql);
        // rv code for stric mode
        this.connection.query("SET SESSION sql_mode = 'STRICT_TRANS_TABLES,NO_ENGINE_SUBSTITUTION';", (err, result) => {
            if (err)
                throw err;
            console.log('SQL mode set for this session.');
        });
        this.connection.query(this._sql, function (error, data) {
            if (!error) {
                callback(1, data);
                //console.log(data);
            }
            else {
                console.log("Mysql query error  : " + error + "");
                delete error.sql;
                callback(10, error);
            }
        });
    }
    Execute(callback) {
        this.log.Debug("Calling Execute function in MysqlManager");
        this.log.Debug(this._sql);
        this._sql = mysql.format(this._sql, this._data);
        this.log.Debug(this._sql);
        this.connection.query(this._sql, function (error, data) {
            if (!error) {
                callback(1, data);
            }
            else {
                console.log("Mysql query error  : " + error + "");
                callback(10, error);
            }
        });
    }
    DataSet(callback) {
        this.log.Debug("Calling Dataset function in MysqlManager Field (" + this._data + "), SQL : " + this._sql);
        this._sql = mysql.format(this._sql, this._data);
        console.log(this._sql);
        this.connection.query(this._sql, function (err, data) {
            if (typeof callback === 'function')
                console.log("callback is a function");
            if (!err) {
                if (data.length > 0) {
                    callback(1, data);
                    console.log("End of Calling Dataset function in MysqlManager");
                }
                else {
                    console.log("No data found");
                    callback(2, "No data found");
                }
            }
            else {
                console.log("Mysql query error  : " + err + "");
                callback(10, err);
            }
        });
    }
    Row(callback) {
        this.log.Debug("Calling Row function in MysqlManager");
        this._sql = mysql.format(this._sql, this._data);
        this.log.Debug(this._sql);
        this.connection.query(this._sql, function (error, data) {
            if (!error) {
                if (data.length > 0) {
                    console.log("No of Rows return from Row function is " + data.length + ".");
                    console.log("End of Calling Row function in MysqlManager");
                    callback(1, data[0]);
                }
                else {
                    console.log("Null Data return");
                    callback(2, "Null Data return");
                }
            }
            else {
                console.log("Mysql query error  : " + error + "");
                callback(10, error);
            }
        });
    }
    NonExecute(callback) {
        this._sql = mysql.format(this._sql, this._data);
        this.log.Debug("Executing query " + this._sql);
        this.connection.query(this._sql, (error, data) => {
            if (!error) {
                this._last = data.insertId;
                if (this._last > 0) {
                    console.log("No of Rows return from Row function is " + this._last + ".");
                    callback(1, data);
                }
                else {
                    console.log("Null Data return");
                    callback(2, data);
                }
            }
            else {
                console.log("Mysql query error  : " + error + "");
                callback(10, error);
            }
        });
    }
    Delete(callback) {
        this.log.Debug("Calling Delete function in MysqlManager");
        this.connection.query(this._sql, function (error, data) {
            if (!error) {
                console.log("End of Calling Delete function in MysqlManager");
                callback(1, { data: data });
            }
            else {
                console.log("Mysql query error  : " + error + "");
                callback(10, error);
            }
        });
    }
    LoadFile(callback) {
        this.log.Debug("Calling Delete function in MysqlManager");
        this.connection.query(this._sql, function (error, data) {
            if (!error) {
                var last_id = data.insertId;
                if (last_id > 0) {
                    console.log("No of Rows return from Row function is " + data.length + ".");
                    console.log("End of Calling Row function in MysqlManager");
                    callback(1, { last: last_id });
                }
            }
            else {
                console.log("Mysql query error  : " + error + "");
                callback(10, error);
            }
        });
    }
}
exports.MysqlManager = MysqlManager;