Current section

Files

Jump to
eventstore lib event_store storage initializer.ex
Raw

lib/event_store/storage/initializer.ex

defmodule EventStore.Storage.Initializer do
@moduledoc false
alias EventStore.Sql.Statements
def run!(conn), do: execute(conn, Statements.initializers())
def reset!(conn), do: execute(conn, Statements.reset())
defp execute(conn, statements) do
Enum.each(statements, &(Postgrex.query!(conn, &1, [], pool: DBConnection.Poolboy)))
end
end