mirror of
https://github.com/Diggsey/sqlxmq.git
synced 2024-11-25 09:41:01 +00:00
16 lines
482 B
MySQL
16 lines
482 B
MySQL
|
CREATE OR REPLACE FUNCTION mq_latest_message(from_channel_name TEXT, from_channel_args TEXT)
|
||
|
|
RETURNS UUID AS $$
|
||
|
|
SELECT COALESCE(
|
||
|
|
(
|
||
|
|
SELECT id FROM mq_msgs
|
||
|
|
WHERE channel_name = from_channel_name
|
||
|
|
AND channel_args = from_channel_args
|
||
|
|
AND after_message_id IS NOT NULL
|
||
|
|
AND id != uuid_nil()
|
||
|
|
ORDER BY created_at DESC, id DESC
|
||
|
|
LIMIT 1
|
||
|
|
),
|
||
|
|
uuid_nil()
|
||
|
|
)
|
||
|
|
$$ LANGUAGE SQL STABLE;
|