41、数据库---------事件系统

数据库

数据库SQLite
SQLite 是一种轻量级的关系数据库管理系统，不需要单独的服务器进程，适合嵌入式应用。Qt 提供了丰富的 SQL 模块，使得在应用程序中集成数据库操作变得简单。本文将通过示例介绍如何使用 Qt 的 SQL 类与 SQLite 数据库进行交互，特别是如何使用 QSqlTableModel、QSqlQueryModel 以及 QSqlQuery 来实现数据的增删改查（CRUD）操作。
我们可以提前用navicat建立一个sqlite的数据库

创建sqlite3数据库，链接名字随便写，数据库名字我命名为example_sqlite

记得点一下数据库文件右边的三个小点的按钮，将数据库另存一下

点击确定后，会创建好sqlite数据库, 可以看到数据库下面有个main的库，库下面有表之类的结构。

建立好数据库后我们可以通过右键表，创建新的表结构

但是我们这里讲述的是如何通过QT代码创建表，所以不在navicat中手动创建表。

我们需要通过代码在数据库中创建一张employees表，并且插入数据

配置 Qt 项目

创建一个新的 Qt Widgets 应用程序项目，假设项目名称为 QtSQLiteExample。

项目文件（.pro）配置：

要使用 Qt 的 SQL 模块，需要在项目文件中添加相关模块：sql

2. QT += core gui sql
4. greaterThan(QT_MAJOR_VERSION, 4): QT += widgets
6. TARGET = QtSQLiteExample
7. TEMPLATE = app
9. SOURCES += main.cpp \
10. mainwindow.cpp
12. HEADERS += mainwindow.h
14. FORMS += mainwindow.ui

复制代码

建立与 SQLite 的连接

在使用任何 SQL 模型或查询之前，需要先建立与 SQLite 数据库的连接。

1. 包含必要的头文件

在需要使用 SQL 功能的文件中，包含 Qt SQL 模块的头文件：

2. #include <QSqlDatabase>
3. #include <QSqlError>
4. #include <QSqlQuery>
5. #include <QDebug>

复制代码

2. 初始化数据库连接

通常，可以在 main.cpp 或应用程序的初始化部分进行数据库连接设置。创建连接的接口如下

3. static QSqlDatabase addDatabase(const QString& type,
4. const QString& connectionName = QLatin1String(defaultConnection));

复制代码

第一个参数type表示数据库的类型，第二个参数connectionName表示连接的名字，我们可以为连接指定名字，如果不设置就用默认连接。

以下示例在 main.cpp 中建立连接

2. // 添加 SQLite 数据库驱动
3. QSqlDatabase db = QSqlDatabase::addDatabase("QSQLITE");
4. // 设置数据库文件路径（相对路径或绝对路径）
5. db.setDatabaseName("example.db");

复制代码

如果程序的执行路径下没有example.db，上述代码会在程序的运行路径创建一个"example.db"文件。

如果我们希望用户选择db文件可以用文件对话框，QFileDialog有一个static函数用来打开文件

2. static QString getOpenFileName(QWidget *parent = nullptr,
3. const QString &caption = QString(),
4. const QString &dir = QString(),
5. const QString &filter = QString(),
6. QString *selectedFilter = nullptr,
7. Options options = Options());

复制代码

第一个参数是父窗口，第二个参数是标题，第三个参数是默认打开哪个文件夹，第四个参数是过滤器，用来指定显示哪些文件。

函数会返回所选择的文件的路径。

我们将建立连接代码稍作修改

2. // 利用文件对话框打开选择db文件
3. auto file_path = QFileDialog::getOpenFileName(nullptr,"选择sqlitedb文件","","*.db");
4. if(file_path.isEmpty()){
5. QMessageBox::critical(nullptr,"文件错误信息","未选择文件!");
6. return false;
7. }

复制代码

我们设置默认选择db文件，如果不选择返回的就是空字符串，空字符串直接判断无效就返回。

接下来我们再调用之前写好的逻辑创建驱动并且设置数据库文件路径

2. // 添加 SQLite 数据库驱动
3. QSqlDatabase db = QSqlDatabase::addDatabase("QSQLITE");
5. // 设置数据库文件路径（相对路径或绝对路径）
6. db.setDatabaseName(file_path);

复制代码

创建好db后我们打开数据库

2. // 打开数据库
3. if (!db.open()) {
4. qDebug() << "无法打开数据库:" << db.lastError().text();
5. return false;
6. }

复制代码

接下来创建数据表，创建数据表的语句有多行，所以采用QT提供R”()“方式，表示原样字符串，我们可以把多行的字符串写到括号里

