irpas技术客

flink-cdc 同步 Postgre SQL 基本配置【1】_小野猪佩奇

irpas 1932

版本要求

PostgreSQL: 9.6, 10, 11, 12 +

连接器:flink-cdc-connectors

操作步骤 更改wal日志方式为logical

wal_level = logical # minimal, replica, or logical

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

修改域信息,保证本机可以连接

新建用户

CREATE USER user WITH PASSWORD 'pwd';

给用户复制流权限

ALTER ROLE user replication;

给用户数据库权限

grant CONNECT,CREATE ON DATABASE test to user;

把当前库public下所有表查询权限赋给用户(可选部分表)

GRANT SELECT ON cgm_device TO user;

发布表

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;


1.本站遵循行业规范,任何转载的稿件都会明确标注作者和来源;2.本站的原创文章,会注明原创字样,如未注明都非原创,如有侵权请联系删除!;3.作者投稿可能会经我们编辑修改或补充;4.本站不提供任何储存功能只提供收集或者投稿人的网盘链接。

标签: #Flinkcdc #同步 #postgre #SQL #基本配置1 #版本要求PostgreSQL #96