将 Ecto Schema 转储到其数据库表示

Question

我有一个存储过程，需要使用 Ecto Schema 中的几个字段作为参数来调用：

Ecto.Adapters.SQL.query(My.Repo, "CALL my_stored_procedure($1, $2, $3)", [myschema.id, myschema.field1, myschema.field2])

当函数调用有效时，我传入 Elixir 值，而不是它们的数据库表示形式。如果不先转储到数据库类型，则无法使用 Elixir 值。例如，一个字段是一个 Ecto.Enum，它在 Elixir 中表示为一个原子，但实际上在数据库中是一个不同的字符串值。我需要将每个字段“转储”到其数据库类型，就像插入记录时 Ecto.Repo.insert/2 处理所有字段一样。我在文档中没有看到任何 Ecto 辅助函数来促进这一点。

Answer 1

您可以对 Ecto 架构进行一些检查，但不幸的是，架构模块不包含有关实际迁移的数据的完整信息。这是我所能达到的最接近的结果：检查模块的结构及其 __changeset__/0 函数。您最终会得到这样的结果：

defmodule SchemaInspector do

  def inspect_schema(module) do
    %{
      source: module,
      fields:
        module.__struct__()
        |> Map.from_struct()
        |> Map.delete(:__meta__)
        |> Enum.map(fn {fieldname, default} ->
          %{name: fieldname, type: fieldtype(module, fieldname), default: default}
        end)
    }
  end

  defp fieldtype(module, fieldname) do
    module.__changeset__()
    |> Map.get(fieldname)
    |> case do
      {:embed, %Ecto.Embedded{cardinality: :many, related: related}} -> "ARRAY(#{related})"
      other -> other
    end
  end
end

然后您可以在其中传递 Elixir Ecto 架构模块名称，例如：

iex> SchemaInspector.inspect_schema(SomeModel)
%{
    fields: [
      %{default: nil, name: :created_at, type: :naive_datetime},
      %{default: nil, name: :created_by, type: :string},
      %{default: nil, name: :creation_date, type: :naive_datetime},
      %{default: nil, name: :id, type: :string},
      %{default: nil, name: :some_number, type: :integer},
      %{default: nil, name: :status, type: :string},
      %{default: nil, name: :updated_at, type: :naive_datetime}
    ],
    source: SomeModel
  }

模块的 __changeset__/0 函数包含有关数据类型的一些信息，但可能还不够满足您的需求。

我编写了一个相关的包来帮助完成此任务：https://hex.pm/packages/inspecto

Answer 2

我最终这样做了：

# Build a dummy update query
query = from(m in MySchema, update: [set: [id: ^myschema.id,
  field1: ^myschema.field1,
  field2: ^myschema.field2]])

# Pass the query to to_sql/2 so we get the raw query and the parameters
# converted to database types
{_query, params} = Repo.to_sql(:update_all, query)

# Then we invoke the stored procedure query with the converted parameters
sql = "CALL my_stored_procedure(:1, :2, :3)"
Ecto.Adapters.SQL.query(Repo, sql, params)

这感觉很hacky，但这是让 Ecto 为我进行转换的最直接的方法。