oracle 开启 cdc

涉及到的表
TTRD_OTC_TRADE

首先需要确认数据库已经开启归档模式

数据库需要执行的语句总结如下
-- 为捕获的数据库启用补充日志记录,以便数据更改捕获更改的数据库行之前的状态,下面说明了如何在数据库级别进行配置。
ALTER DATABASE ADD SUPPLEMENTAL LOG DATA;
-- 修改TREALDEAL表让其支持增量日志
ALTER TABLE TTRD_OTC_TRADE ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS;
-- 给用户赋权限
GRANT RESOURCE,EXECUTE_CATALOG_ROLE,SELECT_CATALOG_ROLE TO datacenter;
GRANT SELECT ANY TRANSACTION,SELECT ANY DICTIONARY,LOCK ANY TABLE TO datacenter;

基于oracle的flink cdc
首先要求数据库开启archiving归档模式，其次需要对所抓取的表TTRD_OTC_TRADE开启增量日志，开启之后cdc会使用oracle工具LOGMINNER对日志进行挖掘
根据官方文档，会对以下表进行读取
V_$LOG
V_$LOG_HISTORY
V_$LOGMNR_LOGS
V_$LOGMNR_CONTENTS
V_$LOGMNR_PARAMETERS
V_$LOGFILE
V_$ARCHIVED_LOG
V_$ARCHIVE_DEST_STATUS
同时会创建一张表LOG_MINING_FLUSH记录游标，并在每次抓取增量日志后更新此游标信息

查询是否成功

alter database add supplemental log data;

alter database add supplemental log data (primary key,unique index) columns ;

然后,通过一下命令去查询是否开启:

select supplemental_log_data_min,SUPPLEMENTAL_LOG_DATA_PK,SUPPLEMENTAL_LOG_DATA_UI

from v$database;

SUPPLEME SUP SUP
-------- --- ---
YES YES YES