如何强制Rails ActiveRecord提交事务刷新

Question

是否可以强制ActiveRecord推送/刷新事务(或只是保存/创建)？

我有一个时钟工作者,可以在后台为几个任务工作者创建任务.问题是,时钟工作者有时会创建一个任务并在将时钟工作者信息完全刷新到数据库之前将其推送给任务工作者,从而导致丑陋的竞争状况.

由于产品的体系结构以及如何生成任务,因此使用after_commit并不可行.

简而言之,我需要能够让一个worker创建一个任务并将该任务刷新到db.

Answer 1

ActiveRecord用于#transaction创建一个开始并回滚或提交事务的块.我相信这会对你的问题有所帮助.基本上(假设Task是一个ActiveRecord类):

Task.transaction do
  new_task = Task.create(...)
end

BackgroundQueue.enqueue(new_task)

你也可以直接去#connection下面:

Task.connection.commit_db_transaction

但是,这有点低级,你必须对代码的使用方式充满信心. #after_commit是最好的答案,即使需要稍微重新调整代码才能使其正常工作.如果它不能确定,那么这两种方法应该有所帮助.