MySqlDbtModel.cpp

Go to the documentation of this file.

#include "MySqlDbtModel.h"
 
 
MySqlDbtModel::MySqlDbtModel(MyLanguageModel *thisLanguageModel, MyConstants *thisConstant, QObject *parent) : QObject(parent), myLanguageModel(thisLanguageModel), myConstants(thisConstant)
{
}
 
MySqlDbtModel::~MySqlDbtModel()
{
    #ifdef USE_SQL_FLAG
    if (myDb.isOpen()) { myDb.close(); }
    #endif
}
 
bool MySqlDbtModel::isDbTable(const QString &thisTable)
{
    setMessage("isDatabase");
    #ifdef USE_SQL_FLAG
    QStringList theTables = myDb.tables();
    if (theTables.contains(thisTable, Qt::CaseInsensitive))  { return true; }
    else                                                     { return false; }
    #else
    return true;
    #endif
}
#ifdef USE_SQL_FLAG
 
void MySqlDbtModel::setSqlDatabase(QSqlDatabase thisDatabase)
{
    setMessage("setSqlDatabase");
    myDb = thisDatabase;
}
 
QSqlDatabase MySqlDbtModel::getSqlDatabase()
{
    setMessage("getSqlDatabase");
    return myDb;
}
#endif
 
QString MySqlDbtModel::getSqlDriver()
{
    setMessage("getSqlDriver");
    return mySqlDriver;
}
 
void MySqlDbtModel::setSqlTableName(const QString &thisTableName)
{
    setMessage("setSqlTableName");
    myTableName = thisTableName;
}
 
QString MySqlDbtModel::getSqlTableName()
{
    setMessage("getSqlTableName");
    return myTableName;
}
 
void MySqlDbtModel::setSqlHostName(const QString &thisHostName)
{
    setMessage("setSqlHostName");
    myHostName = thisHostName;
}
 
QString MySqlDbtModel::getSqlHostName()
{
    setMessage("getSqlHostName");
    return myHostName;
}
 
void MySqlDbtModel::setSqlUserName(const QString &thisUserName)
{
    setMessage("setSqlUserName");
    myUserName = thisUserName;
}
 
QString MySqlDbtModel::getSqlUserName()
{
    setMessage("getSqlUserName");
    return myUserName;
}
 
void MySqlDbtModel::setSqlDatabaseName(const QString &thisPassword)
{
    setMessage("setSqlDatabaseName");
    myDatabaseName = thisPassword;
}
 
QString MySqlDbtModel::getSqlDatabaseName()
{
    setMessage("getSqlDatabaseName");
    return myDatabaseName;
}
 
void MySqlDbtModel::setSqlPassword(const QString &thisPassword)
{
    setMessage("setSqlPassword");
    myPassword = thisPassword;
}
 
QString MySqlDbtModel::getSqlPassword()
{
    setMessage("getSqlPassword");
    return myPassword;
}
 
void MySqlDbtModel::setConnectionName(const QString &thisConnectionName)
{
    setMessage("setConnectionName");
    myConnectionName = thisConnectionName;
}
 
QString MySqlDbtModel::getRecordID()
{
    return myInsertID;
}
 
void MySqlDbtModel::setRecordID(const QString &thisRecordID)
{
    myInsertID = thisRecordID;
}
 
QString MySqlDbtModel::getConnectionName()
{
    setMessage("getConnectionName");
    return myConnectionName;
}
 
void MySqlDbtModel::setSqlDriver(const QString &thisDriver)
{
    setMessage("setSqlDriver");
#ifdef USE_SQL_FLAG
    QString theDriver = thisDriver;
    if (theDriver.length() == 0)  { theDriver = myConstants->MY_SQL_DEFAULT; }
    // Check for Database memory setting
    // ui->checkBoxSettingsMemory->isChecked() || combobox
    // Database Driver
    if (theDriver == ":memory:")
    {
        // SQLite version 3 SQLite version 2 Note: obsolete since Qt 5.14
        mySqlDriver = theDriver;
    }
    else if (theDriver == "QSQLITE" || theDriver == "QSQLITE2")
    {
        // SQLite version 3 SQLite version 2 Note: obsolete since Qt 5.14
        mySqlDriver = theDriver;
    }
    else if (theDriver == "QMYSQL" || theDriver == "MARIADB")
    {
        // MySQL or MariaDB (version 5.0 and above)
        mySqlDriver = theDriver;
    }
    else if (theDriver == "QPSQL")
    {
        // PostgreSQL (versions 7.3 and above)
        mySqlDriver = theDriver;
    }
    else if (theDriver == "QDB2")
    {
        // IBM DB2 (version 7.1 and above)
        mySqlDriver = theDriver;
    }
    else if (theDriver == "QIBASE")
    {
        // Borland InterBase
        mySqlDriver = theDriver;
    }
    else if (theDriver == "QOCI")
    {
        // Oracle Call Interface Driver
        mySqlDriver = theDriver;
    }
    else if (theDriver == "QTDS")
    {
        // Sybase Adaptive Server - Note: obsolete since Qt 4.7
        mySqlDriver = theDriver;
    }
    else
    {
        mySqlDriver = theDriver;
    }
#endif
} // end setSqlDriver
 
