嵌套关联的 Ecto 限制

Question

我在使用 Ecto 进行查询时遇到了一些问题：

SavedDevice
    - belongs_to Devices
    - belongs_to User
Device
    - has_many SavedDevices
    - has_many DeviceLocations
DeviceLocation
    - belongs_to Devices

我想用最新的 DeviceLocation 加载属于 User 的 SavedDevices已保存。

这个解决方案工作正常：

  def list_pdevices_locations(user, limit \ 0) do
    location_query = from(dl in DeviceLocation, order_by: [desc: :inserted_at])
    query =
      from(d in ProvisionedDevice,
        preload: [device_info: [locations: ^location_query]],
        limit: ^limit
      )

    if user.is_admin do
      Repo.all(query)
    else
      Repo.all(from(d in query, where: d.user_id == ^user.id))
    end
  end

但它会加载每个 DeviceLocations。这是一个问题，因为它们可能有数千个，而我只需要最后一个。

当我将 limit: 1 添加到 location_query 时，它 returns 只是 1 DeviceLocation 所有 Devices 而不是 1 Devicelocation per Device.

有什么想法吗？

Answer 1

我不知道这是否可以在预加载中完成，但您可以使用 lateral joins（第 7.2.1.5 节）来实现您想要的。您将要为以下位置创建子查询：

location_query =
  from(dl in DeviceLocation,
    where: parent_as(:d_info).id == dl.device_info_id,
    # Unique rows by device_info_id
    distinct: dl.device_info_id,
    # Order by inserted at to get the most recent entry
    order_by: [desc: dl.inserted_at]
  )

然后从 ProvisionedDevice 加入它：

query = 
  from(pd in ProvisionedDevice,
    inner_join: di as assoc(pd, :device_info),
    # Use the same alias as specified in the subquery
    as: :d_info,
    inner_lateral_join: dl in subquery(location_query),
    on: dl.device_info_id == di.id,
    # You can structure this select any way you like
    select: %{device: pd, info: di, location: dl}
  )

当然，这将不再符合您示例中的 return 规范，但您可以 post 处理结果以符合您之前的合同（如果需要）：

for %{device: device, info: info, location: location} <- Repo.all(query) do
  info_and_location = %{info | locations: [location]}
  %{device | device_info: info_and_location}
end

无论哪种方式，查询都会在一次查询中为您提供一台设备及其信息和最近的位置。

嵌套关联的 Ecto 限制

Ecto limit on nested associations

elixir

phoenix-framework

ecto