Rails 5使用bulk_import批量插入后如何触发after回调

你可以通过以下步骤实现批量插入完成后触发after系列回调：

1. 调用import方法时新增returning: :id参数，开启插入后自动回填主键字段的能力，执行插入后你传入的valid_books数组内的所有ActiveRecord对象会自动填充数据库生成的id、created_at、updated_at等默认字段。
2. 插入完成后遍历valid_books，手动触发after_save、after_create回调即可。

修改后的完整代码示例如下：

valid_books = []
invalid_books = []

books.each do |book|
  if book.valid?
    valid_books << book
  else
    invalid_books << book
  end
end

# 触发before系列回调
valid_books.each do |book|
  book.run_callbacks(:save) { false }
  book.run_callbacks(:create) { false }
end

# 新增returning参数回填主键
Book.import valid_books, validate: false, returning: :id

# 批量插入完成后手动触发after系列回调
valid_books.each do |book|
  book.run_callbacks(:save) { true }
  book.run_callbacks(:create) { true }
  # 若需触发after_commit回调，可新增下行代码，注意要在事务提交后执行
  # book.run_callbacks(:commit)
end

注意事项 #

• run_callbacks传入的块返回值决定了回调的执行范围：返回false时仅执行before_*系列回调，返回true时会执行after_*系列回调，完全匹配分阶段触发的需求。
• 如果数据量级达到百万级，建议分批次处理：每批处理1000-5000条数据，插入完成后立即触发该批次的after回调，再清空该批次的对象数组释放内存，避免出现内存溢出问题。
• 如果after回调中存在操作当前记录以外的数据库写逻辑，建议将整个批量插入+回调执行逻辑包入事务中，避免插入成功但回调执行失败导致的数据不一致问题。

内容的提问来源于stack exchange，提问作者Shilpi Agrawal