Как использовать raw sql с ecto Repo

В Ecto 2.0 (бета) с Postgres вы можете использовать Ecto.Adapters.SQL.query() (текущие документы, 2.0-beta2 docs) для выполнения произвольного SQL; в дополнение к списку самих строк («rows») он возвращает список имен столбцов («columns»).

В приведенном ниже примере я

1. запустить собственный запрос без параметров,
2. преобразовать имена столбцов результата из строк в атомы и
3. объедините их с каждой строкой результатов и сопоставьте их в структуру с помощью Kernel.struct ()

(Вы, вероятно, захотите запустить версию query() (без шума!) И проверить {ok, res}.)

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

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

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

Теперь, когда 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 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__

Помимо 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

См. https://hexdocs.pm/ecto/Ecto.Repo.html#c:load/2

Ecto, по крайней мере, с версии ~> 0.7 вы должны использовать:

Ecto.Adapters.SQL.query / 4

def query(repo, sql, params, opts \\ [])

Выполняет пользовательский SQL-запрос для данного репо.

В случае успеха он должен вернуть кортеж: ok, содержащий карту как минимум с двумя ключами:

•: num_rows - количество затронутых строк •: rows - набор результатов в виде списка. nil может быть возвращен вместо списка, если команда не дает ни одной строки в качестве результата (но все же дает количество затронутых строк, как команда удаления без возврата)

Параметры

•: timeout - время ожидания завершения вызова в миллисекундах,: infinity будет ждать бесконечно (по умолчанию: 5000) •: log - если false, запрос не заносится в журнал.

Примеры

iex> Ecto.Adapters.SQL.query (MyRepo, «ВЫБРАТЬ $ 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)