Method OpenMySqlDatabase

Src/Database/Database.cpp:163–230

}

bool CDatabase::OpenMySqlDatabase(const CParameterDatabase *pPara,
                                  const QString &szConnectName)
{
    bool success = false;
    if(!pPara) return false;

    if(!szConnectName.isEmpty())
        m_szConnectName = szConnectName;

    // 打开或创建数据库
    m_database = QSqlDatabase::addDatabase("QMYSQL", m_szConnectName);
    QString szDbName = pPara->GetDatabaseName();
    if(szDbName.isEmpty()) {
#if DEBUG
        szDbName = "remote_control_dev";
#else
        szDbName = "remote_control";
#endif
    }

    auto &net = pPara->m_Net;
    m_database.setHostName(net.GetHost());
    m_database.setPort(net.GetPort());
    auto &user = net.m_User;
    m_database.setUserName(user.GetName());
    m_database.setPassword(user.GetPassword());
    
    if (!m_database.open()) {
        SetError("Failed to open mysql database: " + m_database.databaseName()
                 + "; Connect name: " + m_database.connectionName()
                 + "; Host: " + net.GetHost()
                 + "; Port: " + QString::number(net.GetPort())
                 + "; User: " + user.GetUser()
                 + "; Error: " + m_database.lastError().text()
                 );
        qCritical(log) << GetError();
        return false;
    }

    m_bOwner = true;

    QSqlQuery query(GetDatabase());
    success = query.exec("CREATE DATABASE IF NOT EXISTS " + szDbName);
    if (!success) {
        SetError("Failed to create mysql database: " + szDbName
                 + "; Error: " + query.lastError().text()
                 + "; Sql: " + query.executedQuery());
        qCritical(log) << GetError();
        return false;
    }

    success = query.exec("use " + szDbName);
    if (!success) {
        SetError("Failed to use " + szDbName
                 + "; Error: " + query.lastError().text()
                 + "; Sql: " + query.executedQuery());
        qCritical(log) << GetError();
        return false;