2. // 创建一个示例表，如果不存在的话
3. QSqlQuery query;
4. QString createTable = R"(
5. CREATE TABLE IF NOT EXISTS employees (
6. id INTEGER PRIMARY KEY AUTOINCREMENT,
7. name TEXT NOT NULL,
8. position TEXT NOT NULL,
9. salary REAL
10. )
11. )";

复制代码

我们写了创建数据表的语句，接下来可以通过query去执行， query是QSqlQuery类型，包含exec方法传入要执行的sql语句，返回执行结果。

2. if (!query.exec(createTable)) {
3. qDebug() << "创建表失败:" << query.lastError().text();
4. return false;
5. }

复制代码

同样的道理，我们可以基于employees表进行增删改查了, 我们可以查询一下employees表中的记录数，如果记录数为0，则向表中插入数据。我们能可以在navicat中新建一个查询，看看查到的结果

一般来说查询语句会返回多行，每一行有多列，因为count比较特殊，只返回1行1列表示员工数量。

所以我们可以取查询结果的第一列，下标为0获取记录数。

2. // 插入示例数据（如果表为空）
3. query.exec("SELECT COUNT(*) FROM employees");
4. if (query.next()) {
5. //查询结果的第0列表示数量
6. int count = query.value(0).toInt();
7. if (count == 0) {
8. QString insertData = "INSERT INTO employees (name, position, salary) VALUES "
9. "('Alice', 'Developer', 60000),"
10. "('Bob', 'Designer', 55000),"
11. "('Charlie', 'Manager', 75000)";
12. if (!query.exec(insertData)) {
13. qDebug() << "插入数据失败:" << query.lastError().text();
14. return false;
15. }
16. }
17. }

复制代码

所以我们给出完整代码

2. bool initializeDatabase()
3. {
4. // 利用文件对话框打开选择db文件
5. auto file_path = QFileDialog::getOpenFileName(nullptr,"选择sqlitedb文件","","*.db");
6. if(file_path.isEmpty()){
7. QMessageBox::critical(nullptr,"文件错误信息","未选择文件!");
8. return false;
9. }
11. // 添加 SQLite 数据库驱动,使用默认连接
12. QSqlDatabase db = QSqlDatabase::addDatabase("QSQLITE");
14. // 设置数据库文件路径（相对路径或绝对路径）
15. db.setDatabaseName(file_path);
17. // 打开数据库
18. if (!db.open()) {
19. qDebug() << "无法打开数据库:" << db.lastError().text();
20. return false;
21. }
23. // 创建一个示例表，如果不存在的话
24. QSqlQuery query;
25. QString createTable = R"(
26. CREATE TABLE IF NOT EXISTS employees (
27. id INTEGER PRIMARY KEY AUTOINCREMENT,
28. name TEXT NOT NULL,
29. position TEXT NOT NULL,
30. salary REAL
31. )
32. )";
34. if (!query.exec(createTable)) {
35. qDebug() << "创建表失败:" << query.lastError().text();
36. return false;
37. }
39. // 插入示例数据（如果表为空）
40. query.exec("SELECT COUNT(*) FROM employees");
41. if (query.next()) {
42. //查询结果的第0列表示数量
43. int count = query.value(0).toInt();
44. if (count == 0) {
45. QString insertData = "INSERT INTO employees (name, position, salary) VALUES "
46. "('Alice', 'Developer', 60000),"
47. "('Bob', 'Designer', 55000),"
48. "('Charlie', 'Manager', 75000)";
49. if (!query.exec(insertData)) {
50. qDebug() << "插入数据失败:" << query.lastError().text();
51. return false;
52. }
53. }
54. }
56. return true;
57. }
59. int main(int argc, char *argv[])
60. {
61. QApplication a(argc, argv);
62. if(!initializeDatabase()){
63. QMessageBox::information(nullptr,"数据库错误","创建数据库失败");
64. return -1;
65. }
66. MainWindow w;
67. w.show();
69. return a.exec();
70. }

复制代码

启动程序选择我们之前创建好的数据库，程序会在数据库中创建employees表，并且插入数据

QSqlTableModel

QSqlTableModel 是 Qt 提供的一个模型类，专门用于操作数据库中的单一表。它基于 SQL 数据库驱动，支持常见的数据库如 SQLite、MySQL、PostgreSQL 等。主要特点包括：

• 直接操作单一表：能够方便地对单个数据库表进行增删改查操作。
• 与视图的无缝集成：可以轻松地与 QTableView、QListView 等视图组件配合使用，实现数据的可视化展示和编辑。
• 支持多种编辑策略：提供灵活的方式来管理数据的提交和取消。
• 自动同步数据：在数据库和模型之间保持数据的一致性。

使用时要用#include

基本使用流程

使用 QSqlTableModel 的基本步骤如下：

