bool CDBOperatorAbstract::_openDBConn(CDatabaseConfig config)
{
    QWriteLocker locker(&m_locker);
    QSqlDatabase db;
    if(QSqlDatabase::contains(m_connectionName))
    {
        db = QSqlDatabase::database(m_connectionName);
        QStringList tables = db.tables();
        if(db.isOpen() && tables.contains(config.m_databaseName))
        {
            m_isConnected = true;
            return true;
        }
    }
    else
    {
        // 此時目標數(shù)據(jù)庫不一定存在，不指定數(shù)據(jù)庫名，會默認連接到mysql的主數(shù)據(jù)庫（mysql數(shù)據(jù)庫）
        db = QSqlDatabase::addDatabase("QMYSQL",m_connectionName);
        db.setHostName(config.m_hostAddress);   // 數(shù)據(jù)庫服務器IP
        db.setPort(config.m_port);              // 端口號
        db.setUserName(config.m_userName);      // 用戶名
        db.setPassword(config.m_userPwd);       // 密碼
    }
    // 連接數(shù)據(jù)庫
    if(!db.open())
    {
        qDebug() << db.lastError().text();
        m_isConnected = false;
        return false;
    }

    QSqlQuery query(db);
    QString strSql = QString("CREATE DATABASE IF NOT EXISTS `%1`").arg(config.m_databaseName);
    //執(zhí)行建表語句，若執(zhí)行成功
    if(query.exec(strSql))
    {
        //若查詢語句有錯
        if(query.lastError().isValid())
        {
            qDebug()<< query.lastError().text();
            m_isConnected = false;
            return false;
        }
    }
    else
    {
        m_isConnected = false;
        return false;
    }

// 確認目標數(shù)據(jù)庫創(chuàng)建成功，關(guān)閉之前打開的默認數(shù)據(jù)庫
db.close();
// 重新設(shè)置連接的數(shù)據(jù)庫名
db.setDatabaseName(config.m_databaseName);
// 重新打開數(shù)據(jù)庫
if(!db.open())
{
    m_isConnected = false;
    return false;
}
else
{
    m_isConnected = true;
    return true;
}
}

bool CDBOperatorAbstract::checkIsInWorkThread()
{
    if(QThread::currentThread() == this->m_pThread)
        return true;
    else
        return false;
}

bool CDBOperatorAbstract::openDBConn(CDatabaseConfig config)
{
    if(checkIsInWorkThread())
    {
        return _openDBConn(config);
    }
    else
    {
        bool isOk = false;
        QMetaObject::invokeMethod(this,"_openDBConn",Qt::BlockingQueuedConnection,
                                  Q_RETURN_ARG(bool,isOk),
                                  Q_ARG(CDatabaseConfig,config));
        return isOk;
    }
}