test.sql
application/octet-stream
Filename: test.sql
Type: application/octet-stream
Part: 1
SELECT pg_create_logical_replication_slot('test_slot', 'test_decoding');
--ALTER SYSTEM SET max_files_per_process = 26;
CREATE TABLE decoding_test(x integer, y text);
do $$
BEGIN
FOR i IN 1..10 LOOP
BEGIN
INSERT INTO decoding_test(x) SELECT generate_series(1,3000);
EXCEPTION
when division_by_zero then perform 'dummy';
END;
END LOOP;
END $$;
SELECT data from pg_logical_slot_get_changes('test_slot', NULL, NULL) LIMIT 10;