Qt操作SQLite資料庫

音視頻開發老舅 發佈 2024-04-02T16:28:21.475744+00:00

下面講解如何在 Qt 中操作 SQlite 資料庫。對資料庫的操作,都是用 SQLite 的語句完成的,把這些指令以 QString 類型,通過 prepare 函數,保存在 QSqlQuery 對象中。

項目中通常需要採用各種資料庫(如 Qracle、SQL Server、MySQL等)來實現對數據的存儲、查詢等功能。下面講解如何在 Qt 中操作 SQlite 資料庫。


1、Sqlite 介紹

Sqlite 資料庫作為 Qt 項目開發中經常使用的一個輕量級的資料庫,可以說是兼容性相對比較好的資料庫之一(Sqlite就像Qt的親兒子,如同微軟兼容Access資料庫一樣)。Qt5 以上版本可以直接使用(Qt自帶驅動),是一個輕量級的資料庫,概況起來具有以下優點:

  • SQLite 的設計目的是嵌入式 SQL 資料庫引擎,它基於純C語言代碼,已經應用於非常廣泛的領域內。
  • SQLite 在需要長時間存儲時可以直接讀取硬碟上的數據文件(.db),在無須長時間存儲時也可以將整個資料庫置於內存中,兩者均不需要額外的伺服器端進程,即 SQLite 是無須獨立運行的資料庫引擎。
  • 原始碼開源,你可以用於任何用途,包括出售它。
  • 零配置 – 無需安裝和管理配置。
  • 不需要配置,不需要安裝,也不需要管理員。
  • 同一個數據文件可以在不同機器上使用,可以在不同字節序的機器間自由共享。
  • 支持多種開發語言,C, C++, PHP, Perl, Java, C#,Python, Ruby等。


2、用法

2.1、準備

1、引入SQL模塊
在Qt項目文件(.pro文件)中,加入SQL模塊:

QT += sql

2、引用頭文件

在需要使用SQL的類定義中,引用相關頭文件。例如:

#include <QSqlDatabase>
#include <QSqlError>
#include <QSqlQuery>


2.2、使用

1、建立資料庫

QSqlDatabase database;

