版本要求

PostgreSQL: 9.6, 10, 11, 12 +

連接器：flink-cdc-connectors

操作步驟

更改wal日志方式為logical

wal_level = logical # minimal, replica, or logical

阿里云中修改參數(shù)設(shè)置會(huì)實(shí)例重啟，謹(jǐn)慎操作

修改域信息，保證本機(jī)可以連接

新建用戶

CREATE USER user WITH PASSWORD 'pwd';

給用戶復(fù)制流權(quán)限

ALTER ROLE user replication;

給用戶數(shù)據(jù)庫(kù)權(quán)限

grant CONNECT,CREATE ON DATABASE test to user;

把當(dāng)前庫(kù)public下所有表查詢權(quán)限賦給用戶（可選部分表）

GRANT SELECT ON cgm_device TO user;

發(fā)布表

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

查詢哪些表已經(jīng)發(fā)布

select * from pg_publication_tables;

其他命令

-- 賦予權(quán)限 GRANT privilege_list | ALL ON table_name TO? role_name;

GRANT SELECT ON? cgm_device TO dev_user;

-- 權(quán)限回收

REVOKE ALL ON ALL TABLES IN SCHEMA public FROM dev_user;

-- 查看某用戶的系統(tǒng)權(quán)限

SELECT * FROM? pg_roles WHERE rolname='dev_user';

-- 查詢當(dāng)前用戶 所有表權(quán)限

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

-- 查看戶在某表的列上的權(quán)限

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

-- 查看usage權(quán)限表

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

-- 查看當(dāng)前用戶能夠訪問的數(shù)據(jù)類型

select * from information_schema.data_type_privileges;

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。