多租户电商Ecto插入订单时预加载关联及价格持久化方案问询

首先，你偏好的第一种方案（在OrderProduct changeset中关联查询价格）确实有很大的优化空间——我们可以既保留changeset封装逻辑的优势，又彻底解决N+1查询和多租户prefix的问题。核心思路是把查询逻辑移到业务层提前批量预加载数据，而非让schema模块单独发起查询。下面详细拆解最优方案和具体实现：

一、核心改进思路 #

原方案的问题根源在于每个OrderProduct changeset都单独调用Repo，导致N+1，且schema模块处理多租户prefix不符合职责划分。我们可以：

1. 在业务层（比如Orders模块）一次性批量获取所有订单项对应的Product和Price数据；
2. 把预加载的价格数据传递给OrderProduct的changeset，避免重复查询；
3. 用Ecto.Multi将查询和插入纳入同一事务，保证原子性（可选但推荐，防止下单时价格变动）。

二、具体代码实现 #

业务层（Orders模块） #

def create_order(attrs, tenant_prefix) do
  # 提取所有订单项的product_id列表
  product_ids = Enum.map(attrs[:order_products], & &1.product_id)

  Ecto.Multi.new()
  # 批量查询并锁定价格（避免下单过程中价格被修改）
  |> Ecto.Multi.run(:product_prices, fn repo, _ ->
    product_price_map =
      from p in Product,
        join: pr in Price, on: p.price_id == pr.id,
        where: p.id in ^product_ids,
        select: {p.id, pr.amount},
        lock: "FOR UPDATE"
      |> repo.all(prefix: tenant_prefix)
      |> Map.new()

    {:ok, product_price_map}
  end)
  # 构建订单及订单项的changeset
  |> Ecto.Multi.insert(:order, fn %{product_prices: price_map} ->
    # 给每个订单项添加上预加载的price字段
    processed_order_products = Enum.map(attrs[:order_products], fn op_attrs ->
      Map.put(op_attrs, :price, price_map[op_attrs.product_id])
    end)

    %Order{}
    |> Order.changeset(Map.put(attrs, :order_products, processed_order_products))
  end)
  |> Repo.transaction(prefix: tenant_prefix)
end

OrderProduct Schema的Changeset #

def changeset(order_product, attrs) do
  order_product
  |> cast(attrs, [:product_id, :price_id, :quantity, :price])
  |> validate_required([:product_id, :quantity, :price])
  # 可添加额外验证：比如price不能为负、quantity大于0等
end

三、方案优势对比 #

• 对比原方案：彻底消除N+1查询（仅一次批量查询），多租户prefix由业务层统一处理，schema模块无需依赖Repo，符合单一职责原则；
• 对比方案2：订单项的价格处理逻辑集中在业务层，避免外部零散遍历，代码更整洁易维护；
• 对比方案3：用Ecto.Multi整合了查询和插入，保证原子性，同时保留了cast_assoc批量插入的便利性。

四、关于“schema外插入时通过join预加载”的疑问 #

完全可以！上面的实现就是在schema外（业务层）通过join查询预加载Product和Price的价格数据，再传递给changeset。这种方式不仅避免了N+1，还能灵活处理多租户prefix——只需要在Repo.all和Repo.transaction时传入prefix: tenant_prefix即可。

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