版本要求

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;

總結

以上是生活随笔為你收集整理的flink-cdc 同步 Postgre SQL 基本配置【1】的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。