1. 建立数据库连接：确保与数据库的连接已建立，并且目标表存在。
2. 创建模型实例：实例化 QSqlTableModel 对象。
3. 设置目标表：指定要操作的数据库表。
4. 选择数据：从数据库中检索数据以填充模型。
5. 与视图集成：将模型与视图组件（如 QTableView）绑定，以显示和编辑数据。
6. 操作数据：通过模型的接口插入、删除或修改数据。
7. 提交或还原更改：根据编辑策略提交更改到数据库或撤销更改。

关键函数与属性

1 构造函数

2. QSqlTableModel(QObject *parent = nullptr, QSqlDatabase db = QSqlDatabase())

复制代码

• parent：父对象，通常设为 nullptr。
• db：使用的数据库连接，如果不传递参数，默认使用默认连接。

2 主要函数

• setTable(const QString &tableName)：设置模型所操作的数据库表。
• select()：从数据库中检索数据并填充模型。
• setEditStrategy(QSqlTableModel::EditStrategy strategy)：设置编辑策略。
• insertRow(int row, const QModelIndex &parent = QModelIndex())：在指定行插入新行。
• removeRow(int row, const QModelIndex &parent = QModelIndex())：删除指定行。
• submitAll()：提交所有更改到数据库（适用于手动提交策略）。
• revertAll()：撤销所有未提交的更改。
• setFilter(const QString &filter)：设置数据过滤条件。
• setSort(int column, Qt::SortOrder order)：设置排序条件。

4. 编辑策略

QSqlTableModel 提供了三种编辑策略，用于控制对数据库的更改是如何提交的：

1. QSqlTableModel::OnManualSubmit（手动提交）：

• • 默认策略。
  • 所有更改（插入、删除、修改）都存储在模型中，直到调用 submitAll() 才提交到数据库。
  • 可以通过 revertAll() 撤销所有未提交的更改。
  • 适用于需要在一次性提交所有更改的场景，例如用户完成一系列编辑后再决定提交。

1. QSqlTableModel::OnRowChange（行更改时提交）：

• • 当用户完成对一行的编辑并移动到另一行时，自动提交该行的更改。
  • 更改直接提交到数据库。
  • 适用于希望实时保存每行更改的场景。

1. QSqlTableModel::OnFieldChange（字段更改时提交）：

• • 当用户更改任何字段的值时，立即提交该更改到数据库。
  • 适用于需要每次字段编辑后立即保存更改的场景。

设置编辑策略示例：

2. model->setEditStrategy(QSqlTableModel::OnManualSubmit);

复制代码

演示案例

我们通过QSqlTableModel和QTableView展示数据库的内容，并且支持在表格中修改提交保存到数据库

界面效果如下

我们在mainwindow中添加变量和函数声明

2. //数据模型
3. QSqlTableModel *model;
4. //设置模型
5. void setupModel();
6. //设置视图
7. void setupView();

复制代码

实现setupModel

2. void MainWindow::setupModel()
3. {
4. //创建模型
5. model = new QSqlTableModel(this);
6. //使用默认连接，对表employees操作
7. model->setTable("employees");
8. //设置提交策略为手动提交
9. model->setEditStrategy(QSqlTableModel::OnManualSubmit);
11. // 设置表头标签
12. model->setHeaderData(0, Qt::Horizontal, "ID");
13. model->setHeaderData(1, Qt::Horizontal, "姓名");
14. model->setHeaderData(2, Qt::Horizontal, "职位");
15. model->setHeaderData(3, Qt::Horizontal, "薪水");
17. //将sql中的数据写入model中
18. if (!model->select()) {
19. QMessageBox::critical(this, "错误", "无法检索数据: " + model->lastError().text());
20. }
21. }

复制代码

在mainwindow构造函数中调用setupModel将数据加载到模型中

2. MainWindow::MainWindow(QWidget *parent)
3. : QMainWindow(parent)
4. , ui(new Ui::MainWindow)
5. {
6. ui->setupUi(this);
7. setupModel();
8. }

复制代码

我们回到mainwindow.ui中添加tableview和几个按钮，下面是整体布局

下面是布局属性图

模型加载成功后，将模型加载到tableview中。

2. void MainWindow::setupView()
3. {
4. //设置模型
5. ui->tableView->setModel(model);
6. //设置选中模式为单个选中
7. ui->tableView->setSelectionMode(QAbstractItemView::SingleSelection);
8. //设置整行选中
9. ui->tableView->setSelectionBehavior(QAbstractItemView::SelectRows);
10. //设置编辑触发模式为双击或者选中时点击
11. ui->tableView->setEditTriggers(QAbstractItemView::DoubleClicked
12. | QAbstractItemView::SelectedClicked);
13. //重置列宽自适应内容
14. ui->tableView->resizeColumnsToContents();
15. }

复制代码

在构造函数中加载视图

