我需要的：
确保原子更新(无记录可以处理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
解决方法
对于插入：
使用事务时,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语句,从而启动和提交多个事务并且整体性能较差.