if (QsqlDatabase::contains("qt_sql_default_connection"))
{
    database = QSqlDatabase::database("qt_sql_default_connection");
}
else
{
    // 建立和SQlite資料庫的連接
    database = QSqlDatabase::addDatabase("QSQLITE");
    // 設置資料庫文件的名字
    database.setDatabaseName("MyDataBase.db");
}
  • 第一行中,建立了一個 QSqlDatabase 對象,後續的操作要使用這個對象。
  • if 語句用來檢查指定的連接(connection)是否存在。這裡指定的連接名稱(connection name)是qt_sql_default_connection,這是 Qt 默認連接名稱。實際使用時,這個名稱可以任意取。如果判斷此連接已經存在,那麼 QSqlDatabase::contains() 函數返回 true。此時,進入第一個分支,QSqlDatabase::database() 返回這個連接。
  • 如果這個連接不存在,則進入else分支,需要創建連接,並添加資料庫。在else分支第一行,addDatabase()的參數QSQLITE是SQLite對應的驅動名,不能改。而且需要注意的是,addDatabase()的第二個參數被省略了,第二個參數的默認參數就是上面提到的Qt默認連接名稱 qt_sql_default_connection。如果需要使用自定義的連接名稱(如果程序需要處理多個資料庫文件的話就會這樣),則應該加入第二個參數,例如:
  • database = QSqlDatabase::addDatabase("QSQLITE", "my_sql_connection);
  • 這個時候,如果在另一個地方需要判斷my_sql_connection連接是否存在,就應該使用 if (QSqlDatabase::contains("my_sql_connection"))。
  • else 分支第二行中,setDatabaseName() 的參數是資料庫文件名。如果這個資料庫不存在,則會在後續操作時自動創建;如果已經存在,則後續的操作會在已有的資料庫上進行。

2、打開資料庫

使用 open() 打開資料庫,並判斷是否成功。注意,在第一步檢查連接是否存在時,如果連接存在,則在返回這個連接的時候,會默認將資料庫打開。

QT開發交流+貲料君羊:714620761

if (!database.open())
{
    qDebug() << "Error: Failed to connect database." << database.lastError();
}
else
{
    // do something
}

如果打開資料庫成功,則進入else分支。對資料庫的操作都需要在else分支中進行。

3、關閉資料庫

資料庫操作完成後,最好關閉。

database.close();

4、操作資料庫

對資料庫進行操作需要用到 QSqlQuery 類,操作前必須定義一個對象。下面舉例說明操作方法。操作需要使用 SQL 語句,本文中的幾個例子會使用幾個常用的語句,關於 SQL 語句的具體信息可以參考我的另一篇博客:[SQL必知必會] 讀書筆記 。

例1:創建表格

創建一個名為student的表格,表格包含三列,第一列是id,第二列是名字,第三列是年齡。

// 用於執行SQL語句的對象
QSqlQuery sqlQuery;
// 構建創建資料庫的sql語句字符串
QString createSql = QString("CREATE TABLE student (\
                          id INT PRIMARY KEY NOT NULL,\
                          name TEXT NOT NULL,\
                          age INT NOT NULL)");
sqlQuery.prepare(createSql);
// 執行sql語句
if(!sqlQuery.exec())
{
    qDebug() << "Error: Fail to create table. " << sqlQuery.lastError();
}
else
{     qDebug() << "Table created!";
}
  • 第一行定義一個 QSqlQuery 對象。
  • 第二行是一個 QString,其中的內容是 SQLite 語句。對資料庫的操作,都是用 SQLite 的語句完成的,把這些指令以 QString 類型,通過 prepare 函數,保存在 QSqlQuery 對象中。也可將指令,以 QString 形式直接寫在 exec() 函數的參數中,例如:
  • sql_query.exec("CREATE TABLE student (ID INT PRIMARY KEY NOT NULL, ...)");
  • 如果 sql_query.exec() 執行成功,則創建表格成功。

例2:插入單行數據

在剛才創建的表格中,插入單行數據。

// 方法一:使用 bindValue 函數插入單行數據
QSqlQuery sqlQuery;
sqlQuery.prepare("INSERT INTO student VALUES(:id,:name,:age)");
sqlQuery.bindValue(":id", max_id + 1);
sqlQuery.bindValue(":name", "Wang");
sqlQuery.bindValue(":age", 25);
if(!sqlQuery.exec())
{
    qDebug() << "Error: Fail to insert data. " << sqlQuery.lastError();
}
else
{
        // do something    
}

// 方法二:使用 addBindValue 函數插入單行數據
QSqlQuery sqlQuery;
sqlQuery.prepare("INSERT INTO student VALUES(?, ?, ?)");
sqlQuery.addBindValue(max_id + 1);
sqlQuery.addBindValue("Wang");
sqlQuery.addBindValue(25);
if(!sqlQuery.exec())
{
    qDebug() << "Error: Fail to insert data. " << sqlQuery.lastError();
}
else
{
        // do something    
}

// 方法三:直接寫出完整語句
if(!sql_query.exec("INSERT INTO student VALUES(3, \"Li\", 23)"))
{
    qDebug() << "Error: Fail to insert data. " << sqlQuery.lastError();
}
else
{
        // do something 
}

例3:查詢全部數據

QSqlQuery sqlQuery;
sqlQuery.exec("SELECT * FROM student");
if(!sqlQuery.exec())
{
        qDebug() << "Error: Fail to query table. " << sqlQuery.lastError();
}
else
{
        while(sqlQuery.next())
        {
                int id = sqlQuery.value(0).toInt();
                QString name = sqlQuery.value(1).toString();
                int age = sqlQuery.value(2).toInt();
                qDebug()<<QString("id:%1    name:%2    age:%3").arg(id).arg(name).arg(age);
        }
}

例4:更新數據(修改數據)

QSqlQuery sqlQuery;
sqlQuery.prepare("UPDATE student SET name=?,age=? WHERE id=?");
sqlQuery.addBindValue(name);
sqlQuery.addBindValue(age);
sqlQuery.addBindValue(id);
if(!sqlQuery.exec())
{
    qDebug() << sqlQuery.lastError();
}
else
{
    qDebug() << "updated data success!";
}


3、完整示例程序

上面只是列舉了幾個常用的SQL語句例子,下面貼出一個完整示例程序:

SqliteOperator.h

#ifndef SQLITEOPERATOR_H
#define SQLITEOPERATOR_H

#include <QSqlDatabase>
#include <QSqlQuery>
#include <QSqlError>
#include <QDebug>

typedef struct
{
    int id;
    QString name;
    int age;
}w2dba;

class SqliteOperator
{
public:
    SqliteOperator();

    // 打開資料庫
    bool openDb(void);
    // 創建數據表
    void createTable(void);
    // 判斷數據表是否存在
    bool isTableExist(QString& tableName);
    // 查詢全部數據
    void queryTable();
    // 插入數據
    void singleInsertData(w2dba &singleData); // 插入單條數據
    void moreInsertData(QList<w2dba> &moreData); // 插入多條數據
    // 修改數據
    void modifyData(int id, QString name, int age);
    // 刪除數據
    void deleteData(int id);
    //刪除數據表
    void deleteTable(QString& tableName);
    // 關閉資料庫
    void closeDb(void);

private:
    QSqlDatabase database;// 用於建立和資料庫的連接
};

#endif //  SQLITEOPERATOR_H

SqliteOperator.cpp

#include "sqliteoperator.h"

// 構造函數中初始化資料庫對象,並建立資料庫
SqliteOperator::SqliteOperator()
{
    if (QSqlDatabase::contains("qt_sql_default_connection"))
    {
        database = QSqlDatabase::database("qt_sql_default_connection");
    }
    else
    {
        // 建立和SQlite資料庫的連接
        database = QSqlDatabase::addDatabase("QSQLITE");
        // 設置資料庫文件的名字
        database.setDatabaseName("MyDataBase.db");
    }
}

// 打開資料庫
bool SqliteOperator::openDb()
{
    if (!database.open())
    {
        qDebug() << "Error: Failed to connect database." << database.lastError();
    }
    else
    {
        // do something
    }

    return true;
}

// 創建數據表
void SqliteOperator::createTable()
{
    // 用於執行sql語句的對象
    QSqlQuery sqlQuery;
    // 構建創建資料庫的sql語句字符串
    QString createSql = QString("CREATE TABLE student (\
                          id INT PRIMARY KEY NOT NULL,\
                          name TEXT NOT NULL,\
                          age INT NOT NULL)");
    sqlQuery.prepare(createSql);
    // 執行sql語句
    if(!sqlQuery.exec())
    {
        qDebug() << "Error: Fail to create table. " << sqlQuery.lastError();
    }
    else
    {
        qDebug() << "Table created!";
    }
}

// 判斷資料庫中某個數據表是否存在
bool SqliteOperator::isTableExist(QString& tableName)
{
    QSqlDatabase database = QSqlDatabase::database();
    if(database.tables().contains(tableName))
    {
        return true;
    }

    return false;
}

// 查詢全部數據
void SqliteOperator::queryTable()
{
    QSqlQuery sqlQuery;
    sqlQuery.exec("SELECT * FROM student");
    if(!sqlQuery.exec())
    {
        qDebug() << "Error: Fail to query table. " << sqlQuery.lastError();
    }
    else
    {
        while(sqlQuery.next())
        {
            int id = sqlQuery.value(0).toInt();
            QString name = sqlQuery.value(1).toString();
            int age = sqlQuery.value(2).toInt();
            qDebug()<<QString("id:%1    name:%2    age:%3").arg(id).arg(name).arg(age);
        }
    }
}

// 插入單條數據
void SqliteOperator::singleInsertData(w2dba &singledb)
{
    QSqlQuery sqlQuery;
    sqlQuery.prepare("INSERT INTO student VALUES(:id,:name,:age)");
    sqlQuery.bindValue(":id", singledb.id);
    sqlQuery.bindValue(":name", singledb.name);
    sqlQuery.bindValue(":age", singledb.age);
    if(!sqlQuery.exec())
    {
        qDebug() << "Error: Fail to insert data. " << sqlQuery.lastError();
    }
    else
    {
        // do something
    }
}

// 插入多條數據
void SqliteOperator::moreInsertData(QList<w2dba>& moredb)
{
    // 進行多個數據的插入時,可以利用綁定進行批處理
    QSqlQuery sqlQuery;
    sqlQuery.prepare("INSERT INTO student VALUES(?,?,?)");
    QVariantList idList,nameList,ageList;
    for(int i=0; i< moredb.size(); i++)
    {
        idList <<  moredb.at(i).id;
        nameList << moredb.at(i).name;
        ageList << moredb.at(i).age;
    }
    sqlQuery.addBindValue(idList);
    sqlQuery.addBindValue(nameList);
    sqlQuery.addBindValue(ageList);

    if (!sqlQuery.execBatch()) // 進行批處理,如果出錯就輸出錯誤
    {
        qDebug() << sqlQuery.lastError();
    }
}

// 修改數據
void SqliteOperator::modifyData(int id, QString name, int age)
{
    QSqlQuery sqlQuery;
    sqlQuery.prepare("UPDATE student SET name=?,age=? WHERE id=?");
    sqlQuery.addBindValue(name);
    sqlQuery.addBindValue(age);
    sqlQuery.addBindValue(id);
    if(!sqlQuery.exec())
    {
        qDebug() << sqlQuery.lastError();
    }
    else
    {
        qDebug() << "updated data success!";
    }
}

// 刪除數據
void SqliteOperator::deleteData(int id)
{
    QSqlQuery sqlQuery;

    sqlQuery.exec(QString("DELETE FROM student WHERE id = %1").arg(id));
    if(!sqlQuery.exec())
    {
        qDebug()<<sqlQuery.lastError();
    }
    else
    {
        qDebug()<<"deleted data success!";
    }
}

//刪除數據表
void SqliteOperator::deleteTable(QString& tableName)
{
    QSqlQuery sqlQuery;

    sqlQuery.exec(QString("DROP TABLE %1").arg(tableName));
    if(sqlQuery.exec())
    {
        qDebug() << sqlQuery.lastError();
    }
    else
    {
        qDebug() << "deleted table success";
    }
}

void SqliteOperator::closeDb(void)
{
    database.close();
}

main.cpp

QT開發交流+貲料君羊:714620761

#include <QCoreApplication>
#include "sqliteoperator.h"
#include <QString>

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    //創建並打開SQLite資料庫
    SqliteOperator sqlTest;
    sqlTest.openDb();

    // 創建數據表
    sqlTest.createTable();

    // 判斷數據表是否存在
    QString str1 = QString("student");
    qDebug() << "isTabelExist:" <<sqlTest.isTableExist(str1);

    // 插入單條數據
    w2dba w2dbaTest1 = {1, "zhangSan", 24};
    w2dba w2dbaTest2 = {2, "lisi", 28};
    sqlTest.singleInsertData(w2dbaTest1);
    sqlTest.singleInsertData(w2dbaTest2);

    // 插入多條數據
    QList<w2dba> list;
    w2dba w2dbaTest3 = {3, "liwu", 26};
    w2dba w2dbaTest4 = {4, "niuer", 27};
    list.append(w2dbaTest3);
    list.append(w2dbaTest4);
    sqlTest.moreInsertData(list);
    // 查詢全部數據
    sqlTest.queryTable();
    qDebug() << endl;

    // 修改數據
    sqlTest.modifyData(2, "modify", 10);
    // 查詢全部數據
    sqlTest.queryTable();
    qDebug() << endl;

    // 刪除數據
    sqlTest.deleteData(2);
    // 查詢全部數據
    sqlTest.queryTable();
    qDebug() << endl;

    // 刪除數據表
    QString str2 = QString("student");
    sqlTest.deleteTable(str2);

    //關閉資料庫
    sqlTest.closeDb();

    return a.exec();
}

運行結果如下:

Table created!
isTabelExist: true
"id:1    name:zhangSan    age:24"
"id:2    name:lisi    age:28"
"id:3    name:liwu    age:26"
"id:4    name:niuer    age:27"

updated data success!
"id:1    name:zhangSan    age:24"
"id:2    name:modify    age:10"
"id:3    name:liwu    age:26"
"id:4    name:niuer    age:27"

deleted data success!
"id:1    name:zhangSan    age:24"
"id:3    name:liwu    age:26"
"id:4    name:niuer    age:27"

deleted table success
關鍵字: