版本要求

PostgreSQL: 9.6, 10, 11, 12 +

连接器：flink-cdc-connectors

操作步骤

1. 更改wal日志方式为logical

wal_level = logical # minimal, replica, or logical

阿里云中修改参数设置会实例重启，谨慎操作

1. 修改域信息，保证本机可以连接

1. 新建用户

CREATE USER user WITH PASSWORD 'pwd';

1. 给用户复制流权限

ALTER ROLE user replication;

1. 给用户数据库权限

grant CONNECT,CREATE ON DATABASE test to user;

1. 把当前库public下所有表查询权限赋给用户（可选部分表）

GRANT SELECT ON cgm_device TO user;

1. 发布表

CREATE PUBLICATION dbz_publication FOR TABLE  cgm_device,cgm_user_info,cgm_user_action,cgm_user_patient;

查询哪些表已经发布

select * from pg_publication_tables;

其他命令

-- 赋予权限 GRANT privilege_list | ALL ON table_name TO  role_name;

GRANT SELECT ON  cgm_device TO dev_user;

-- 权限回收

REVOKE ALL ON ALL TABLES IN SCHEMA public FROM dev_user;

-- 查看某用户的系统权限

SELECT * FROM  pg_roles WHERE rolname='dev_user';

-- 查询当前用户 所有表权限

SELECT * FROM information_schema.table_privileges WHERE grantee = 'dev_user'

-- 查看户在某表的列上的权限

select * from information_schema.column_privileges where grantee='dev_user';

-- 查看usage权限表

SELECT * FROM information_schema.usage_privileges WHERE grantee = 'dev_user'

-- 查看当前用户能够访问的数据类型

select * from information_schema.data_type_privileges;