bool MySqlDbtModel::createDataBaseConnection()
{
    setMessage("createDataBaseConnection");
#ifdef USE_SQL_FLAG
    // Make sure Drive is set
    if (mySqlDriver == "NOTSET") { setSqlDriver(myConstants->MY_SQL_DEFAULT); }
    QString theDb = getSqlDatabaseName();
    // Database Driver
    if (mySqlDriver == ":memory:")
    {
        myDb = QSqlDatabase::addDatabase("QSQLITE"); 
        myDb.setDatabaseName(":memory:");
    }
    else
    {
        if (mySqlDriver == "QSQLITE" || mySqlDriver == "QSQLITE2")
        {   
            // SQLite version 3 and SQLite version 2 Note: obsolete since Qt 5.14
            if (theDb.contains(".db"))
            {
                if (!myLanguageModel->mySetting->isFileExists(theDb))
                {
                    qCritical() << "createDataBaseConnection new DB: " << theDb;
                }
            }
            else
            {
                theDb = QString("%1%2%3.db").arg(myLanguageModel->mySetting->getAppDataLocation(), QDir::separator(), getSqlDatabaseName());
            }
            //
            myDb = QSqlDatabase::addDatabase(mySqlDriver); 
            myDb.setDatabaseName(theDb);
            //    myDb.setHostName(getSqlHostName());
            //    myDb.setUserName(getSqlUserName());
            //    myDb.setPassword(getSqlPassword());
            //
        }
        else if (mySqlDriver == "QDB2")
        {   
            // IBM DB2 (version 7.1 and above)
            myDb = QSqlDatabase::addDatabase(mySqlDriver, myConnectionName);
            myDb.setHostName(getSqlHostName());
            myDb.setDatabaseName(getSqlDatabaseName());
            myDb.setUserName(getSqlUserName());
            myDb.setPassword(getSqlPassword());
        }
        else if (mySqlDriver == "QIBASE")
        {   
            // Borland InterBase
            myDb = QSqlDatabase::addDatabase(mySqlDriver, myConnectionName);
            myDb.setHostName(getSqlHostName());
            myDb.setDatabaseName(getSqlDatabaseName());
            myDb.setUserName(getSqlUserName());
            myDb.setPassword(getSqlPassword());
        }
        else if (mySqlDriver == "QMYSQL" || mySqlDriver == "MARIADB")
        {   
            // MySQL or MariaDB (version 5.0 and above)
            myDb = QSqlDatabase::addDatabase(mySqlDriver, myConnectionName);
            myDb.setHostName(getSqlHostName());
            myDb.setDatabaseName(getSqlDatabaseName());
            myDb.setUserName(getSqlUserName());
            myDb.setPassword(getSqlPassword());
        }
        else if (mySqlDriver == "QOCI")
        {   
            // Oracle Call Interface Driver
            myDb = QSqlDatabase::addDatabase(mySqlDriver, myConnectionName);
            myDb.setHostName(getSqlHostName());
            myDb.setDatabaseName(getSqlDatabaseName());
            myDb.setUserName(getSqlUserName());
            myDb.setPassword(getSqlPassword());
        }
        else if (mySqlDriver == "QPSQL")
        {   
            // PostgreSQL (versions 7.3 and above)
            myDb = QSqlDatabase::addDatabase(mySqlDriver, myConnectionName);
            myDb.setHostName(getSqlHostName());
            myDb.setDatabaseName(getSqlDatabaseName());
            myDb.setUserName(getSqlUserName());
            myDb.setPassword(getSqlPassword());
        }
        else if (mySqlDriver == "QTDS")
        {   
            // Sybase Adaptive Server - Note: obsolete since Qt 4.7
            myDb = QSqlDatabase::addDatabase(mySqlDriver, myConnectionName);
            myDb.setHostName(getSqlHostName());
            myDb.setDatabaseName(getSqlDatabaseName());
            myDb.setUserName(getSqlUserName());
            myDb.setPassword(getSqlPassword());
        }
    } // end ! if (:memory:)
    if (!myDb.open())
    {
        if(!QSqlDatabase::isDriverAvailable(mySqlDriver))
        {
            myLanguageModel->mySetting->showMessageBox(tr("Database SQL Driver is missing").toLocal8Bit(), tr("Install SQL").toLocal8Bit(), myLanguageModel->mySetting->Critical);
            return false;
        }
        else
        {
            myLanguageModel->mySetting->showMessageBox(QString("%1: %2").arg(tr("Cannot open database"), myDb.lastError().text()).toLocal8Bit(), tr("Unable to establish a database connection").toLocal8Bit(), myLanguageModel->mySetting->Critical);
            return false;
        }
    }
    // Set Settings
    myLanguageModel->mySetting->writeSettings(myConstants->MY_SQL_DB_NAME, theDb);
    myLanguageModel->mySetting->writeSettings(myConstants->MY_SQL_DB_TYPE, "QSQLITE");
#endif
    return true;
} // end createDataBaseConnection
 
