import Mysql from 'mysql'
import Object from '../model/Object'
import config from '../config/Config'
import logger from '../logger/Logger'

let pool = Mysql.createPool(config["mysql"])

class DBService {
    
    async query(sql: string, args: any[]): Promise<Object> {
        return new Promise<Object>((resolve, reject) => {
            pool.getConnection((err, conn) => {
                if (err) {
                    reject({ err })
                    return
                }
    
                conn.query(sql, args, (err, rows) => {
                    if (err) {
                        reject({ err })
                        return
                    }

                    resolve({ rows })
                })
                
                conn.release()
            })
        }).catch((err) => {
            return { err }
        })
    }

    async insert(sql: string, args: any[]): Promise<Object> {
        return new Promise<Object>((resolve, reject) => {
            pool.getConnection((err, conn) => {
                if (err) {
                    reject({ err })
                    return
                }

                conn.query(sql, args, (err, rows) => {
                    if (err) {
                        reject({ err })
                        return
                    }
                    resolve({})
                })
                
                conn.release()
            })
        }).catch((err) => {
            return { err }
        })
    }
}

export = DBService