ash-project/ash_postgres
1
0
Fork 0
mirror of https://github.com/ash-project/ash_postgres.git synced 2024-09-19 13:03:14 +12:00
Code Issues Projects Releases Packages Wiki Activity

fix: allow non-unique has_many source_attributes (#355)

Browse source 
* fix: allow non-unique has_many source_attributes

* fix composite primary key case
This commit is contained in:
Jesse Williams 2024-07-18 13:37:31 -07:00 committed by GitHub
parent c47ed40a55
commit 8f79fcb59d
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 35 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
lib/data_layer.ex
View file

@ -1044,9 +1044,43 @@ defmodule AshPostgres.DataLayer do
{:ok, data_layer_query} ->
source_values = Enum.map(root_data, &Map.get(&1, source_attribute))
source_filter =
case source_pkey do
[] ->
Ecto.Query.dynamic([source], field(source, ^source_attribute) in ^source_values)
[field] ->
values = Enum.map(root_data, &Map.get(&1, field))
Ecto.Query.dynamic([source], field(source, ^field) in ^values)
fields ->
Enum.reduce(root_data, nil, fn record, acc ->
row_match =
Enum.reduce(fields, nil, fn field, acc ->
if is_nil(acc) do
Ecto.Query.dynamic(
[source],
field(source, ^field) == ^Map.get(record, field)
)
else
Ecto.Query.dynamic(
[source],
field(source, ^field) == ^Map.get(record, field) and ^acc
)
end
end)
if is_nil(acc) do
row_match
else
Ecto.Query.dynamic(^row_match or ^acc)
end
end)
end
data_layer_query =
from(source in data_layer_query,
where: field(source, ^source_attribute) in ^source_values
where: ^source_filter
)
if query.__ash_bindings__[:__order__?] do