爲什麼我得到協議Enumerable沒有爲＃Ecto.Query實現？

Question

雖然我經過查詢資料庫由this answer這樣的啓發：

teams_users = Repo.all (from(t in Team, where: t.owner_id == ^user_id)) 
    |> Enum.each(&team_users/1) 


def team_users (team) do 
    %{id: id} = team 
    Repo.all (from(tu in TeamUser, where: tu.team_id == ^id)) 
end 

不過，我得到這個錯誤：

[error] GenServer #PID<0.450.0> terminating 
** (Protocol.UndefinedError) protocol Enumerable not implemented for #Ecto.Query<from t in App.Team, where: t.owner_id == ^1> 
    (elixir) lib/enum.ex:1: Enumerable.impl_for!/1 
    (elixir) lib/enum.ex:116: Enumerable.reduce/3 
    (elixir) lib/enum.ex:1477: Enum.reduce/3 
    (elixir) lib/enum.ex:609: Enum.each/2 
    (App) web/channels/user_channel.ex:93: App.UserChannel.handle_in/3 
    (phoenix) lib/phoenix/channel/server.ex:223: Phoenix.Channel.Server.handle_info/2 
    (stdlib) gen_server.erl:615: :gen_server.try_dispatch/4 
    (stdlib) gen_server.erl:681: :gen_server.handle_msg/5 
    (stdlib) proc_lib.erl:240: :proc_lib.init_p_do_apply/3 

什麼我試圖做的是讓所有的球隊，然後獲得每個團隊的用戶，那麼我希望所有的用戶都在一個陣列中。

我想念什麼？有什麼建議？有沒有更好的方法來實現這一目標？

Answer 1

所以你在這裏有一個問題與此代碼：

teams_users = Repo.all (from(t in Team, where: t.owner_id == ^user_id)) 
|> Enum.each(&team_users/1) 

您應該刪除Repo.all和(

之間

teams_users = Repo.all(from(t in Team, where: t.owner_id == ^user_id)) 
|> Enum.each(&team_users/1) 

的空間你也可以這樣寫：

teams_users = 
from(t in Team, where: t.owner_id == ^user_id) 
|> Repo.all() 
|> Enum.each(&team_users/1) 

但是，這樣做會引入n + 1個查詢。您將進行一次查詢以獲取您的團隊，然後再查詢另一個團隊用戶。你應該看看Repo.preload/2。

teams_users = 
    from(t in Team, where: t.owner_id == ^user_id) 
    |> Repo.all() 
    |> Repo.preload(:team_users)