Qt之数据库使用（十四）

Qt开发 系列文章 - QSqlDatabase-SQLite（十四）

---

目录
媒介
一、SQLite
二、SQLite使用
1.添加SQL
2.创建数据库
3.定义类及相关变量
4.相关功能函数
5.用户类定义
6.用户类使用
7.效果演示
8.SQLite数据库
总结

---

媒介

‌Qt支持的数据库包罗SQLite、MySQL、PostgreSQL、ODBC等‌。其中，SQLite是Qt默认支持的数据库，无需额外的驱动就可以使用，适当轻量级的应用，不需要多用户、大数据量的场景。对于大型应用，MySQL和PostgreSQL则是更好的选择，它们提供了更强盛的数据处理能力‌。本文将讲授SQLite的设计使用。

---

一、SQLite

SQLite是一款轻量级的嵌入式数据库，它的数据库就是一个文件，可以直接通过Qt的SQL模块操纵。SQLite的上风在于无需配置、轻量级，适当不需要多用户、大数据量的场景‌。在Qt中使用SQLite时，可以通过QSqlDatabase类来创建一个数据库连接，使用addDatabase()函数指定命据库类型为"QSQLITE"，然后设置数据库名字并打开数据库‌ 。
二、SQLite使用

Qt中对SQLite的使用，通常需要用到以下几个相关类：

• QSqlDatabase类：数据库连接类，表现一个数据库连接；
  
• QSqlQuery类：数据库操纵类，可以操纵SQL语句；
  
• QSqlError类：数据库错误信息类，用户网络数据库底层通报到Qt中的错误信息。
  

下面将讲授SQLite在Qt中的使用。
1.添加SQL

想使用SQL，首先需要先在.pro项目配置文件中添加sql模块，如下所示。

1. QT       += sql

复制代码

2.创建数据库

在原有的Qt项目上新建一个类，用于专门操纵数据库的，并将该类属于工程项目主窗口的私有变量（固然你也可以不创建该类，直接在项目在构造函数上定义该数据库，进行使用）。
在Qt原有项目怎样新建一个类，在博主以前的博文有详细的先容，这里本文不做先容，将设计在新建的类的构造函数处定义数据变量，具体有以下步调。

• 先打印出，电脑所装Qt支持的数据库种类；
  
• 创建数据库文件的路径及名称；
  
• 添加SQLite驱动，创建连接；
  
• 看SQLite是否存在，若不存在，主动创建；若存在，在已有的数据库上进行；
  
• 打开创建的数据库；
  
• 开启事务，预备进行操纵；
  
• 创建数据库操纵类QSqlQuery；
  
• 在数据库上创建多少表格；
  
• 提交事务到数据库，并生存更改。
  

具体实现，代码如下（示例）：

1. void testhread::InitQSqlite()
2. {
3.     //**0**打印Qt支持的数据库
4.     qDebug() << "QSqlDatabase=" << QSqlDatabase::drivers();
5.     //**1**创建数据库名称及路径
6.     QTime systime = QTime::currentTime();
7.     QString saveFileFolder = QApplication::applicationDirPath()+"/savefile/";
8.     QDir folder; //创建文件夹
9.     if(!folder.exists(saveFileFolder))
10.         folder.mkpath(saveFileFolder); //不存在则创建文件夹
11.     QString DBFileName = "dbmsg" + systime.toString("hh-mm-ss") + ".db";
12.     QString DBFilePath = saveFileFolder + DBFileName;
13.     //**2**添加SQLite驱动 创建连接
14.     m_db = QSqlDatabase::addDatabase("QSQLITE");
15.     //**3**SQLite不存在，自动创建；已经存在，在已有的数据库上进行。
16.     m_db.setDatabaseName(DBFilePath);
17.     //**4**打开数据库
18.     if(!m_db.open()){
19.         qDebug() << "Failed to open database！" << m_db.lastError().text();
20.         return;
21.     } else
22.         qInfo() << "Successfully opened database! SQLite Type.";
23.     //**5**开始事务
24.     if (!m_db.transaction()) {
25.         qDebug() << "Failed to begin transaction";
26.         return;
27.     }
28.     //**6**创建数据库QSqlQuery
29.     sql = new QSqlQuery(m_db);
30.     //**7**在数据库上创建表格-student
31.     QString createSql = QString("CREATE TABLE IF NOT EXISTS student (\
32.                               id INT PRIMARY KEY NOT NULL,name TEXT NOT NULL,\
33.                               age INT NOT NULL,height INT NOT NULL)");
34.     if(!sql->exec(createSql))
35.         qDebug() << "Error: Fail to create student table. " << sql->lastError();
36.     else
37.         qDebug() << "student table create successful!";
38.     //在数据库上创建表格-状态反馈
39.     createSql = QString("CREATE TABLE IF NOT EXISTS MachineStatus(\
40.                                Systime INTEGER (4) PRIMARY KEY,stat INTEGER (1),MainVer INTEGER (1),SubVer INTEGER (1),\
41.                                Type INTEGER (1),Broad INTEGER (1),Online INTEGER (1))");
42.     if(!sql->exec(createSql))
43.         qDebug() << QString("Fail to create MachineStatus table.")<< sql->lastError();
44.     else
45.         qDebug() << "MachineStatus table create successful!";
46.     //**8**提交事务并保存更改
47.     if (!m_db.commit()) {
48.         qDebug() << "Failed to commit transaction";
49.         return;
50.     }
51. }

