Rails 7.0中如何在数据库事务外更新JobStatus记录？

要让JobStatus的更新脱离外层事务立即生效，你可以通过开启独立事务或者直接执行SQL更新两种方式实现，以下是具体实现：

方法一：使用独立事务包裹进度更新 #

在Rails中，默认嵌套事务不会真正提交，需要通过requires_new: true强制创建独立事务，确保进度更新立即写入数据库：

class BackgroundJob < ApplicationJob
  def perform(job_status_id)
    job_status = JobStatus.find(job_status_id)
    update_progress(job_status, 0)

    ActiveRecord::Base.transaction do
      # ... 更新第一批记录
      update_progress(job_status, 25)
      # ... 更新第二批记录
      update_progress(job_status, 50)
      # ... 更新第三批记录
      update_progress(job_status, 75)
      # ... 完成所有记录更新
      update_progress(job_status, 100)
    end
  end

  private

  def update_progress(job_status, percent)
    # 开启独立事务，不受外层事务影响
    ActiveRecord::Base.transaction(requires_new: true) do
      job_status.update!(percent_complete: percent)
    end
  end
end

说明 #

• requires_new: true会创建完全独立的数据库事务，执行完成后立即提交，外层事务的提交或回滚不会影响这个独立事务的结果。
• 使用update!替代update，若进度更新失败会直接抛出异常，便于排查问题。

方法二：直接执行SQL更新（更高效） #

使用update_all直接生成并执行更新SQL，绕过ActiveRecord的事务上下文，同样能实现实时更新：

class BackgroundJob < ApplicationJob
  def perform(job_status_id)
    update_progress(job_status_id, 0)

    ActiveRecord::Base.transaction do
      # ... 更新第一批记录
      update_progress(job_status_id, 25)
      # ... 更新第二批记录
      update_progress(job_status_id, 50)
      # ... 更新第三批记录
      update_progress(job_status_id, 75)
      # ... 完成所有记录更新
      update_progress(job_status_id, 100)
    end
  end

  private

  def update_progress(job_status_id, percent)
    JobStatus.where(id: job_status_id).update_all(percent_complete: percent)
  end
end

说明 #

• update_all不会加载JobStatus对象，直接执行UPDATE语句，性能更优。
• 同样不受外层事务影响，更新会立即生效。

注意事项 #

无论使用哪种方法，进度更新一旦提交就不会被外层事务的回滚撤销，这符合需求——用户需要看到真实的执行进度，即使最终批量更新失败。

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