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