mirror of
https://github.com/fly-apps/live_beats.git
synced 2024-05-18 01:02:42 +00:00
24 lines
576 B
Elixir
24 lines
576 B
Elixir
defmodule LiveBeats.Repo do
|
|
use Ecto.Repo,
|
|
otp_app: :live_beats,
|
|
adapter: Ecto.Adapters.Postgres
|
|
|
|
def replica, do: LiveBeats.config([:replica])
|
|
|
|
@locks %{playlist: 1}
|
|
|
|
def multi_transaction_lock(multi, scope, id) when is_atom(scope) and is_integer(id) do
|
|
scope_int = Map.fetch!(@locks, scope)
|
|
|
|
Ecto.Multi.run(multi, scope, fn repo, _changes ->
|
|
repo.query("SELECT pg_advisory_xact_lock(#{scope_int}, #{id})")
|
|
end)
|
|
end
|
|
end
|
|
|
|
defmodule LiveBeats.ReplicaRepo do
|
|
use Ecto.Repo,
|
|
otp_app: :live_beats,
|
|
adapter: Ecto.Adapters.Postgres
|
|
end
|