2. MainWindow::MainWindow(QWidget *parent) :
3. QMainWindow(parent),
4. ui(new Ui::MainWindow)
5. {
6. ui->setupUi(this);
7. //加载模型
8. setupModel();
9. //加载视图
10. setupView();
11. }

复制代码

运行程序，选择db后弹出界面如下

接下来我们实现增加功能, 点击添加后默认添加一行数据

ui中右键添加按钮，选择槽函数跳转到实现，然后写具体添加逻辑

2. //添加按钮
3. void MainWindow::on_addBtn_clicked()
4. {
5. //获取模型行数
6. int row = model->rowCount();
7. //在最后一行插入
8. if (!model->insertRow(row)) {
9. QMessageBox::warning(this, "错误", "无法插入行: "
10. + model->lastError().text());
11. return;
12. }
14. // 自动设置默认值（可选）
15. model->setData(model->index(row, 1), "新员工");
16. model->setData(model->index(row, 2), "职位");
17. model->setData(model->index(row, 3), 50000.0);
19. //提交新插入的数据
20. if (!model->submitAll()) {
21. QMessageBox::warning(this, "错误", "无法提交新行: "
22. + model->lastError().text());
23. }
24. }

复制代码

查看数据库可以看到数据是写入成功了

接下来我们实现删除逻辑

2. void MainWindow::on_delBtn_clicked()
3. {
4. //获取选中的行
5. QModelIndexList selection = ui->tableView->selectionModel()->selectedRows();
6. if (selection.isEmpty()) {
7. QMessageBox::information(this, "提示", "请选择要删除的行。");
8. return;
9. }
11. //行号列表
12. QList<int> row_list;
13. //遍历选中，将行号存起来
14. foreach (QModelIndex index, selection) {
15. row_list.append(index.row());
16. }
18. //排序从大到小
19. std::sort(row_list.begin(),row_list.end(),std::greater<int>());
21. //从行号大的删除
22. for(auto & row : row_list){
23. model->removeRow(row);
24. }
26. //提交修改
27. if (!model->submitAll()) {
28. QMessageBox::warning(this, "错误", "无法删除行: " + model->lastError().text());
29. }
30. }

复制代码

实现提交逻辑， 当我们修改表格数据后可以将修改提交到数据库

2. void MainWindow::on_subBtn_clicked()
3. {
4. //提交模型修改到数据库
5. if (!model->submitAll()) {
6. QMessageBox::warning(this, "错误", "无法提交更改: " + model->lastError().text());
7. } else {
8. QMessageBox::information(this, "成功", "更改已提交。");
9. }
10. }

复制代码

我们新建一条数据，在数据库后台看到的还是默认值，修改后不提交，发现数据库也没变，点击提交后，再查看数据库就发现记录写入数据库了。

接下来实现撤销逻辑，当我们修改后点击还原，会将model还原为和数据库一致的状态

2. void MainWindow::on_revertBtn_clicked()
3. {
4. //还原数据模型
5. model->revertAll();
6. QMessageBox::information(this, "已还原", "所有未提交的更改已还原。");
7. }

复制代码

拓展

控制列宽

之前的表格列的宽度太小了，而且我们希望每一列文字居中对齐，并且我们希望薪水可以限制，

那么重新实现代理

2. #ifndef MYDELEGATE_H
3. #define MYDELEGATE_H
4. #include <QStyledItemDelegate>
5. #include <QPainter>
6. #include <QSpinBox>
8. class Mydelegate : public QStyledItemDelegate
9. {
10. public:
11. Mydelegate(QObject *parent = nullptr):QStyledItemDelegate(parent){}
12. void paint(QPainter *painter,
13. const QStyleOptionViewItem &option, const QModelIndex &index)
14. const override{
15. //拷贝一份样式的副本，防止对引用做出污染
16. QStyleOptionViewItem opt = option;
17. //绑定opt和index
18. initStyleOption(&opt, index);
20. // 根据列设置不同的对齐方式
21. opt.displayAlignment = Qt::AlignCenter;
23. // 调用基类绘制（确保选中状态等被正确处理）
24. QStyledItemDelegate::paint(painter, opt, index);
25. }
27. //创建编辑器
28. QWidget *createEditor(QWidget *parent,
29. const QStyleOptionViewItem &option,
30. const QModelIndex &index) const override{
31. //判断如果是第三列，则创建spinbox
32. if(index.column() == 3){
33. //创建spinbox
34. QSpinBox *editor = new QSpinBox(parent);
35. //设置最低薪水
36. editor->setMinimum(3000);
37. //设置最高薪水
38. editor->setMaximum(2000000);
39. //设置spinbox步长
40. editor->setSingleStep(1000);
41. return editor;
42. }
43. //其他列调用基类默认函数创建
44. return QStyledItemDelegate::createEditor(parent,option,index);
45. }
47. //将模型的数据放入编辑器中
48. void setEditorData(QWidget *editor, const QModelIndex &index) const override{
49. //如果是第三列
50. if(index.column() == 3){
51. //获取数据
52. int value = index.model()->data(index, Qt::EditRole).toInt();
53. QSpinBox *spinBox = static_cast<QSpinBox*>(editor);
54. //将数据设置到编辑器中
55. spinBox->setValue(value);
56. return;
57. }
58. //其他列调用基类设置数据
59. return QStyledItemDelegate::setEditorData(editor,index);
60. }
61. //将编辑其中的数据放入模型中
62. void setModelData(QWidget *editor,
63. QAbstractItemModel *model,
64. const QModelIndex &index) const override{
65. if(index.column() == 3){
66. //editor强制转换为QSpinBox
67. QSpinBox *spinBox = static_cast<QSpinBox*>(editor);
68. //检测输入是否合法，做数值限制
69. spinBox->interpretText();
70. //获取spinBox的值
71. int value = spinBox->value();
72. //将这个值写入模型
73. model->setData(index, value, Qt::EditRole);
74. return;
75. }
77. //其他类型调用默认的设置函数
78. QStyledItemDelegate::setModelData(editor,model,index);
79. }
80. //更新编辑区域
81. void updateEditorGeometry(QWidget *editor,
82. const QStyleOptionViewItem &option,
83. const QModelIndex &index) const override{
84. //设置编辑区域
85. editor->setGeometry(option.rect);
86. }
87. };
89. #endif // MYDELEGATE_H