复制代码

3.定义类及相关变量

上一步我们在原有的Qt项目上新建一个类，用于专门操纵数据库的，这里来定义该类。具体实现，代码如下（示例）：

1. #ifndef TESTHREAD_H
2. #define TESTHREAD_H
4. #include <QThread>
5. #include <QDebug>
6. #include <QByteArray>
7. #include <QTableView>
8. #include <QSqlQueryModel>
9. #include <QSqlDatabase>
10. #include <QSqlError>
11. #include <QFile>
12. #include <QSqlQuery>
13. #include <QSqlRecord>
14. #include <QTime>
15. #include <QDir>
16. #include "qstandarditemmodel.h"
18. #define MAXROWCNT 20
19. #define MAXROWHIG 4
20. #define MAXCOLWID 79
21. //状态反馈信息
22. typedef struct
23. {
24.         qint32 Systime;
25.         quint8 stat, MainVer, SubVer, Type, Broad;
26.         quint8 Online;
27. }FK_SatFBInfo_struct;
29. class testhread : public QThread
30. {
31.     Q_OBJECT
32. public:
33.     testhread();
34.     ~testhread(){}
36.     QTableView *UNKNTableView;
37.     FK_SatFBInfo_struct *FKSatFBInfo;
38.     QSqlDatabase m_db;           //数据库对象
39.     QSqlQuery *sql;
40.     bool g_flag;
41.     bool pushmsg_flag;
42.     void InitTableView(void);
43. protected:
44.     void InitQSqlite(void);
45.     void run(void);
46.     void ShowFKSFInfo(FK_SatFBInfo_struct *pFKSF);
47. private:
48.     QStandardItemModel* m_Model;
49. };
50. #endif // TESTHREAD_H

复制代码

4.相关功能函数

相关功能函数主要包罗构造函数（实现变量及数据库初始化）、线程run()函数。
这里讲授下，接纳线程实现的方式，初始化（定义好）数据库文件后，然后通过UI界面上来控制线程启动，和决定是否向数据库不间断地插入数据，完成数据生存到数据库文件上，末了还通过UI界面表格将数据库的数据刷到表格上。至于为啥如许设计实现，效率更高更快，一般在网络、工业上数据处理均接纳如许的方式。
具体实现，代码如下（示例）：

