09-05 验证提交中断

题目

在完成标记更新前制造数据库错误，确认结果插入也回滚；去掉故障重新运行，检查这本书重新进入待处理任务。

推导与做法

complete_job 先写结果，再标任务完成，两步属于一个事务。触发器专门在第二步 UPDATE jobs 时抛错，第一步 INSERT items 也应撤回。

故障后应看到 items=0、jobs_pending=1；移除触发器再执行，得到 items=1、jobs_done=1。只检查异常出现还不够，要从库里核对结果和任务标记是否一起恢复。

过程图

%% 每个节点保留输入、执行位置或执行后的实际状态。 flowchart TD S0["INSERT items 已执行，尚未提交"] S1["UPDATE jobs 时触发器抛错"] S0 --> S1 S2["同一事务回滚：items0，pending1"] S1 --> S2 S3["移除故障重试：items1，done1"] S2 --> S3 classDef default fill:#EEF0FB,stroke:#4657B5,color:#24324A linkStyle default stroke:#4657B5

实现与运行

查看带注释实现。本题与相关处理函数放在同一章节代码文件中；启动工具负责定位相邻项目和选择题号。

在配套目录的 爬虫与数据采集/crawler_project 中运行。先按项目 README 执行 uv sync --locked。

# 使用项目解释器运行本题，题号决定执行哪一组演示。
uv run python "../../学习索引/参考实现/代码/ch09.py" 09-05

程序按题号输出处理后的值、查询结果或状态。先和前面的手算比较，再修改一项输入重跑。

查看本题运行结果

# 与上面的手算状态和题目数值逐项比较。
{
  "after_failure": {
    "pages_done": 1,
    "pages_pending": 0,
    "jobs_done": 0,
    "jobs_pending": 1,
    "items": 0
  },
  "after_retry": {
    "pages_done": 1,
    "pages_pending": 0,
    "jobs_done": 1,
    "jobs_pending": 0,
    "items": 1
  }
}