复制代码

修改tableview表头的显示方式为拉伸，并且创建代理

2. void MainWindow::setupView()
3. {
4. //设置模型
5. ui->tableView->setModel(model);
6. //设置选中模式为单个选中
7. ui->tableView->setSelectionMode(QAbstractItemView::SingleSelection);
8. //设置整行选中
9. ui->tableView->setSelectionBehavior(QAbstractItemView::SelectRows);
10. //设置编辑触发模式为双击或者选中时点击
11. ui->tableView->setEditTriggers(QAbstractItemView::DoubleClicked
12. | QAbstractItemView::SelectedClicked);
13. //设置表头宽度拉伸
14. ui->tableView->horizontalHeader()->setSectionResizeMode(QHeaderView::Stretch);
15. //创建代理
16. auto * delegate = new Mydelegate(this);
17. //设置代理
18. ui->tableView->setItemDelegate(delegate);
19. //重置列宽自适应内容
20. ui->tableView->resizeColumnsToContents();
21. }

复制代码

再次运行能看到效果要求的效果

QSqlQueryModel

QSqlQueryModel 是只读模型，适用于执行自定义查询并将结果显示在视图中。它不支持对数据进行直接编辑。

1. 包含头文件

2. #include <QSqlQueryModel>

复制代码

2. 基本用法

QSqlQueryModel有两个方法，都是用来执行sql语句的，只是参数不同。

2. //执行查询，传入QSqlQuery做的查询
3. void setQuery(const QSqlQuery &query);
4. //执行查询，可指定查询语句和数据库
5. void setQuery(const QString &query, const QSqlDatabase &db = QSqlDatabase());

复制代码

3. 实现案例

以下示例展示如何使用 QSqlQueryModel 来执行自定义查询并显示结果。

我们需要显示如下的视图界面，右侧的为按薪水排序的只读视图。我们可以利用 QSqlQueryModel按照薪水排序存储，并且放入tableview中展示。

我们在之前的案例ui中再增加一个视图，用来显示最高薪水，并且增加按钮，用来刷新最高薪水

属性结构图

在mainwindow的类中添加QSqueryModel*类型的成员变量, 以及响应刷新的槽函数

2. private slots:
3. void on_refreshBtn_clicked();
4. private:
5. //查询模型，用来做显示工资排序
6. QSqlQueryModel* query_model;

复制代码

然后在setupModel中添加query_model的初始化，并且编写sql语句将薪水按从大到小排序列出来

2. void MainWindow::setupModel()
3. {
4. //创建模型
5. model = new QSqlTableModel(this);
6. //使用默认连接，对表employees操作
7. model->setTable("employees");
8. //设置提交策略为手动提交
9. model->setEditStrategy(QSqlTableModel::OnManualSubmit);
11. // 设置表头标签
12. model->setHeaderData(0, Qt::Horizontal, "ID");
13. model->setHeaderData(1, Qt::Horizontal, "姓名");
14. model->setHeaderData(2, Qt::Horizontal, "职位");
15. model->setHeaderData(3, Qt::Horizontal, "薪水");
17. //将sql中的数据写入model中
18. if (!model->select()) {
19. QMessageBox::critical(this, "错误", "无法检索数据: " + model->lastError().text());
20. }
22. //创建查询模型
23. query_model = new QSqlQueryModel(this);
25. //编写查询语句
26. QString query_str = "SELECT * FROM employees ORDER BY salary DESC";
27. //创建查询
28. query_model->setQuery(query_str);
30. //判断查询是否出错
31. if (query_model->lastError().isValid()) {
32. QMessageBox::critical(this, "错误", "无法检索数据: " +
33. query_model->lastError().text());
34. }
36. //设置表头标签
37. query_model->setHeaderData(0, Qt::Horizontal, "ID");
38. query_model->setHeaderData(1, Qt::Horizontal, "姓名");
39. query_model->setHeaderData(2, Qt::Horizontal, "职位");
40. query_model->setHeaderData(3, Qt::Horizontal, "薪水");
42. }

