如何强制Rails ActiveRecord提交事务刷新
是否可以强制ActiveRecord推送/刷新事务(或只是保存/创建)?
我有一个时钟工作者,可以在后台为几个任务工作者创建任务。 问题是,时钟工作者有时会创建一个任务并将其推送给任务工作者,然后才能将时钟工作者信息完全刷新到数据库,从而导致丑陋的竞争状况。
由于产品的体系结构以及如何生成任务,因此使用after_commit并不可行。
简而言之,我需要能够让一个worker创建一个任务并将该任务刷新到db。
ActiveRecord使用#transaction
创建一个开始并回滚或提交事务的块。 我相信这会对你的问题有所帮助。 基本上(假设Task是一个ActiveRecord类):
Task.transaction do new_task = Task.create(...) end BackgroundQueue.enqueue(new_task)
你也可以直接进入下面的#connection
:
Task.connection.commit_db_transaction
但是,这有点低级,你必须对代码的使用方式充满信心。 #after_commit
是最好的答案,即使需要稍微重新调整代码才能使其正常工作。 如果它不能确定,那么这两种方法应该有所帮助。