快捷導(dǎo)航

Qt 數(shù)據(jù)庫QSqlDatabase使用示例

更新時間：2023年12月15日 15:45:22 作者：kahh

本文主要介紹了Qt數(shù)據(jù)庫QSqlDatabase使用示例,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

創(chuàng)建數(shù)據(jù)庫

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
    {
        // 此時目標(biāo)數(shù)據(jù)庫不一定存在，不指定數(shù)據(jù)庫名，會默認(rèn)連接到mysql的主數(shù)據(jù)庫（mysql數(shù)據(jù)庫）
        db = QSqlDatabase::addDatabase("QMYSQL",m_connectionName);
        db.setHostName(config.m_hostAddress);   // 數(shù)據(jù)庫服務(wù)器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;
    }

// 確認(rèn)目標(biāo)數(shù)據(jù)庫創(chuàng)建成功，關(guān)閉之前打開的默認(rè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;
}
}

在上述創(chuàng)建數(shù)據(jù)庫的代碼中有幾個需要注意的地方：
1、一個QSqlDatabase對象表示的是一個數(shù)據(jù)庫連接，而不是字面上的數(shù)據(jù)庫（數(shù)據(jù)庫連接與數(shù)據(jù)庫的關(guān)系是：一個數(shù)據(jù)庫連接可以通過修改配置連接到多個數(shù)據(jù)庫，一個數(shù)據(jù)庫也可以有多個數(shù)據(jù)庫連接）

2、addDatabase()方法需要指定數(shù)據(jù)庫驅(qū)動類型，如MySQL、SQLite……，如果沒有指定連接名，將默認(rèn)使用defaultConnection作為連接名。對于同一個連接，重復(fù)調(diào)用addDatabase()，會提示：

QSqlDatabasePrivate::addDatabase: duplicate connection name
‘qt_sql_default_connection’, old connection removed.

3、removeDatabase()刪除數(shù)據(jù)庫連接，需要在確保所有QSqlQuery查詢操作執(zhí)行完畢并且銷毀，否則會提示：

QSqlDatabasePrivate::removeDatabase: connection ‘qt_sql_default_connection’ is still in use, all queries will cease to work.

4、在進(jìn)行數(shù)據(jù)庫連接時，目標(biāo)數(shù)據(jù)庫可能還不存在，這時候可以不指定數(shù)據(jù)庫名進(jìn)行連接，此會將連接到數(shù)據(jù)庫服務(wù)器的主數(shù)據(jù)庫，例如我使用的是MySQL數(shù)據(jù)庫服務(wù)器，就會連接到mysql數(shù)據(jù)庫

在這里插入圖片描述

5、數(shù)據(jù)庫連接建立成功后，創(chuàng)建目標(biāo)數(shù)據(jù)庫（不存在時才創(chuàng)建），確保目標(biāo)數(shù)據(jù)庫創(chuàng)建成功后，先關(guān)閉之前的數(shù)據(jù)庫連接，設(shè)置數(shù)據(jù)庫名稱后再重新打開。（只有重新打開數(shù)據(jù)庫連接，數(shù)據(jù)庫配置才會生效）

多線程使用數(shù)據(jù)庫

QSqlDatabase是非線程安全的，意味著在多線程環(huán)境下同時使用同一個數(shù)據(jù)庫連接對象可能會導(dǎo)致競態(tài)條件和數(shù)據(jù)一致性問題。因此，每個線程最好都維護(hù)一個獨(dú)立的數(shù)據(jù)庫連接，并且在同一個線程中創(chuàng)建、使用和關(guān)閉數(shù)據(jù)庫連接。如果數(shù)據(jù)庫連接有父對象，它和父對象也必須在同一個線程。
一般用QMap來管理線程和對應(yīng)的數(shù)據(jù)庫連接，可以用QMap<QThread*,QSqlDatabase*>來存儲，也可以用QMap<QThread*,QString>來存儲（存連接名）

由于程序可能在各個地方操作數(shù)據(jù)庫，為了讓數(shù)據(jù)庫連接的創(chuàng)建和使用保持在同一個線程中，可以用QMetaObject::invokeMethod()將數(shù)據(jù)庫的創(chuàng)建、使用、關(guān)閉都移動到數(shù)據(jù)庫連接所在的線程中

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;
    }
}

用BlockingQueuedConnection的連接方式，會將目標(biāo)函數(shù)放在接收者的生存線程中執(zhí)行，并且阻塞發(fā)送者所在的線程，直到目標(biāo)函數(shù)執(zhí)行完畢。