复制代码

设置视图的逻辑把QSqlQueryModel和视图绑定, 为了美观，我们将表头模式设置为拉伸

2. void MainWindow::setupView()
3. {
4. //设置模型
5. ui->tableView->setModel(model);
6. //设置选中模式为单个选中
7. ui->tableView->setSelectionMode(QAbstractItemView::SingleSelection);
8. //设置整行选中
9. ui->tableView->setSelectionBehavior(QAbstractItemView::SelectRows);
10. //设置编辑触发模式为双击或者选中时点击
11. ui->tableView->setEditTriggers(QAbstractItemView::DoubleClicked
12. | QAbstractItemView::SelectedClicked);
13. //设置表头宽度拉伸
14. ui->tableView->horizontalHeader()->setSectionResizeMode(QHeaderView::Stretch);
16. // 设置model
17. ui->highView->setModel(query_model);
18. // 设置单选模式
19. ui->highView->setSelectionMode(QAbstractItemView::SingleSelection);
20. // 设置一次选择一行
21. ui->highView->setSelectionBehavior(QAbstractItemView::SelectRows);
22. // 设置不触发编辑
23. ui->highView->setEditTriggers(QAbstractItemView::NoEditTriggers);
24. // 设置表头自动拉伸
25. ui->highView->horizontalHeader()->setSectionResizeMode(QHeaderView::Stretch);
27. }

复制代码

实现刷新按钮的槽函数逻辑，其实就是再次查询一下数据库，将结果写入query_model，因为query_model已经和视图绑定了，就会导致视图自动刷新

2. void MainWindow::on_refreshBtn_clicked()
3. {
4. //编写查询语句
5. QString query_str = "SELECT * FROM employees ORDER BY salary DESC";
6. //创建查询
7. query_model->setQuery(query_str);
9. //判断查询是否出错
10. if (query_model->lastError().isValid()) {
11. QMessageBox::critical(this, "错误", "无法检索数据: " +
12. query_model->lastError().text());
13. }
14. }

复制代码

再次运行，就会弹出案例界面，并且我们在左侧编辑数据后提交，点击刷新，右侧视图就会出现按照薪水排序的效果

4.实现代理(拓展内容)

同学们看到表格内容不是按照居中对齐的，对于这种情况我们可以重新实现代理

2. #ifndef MYDELEGATE_H
3. #define MYDELEGATE_H
4. #include <QStyledItemDelegate>
5. #include <QPainter>
6. #include <QSpinBox>
8. class Mydelegate : public QStyledItemDelegate
9. {
10. public:
11. Mydelegate(QObject *parent = nullptr):QStyledItemDelegate(parent){}
12. void paint(QPainter *painter,
13. const QStyleOptionViewItem &option, const QModelIndex &index)
14. const override{
15. //拷贝一份样式的副本，防止对引用做出污染
16. QStyleOptionViewItem opt = option;
17. //绑定opt和index
18. initStyleOption(&opt, index);
20. // 根据列设置不同的对齐方式
21. opt.displayAlignment = Qt::AlignCenter;
23. // 调用基类绘制（确保选中状态等被正确处理）
24. QStyledItemDelegate::paint(painter, opt, index);
25. }
27. //创建编辑器
28. QWidget *createEditor(QWidget *parent,
29. const QStyleOptionViewItem &option,
30. const QModelIndex &index) const override{
31. //判断如果是第三列，则创建spinbox
32. if(index.column() == 3){
33. //创建spinbox
34. QSpinBox *editor = new QSpinBox(parent);
35. //设置最低薪水
36. editor->setMinimum(3000);
37. //设置最高薪水
38. editor->setMaximum(2000000);
39. //设置spinbox步长
40. editor->setSingleStep(1000);
41. return editor;
42. }
43. //其他列调用基类默认函数创建
44. return QStyledItemDelegate::createEditor(parent,option,index);
45. }
47. //将模型的数据放入编辑器中
48. void setEditorData(QWidget *editor, const QModelIndex &index) const override{
49. //如果是第三列
50. if(index.column() == 3){
51. //获取数据
52. int value = index.model()->data(index, Qt::EditRole).toInt();
53. QSpinBox *spinBox = static_cast<QSpinBox*>(editor);
54. //将数据设置到编辑器中
55. spinBox->setValue(value);
56. return;
57. }
58. //其他列调用基类设置数据
59. return QStyledItemDelegate::setEditorData(editor,index);
60. }
61. //将编辑其中的数据放入模型中
62. void setModelData(QWidget *editor,
63. QAbstractItemModel *model,
64. const QModelIndex &index) const override{
65. if(index.column() == 3){
66. //editor强制转换为QSpinBox
67. QSpinBox *spinBox = static_cast<QSpinBox*>(editor);
68. //检测输入是否合法，做数值限制
69. spinBox->interpretText();
70. //获取spinBox的值
71. int value = spinBox->value();
72. //将这个值写入模型
73. model->setData(index, value, Qt::EditRole);
74. return;
75. }
77. //其他类型调用默认的设置函数
78. QStyledItemDelegate::setModelData(editor,model,index);
79. }
80. //更新编辑区域
81. void updateEditorGeometry(QWidget *editor,
82. const QStyleOptionViewItem &option,
83. const QModelIndex &index) const override{
84. //设置编辑区域
85. editor->setGeometry(option.rect);
86. }
87. };
89. #endif // MYDELEGATE_H

