-- 创建复制用户（在 Host1 主库上运行）
DO $$
BEGIN
  IF NOT EXISTS (SELECT FROM pg_catalog.pg_roles WHERE rolname = 'replicator') THEN
    CREATE ROLE replicator WITH REPLICATION LOGIN PASSWORD 'Bjang09@686^*^';
  END IF;
END
$$;

-- 创建复制槽（用于主从复制）
SELECT pg_create_physical_replication_slot('replication_slot_slave')
WHERE NOT EXISTS (SELECT 1 FROM pg_replication_slots WHERE slot_name = 'replication_slot_slave');