Current section

Files

Jump to
eventstore lib event_store storage initializer.ex
Raw

lib/event_store/storage/initializer.ex

defmodule EventStore.Storage.Initializer do
alias EventStore.Sql.Statements
def run!(conn) do
Statements.initializers
|> Enum.each(&(Postgrex.query!(conn, &1, [])))
end
def reset!(conn) do
Postgrex.query!(conn, Statements.truncate_tables, [])
end
end