bool MySqlDbtModel::runQuery(const QString &thisQuery)
{
    setMessage("runQuery=" + thisQuery);
    #ifdef USE_SQL_FLAG
    QSqlQuery theQuery; 
    if (theQuery.exec(thisQuery))
    {
        setRecordID(theQuery.lastInsertId().toString());
        return true;
    }
    else
    {
        qCritical() << "Error running Query: " << thisQuery << theQuery.lastError().text() << ", SqLite error code:" << theQuery.lastError();
        setRecordID("-1");
        return false;
    }
    #else
    return true;
    #endif
}
 
bool MySqlDbtModel::moveDb(const QString &thisSourceFile,const QString &thisSourcePath, const QString &thisDestinationFolder)
{
    setMessage("moveDb");
#ifdef USE_SQL_FLAG
    QFile file(QString("%1%2%3").arg(thisSourcePath, QDir::separator(), thisSourceFile));
    //
    QString theNewDatabaseName = QString("%1%2%3").arg(thisDestinationFolder, QDir::separator(), thisSourceFile);
    //
    if (myLanguageModel->mySetting->isFileExists(theNewDatabaseName))
    {
        if (!myLanguageModel->mySetting->questionYesNo("Overwrite Database", "Are you sure you want to overwrite existing Database?"))
        {
            return true;
        }
    }
    //
    if (myDb.isOpen()) { myDb.close(); }
    if (file.rename(theNewDatabaseName))
    {
        myDatabaseName = theNewDatabaseName;
        return createDataBaseConnection();
    }
    else { return true; }
#else
    return true;
#endif
}
 
QString MySqlDbtModel::runProcces(const QString &thisExePath, const QString &thisArgument, bool isWait, int thisWaitTimeSec)
{
    QProcess *thisProcess = new QProcess(this);
    if (isWait)
    {
        thisProcess->start(thisExePath, QStringList() << thisArgument);
        // default wait time 30 sec
        if(!thisProcess->waitForStarted()) { qWarning() << tr("runProcces cannot start process"); }
        // wait time
        int waitTime = thisWaitTimeSec * 1000; // 60000 = 60 sec divide by 1000
        // now wait
        if (!thisProcess->waitForFinished(waitTime)) { qWarning() << tr("runProcces timeout .."); }
    }
    else
    {
        thisProcess->start(thisExePath, QStringList() << thisArgument);
        thisProcess->waitForFinished();
    }
    //
    thisProcess->setProcessChannelMode(QProcess::MergedChannels);
    myRunReturnCode = thisProcess->exitCode();
    return QString(thisProcess->readAllStandardOutput().simplified());
}
 
int MySqlDbtModel::getRunReturnCode()
{
    return myRunReturnCode;
}
 
void MySqlDbtModel::setDebugMessage(bool thisState)
{
    isDebugMessage = thisState;
}
 
bool MySqlDbtModel::getDebugMessage()
{
    return isDebugMessage;
}
 
void MySqlDbtModel::setMessage(const QString &thisMessage)
{
    if (isDebugMessage)
    {
        qDebug() << thisMessage;
        //std::cout << thisMessage.toStdString() << std::endl;
    }
}