我有一个upsert需求，需要调用Postgres存储过程或使用公共表达式。我还使用pgcrypto扩展来处理密码，并且希望使用Postgres函数（如“crypt”）来编码/解码密码。
但是我找不到在Ecto中使用部分或全部原始SQL的方法，这意味着Ecto只支持Elixir DSL并且不允许在DSL不足时切换到原始SQL吗？
我发现我可以通过适配器查询（Rocket是应用程序的名称）。
q = Ecto.Adapters.Postgres.query(Rocket.Repo,"select * from users limit 1",[])
但不确定如何将此传递给模型。我新手使用 Elixir，似乎应该能够使用 Ecto.Model.Schema.schema/3，但这会失败。
Rocket.User.__schema__(:load,q.rows |> List.first,0)
** (FunctionClauseError) no function clause matching in Rocket.User.__schema__/3
Ecto.Adapters.SQL.query()（当前文档，2.0-beta2文档）执行任意SQL查询; 除了返回行本身的列表外（“rows”），它还会返回列名的列表（“columns”）。在下面的示例中，我：
（您可能想要运行没有感叹号! 的query()版本并检查{ok, res}。）
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
Kernel.struct将绕过模式的类型转换，因此如果将changeset作为最后一个函数调用，则认为这将起作用。但是，我只想获取changeset.data（快速阅读2.0文档），那现在它是结构体的引用？ - Krut针对 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)
__MODULE__.load(model, fields)代替Ecto.Schema.__load__。现在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)
除了Ecto.Adapters.SQL.query/4之外，还有Ecto.Query.API.fragment/1可以用于向数据库发送查询表达式。例如，要使用Postgres的数组函数array_upper，可以使用以下方法：
Ecto.Query.where([x], fragment("array_upper(some_array_field, 1)]" == 1)
Ecto 2.2.8提供了Ecto.Query.load/2，因此您可以像这样操作：
use Ecto.Repo
def execute_and_load(sql, params, model) do
result = query!(sql, params)
Enum.map(result.rows, &load(model, {result.columns, &1}))
end
如果是Ecto版本大于0.7，建议使用以下方法：
Ecto.Adapters.SQL.query/4
def query(repo, sql, params, opts \\ [])
在给定的存储库上运行自定义SQL查询。
如果成功，它必须返回一个包含至少两个键的map的 :ok 元组:
• :num_rows - 受影响的行数 • :rows - 结果集的列表形式。如果命令没有产生任何行作为结果(但仍然产生了受影响的行数, 如不返回删除命令), 可以返回 nil。
选项
• :timeout - 调用完成的等待时间（以毫秒为单位），:infinity 将无限期地等待 (默认值：5000) • :log - 当为 false 时，不记录查询日志
例子
iex> Ecto.Adapters.SQL.query(MyRepo, "SELECT $1 + $2", [40, 2])
%{rows: [{42}], num_rows: 1}
这是 https://stackoverflow.com/users/1758892/thousandsofthem 的示例，但缩小了一点点（由他/她提供）
defmodule MyApp.Repo do
[...]
def execute_and_load(sql, params, schema) do
response = query!(sql, params)
Enum.map(response.rows, fn row ->
fields = Enum.zip(response.columns, row) |> Enum.into(%{})
Ecto.Schema.__load__(schema, nil, nil, nil, fields,
&Ecto.Type.adapter_load(__adapter__(), &1, &2))
end)
end
end
至少使用 Ecto 4.0，您可以使用适配器进行查询，然后将结果提供给 Ecto.Model.schema/3：
q = Ecto.Adapters.Postgres.query(Rocket.Repo,"select * from users limit 1",[])
Rocket.User.__schema__(:load,q.rows |> List.first,0)
__schema__(:load, ..., ...)是否应该直接这样使用有矛盾的感觉...但你的解决方案非常适合当前的代码！ - José Valim