复制代码

新增setupDelegate方法，然后在setupDelegate中设置代理，我们为两个视图设置代理

2. //设置代理
3. void MainWindow::setupDelegate()
4. {
5. //创建模型代理
6. auto* model_delegate = new Mydelegate(this);
7. //设置代理
8. ui->tableView->setItemDelegate(model_delegate);
10. //创建查询模型代理
11. auto* query_model_delegate = new Mydelegate(this);
12. //设置代理
13. ui->highView->setItemDelegate(query_model_delegate);
14. }

复制代码

在mainwindow的构造函数添加调用

2. MainWindow::MainWindow(QWidget *parent) :
3. QMainWindow(parent),
4. ui(new Ui::MainWindow)
5. {
6. ui->setupUi(this);
7. //加载模型
8. setupModel();
9. //加载视图
10. setupView();
11. //设置代理
12. setupDelegate();
13. }

复制代码

QSqlQuery

QSqlQuery 提供了更底层的 SQL 操作能力，适用于执行自定义的 SQL 语句，如复杂的查询、事务处理以及动态参数绑定。

1. 基本用法

以下示例展示如何使用 QSqlQuery 来执行查询和插入操作。

在执行sql语句前，我们还是要创建数据库类型，并且设置要操作的数据库

2. bool executeQueries()
3. {
4. // 利用文件对话框打开选择db文件
5. auto file_path = QFileDialog::getOpenFileName(nullptr,"选择sqlitedb文件","","*.db");
6. if(file_path.isEmpty()){
7. QMessageBox::critical(nullptr,"文件错误信息","未选择文件!");
8. return false;
9. }
11. // 添加 SQLite 数据库驱动,使用默认连接
12. QSqlDatabase db = QSqlDatabase::addDatabase("QSQLITE");
14. // 设置数据库文件路径（相对路径或绝对路径）
15. db.setDatabaseName(file_path);
17. // 打开数据库
18. if (!db.open()) {
19. qDebug() << "无法打开数据库:" << db.lastError().text();
20. return false;
21. }
22. //...todo 查询逻辑
23. }

复制代码

如果执行的sql语句不带参数，我们可以直接执行sql语句

2. bool executeQueries(){
3. //...省略数据库连接
4. QSqlQuery query;
6. // 执行查询
7. QString selectQuery = "SELECT id, name, position, salary FROM employees";
8. if (!query.exec(selectQuery)) {
9. qDebug() << "查询失败:" << query.lastError().text();
10. return false;
11. }
13. //如果有多条数据，通过循环依次打印
14. while (query.next()) {
15. //获取每条查询结果的第一个字段，从0开始
16. int id = query.value(0).toInt();
17. //获取每条查询结果的第二个字段，从1开始
18. QString name = query.value(1).toString();
19. //获取每条查询结果的第三个字段，从2开始
20. QString position = query.value(2).toString();
21. //获取每条查询结果的第四个字段，从3开始
22. double salary = query.value(3).toDouble();
23. //输出查询结果
24. qDebug() << id << name << position << salary;
25. }
27. }

复制代码

2. 参数绑定

使用参数绑定可以防止 SQL 注入，并使代码更清晰。

如果执行的sql语句需要携带参数，我们可以通过:占位名的方式填入查询语句，并且在查询前将实际参数绑定给这个占位符即可

