如何在Qt中实现数据库的事务和并发控制？-QT开发中文网

在Qt中实现数据库的事务和并发控制，可以采用以下方法：

开启事务

QSqlDatabase::database().transaction();

执行SQL语句

QSqlQuery query;
query.exec("UPDATE students SET age = 20 WHERE name = '张三'");
query.exec("UPDATE students SET age = 22 WHERE name = '李四'");

提交事务

QSqlDatabase::database().commit();

回滚事务（若需要）

QSqlDatabase::database().rollback();

对于并发控制，可以使用悲观锁或乐观锁来避免数据冲突。

悲观锁

使用FOR UPDATE关键字在查询语句中加上排它锁，保证在查询过程中其他线程无法修改数据。

// 查询一个学生信息，并加上排它锁
QString sql = "SELECT * FROM students WHERE id = :id FOR UPDATE";
QSqlQuery query;
query.prepare(sql);
query.bindValue(":id", 1);
if (query.exec()) {
    if (query.next()) {
        // 获取学生信息...
    }
}

乐观锁

在数据表中添加一个版本号字段version，每次更新数据时将版本号+1。在查询时获取当前版本号，并在更新时判断该记录的版本号是否与查询时相同，如果不同则说明其他线程已经修改了该记录。

// 查询一个学生信息及其版本号
QString sql = "SELECT age, gender, version FROM students WHERE id = :id";
QSqlQuery query;
query.prepare(sql);
query.bindValue(":id", 1);
if (query.exec()) {
    if (query.next()) {
        int age = query.value(0).toInt();
        QString gender = query.value(1).toString();
        int version = query.value(2).toInt();

        // 更新学生信息（带版本号判断）
        QString updateSql = "UPDATE students SET age=:age, gender=:gender, version=version+1 WHERE id=:id AND version=:version";
        QSqlQuery updateQuery;
        updateQuery.prepare(updateSql);
        updateQuery.bindValue(":age", 20);
        updateQuery.bindValue(":gender", "男");
        updateQuery.bindValue(":id", 1);
        updateQuery.bindValue(":version", version);
        if (updateQuery.exec() && updateQuery.numRowsAffected() > 0) {
            qDebug() << "更新成功！";
        } else {
            qDebug() << "更新失败，数据已被其他线程修改！";
        }
    }
}

以上是在Qt中实现数据库的事务和并发控制的基本方法。需要根据具体情况调整SQL语句和锁策略，以确保程序正确、高效地运行。