1. #include "testhread.h"
2. testhread::testhread()
3. {
4.     qRegisterMetaType<QVector<int>>("QVector<int");
5.     qRegisterMetaTypeStreamOperators<QVector<int>>();
6.     g_flag = false;
7.     pushmsg_flag = false;
8.     memset(&FKSatFBInfo,0,sizeof(FKSatFBInfo));
9.     InitQSqlite();
10. }
11. void testhread::InitTableView(void)
12. {
13.     m_Model = new QStandardItemModel;
14.     QStringList list;
15.     list << QString("Time")<<"运行状态"<<"主版本号"<<"子版本号"<<"项目类型"<<"板上自检"<<"在线状态";
16.     // 设置表格行数和列数
17.     m_Model = new QStandardItemModel(MAXROWCNT, list.size(), this);
18.     // 设置表头
19.     m_Model->setHorizontalHeaderLabels(list);
20.     UNKNTableView->setModel(m_Model);
21.     //UNKNTableView->setAutoScroll(true);
22.     UNKNTableView->setEditTriggers(QAbstractItemView::NoEditTriggers);
23.     for(quint8 i= 0; i<list.size(); i++)
24.         UNKNTableView->setColumnWidth(i, MAXCOLWID);
25.     for(quint16 i= 0; i<MAXROWCNT; i++)
26.         UNKNTableView->setRowHeight(i, MAXROWHIG);
27. }
28. void testhread::run()
29. {
30.     FK_SatFBInfo_struct FKSatFBInfo;
31.     while(g_flag)
32.     {
33.         if (pushmsg_flag) {
34.             //插入表格
35.             QString tempinfo = QString("INSERT INTO MachineStatus(Systime,stat,MainVer,"
36.                                        "SubVer,Type,Broad,Online) VALUES(?,?,?,?,?,?,?)");
37.             sql->prepare(tempinfo);
38.             FKSatFBInfo.Systime += 500;
39.             FKSatFBInfo.stat = 3;
40.             FKSatFBInfo.MainVer = 1;
41.             FKSatFBInfo.SubVer = 2;
42.             FKSatFBInfo.Type = 0;
43.             FKSatFBInfo.Broad = 0;
44.             FKSatFBInfo.Online = 1;
45.             sql->addBindValue(FKSatFBInfo.Systime);
46.             sql->addBindValue(FKSatFBInfo.stat);
47.             sql->addBindValue(FKSatFBInfo.MainVer);
48.             sql->addBindValue(FKSatFBInfo.SubVer);
49.             sql->addBindValue(FKSatFBInfo.Type);
50.             sql->addBindValue(FKSatFBInfo.Broad);
51.             sql->addBindValue(FKSatFBInfo.Online);
52.             if(!sql->exec())
53.                 qDebug() << "Fail to insert data. " << sql->lastError().text();
54.             ShowFKSFInfo(&FKSatFBInfo);
55.         }
56.         msleep(500);
57.     }
58. }
60. void testhread::ShowFKSFInfo(FK_SatFBInfo_struct *pFKSF)
61. {
62.     static quint16 cnt=0;
63.     if(cnt == (MAXROWCNT)){
64.         for(quint16 i=0;i<MAXROWCNT;i++){
65.             for(quint8 j=0;j<7;j++){
66.                 auto tempIndex = UNKNTableView->model()->index(i, j);
67.                 m_Model->clearItemData(tempIndex);
68.             }
69.         }
70.         cnt = 0;
71.     }
72.     m_Model->setData(m_Model->index(cnt, 0), pFKSF->Systime);
73.     m_Model->setData(m_Model->index(cnt, 1), "空闲态0");
74.     m_Model->setData(m_Model->index(cnt, 2), pFKSF->MainVer);
75.     m_Model->setData(m_Model->index(cnt, 3), pFKSF->SubVer);
76.     m_Model->setData(m_Model->index(cnt, 4), pFKSF->Type);
77.     m_Model->setData(m_Model->index(cnt, 5), pFKSF->Broad);
78.     m_Model->setData(m_Model->index(cnt, 6), pFKSF->Online);
79.     auto lastModelIndex = UNKNTableView->model()->index(cnt, 0);
80.     UNKNTableView->scrollTo(lastModelIndex); // 滚动到当前行
81.     cnt++;
82. }

复制代码

5.用户类定义

用户类主要是指项目主窗口变量，定义了其构造函数、析构函数、UI界面信号槽函数、及相关类定义为私有变量，具体实当代码如下（示例）：

1. #ifndef CSQLTEST_H
2. #define CSQLTEST_H
4. #include <QMainWindow>
5. #include "testhread.h"
6. namespace Ui {
7. class CSqlTest;
8. }
9. class CSqlTest : public QMainWindow
10. {
11.     Q_OBJECT
12. public:
13.     explicit CSqlTest(QWidget *parent = nullptr);
14.     ~CSqlTest();
15. private slots:
16.     void on_pBinsert_clicked();
17.     void on_pBchange_clicked();
18.     void on_pBlookup_clicked();
19.     void on_pBexit_clicked();
20.     void on_pBclea_clicked();
21.     void on_pBConditional_clicked();
22.     void on_pushButton_6_clicked();
23.     void on_pBstarthd_clicked();
24.     void on_pBpushmsg_clicked();
25. private:
26.     Ui::CSqlTest *ui;
27.     QSqlQueryModel  *m_pModel; //数据模型对象
28.     testhread*      DBthd;
29.     void displayRecord(QSqlQuery query); //展示query所查询到的数据
30. };
31. #endif // CSQLTEST_H

复制代码

6.用户类使用

