Rails Active Record：CSV导入记录时如何同时创建Lead及其关联模型

方案1：事务包裹+先保存Lead再创建关联记录 #

用数据库事务包裹整个操作，确保Lead和关联的邮箱、电话要么全部创建成功，要么都不创建，避免数据不一致。同时要注意操作关联对象时，使用Lead的实例而非类本身。

修改后的代码：

require 'csv'

class Lead < ApplicationRecord
  has_many :exports
  has_many :emails
  has_many :phones # 补充原代码缺失的关联定义

  def self.import(file)
    CSV.foreach(file.path, headers: true) do |row|
      # 事务保证操作原子性
      ActiveRecord::Base.transaction do
        lead = Lead.new(
          url: row[0],
          alexa: row[1]
        )
        lead.save! # 强制保存，失败则触发事务回滚

        # 处理邮箱记录
        unless row[6].blank?
          email_batch = row[6].split(",").first(2) # 和[0..1]效果一致，写法更直观
          email_batch.each do |email_str|
            lead.emails.find_or_create_by(email1: email_str.strip) # 去除字符串前后空格
          end
        end

        # 处理电话记录
        unless row[7].blank?
          phone_batch = row[7].split(",").first(2)
          phone_batch.each do |phone_str|
            lead.phones.find_or_create_by(phone_number: phone_str.strip)
          end
        end
      end
    end
  end
end

方案2：用嵌套属性一次性创建所有记录 #

借助Rails的accepts_nested_attributes_for特性，提前构建包含关联对象属性的哈希，一次性完成Lead和关联记录的创建。

代码示例：

require 'csv'

class Lead < ApplicationRecord
  has_many :exports
  has_many :emails
  has_many :phones

  # 声明支持嵌套属性，允许通过Lead创建关联记录
  accepts_nested_attributes_for :emails, :phones

  def self.import(file)
    CSV.foreach(file.path, headers: true) do |row|
      lead_attrs = {
        url: row[0],
        alexa: row[1],
        emails_attributes: [],
        phones_attributes: []
      }

      # 构建邮箱嵌套属性
      unless row[6].blank?
        row[6].split(",").first(2).each do |email_str|
          email_str = email_str.strip
          existing_email = Email.find_or_initialize_by(email1: email_str)
          lead_attrs[:emails_attributes] << existing_email.attributes.slice("email1")
        end
      end

      # 构建电话嵌套属性
      unless row[7].blank?
        row[7].split(",").first(2).each do |phone_str|
          phone_str = phone_str.strip
          existing_phone = Phone.find_or_initialize_by(phone_number: phone_str)
          lead_attrs[:phones_attributes] << existing_phone.attributes.slice("phone_number")
        end
      end

      # 一次性创建Lead及关联记录
      Lead.create(lead_attrs)
    end
  end
end

关键注意点 #

• 原代码中self.emails是错误用法，self指向Lead类，关联操作必须使用Lead的实例对象
• 用blank?替代empty?，可同时处理nil和空字符串的情况
• 拆分后用strip处理字符串，避免前后空格导致的重复记录
• 事务能有效避免“Lead保存成功但关联记录创建失败”的部分数据写入问题

内容的提问来源于stack exchange，提问作者Ali Ove