如何在Rails控制器的create和update动作中运行指定迁移文件？

首先得掰扯清楚：你的CombineItemsInSale迁移里的up方法是用来批量处理所有已存在的Sale记录的，而如果你的需求是每次创建或更新单个Sale时自动合并它的重复商品项，直接调用迁移类的方法其实不是最合理的选择——毕竟迁移的设计初衷是一次性的数据库结构/数据变更，不是用来复用业务逻辑的。

下面分两种场景给你解决方案：

场景1：单Sale创建/更新时执行合并逻辑（强烈推荐） #

更好的做法是把迁移里的核心逻辑抽出来放到Sale模型里，做成实例方法，然后在控制器里调用，或者用模型回调自动触发，这样更符合Rails「胖模型瘦控制器」的原则。

第一步：在Sale模型中封装合并逻辑 #

打开app/models/sale.rb，添加这个实例方法：

class Sale < ApplicationRecord
  has_many :items

  # 合并当前Sale下重复的商品项
  def combine_duplicate_items
    # 按product_id分组统计数量
    product_quantities = items.group(:product_id).sum(:quantity)
    
    product_quantities.each do |product_id, total_quantity|
      next if total_quantity <= 1 # 数量不大于1的不用合并

      # 删除当前商品的所有旧条目
      items.where(product_id: product_id).delete_all
      # 创建合并后的新条目
      items.create!(product_id: product_id, quantity: total_quantity)
    end
  end
end

第二步：在控制器中调用该方法 #

假设你的控制器是SalesController，修改create和update动作：

class SalesController < ApplicationController
  def create
    @sale = Sale.new(sale_params)
    
    if @sale.save
      # 保存成功后执行合并逻辑
      @sale.combine_duplicate_items
      redirect_to @sale, notice: 'Sale创建成功'
    else
      render :new
    end
  end

  def update
    if @sale.update(sale_params)
      # 更新成功后执行合并逻辑
      @sale.combine_duplicate_items
      redirect_to @sale, notice: 'Sale更新成功'
    else
      render :edit
    end
  end

  private
    def sale_params
      # 根据你的实际需求调整允许的参数
      params.require(:sale).permit(:name, items_attributes: [:product_id, :quantity])
    end
end

可选：用模型回调自动执行 #

如果你希望Sale在保存（不管是创建还是更新）时自动执行合并逻辑，不用手动在控制器里调用，可以加个模型回调：

class Sale < ApplicationRecord
  has_many :items
  # 只有当Sale有items的时候才执行合并
  after_save :combine_duplicate_items, if: -> { items.any? }

  private
    def combine_duplicate_items
      product_quantities = items.group(:product_id).sum(:quantity)
      
      product_quantities.each do |product_id, total_quantity|
        next if total_quantity <= 1

        items.where(product_id: product_id).delete_all
        items.create!(product_id: product_id, quantity: total_quantity)
      end
    end
end

这样控制器里就不用额外加代码了，逻辑完全封装在模型里，更干净。

场景2：必须在控制器中执行迁移的批量逻辑（不推荐） #

如果你的需求真的是每次执行create/update动作时，对数据库里所有Sale进行批量合并（和迁移的up方法完全一样），那也能实现，但真的不建议这么做——这会遍历所有Sale记录，性能开销极大，频繁调用会给数据库造成很大压力，而且反复执行迁移逻辑可能导致数据异常。

实现步骤 #

首先要确保迁移类能被控制器加载，然后直接调用它的up方法：

class SalesController < ApplicationController
  # 加载迁移文件，注意路径要和你实际的迁移文件位置一致
  require Rails.root.join('db', 'migrate', '123blablabla.rb')

  def create
    # ... 你的create动作原有逻辑 ...
    # 执行迁移的up方法
    CombineItemsInSale.new.up
    # ... 后续跳转或响应逻辑 ...
  end

  def update
    # ... 你的update动作原有逻辑 ...
    CombineItemsInSale.new.up
    # ... 后续跳转或响应逻辑 ...
  end
end

再次提醒：这种方式风险高、性能差，除非万不得已，千万别用。

最后总结 #

优先选场景1的方案，把业务逻辑封装到模型里，既符合Rails的设计规范，代码也更好维护，性能也有保障。

内容的提问来源于stack exchange，提问作者Justin Jedi