完成相关类私有变量初始化，主要包罗Ui::CSqlTest *ui、QSqlQueryModel  *m_pModel、testhread *DBthd。还实现了UI界面上的信号槽功能，主要包罗想表格中插入数据、更改表格、查询所有表格上所有数据、清除表等等，具体看UI界面，实当代码如下（示例）：

1. #include "csqltest.h"
2. #include "ui_csqltest.h"
3. CSqlTest::CSqlTest(QWidget *parent)
4.     : QMainWindow(parent)
5.     , ui(new Ui::CSqlTest)
7. {
8.     ui->setupUi(this);
9.     /****创建线程类变量*****/
10.     DBthd = new testhread();
11.     /****将UI上表格视图地址赋值到线程变量上*****/
12.     DBthd->UNKNTableView = ui->UNTableView;
13.     /****表格初始化*****/
14.     DBthd->InitTableView();
15. }
16. CSqlTest::~CSqlTest()
17. {
18.     if(DBthd->isRunning()) {
19.         DBthd->terminate();
20.         DBthd->wait(1);
21.     }
22.     if(DBthd != nullptr)
23.         delete DBthd;
24.     delete ui;
25. }
26. void CSqlTest::on_pBstarthd_clicked()
27. {
28.     if(ui->pBstarthd->text() == "启动线程") {
29.         DBthd->g_flag = true;
30.         DBthd->start();
31.         ui->pBstarthd->setText("停止线程");
32.     }
33.     else {
34.         DBthd->g_flag = 0;
35.         ui->pBstarthd->setText("启动线程");
36.     }
37. }
38. //显示在表上QSqlQueryModel
39. void CSqlTest::on_pushButton_6_clicked()
40. {
41.     //为数据模型设置父对象
42.     m_pModel = new QSqlQueryModel(DBthd);
43.     //查询数据
44.     m_pModel->setQuery(QString("select * from student"));
45.     if(m_pModel->lastError().isValid()) {
46.         qDebug() << "Data query failed!!" << m_pModel->lastError().text();
47.         return;
48.     }
49.     //设置数据模型指定列的列标题（若是不设置，则标题为和数据表上一样）
50.     m_pModel->setHeaderData(0, Qt::Horizontal, "学号");
51.     m_pModel->setHeaderData(1, Qt::Horizontal, "姓名");
52.     m_pModel->setHeaderData(2, Qt::Horizontal, "年龄");
53.     m_pModel->setHeaderData(3, Qt::Horizontal, "身高");
54.     //将数据模型设置到tableView控件上
55.     ui->tableView->setModel(m_pModel);
56. }
58. void CSqlTest::on_pBinsert_clicked()
59. {
60.     //插入表格
61.     QSqlQuery p;
62.     int id = ui->lineEdit_3->text().toInt();
63.     QString name = ui->lineEdit_2->text();
64.     int age = ui->lineEdit->text().toInt();
65.     int height = ui->lineEdit_4->text().toInt();
66.     QString tempinfo = QString("INSERT INTO student(id, name, age, height) VALUES(?,?,?,?)");
67.     p.prepare(tempinfo);
68.     p.addBindValue(id);
69.     p.addBindValue(name);
70.     p.addBindValue(age);
71.     p.addBindValue(height);
72.     if(!p.exec())
73.         qDebug() << "Fail to insert data. " << p.lastError().text();
74. }
75. void CSqlTest::displayRecord(QSqlQuery query)
76. {
77.     //获取一个记录对象
78.     QSqlRecord rec =  query.record();
79.     QString columTitle(""); //用于组列标题的变量
80.     for(int index = 0; index != rec.count(); ++index) {
81.         //循环获取每个列标题，并添加到列标题字符串中
82.         columTitle.append(rec.fieldName(index) + "\t");
83.     }
84.     //将列标题添加到显示控件中
85.     ui->textBrowser->append(columTitle);
86.     //循环获取每条记录
87.     while (query.next())
88.     {
89.         //将当前记录的数据组成字符串，然后添加到显示控件中
90.         QString record("");
91.         for(int index = 0; index != rec.count(); ++index) {
92.             record.append(query.value(index).toString() + "\t");
93.         }
94.         ui->textBrowser->append(record);
95.     }
96.     ui->textBrowser->append("================Run successfully==================\n");
97. }
98. void CSqlTest::on_pBlookup_clicked()
99. {
100.     QString tempinfo = "SELECT name FROM sqlite_master WHERE type='table';";
101.     if (!DBthd->sql->exec(tempinfo)) {
102.         qDebug() << "Error: Unable to execute query:" << DBthd->sql->lastError().text();
103.     }
104.     else{
105.         QStringList tableNames;
106.         while (DBthd->sql->next()) {
107.             QString name = DBthd->sql->value(0).toString();
108.             tableNames.append(name);
109.         }
110.         // 查询所有表上所有数据
111.         for (const QString &name : tableNames) {
112.             ui->textBrowser->append(QString("查询%1表所有数据:").arg(name));
113.             tempinfo = QString("SELECT * FROM %1").arg(name); // 从"student"这个表中查询出所有的数据, *表示查询表中的所有列
114.             if(!DBthd->sql->exec(tempinfo))
115.                 qDebug() << "Error: Fail to query table. " << DBthd->sql->lastError();
116.             else
117.                 displayRecord(*(DBthd->sql));
118.         }
119.     }
120.     //查询完成后结束查询 清理和释放资源
121.     //DBthd->sql->finish();
122. }
123. void CSqlTest::on_pBConditional_clicked()
124. {
125.     QSqlQuery p;
126.     //添加准备执行的SQL语句（条件查询）
127.     p.prepare("select * from student where age > :age and id like ? ");
128.     p.bindValue(":age", 23);    //指定标识符赋值
129.     p.bindValue(1, "003");      //根据标识符下标赋值（从0开始）
130.     p.exec();   //直接使用空的exec运行
131.     ui->textBrowser->append("条件查询:");
132.     displayRecord(p);
133.     p.finish();
134.     //更新操作
135.     bool flag = p.exec("update student set age = 30 where id like '003'");
136.     if(!flag)
137.         return;
138.     ui->textBrowser->append("更新成功！！！！！！！！！！");
139. }
140. void CSqlTest::on_pBexit_clicked()
141. {
142.     DBthd->m_db.close();
143.     close();
144. }
145. void CSqlTest::on_pBclea_clicked()
146. {
147.     // 获取数据库中的所有表格名称
148.     QStringList tables = DBthd->m_db.tables();
149.     foreach (const QString& table, tables) {
150.         qDebug() << table;
151.     }
152.     if(tables.size() <= 1){
153.         return;
154.     }
155.     //删除数据表
156.     QSqlQuery p;
157.     for(int i=0;i<(tables.size()-1);i++){
158.         p.exec(QString("DROP TABLE %1").arg(tables.at(i)));
159.     }
160.     if(p.exec())
161.         qDebug() << p.lastError();
162.     else
163.         qDebug() << "deleted table success";
164. }
165. void CSqlTest::on_pBchange_clicked()
166. {
167.     //在表格上更改student信息
168.     QString tempinfo = QString("UPDATE student SET name=:name,age=:age,height=:height WHERE id=:id");
169.     int id = ui->lineEdit_3->text().toInt();
170.     QString name = ui->lineEdit_2->text();
171.     int age = ui->lineEdit->text().toInt();
172.     int height = ui->lineEdit_4->text().toInt();
173.     DBthd->sql->prepare(tempinfo);
174.     DBthd->sql->bindValue(":id",id);
175.     DBthd->sql->bindValue(":name",name);
176.     DBthd->sql->bindValue(":age",age);
177.     DBthd->sql->bindValue(":height",height);
178.     if(!DBthd->sql->exec())
179.         qDebug() << DBthd->sql->lastError();
180.     else
181.         qDebug() << "updated data success!";
182. }
183. void CSqlTest::on_pBpushmsg_clicked()
184. {
185.     if(ui->pBpushmsg->text() == "压力测试") {
186.         DBthd->pushmsg_flag = true;
187.         ui->pBpushmsg->setText("停止测试");
188.     }
189.     else {
190.         DBthd->pushmsg_flag = 0;
191.         ui->pBpushmsg->setText("压力测试");
192.     }
193. }

复制代码

7.效果演示

完成上面代码后，编译运行，效果如下。

8.SQLite数据库

软件运行完后，在生存的目录路径下面，找到数据库文件，如下。其中dbmsg16-32-19.db文件在运行时按过按钮“清除旧表”，导致内里的内容被清空。

重新运行后，打开dbmsg16-36-58.db文件内容如下，可以看到生存的数据内容。

注意事项：要打开.db文件，需下载安装SQLiteStudio，博主使用的是SQLiteStudio-3.2.1版本的，相关链接见文末，内里已经下载好了的，直接安装使用即可。

---

总结

博文中相应的工程代码Qt-Case.zip 利用Qt开发软件进行编的例程，为博文提供案例-CSDN文库。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。