Packages
eventstore
1.3.2
1.4.8
1.4.7
1.4.6
1.4.4
1.4.3
1.4.2
1.4.1
1.4.0
1.3.2
1.3.1
1.3.0
1.2.3
1.2.2
1.2.1
1.2.0
1.1.0
1.0.3
1.0.2
1.0.1
1.0.0
1.0.0-rc.0
0.17.0
0.16.2
0.16.1
0.16.0
0.15.1
0.15.0
0.14.0
0.14.0-rc.0
0.13.2
0.13.1
0.13.0
0.12.1
0.12.0
0.11.0
0.11.0-rc.0
0.10.1
0.10.0
0.9.0
0.8.1
0.8.0
0.7.4
0.7.3
0.7.2
0.7.1
0.7.0
0.6.2
0.6.1
0.6.0
0.5.2
0.5.1
0.5.0
0.4.3
0.4.2
0.4.1
0.4.0
0.3.0
0.2.1
0.2.0
0.1.0
0.0.5
0.0.4
0.0.3
0.0.2
0.0.1
Event store using PostgreSQL for persistence.
Current section
Files
Jump to
Current section
Files
lib/event_store/sql/statements.ex
defmodule EventStore.Sql.Statements do
@moduledoc false
require EEx
alias EventStore.Sql.{Init, Reset}
defdelegate initializers(config), to: Init, as: :statements
defdelegate reset(config), to: Reset, as: :statements
for {fun, args} <- [
{:create_stream, [:schema]},
{:insert_events, [:schema, :stream_id, :number_of_events]},
{:insert_events_any_version, [:schema, :stream_id, :number_of_events]},
{:insert_link_events, [:schema, :number_of_events]},
{:soft_delete_stream, [:schema]},
{:hard_delete_stream, [:schema]},
{:insert_subscription, [:schema]},
{:delete_subscription, [:schema]},
{:try_advisory_lock, [:schema]},
{:advisory_unlock, [:schema]},
{:subscription_ack, [:schema]},
{:insert_snapshot, [:schema]},
{:delete_snapshot, [:schema]},
{:query_all_subscriptions, [:schema]},
{:query_subscription, [:schema]},
{:query_stream_info, [:schema]},
{:query_snapshot, [:schema]},
{:query_stream_events_backward, [:schema]},
{:query_stream_events_forward, [:schema]}
] do
file = Path.expand("statements/#{fun}.sql.eex", __DIR__)
@external_resource file
EEx.function_from_file(:def, fun, file, args, engine: EventStore.EExIOListEngine)
end
end