#include "sqlworker.h"
#include <QDebug>
#include <QSqlError>
#include <QSqlQuery>
#include <QtSql>

sqlWorker::sqlWorker(const QString& hostName, const QString& dbName, const QString& userName, const QString& pwd)
{
    workDB = QSqlDatabase::addDatabase("QMYSQL", CONNECTION_NAME);
    workDB.setHostName(hostName);
    workDB.setDatabaseName(dbName);
    workDB.setUserName(userName);
    workDB.setPassword(pwd);
    if(!workDB.open()) {
        qDebug() << "Failed to open mysql database at host " << hostName << " with database name " << dbName << "and username " << userName;
        qDebug() << "Reason : " << workDB.lastError().text();
    } else {
        qDebug("db opened successfull.");
        query = new QSqlQuery(workDB);
        qDebug("query created.");
    }
}

sqlWorker::sqlWorker()
{
    sqlWorker(DEFAULT_HOSTNAME, DEFAULT_DBNAME, DEFAULT_USERNAME, DEFAULT_PASSWORD);
}

sqlWorker::~sqlWorker()
{
    qDebug() << "Entering sqlWorker::~sqlWorker() ...";
    if(workDB.isOpen())
        workDB.close();
    QSqlDatabase::removeDatabase(CONNECTION_NAME);
}

QString sqlWorker::sqlVersion()
{

    qDebug() << "workDB status : " << (workDB.isOpen() ? "opened" : "CLOSED")/* << "query status : " << (query->isActive() ? "active" : "inactive")*/;
    qDebug("Entering sqlVersion(). Sending query->exec()");
    query->exec();
    qDebug("Getting query->next()");
    QString result;
    while(query->next()) {
        result.append("\t" + query->value(0).toString());
    }
    return result;
}