Merge pull request #12 from agraven/migration-files

Move migration changes to separate files
This commit is contained in:
Diggory Blake 2021-09-21 14:01:40 +01:00 committed by GitHub
commit ab35a58716
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
8 changed files with 46 additions and 46 deletions

View file

@ -1,5 +1,3 @@
DROP FUNCTION mq_clear;
DROP FUNCTION mq_clear_all;
DROP FUNCTION mq_checkpoint; DROP FUNCTION mq_checkpoint;
DROP FUNCTION mq_keep_alive; DROP FUNCTION mq_keep_alive;
DROP FUNCTION mq_delete; DROP FUNCTION mq_delete;

View file

@ -287,24 +287,3 @@ RETURNS VOID AS $$
id = msg_id; id = msg_id;
$$ LANGUAGE SQL; $$ LANGUAGE SQL;
-- Deletes all messages from a list of channel names.
CREATE FUNCTION mq_clear(channel_names TEXT[])
RETURNS VOID AS $$
BEGIN
WITH deleted_ids AS (
DELETE FROM mq_msgs WHERE channel_name = ANY(channel_names) RETURNING id
)
DELETE FROM mq_payloads WHERE id IN (SELECT id FROM deleted_ids);
END;
$$ LANGUAGE plpgsql;
-- Deletes all messages.
CREATE FUNCTION mq_clear_all()
RETURNS VOID AS $$
BEGIN
WITH deleted_ids AS (
DELETE FROM mq_msgs RETURNING id
)
DELETE FROM mq_payloads WHERE id IN (SELECT id FROM deleted_ids);
END;
$$ LANGUAGE plpgsql;

View file

@ -0,0 +1,2 @@
DROP FUNCTION mq_clear;
DROP FUNCTION mq_clear_all;

View file

@ -0,0 +1,21 @@
-- Deletes all messages from a list of channel names.
CREATE FUNCTION mq_clear(channel_names TEXT[])
RETURNS VOID AS $$
BEGIN
WITH deleted_ids AS (
DELETE FROM mq_msgs WHERE channel_name = ANY(channel_names) RETURNING id
)
DELETE FROM mq_payloads WHERE id IN (SELECT id FROM deleted_ids);
END;
$$ LANGUAGE plpgsql;
-- Deletes all messages.
CREATE FUNCTION mq_clear_all()
RETURNS VOID AS $$
BEGIN
WITH deleted_ids AS (
DELETE FROM mq_msgs RETURNING id
)
DELETE FROM mq_payloads WHERE id IN (SELECT id FROM deleted_ids);
END;
$$ LANGUAGE plpgsql;

View file

@ -1,5 +1,3 @@
DROP FUNCTION mq_clear;
DROP FUNCTION mq_clear_all;
DROP FUNCTION mq_checkpoint; DROP FUNCTION mq_checkpoint;
DROP FUNCTION mq_keep_alive; DROP FUNCTION mq_keep_alive;
DROP FUNCTION mq_delete; DROP FUNCTION mq_delete;

View file

@ -287,24 +287,3 @@ RETURNS VOID AS $$
id = msg_id; id = msg_id;
$$ LANGUAGE SQL; $$ LANGUAGE SQL;
-- Deletes all messages from a list of channel names.
CREATE FUNCTION mq_clear(channel_names TEXT[])
RETURNS VOID AS $$
BEGIN
WITH deleted_ids AS (
DELETE FROM mq_msgs WHERE channel_name = ANY(channel_names) RETURNING id
)
DELETE FROM mq_payloads WHERE id IN (SELECT id FROM deleted_ids);
END;
$$ LANGUAGE plpgsql;
-- Deletes all messages.
CREATE FUNCTION mq_clear_all()
RETURNS VOID AS $$
BEGIN
WITH deleted_ids AS (
DELETE FROM mq_msgs RETURNING id
)
DELETE FROM mq_payloads WHERE id IN (SELECT id FROM deleted_ids);
END;
$$ LANGUAGE plpgsql;

View file

@ -0,0 +1,2 @@
DROP FUNCTION mq_clear;
DROP FUNCTION mq_clear_all;

View file

@ -0,0 +1,21 @@
-- Deletes all messages from a list of channel names.
CREATE FUNCTION mq_clear(channel_names TEXT[])
RETURNS VOID AS $$
BEGIN
WITH deleted_ids AS (
DELETE FROM mq_msgs WHERE channel_name = ANY(channel_names) RETURNING id
)
DELETE FROM mq_payloads WHERE id IN (SELECT id FROM deleted_ids);
END;
$$ LANGUAGE plpgsql;
-- Deletes all messages.
CREATE FUNCTION mq_clear_all()
RETURNS VOID AS $$
BEGIN
WITH deleted_ids AS (
DELETE FROM mq_msgs RETURNING id
)
DELETE FROM mq_payloads WHERE id IN (SELECT id FROM deleted_ids);
END;
$$ LANGUAGE plpgsql;