decoder_raw

pig build pkg decoder_raw         # 构建 RPM / DEB 包

pig repo add pgsql -u          # 添加仓库并更新缓存

wal_level = logical
max_replication_slots = 10
max_wal_senders = 10

-- 创建逻辑复制槽
SELECT * FROM pg_create_logical_replication_slot('raw_slot', 'decoder_raw');

-- 执行 DML 操作
INSERT INTO my_table VALUES (1, 'hello');
UPDATE my_table SET val = 'world' WHERE id = 1;
DELETE FROM my_table WHERE id = 1;

-- 获取原始 SQL 变更
SELECT data FROM pg_logical_slot_get_changes('raw_slot', NULL, NULL);
-- 输出：
-- 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;

-- 删除槽
SELECT pg_drop_replication_slot('raw_slot');

# 创建槽
pg_recvlogical -d postgres --slot raw_slot --create-slot -P decoder_raw

# 流式传输 SQL 语句变更
pg_recvlogical -d postgres --slot raw_slot --start -f -

# 删除槽
pg_recvlogical -d postgres --slot raw_slot --drop-slot