如何将原始sql与ecto Repo一起使用

Question

我有一个upsert需求，所以我需要调用postgres存储过程或使用公共表表达式。我还将pgcrypto扩展用于密码，并希望使用postgres函数（例如“crypt”来编码/解码密码）。

但是我找不到让ecto部分或全部使用原始sql的方法，是不是打算让ecto只支持长生不老的dsl，而不允许在dsl不够用的情况下使用原始sql？

我发现我可以通过适配器进行查询（Rocket是应用程序的名称）

q = Ecto.Adapters.Postgres.query(Rocket.Repo,"select * from users limit 1",[])

但不确定如何将其带到模型中。我是长生不老药的新手，似乎我应该能够使用 Ecto.Model.Schem.schema/3，但这失败了

Rocket.User.__schema__(:load,q.rows |> List.first,0)
** (FunctionClauseError) no function clause matching in Rocket.User.__schema__/3    

Answer 1

现在 Ecto 1.0 已经出来了，这应该可以工作一段时间：

将以下函数添加到Repo模块中：

def execute_and_load(sql, params, model) do
  Ecto.Adapters.SQL.query!(__MODULE__, sql, params)
  |> load_into(model)
end

defp load_into(response, model) do
  Enum.map response.rows, fn(row) ->
    fields = Enum.reduce(Enum.zip(response.columns, row), %{}, fn({key, value}, map) ->
      Map.put(map, key, value)
    end)

    Ecto.Schema.__load__(model, nil, nil, [], fields, &__MODULE__.__adapter__.load/2)
  end
end

并照此使用:

Repo.execute_and_load("SELECT * FROM users WHERE id = $1", [1], User)

Answer 2

ECTO 2.0的修改解决方案：

在repo.ex中：

  def execute_and_load(sql, params, model) do
    Ecto.Adapters.SQL.query!(__MODULE__, sql, params)
    |> load_into(model)
  end

  defp load_into(response, model) do
    Enum.map(response.rows, fn row ->
      fields = Enum.reduce(Enum.zip(response.columns, row), %{}, fn({key, value}, map) ->
        Map.put(map, key, value)
      end)
      Ecto.Schema.__load__(model, nil, nil, nil, fields,
                           &Ecto.Type.adapter_load(__adapter__, &1, &2))
    end)
  end

用法：

Repo.execute_and_load("SELECT * FROM users WHERE id = $1", [1], User)

更新：对于Ecto 3，您可以使用__MODULE__.load（model，fields）而不是Ecto.Schema.__load__

Answer 3

在带有Postgres的Ecto 2.0（beta版）上，您可以使用＜code＞Ecto.Adapters.SQL。query（）（当前文档，2.0-beta2文档）执行任意SQL；除了行本身的列表（“rows”）之外，它还碰巧返回了列名列表（“columns”）。

在下面的示例中，I

1. 运行不带参数的自定义查询，
2. 将结果的列名从字符串转换为原子，以及
3. 将它们与结果的每一行合并，并使用 Kernel.struct（） 将其映射到结构中

（您可能希望运行query（）版本（没有爆炸！）并检查＜code＞｛ok，res｝＜/code＞。）

qry = "SELECT * FROM users"
res = Ecto.Adapters.SQL.query!(Repo, qry, []) # 1

cols = Enum.map res.columns, &(String.to_atom(&1)) # 2

roles = Enum.map res.rows, fn(row) ->
  struct(MyApp.User, Enum.zip(cols, row)) # 3
end