Ecto左连接子查询获取记录时返回空结构体而非nil的问题

这是个很常见的Ecto左连接场景问题，我来帮你拆解原因和最优方案：

为什么会出现这种差异？ #

左连接子查询返回空结构体的原因 #

当你使用Ecto的left_join关联子查询时，Ecto会严格按照你指定的Schema（比如MyApp.ForumTopic）来映射查询结果。即使子查询没有匹配到任何行，SQL返回的是全NULL的行，Ecto依然会把这些NULL字段封装成一个对应的Schema结构体实例——也就是所有字段为nil的ForumTopic/ForumPost对象，而不是直接返回nil。这是Ecto的默认行为，目的是保持结果类型的一致性。

片段宏返回nil的原因 #

而用片段宏（比如lft.id == last_topic_id(fc.id)）的方式，本质上是直接在SQL层面判断是否存在匹配记录。当没有匹配时，对应的字段会返回SQL的NULL，而Ecto不会把这个原始的NULL值封装成Schema结构体，所以最终你得到的是nil。这种方式相当于绕过了Ecto的自动Schema映射，直接处理原始的SQL值，代价是需要编写复杂的SQL片段，还可能影响查询性能。

最优解决方案 #

根据你的场景，推荐以下几种方案，按实现成本和优雅度排序：

1. 在结果处理阶段过滤空结构体（最简单） #

既然Ecto返回的是全nil的结构体，你只需要在fold_category_data函数里加个简单的判断，把无效的空结构体转为nil即可：

defp fold_category_data(category, lft, lfp, profile) do
  # 判断主题是否有效：ID不为nil则保留，否则转为nil
  valid_topic = if not is_nil(lft.id), do: lft, else: nil
  # 帖子的有效性依赖主题是否存在，以及自身ID是否非nil
  valid_post = if valid_topic && not is_nil(lfp.id), do: lfp, else: nil

  # 后续的折叠逻辑，使用valid_topic和valid_post代替原参数
  %{
    category
    | last_topic: valid_topic,
      last_post: valid_post
  }
end

这个方案完全不需要修改查询逻辑，只调整结果处理函数，代码简洁，对性能没有任何影响，是最推荐的方案。

2. 修改查询的Select语句，让Ecto返回nil #

如果你希望在查询阶段就直接得到nil而不是空结构体，可以在select中使用fragment来判断是否存在有效记录，把空结构体转为SQL的NULL，这样Ecto就会映射成nil：

from fc in ForumCategory,
  left_join: lft in subquery(topics_query), on: lft.forum_category_id == fc.id,
  left_join: lfp in subquery(posts_query), on: lfp.forum_topic_id == lft.id,
  left_join: p in Profile, on: p.id == lfp.profile_id,
  select: {
    fc,
    # 当主题ID不为空时返回主题结构体，否则返回NULL
    fragment("CASE WHEN ? IS NOT NULL THEN ? ELSE NULL END", lft.id, lft),
    # 同理处理帖子
    fragment("CASE WHEN ? IS NOT NULL THEN ? ELSE NULL END", lfp.id, lfp),
    p
  }

这种方式只需要少量的SQL片段，比你之前的全片段方案简洁很多，同时能在查询阶段就得到期望的nil值。

3. 用批量预加载替代左连接子查询（更符合Ecto idiom） #

如果想更贴合Ecto的惯用写法，可以把查询拆分成几步，批量获取数据，避免复杂的子查询嵌套：

# 第一步：获取所有分类
categories = Repo.all(ForumCategory)
category_ids = Enum.map(categories, & &1.id)

# 第二步：批量获取每个分类的最新主题ID（假设用inserted_at判断最新，也可以用ID）
latest_topic_map = Repo.all(
  from t in ForumTopic,
    where: t.forum_category_id in ^category_ids,
    group_by: t.forum_category_id,
    select: {t.forum_category_id, max(t.inserted_at), t.id}
)
|> Enum.reduce(%{}, fn {cat_id, _, topic_id}, acc ->
  Map.put(acc, cat_id, topic_id)
end)

# 第三步：获取这些主题及其最新帖子
topic_ids = latest_topic_map |> Map.values() |> Enum.reject(&is_nil/1)
latest_topics = Repo.all(
  from t in ForumTopic,
    where: t.id in ^topic_ids,
    left_join: p in subquery(
      from p in ForumPost,
        group_by: p.forum_topic_id,
        select: %{topic_id: p.forum_topic_id, post_id: max(p.id)}
    ), on: p.topic_id == t.id,
    left_join: post in ForumPost, on: post.id == p.post_id,
    preload: [forum_posts: {post, :profile}]
)
|> Map.new(&{&1.id, &1})

# 第四步：把最新主题和帖子关联到分类
Enum.map(categories, fn category ->
  topic = latest_topics[latest_topic_map[category.id]]
  post = if topic, do: Enum.find(topic.forum_posts, & &1.id), else: nil
  %{category | last_topic: topic, last_post: post}
end)

这种方式把复杂的关联拆分成多个批量查询，避免了嵌套子查询的性能问题，同时代码可读性更高，符合Ecto的设计哲学。

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