2. bool executeQueries(){
3. //...省略数据库连接和打开
4. // 插入数据，通过:name, :position, :salary占位
5. QString insertQuery = "INSERT INTO employees (name, position, salary) VALUES (:name, :position, :salary)";
6. if (!query.prepare(insertQuery)) {
7. qDebug() << "准备插入语句失败:" << query.lastError().text();
8. return false;
9. }
10. //绑定参数，通过绑定:name,:position,:salary为具体参数
11. query.bindValue(":name", "David");
12. query.bindValue(":position", "Tester");
13. query.bindValue(":salary", 48000.0);
15. //执行sql语句
16. if (!query.exec()) {
17. qDebug() << "插入失败:" << query.lastError().text();
18. return false;
19. } else {
20. qDebug() << "成功插入一条记录。";
21. }
23. return true;
24. }

复制代码

如果写着麻烦，可以用?占位

2. bool executeQueries(){
3. //...省略数据库连接和打开
4. // 插入数据，通过?占位
5. QString insertQuery = "INSERT INTO employees (name, position, salary) VALUES (?,?,?)";
6. if (!query.prepare(insertQuery)) {
7. qDebug() << "准备插入语句失败:" << query.lastError().text();
8. return false;
9. }
10. //绑定参数，将具体参数name1,position1,salary1按顺序填入？位置
11. query.addBindValue("name1");
12. query.addBindValue("position1");
13. query.addBindValue("salary1");
15. //执行sql语句
16. if (!query.exec()) {
17. qDebug() << "插入失败:" << query.lastError().text();
18. return false;
19. } else {
20. qDebug() << "成功插入一条记录。";
21. }
23. return true;
24. }

复制代码

3. 事务处理(拓展内容)

在执行多个相关的 SQL 语句时，可以使用事务确保操作的原子性。

开启事物需要提前设置数据库，我们将数据库的打开操作提出到一个函数里，将数据库设置为全局变量

2. QSqlDatabase db;
3. bool openDB(){
4. // 利用文件对话框打开选择db文件
5. auto file_path = QFileDialog::getOpenFileName(nullptr,"选择sqlitedb文件","","*.db");
6. if(file_path.isEmpty()){
7. QMessageBox::critical(nullptr,"文件错误信息","未选择文件!");
8. return false;
9. }
11. // 添加 SQLite 数据库驱动,使用默认连接
12. db = QSqlDatabase::addDatabase("QSQLITE");
14. // 设置数据库文件路径（相对路径或绝对路径）
15. db.setDatabaseName(file_path);
17. // 打开数据库
18. if (!db.open()) {
19. qDebug() << "无法打开数据库:" << db.lastError().text();
20. return false;
21. }
22. return true;
23. }

复制代码

创建事务，事务中有多条操作，最后一起提交，如果某一条失败了则回滚

2. //执行事物
3. bool performTransaction()
4. {
5. //创建事务
6. if (!db.transaction()) {
7. qDebug() << "事务开始失败:" << db.lastError().text();
8. return false;
9. }
11. QSqlQuery query;
12. //注意sqlite查询语句中有字符串的用单引号包裹
13. if (!query.exec("UPDATE employees SET salary = salary + 5000 WHERE position = 'Developer'")) {
14. qDebug() << "更新失败:" << query.lastError().text();
15. //如果失败则回滚
16. db.rollback();
17. return false;
18. }
20. //如果不会拼接可以采用之前替换的方式
21. auto query_str = "UPDATE employees SET salary = salary + 3000 WHERE position = ?";
22. //准备执行
23. if(!query.prepare(query_str)){
24. qDebug() << "准备更新失败:" << query.lastError().text();
25. //回滚
26. db.rollback();
27. return false;
28. }
30. //绑定数值
31. query.addBindValue("Designer");
33. //执行语句
35. if (!query.exec()) {
36. qDebug() << "更新失败:" << query.lastError().text();
37. db.rollback();
38. return false;
39. }
41. //执行完成后要提交结果，将多次执行的结果一次提交
42. if (!db.commit()) {
43. qDebug() << "事务提交失败:" << db.lastError().text();
44. db.rollback();
45. return false;
46. }
48. qDebug() << "事务成功提交。";
49. return true;
50. }

复制代码

4 获取自动生成的键（扩展内容）

通过query.lastInsertId().toInt(),我们可以获得插入返回的id

2. //获取插入后返回的id
3. bool insertAndRetrieveId(const QString &name, const QString &position, double salary, int &id)
4. {
5. QSqlQuery query;
6. query.prepare("INSERT INTO employees (name, position, salary) VALUES (:name, :position, :salary)");
7. query.bindValue(":name", name);
8. query.bindValue(":position", position);
9. query.bindValue(":salary", salary);
11. if (!query.exec()) {
12. qDebug() << "插入失败:" << query.lastError().text();
13. return false;
14. }
16. // 获取最后插入的 ID
17. id = query.lastInsertId().toInt();
18. return true;
19. }

复制代码