如何向Elixir/Ecto子查询传递变量？报错解决方案

简单可行的方案：用let绑定外部变量 + 子查询内用^引用 #

Ecto的子查询无法直接访问外部查询的表别名（比如ev、tx），但可以通过绑定变量传递的方式解决，步骤如下：

• 在外部查询中用let关键字，把需要传递给子查询的字段（ev.id、tx.marked_at）绑定为本地变量
• 在子查询内用^前缀引用这些绑定好的变量，Ecto会自动处理参数传递，同时避免SQL注入

示例代码 #

假设你原来的报错查询大致如下：

from ev in Event,
  join: tx in Transaction, on: ev.id == tx.event_id,
  select: %{
    event_id: ev.id,
    latest_marked: coalesce(
      (from pm in Payment, where: pm.event_id == ev.id and pm.created_at < tx.marked_at, select: max(pm.amount)),
      0
    )
  }

修复后的代码：

from ev in Event,
  join: tx in Transaction, on: ev.id == tx.event_id,
  # 绑定外部字段为本地变量
  let: event_id = ev.id,
  let: marked_at = tx.marked_at,
  select: %{
    event_id: event_id,
    latest_marked: coalesce(
      # 子查询内用^引用绑定的变量
      (from pm in Payment, 
       where: pm.event_id == ^event_id and pm.created_at < ^marked_at,
       select: max(pm.amount)),
      0
    )
  }

原理说明 #

let关键字会把外部查询的字段值绑定到当前查询上下文的变量中，子查询通过^前缀引用这些变量时，Ecto会将其作为参数注入到SQL查询里，相当于在子查询中使用了外部查询的对应字段值，同时严格遵循SQL语法规则，不会出现变量未定义的错误。

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