如何将Ecto Join查询结果格式化为指定结构的JSON？

嘿，我来帮你搞定这个Ecto查询结果格式化的问题！你现在遇到的核心问题是Join查询会把每条用户数据和组数据重复返回，导致组信息冗余，我们可以通过两种方式实现你想要的目标结构：

方法一：利用Ecto关联预加载（推荐） #

这种方式更贴合Ecto的设计理念，不仅能避免数据冗余，还能保证查询效率。

首先确保你的Group Schema已经定义了和Users的关联关系：

# lib/your_app/schemas/group.ex
schema "groups" do
  field :name, :string
  field :updated_at, :utc_datetime
  # 关联用户表，foreign_key对应Users表中的group_id字段
  has_many :users, YourApp.Users, foreign_key: :group_id
end

然后直接查询目标组并预加载关联的用户：

# 获取指定ID的组，同时预加载该组下的所有用户
case Repo.get(Group, ^group_id) do
  nil -> 
    # 处理组不存在的异常场景
    %{success: false, message: "Group not found"}
  group ->
    # 预加载用户（也可以直接在get时添加preload: :users，一次性完成查询）
    group_with_users = Repo.preload(group, :users)
    # 格式化为目标JSON结构
    formatted_data = %{
      success: true,
      data: %{
        group_id: group_with_users.id,
        group_name: group_with_users.name,
        updated_at: DateTime.to_iso8601(group_with_users.updated_at),
        users: Enum.map(group_with_users.users, fn user ->
          %{
            user_name: user.name,
            description: user.description
          }
        end)
      }
    }
    # 若需要转为JSON字符串，可使用Jason.encode!(formatted_data)
    formatted_data
end

为什么推荐这个方法？

• 无冗余数据：Ecto会先查询单个组，再批量查询该组下的用户，避免了N+1查询问题
• 逻辑更清晰：利用Ecto的关联机制，代码可读性更高，维护成本更低

方法二：对现有Join查询结果进行合并处理 #

如果暂时不想修改原有Join查询逻辑，可以通过Enum.reduce对返回的冗余结果进行合并，把相同组的用户数据整理到数组中：

# 你的原有查询代码
query = 
  from ms in Group,
    join: m in Users,
    on: ms.id == m.group_id,
    select: %{
      group_id: ms.id,
      group_name: ms.name,
      updated_at: ms.updated_at,
      user_name: m.name,
      description: m.description
    },
    where: ms.id == ^group_id

result = 
  query 
  |> order_by(desc: :created_at) 
  |> Repo.all() 
  |> Enum.map(&Map.take(&1, [:group_id, :group_name, :updated_at, :user_name, :description]))

# 合并冗余的组数据，整理用户列表
merged_group = 
  Enum.reduce(result, nil, fn item, acc ->
    case acc do
      nil ->
        # 初始化组数据，添加第一个用户
        %{
          group_id: item.group_id,
          group_name: item.group_name,
          updated_at: DateTime.to_iso8601(item.updated_at),
          users: [%{user_name: item.user_name, description: item.description}]
        }
      current ->
        # 追加用户到数组（因查询条件限定单个group_id，无需判断组是否重复）
        updated_users = current.users ++ [%{user_name: item.user_name, description: item.description}]
        Map.put(current, :users, updated_users)
    end
  end)

# 组装最终响应结构
formatted_response = %{
  success: true,
  data: merged_group
}

注意：由于你的查询条件限定了单个group_id，所以结果只会包含一个组的数据，因此Enum.reduce的逻辑可以简化，无需处理多组的情况。

两种方法都能得到你想要的无冗余JSON结构，如果是新项目或者允许调整查询逻辑，优先推荐方法一哦！

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