Current section
Files
Jump to
Current section
Files
lib/queuetopia/migrations/v4.ex
defmodule Queuetopia.Migrations.V4 do
@moduledoc false
use Ecto.Migration
def up do
case repo().__adapter__() do
Ecto.Adapters.Postgres ->
execute("""
create or replace function queuetopia_nextval_gapless_sequence()
returns bigint
language plpgsql
as
$$
declare
next_value bigint := 1;
begin
update queuetopia_sequences set sequence = sequence + 1 returning sequence into next_value;
return next_value;
end;
$$
""")
Ecto.Adapters.MyXQL ->
execute("""
DROP FUNCTION IF EXISTS queuetopia_nextval_gapless_sequence;
""")
execute("""
CREATE FUNCTION queuetopia_nextval_gapless_sequence()
RETURNS INTEGER DETERMINISTIC
begin
declare next_value INTEGER;
update queuetopia_sequences set sequence = LAST_INSERT_ID(sequence+1);
select LAST_INSERT_ID() into next_value;
RETURN next_value;
end;
""")
end
end
def down do
execute("""
DROP FUNCTION IF EXISTS queuetopia_nextval_gapless_sequence;
""")
end
end