ActiveRecord在事務中執行批量插入/刪除操作嗎？

Question

我需要什麼：

1. 保證（無記錄可被處理2次）
2. 所有1000行批量刪除所選

---

@queue = Queue.where("col = 1").limit(1000) 
ids = [] 
@queue.each do |row| 
    Queue.do_something(row) 
    ids << row.id 
end 

Queue.delete_all("id in (#{ids.join(',')}) ") 

是一樣的原子更新

Queue.transaction do 
    @queue.each do |row| 
     Queue.do_something(row) 
     Queue.delete(row.id) 
    end 
end 

Answer 1

對於插入：

使用事務時，ActiveRecord不執行批量插入。然而，它確實提高了一點，因爲它使用單個事務來執行所有的INSERT語句，而不是每個INSERT語句的一個事務。

所以：

Queue.transaction do 
    @queue.each do |row| 
    # an INSERT is done here 
    end 
end 

將是快於：

@queue.each do |row| 
    # an INSERT is done here 
end 

有關如何真正做到批量插入更多的信息，看看這個article。

對於刪除：

ActiveRecord的delete_all調用是一個單獨的SQL DELETE語句，所以我想你可以認爲這是一個批量刪除（沒必要在這裏使用一個事務，因爲它是在一個事務中通過的ActiveRecord已經封裝）。在每條記錄上調用delete時情況並非如此，這將導致多個SQL DELETE語句，從而啓動並提交多個事務並且整體上性能較低。

Answer 2

我建議你看看ActiveRecord導入：https://github.com/zdennis/activerecord-import。

我正在使用此工具在10,000行和100,000行之間插入數據。

books = [] 
10.times do |i| 
    books << Book.new(:name => "book #{i}") 
end 
Book.import books 

如果你使用MySQL，它也支持對重複密鑰更新，因此您可以智能地將新/更新舊行。 https://github.com/zdennis/activerecord-import/wiki/MySQL:-On-Duplicate-Key-Update-Support