使用Ecto Fragment作为查询源遇阻，求动态查询组合方案

我刚好之前处理过类似的需求，其实Ecto是支持把Fragment作为查询源来进行动态组合的，只是需要用正确的方式包装一下，不用被迫用Ecto.Adapters.SQL.query!。给你两个实用的方案：

方案一：用subquery/1包装Fragment（最常用） #

把你的Fragment转换成Ecto可识别的子查询，之后就能像操作普通Ecto查询一样，链式调用where/select/order_by等方法进行动态组合了。

举个具体例子：
假设你有一个返回用户数据的原生SQL片段，想在它之上动态添加搜索条件和字段选择：

# 第一步：定义你的原生Fragment
recent_users_fragment = fragment("SELECT id, name, email, created_at FROM users WHERE created_at > NOW() - INTERVAL '7 days'")

# 第二步：用subquery包装，转换成Ecto子查询
sub_query = subquery(recent_users_fragment)

# 第三步：基于子查询构建动态查询
# 动态添加搜索条件
search_term = "alice"
query = from u in sub_query, where: u.name ilike ^"%#{search_term}%"

# 动态选择字段（比如根据配置决定是否返回邮箱）
include_email = true
query = if include_email, 
  do: from u in query, select: {u.id, u.name, u.email}, 
  else: from u in query, select: {u.id, u.name}

# 最后执行查询
Repo.all(query)

这个方法的好处是完全兼容Ecto的查询构造器，所有动态组合的逻辑都可以用Ecto的语法实现，不用手动拼接原生SQL，还能避免SQL注入风险。

方案二：用CTE（WITH子句）绑定Fragment（适合复杂场景） #

如果你的需求涉及多个子查询或者需要更灵活的查询结构，可以用Ecto的with_cte/3功能，把Fragment定义为CTE，然后在主查询中引用它。

例子：

# 定义基于Fragment的CTE
active_users_cte = fragment("SELECT id, name FROM users WHERE active = true AND last_login > NOW() - INTERVAL '30 days'")

# 主查询引用CTE的表名
base_query = from u in "active_users", select: u.name

# 动态调整CTE（比如根据条件切换不同的Fragment）
use_recent_login = true
cte_def = if use_recent_login,
  do: ["active_users": active_users_cte],
  else: ["active_users": fragment("SELECT id, name FROM users WHERE active = true")]

# 绑定CTE并执行查询
Repo.all(from q in base_query, with_cte: cte_def)

注意事项 #

• 确保Fragment返回的列名和你在Ecto查询中引用的完全一致，否则会出现"字段不存在"的报错
• 如果Fragment返回的字段类型和Ecto预期不符，可以用type/2函数转换，比如type(u.age, :integer)
• 所有动态参数一定要用^符号插值，不要直接拼接字符串，避免SQL注入

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