Rails 的 transaction 事务处理
最近太做一个数据排名统计,统计过程中需要删除旧的缓存统计数据,最开始写的时候就直接 CachePostTotal.connection.execute("truncate table cache_post_totals")
先把这个表给重置了,然后再循环往里面插入新的统计数据。
但后面发现,这样的做法存在大问题:
- 当我
truncate table
的时候,cache_post_totals
表已经被清除了。但新的数据还没有存上去,如果在这个时候有人读取这张表时,就会找不到数据,这样是有问题的。 - 在中间插入新数据的循环中有可能会出现异常、Model 验证不通过等情况而使得统计流程中断,但这个时候
cache_post_totals
表的数据已被改变。
要解决这个问题哪就要上 事务 了! Rails ActiveRecord 对事务的处理实现的很方便,只用Model.transaction do … end 将对 Model 表的操作的代码包起来就可以了,这样一来,在 transaction do .. end 之间的数据更新动作并不会立刻改变表里面的数据,而是要等到完全执行完成后,过了 end 才更新。
来看一下这一段例子:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 |
|
另外有个小细节需要注意,如果你是使用 Model.connection.execute()
方法执行的语句,那么事务将不会起作用!
交易Transactions
Transaction(交易)保證所有資料的操作都只有在成功的情況下才會寫入到資料庫,最著名的例子也就是銀行的帳戶交易,只有在帳戶提領金額及存入帳戶這兩個動作都成功的情況下才會將這筆操作寫入資料庫,否則在其中一個動作因為某些原因失敗的話就會放棄所有已做的操作將資料回復到交易前的狀態。在Rails中使用交易的方式像這樣:
ActiveRecord::Base.transaction do
david.withdrawal(100)
mary.deposit(100)
end
你可以在一個交易中包含不同Active Record的類別或物件,這是因為交易是以資料庫連線為範圍,而不是個別Model:
User.transaction do
User.create!(:name => ‘ihower‘)
Feed.create!
end
注意到這裡我們要使用create!
而不是create
,這是因為前者驗證失敗才會丟出例外,好讓整個交易失敗。同理,在交易裡做更新應該使用update_attributes!
而不是update_attributes
。
單一Model的save
及destroy
方法已經幫你使用transaction包起來了,當資料驗證失敗或其中的回呼發生例外時,Rails就會觸發rollback。所以下述的交易區塊是多餘的不需要寫:
User.transaction do # 這是多餘的
User.create!(:name => ‘ihower‘)
end
另外,由於資料的更新要在交易完成後才能被讀取到,所以如果你在after_save
回呼裡讓外部服務存取(例如呼叫全文搜尋引擎做索引),很可能因為交易尚未完成,會讀取不到更新。這時候必須改用after_commit
這個回呼,才能確保讀取到交易完成後的資料。
感谢http://ihower.tw/rails3/activerecord-others.html 和http://huacnlee.com/blog/rails-transaction-tutorial/作者分享知识
rails transaction 的用法