Qt中含外键的多SQL语句批量插入实现方案问询

问题背景 #

SQL数据表存在外键关联（job_format.job_format_id关联vacancy.job_format，vacancy.vacancy_id关联skills_for_vacancy.vacancy_id），逐个执行INSERT语句时容易因外键约束或部分操作失败导致数据不一致，需要在Qt中实现原子性的批量插入。

核心解决方案：使用数据库事务 #

利用Qt的数据库事务机制，保证一组插入操作要么全部成功提交，要么全部失败回滚，彻底解决外键关联下的部分插入问题。

实现代码示例 #

修正原代码的拼写错误（ISERT改为INSERT），并通过事务包裹所有插入操作：

// 获取当前数据库连接
QSqlDatabase db = QSqlDatabase::database();
// 开启事务
if (!db.transaction()) {
    qDebug() << "事务开启失败:" << db.lastError().text();
    return;
}

QSqlQuery query;
bool allSuccess = true;

// 第一步：插入job_format（被vacancy引用的父表）
query.prepare("INSERT INTO job_format (job_format_id, location, work_schedule) "
              "VALUES (:job_format_idValue, :locationValue, :work_scheduleValue)");
query.bindValue(":job_format_idValue", lastJobFormat + 1);
query.bindValue(":locationValue", ui->tableWidgetData->item(i,4)->text());
query.bindValue(":work_scheduleValue", ui->tableWidgetData->item(i,3)->text());
if (!query.exec()) {
    qDebug() << "job_format插入失败:" << query.lastError().text();
    allSuccess = false;
}

// 第二步：插入vacancy（依赖job_format，同时被skills_for_vacancy引用）
if (allSuccess) {
    query.prepare("INSERT INTO vacancy (vacancy_id, salary, company_id, profession, job_format, contacts, experience) "
                  "VALUES (:vacancy_idValue, :salaryValue, :company_idValue, :professionValue, :job_formatValue, :contactsValue, :experienceValue)");
    query.bindValue(":vacancy_idValue", lastVacancy + 1);
    query.bindValue(":salaryValue", ui->tableWidgetData->item(i,5)->text());
    query.bindValue(":company_idValue", currentID);
    query.bindValue(":professionValue", ui->tableWidgetData->item(i,0)->text());
    query.bindValue(":job_formatValue", lastJobFormat + 1); // 关联刚插入的job_format_id
    query.bindValue(":contactsValue", ui->tableWidgetData->item(i,6)->text());
    query.bindValue(":experienceValue", ui->tableWidgetData->item(i,1)->text());
    if (!query.exec()) {
        qDebug() << "vacancy插入失败:" << query.lastError().text();
        allSuccess = false;
    }
}

// 第三步：插入skills_for_vacancy（依赖vacancy）
if (allSuccess) {
    query.prepare("INSERT INTO skills_for_vacancy (line_skills_for_vacancy_id, vacancy_id, skill) "
                  "VALUES (:line_skills_for_vacancy_idValue, :vacancy_idValue, :skill)");
    query.bindValue(":line_skills_for_vacancy_idValue", lastLineSkill + 1);
    query.bindValue(":vacancy_idValue", lastVacancy + 1); // 关联刚插入的vacancy_id
    query.bindValue(":skill", tableSkillsMas[i]);
    if (!query.exec()) {
        qDebug() << "skills_for_vacancy插入失败:" << query.lastError().text();
        allSuccess = false;
    }
}

// 提交或回滚事务
if (allSuccess) {
    if (db.commit()) {
        qDebug() << "所有插入操作执行成功";
        // 成功后更新自增ID变量
        lastJobFormat++;
        lastVacancy++;
        lastLineSkill++;
    } else {
        qDebug() << "事务提交失败:" << db.lastError().text();
        db.rollback();
    }
} else {
    db.rollback();
    qDebug() << "插入操作失败，已回滚所有变更";
}

关键注意事项 #

• 插入顺序严格遵循外键依赖：必须先插入被引用的父表（job_format），再插入依赖它的子表（vacancy），最后插入依赖子表的关联表（skills_for_vacancy），否则外键约束会直接报错。
• 事务的原子性保障：事务开启后，所有操作在commit()前都不会写入数据库，一旦某一步失败，rollback()会撤销所有已执行的操作，避免数据不一致。
• 参数绑定准确性：外键字段的值必须和父表刚插入的ID完全匹配，确保关联关系正确。
• 错误检查：每一步执行后都要调用exec()的返回值判断是否成功，及时终止后续操作并触发回滚。

内容的提问来源于stack exchange，提问作者user20324932