decoder_raw

pig build pkg decoder_raw;		# build rpm/deb

pig repo add pgsql -u   # add both repo and update cache

pig install decoder_raw;		# install via package name, for the active PG version

pig install decoder_raw -v 18;   # install for PG 18
pig install decoder_raw -v 17;   # install for PG 17
pig install decoder_raw -v 16;   # install for PG 16
pig install decoder_raw -v 15;   # install for PG 15
pig install decoder_raw -v 14;   # install for PG 14

wal_level = logical
max_replication_slots = 10
max_wal_senders = 10

-- Create a logical replication slot
SELECT * FROM pg_create_logical_replication_slot('raw_slot', 'decoder_raw');

-- Perform DML operations
INSERT INTO my_table VALUES (1, 'hello');
UPDATE my_table SET val = 'world' WHERE id = 1;
DELETE FROM my_table WHERE id = 1;

-- Get changes as raw SQL
SELECT data FROM pg_logical_slot_get_changes('raw_slot', NULL, NULL);
-- Output:
-- INSERT INTO public.my_table (id, val) VALUES (1, 'hello');
-- UPDATE public.my_table SET val = 'world' WHERE id = 1;
-- DELETE FROM public.my_table WHERE id = 1;

-- Drop the slot
SELECT pg_drop_replication_slot('raw_slot');

# Create slot
pg_recvlogical -d postgres --slot raw_slot --create-slot -P decoder_raw

# Stream changes as SQL statements
pg_recvlogical -d postgres --slot raw_slot --start -f -

# Drop slot
pg_recvlogical -d postgres --slot raw_slot --drop-slot