跳到主要内容
版本：3.0.0

Oracle CDC

Oracle CDC 数据源连接器

支持的引擎​

SeaTunnel Zeta
Flink

关键特性​

描述​

Oracle CDC 连接器允许从 Oracle 数据库读取快照数据和增量数据。本文档描述了如何设置 Oracle CDC 连接器以针对 Oracle 数据库运行 SQL 查询。

注意​

Debezium Oracle 连接器不依赖于连续挖掘（continuous mining）选项。该连接器负责检测日志切换并自动调整正在挖掘的日志，这正是连续挖掘选项自动为您完成的工作。 因此，您不能在 debezium 中设置名为 log.mining.continuous.mine 的属性。

支持的数据源信息​

数据源支持的版本驱动类UrlMaven
Oracle不同的依赖版本有不同的驱动类。oracle.jdbc.OracleDriverjdbc:oracle:thin:@datasource01:1523:xehttps://mvnrepository.com/artifact/com.oracle.database.jdbc/ojdbc8

数据库依赖​

安装 Jdbc 驱动​

  1. 您需要确保 jdbc 驱动 jar 包 已放置在 ${SEATUNNEL_HOME}/plugins/ 目录下。
  2. 为了支持 i18n 字符集，请将 orai18n.jar 复制到 $SEATUNNEL_HOME/plugins/ 目录。

适用于 SeaTunnel Zeta 引擎​

  1. 您需要确保 jdbc 驱动 jar 包 已放置在 ${SEATUNNEL_HOME}/lib/ 目录下。
  2. 为了支持 i18n 字符集，请将 orai18n.jar 复制到 $SEATUNNEL_HOME/lib/ 目录。

启用 Oracle Logminer​

要在 Seatunnel 中使用 Logminer（Oracle 提供的内置工具）启用 Oracle CDC（变更数据捕获），请按照以下步骤操作：

在非 CDB（容器数据库）模式下启用 Logminer。​

  1. 操作系统创建一个空的目录来存储 Oracle 归档日志和用户表空间。
mkdir -p /opt/oracle/oradata/recovery_area
mkdir -p /opt/oracle/oradata/ORCLCDB
chown -R oracle /opt/oracle/***
  1. 以管理员身份登录并启用 Oracle 归档日志。
sqlplus /nolog;
connect sys as sysdba;
alter system set db_recovery_file_dest_size = 10G;
alter system set db_recovery_file_dest = '/opt/oracle/oradata/recovery_area' scope=spfile;
shutdown immediate;
startup mount;
alter database archivelog;
alter database open;
ALTER DATABASE ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS;
archive log list;
  1. 以管理员身份登录并创建一个名为 logminer_user 的账户，密码为 "oracle"，并授予其读取表和日志的权限。
CREATE TABLESPACE logminer_tbs DATAFILE '/opt/oracle/oradata/ORCLCDB/logminer_tbs.dbf' SIZE 25M REUSE AUTOEXTEND ON MAXSIZE UNLIMITED;
CREATE USER logminer_user IDENTIFIED BY oracle DEFAULT TABLESPACE logminer_tbs QUOTA UNLIMITED ON logminer_tbs;

GRANT CREATE SESSION TO logminer_user;
GRANT SELECT ON V_$DATABASE to logminer_user;
GRANT SELECT ON V_$LOG TO logminer_user;
GRANT SELECT ON V_$LOGFILE TO logminer_user;
GRANT SELECT ON V_$LOGMNR_LOGS TO logminer_user;
GRANT SELECT ON V_$LOGMNR_CONTENTS TO logminer_user;
GRANT SELECT ON V_$ARCHIVED_LOG TO logminer_user;
GRANT SELECT ON V_$ARCHIVE_DEST_STATUS TO logminer_user;
GRANT EXECUTE ON DBMS_LOGMNR TO logminer_user;
GRANT EXECUTE ON DBMS_LOGMNR_D TO logminer_user;
GRANT SELECT ANY TRANSACTION TO logminer_user;
GRANT SELECT ON V_$TRANSACTION TO logminer_user;
注意：Oracle 11g 不支持以下命令​
GRANT LOGMINING TO logminer_user;
仅授予需要采集的表的权限​
GRANT SELECT ANY TABLE TO logminer_user;
GRANT ANALYZE ANY TO logminer_user;

在 Oracle CDB (容器数据库) + PDB (可插拔数据库) 模式下启用 Logminer​

  1. 操作系统创建一个空的目录来存储 Oracle 归档日志和用户表空间。
mkdir -p /opt/oracle/oradata/recovery_area
mkdir -p /opt/oracle/oradata/ORCLCDB
mkdir -p /opt/oracle/oradata/ORCLCDB/ORCLPDB1
chown -R oracle /opt/oracle/***
  1. 以管理员身份登录并启用日志记录
sqlplus /nolog
connect sys as sysdba; # 密码: oracle
alter system set db_recovery_file_dest_size = 10G;
alter system set db_recovery_file_dest = '/opt/oracle/oradata/recovery_area' scope=spfile;
shutdown immediate
startup mount
alter database archivelog;
alter database open;
archive log list;
  1. 在 CDB 中执行
ALTER TABLE TEST.* ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS;
ALTER TABLE TEST.T2 ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS;
  1. 创建 debeziume 账户

在 CDB 中操作

sqlplus sys/top_secret@//localhost:1521/ORCLCDB as sysdba
CREATE TABLESPACE logminer_tbs DATAFILE '/opt/oracle/oradata/ORCLCDB/logminer_tbs.dbf'
 SIZE 25M REUSE AUTOEXTEND ON MAXSIZE UNLIMITED;
exit;

在 PDB 中操作

sqlplus sys/top_secret@//localhost:1521/ORCLPDB1 as sysdba
 CREATE TABLESPACE logminer_tbs DATAFILE '/opt/oracle/oradata/ORCLCDB/ORCLPDB1/logminer_tbs.dbf'
   SIZE 25M REUSE AUTOEXTEND ON MAXSIZE UNLIMITED;
 exit;
  1. 在 CDB 中操作
sqlplus sys/top_secret@//localhost:1521/ORCLCDB as sysdba

CREATE USER c##dbzuser IDENTIFIED BY dbz
DEFAULT TABLESPACE logminer_tbs
QUOTA UNLIMITED ON logminer_tbs
CONTAINER=ALL;

GRANT CREATE SESSION TO c##dbzuser CONTAINER=ALL;
GRANT SET CONTAINER TO c##dbzuser CONTAINER=ALL;
GRANT SELECT ON V_$DATABASE to c##dbzuser CONTAINER=ALL;
GRANT FLASHBACK ANY TABLE TO c##dbzuser CONTAINER=ALL;
GRANT SELECT ANY TABLE TO c##dbzuser CONTAINER=ALL;
GRANT SELECT_CATALOG_ROLE TO c##dbzuser CONTAINER=ALL;
GRANT EXECUTE_CATALOG_ROLE TO c##dbzuser CONTAINER=ALL;
GRANT SELECT ANY TRANSACTION TO c##dbzuser CONTAINER=ALL;
GRANT LOGMINING TO c##dbzuser CONTAINER=ALL;

GRANT CREATE TABLE TO c##dbzuser CONTAINER=ALL;
GRANT LOCK ANY TABLE TO c##dbzuser CONTAINER=ALL;
GRANT CREATE SEQUENCE TO c##dbzuser CONTAINER=ALL;

GRANT EXECUTE ON DBMS_LOGMNR TO c##dbzuser CONTAINER=ALL;
GRANT EXECUTE ON DBMS_LOGMNR_D TO c##dbzuser CONTAINER=ALL;

GRANT SELECT ON V_$LOG TO c##dbzuser CONTAINER=ALL;
GRANT SELECT ON V_$LOG_HISTORY TO c##dbzuser CONTAINER=ALL;
GRANT SELECT ON V_$LOGMNR_LOGS TO c##dbzuser CONTAINER=ALL;
GRANT SELECT ON V_$LOGMNR_CONTENTS TO c##dbzuser CONTAINER=ALL;
GRANT SELECT ON V_$LOGMNR_PARAMETERS TO c##dbzuser CONTAINER=ALL;
GRANT SELECT ON V_$LOGFILE TO c##dbzuser CONTAINER=ALL;
GRANT SELECT ON V_$ARCHIVED_LOG TO c##dbzuser CONTAINER=ALL;
GRANT SELECT ON V_$ARCHIVE_DEST_STATUS TO c##dbzuser CONTAINER=ALL;
GRANT analyze any TO debeziume_1 CONTAINER=ALL;

exit;

数据类型映射​

Oracle 数据类型SeaTunnel 数据类型
INTEGERINT
FLOATDECIMAL(38, 18)
NUMBER(precision <= 9, scale == 0)INT
NUMBER(9 < precision <= 18, scale == 0)BIGINT
NUMBER(18 < precision, scale == 0)DECIMAL(38, 0)
NUMBER(precision == 0, scale == 0)DECIMAL(38, 18)
NUMBER(scale != 0)DECIMAL(38, 18)
BINARY_DOUBLEDOUBLE
BINARY_FLOAT
REAL		FLOAT
CHAR
NCHAR
NVARCHAR2
VARCHAR2
LONG
ROWID
NCLOB
CLOB
STRING
DATEDATE
TIMESTAMP
TIMESTAMP WITH LOCAL TIME ZONE		TIMESTAMP
BLOB
RAW
LONG RAW
BFILE		BYTES

源端选项​

参数名称类型是否必选默认值描述
urlString是-JDBC 连接的 URL，例如：jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB。
usernameString是-连接数据库服务器时使用的数据库用户名。
passwordString是-连接数据库服务器时使用的数据库密码。
database-namesList否-要监控的数据库名称。
schema-namesList否-要监控的数据库 Schema 名称。
table-namesList条件必填-要监控的数据库表名，建议使用 database.schema.table 格式，例如：ORCLCDB.DEBEZIUM.FULL_TYPES。table-names 和 table-pattern 二选一配置。
table-patternString条件必填-要捕获的表名正则表达式。table-names 和 table-pattern 二选一配置。
table-names-configList否-按表单独配置。例如：[{"table": "ORCLCDB.DEBEZIUM.FULL_TYPES","primaryKeys": ["ID"],"snapshotSplitColumn": "ID"}]。当表没有主键、需要自定义主键，或需要指定快照拆分列时使用。
startup.modeEnum否INITIALOracle CDC 使用者的可选启动模式，有效枚举值为 initial、latest、timestamp 和 specific。
initial：启动时同步历史数据，然后同步增量数据。
latest：从最新偏移量启动，并跳过初始快照。
timestamp：从 startup.timestamp 解析出的 SCN 启动。
specific：从用户提供的 SCN 启动。
startup.timestampLong否-从指定的时间戳（自 Unix 纪元以来的毫秒数）启动。当 startup.mode = timestamp 时，该时间戳会按 server-time-zone 转换。注意，当 startup.mode 选项使用 timestamp 时，此选项是必需的。
startup.specific-offset.scnLong否-从指定的 Oracle SCN 启动。注意，当 startup.mode 选项使用 specific 时，此选项是必需的。该 SCN 必须仍可被所选 Oracle 日志挖掘后端读取。
stop.modeEnum否NEVEROracle CDC 使用者的可选停止模式。当前唯一有效值是 never，因此流式 Oracle CDC source 会一直运行，直到任务被停止。
snapshot.split.sizeInteger否8096表快照的拆分大小（行数），在读取表快照时，捕获的表将被拆分为多个拆分块。
snapshot.fetch.sizeInteger否1024读取表快照时每次轮询的最大获取大小。
server-time-zoneString否UTC数据库服务器中的会话时区。如果未设置，则使用 ZoneId.systemDefault() 来确定服务器时区。该参数也用于将 startup.timestamp 转换为 SCN。若数据库时区与 JVM 时区不同，建议显式配置。
connect.timeout.msDuration否30000连接器在尝试连接数据库服务器后超时的最大等待时间。
connect.max-retriesInteger否3连接器尝试建立数据库服务器连接的最大重试次数。
connection.pool.sizeInteger否20JDBC 连接池大小。
incremental.parallelismInteger否1全量快照阶段结束、进入增量日志读取后使用的并行读取数量。
chunk-key.even-distribution.factor.upper-boundDouble否100分块键分布因子的上限。此因子用于确定表数据是否均匀分布。如果计算出的分布因子小于或等于此上限（即 (MAX(id) - MIN(id) + 1) / 行数），则表分块将针对均匀分布进行优化。否则，如果分布因子较大，则表将被视为分布不均，如果估计的分片数超过 sample-sharding.threshold 指定的值，则将使用基于采样的分片策略。默认值为 100.0。
chunk-key.even-distribution.factor.lower-boundDouble否0.05分块键分布因子的下限。此因子用于确定表数据是否均匀分布。如果计算出的分布因子大于或等于此下限（即 (MAX(id) - MIN(id) + 1) / 行数），则表分块将针对均匀分布进行优化。否则，如果分布因子较小，则表将被视为分布不均，如果估计的分片数超过 sample-sharding.threshold 指定的值，则将使用基于采样的分片策略。默认值为 0.05。
sample-sharding.thresholdInteger否1000此配置指定触发采样分片策略的预估分片数阈值。当分布因子超出 chunk-key.even-distribution.factor.upper-bound 和 chunk-key.even-distribution.factor.lower-bound 指定的范围，并且预估的分片数（计算为近似行数 / 分块大小）超过此阈值时，将使用采样分片策略。这有助于更有效地处理大型数据集。默认值为 1000 个分片。
inverse-sampling.rateInteger否1000采样分片策略中使用的采样率的倒数。例如，如果此值设置为 1000，则意味着在采样过程中应用 1/1000 的采样率。此选项提供了控制采样粒度的灵活性，从而影响最终的分片数量。在处理首选较低采样率的极大型数据集时，它特别有用。默认值为 1000。
split.allow-samplingBoolean否true是否启用基于采样的分片策略。当设置为 false 时，无论预估分片数是否超过阈值，系统都将回退到非均匀分片方式（迭代查询方式）。
enable_concurrent_readBoolean否true是否在快照阶段启用基于分片的并发读取。当设置为 false 时，source 会跳过分片分析，并以单个 split 读取整张表，适合没有索引的表。默认值为 true。
exactly_onceBoolean否false启用精确一次语义。
use_select_countBoolean否false使用 select count 统计表行数，而不是在全量阶段使用其他方法。在这种情况下，当通过分析表使用 SQL 更新统计信息更快时，直接使用 select count。
skip_analyzeBoolean否false在全量阶段跳过表行数的分析。在这种情况下，您需要定期调度分析表 SQL 以更新相关表统计信息，或者您的表数据更改不频繁。
formatEnum否DEFAULTOracle CDC 的可选输出格式，有效枚举值为 DEFAULT、COMPATIBLE_DEBEZIUM_JSON。
schema-changes.enabledBoolean否falseSchema 演进默认禁用。目前我们仅支持 add column、drop column、rename column 和 modify column。
schema-changes.includeList否-仅向下游发送列出的 schema change 事件类型（需 schema-changes.enabled = true）。为空表示全部允许。详见 Schema change 事件过滤。
schema-changes.excludeList否-此处列出的 schema change 事件类型不会发送到下游。在 schema-changes.include 之后应用；冲突时 exclude 优先。详见 Schema change 事件过滤。
debeziumConfig否-透传 Debezium 属性 给 Debezium Embedded Engine，该引擎用于捕获 Oracle 服务器的数据更改。
common-options否-源端插件常用参数，详情请参阅 源端常用选项。
decimal_type_narrowingBoolean否true数值类型收缩，如果为 true，则在不损失精度的情况下，将 decimal 类型收缩为 int 或 long 类型。目前仅支持 Oracle。请参阅下文的 decimal_type_narrowing。

decimal_type_narrowing​

数值类型收缩，如果为 true，则在不损失精度的情况下，将 decimal 类型收缩为 int 或 long 类型。目前仅支持 Oracle。

例如：

decimal_type_narrowing = true

OracleSeaTunnel
NUMBER(1, 0)Boolean
NUMBER(6, 0)INT
NUMBER(10, 0)BIGINT

decimal_type_narrowing = false

OracleSeaTunnel
NUMBER(1, 0)Decimal(1, 0)
NUMBER(6, 0)Decimal(6, 0)
NUMBER(10, 0)Decimal(10, 0)

任务示例​

简单示例​

支持多表读取

source {
  # 这是一个示例源端插件，**仅用于测试和演示源端插件功能**
  Oracle-CDC {
    plugin_output = "customers"
    username = "system"
    password = "top_secret"
    database-names = ["ORCLCDB"]
    schema-names = ["DEBEZIUM"]
    table-names = ["ORCLCDB.DEBEZIUM.FULL_TYPES", "ORCLCDB.DEBEZIUM.FULL_TYPES2"]
    url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
    source.reader.close.timeout = 120000
    connection.pool.size = 1
    debezium {
      database.oracle.jdbc.timezoneAsRegion = "false"
    }
  }
}

在全量阶段使用 select count(*) 代替 analysis table 来统计表行数

source {
# 这是一个示例源端插件，**仅用于测试和演示源端插件功能**
  Oracle-CDC {
    plugin_output = "customers"
    use_select_count = true 
    username = "system"
    password = "top_secret"
    database-names = ["ORCLCDB"]
    schema-names = ["DEBEZIUM"]
    table-names = ["ORCLCDB.DEBEZIUM.FULL_TYPES"]
    url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
    source.reader.close.timeout = 120000
  }
}

使用 select NUM_ROWS from all_tables 获取表行数，但跳过 analyze table 操作。

source {
# 这是一个示例源端插件，**仅用于测试和演示源端插件功能**
  Oracle-CDC {
    plugin_output = "customers"
    skip_analyze = true 
    username = "system"
    password = "top_secret"
    database-names = ["ORCLCDB"]
    schema-names = ["DEBEZIUM"]
    table-names = ["ORCLCDB.DEBEZIUM.FULL_TYPES"]
    url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
    source.reader.close.timeout = 120000
  }
}

支持表的自定义主键​

source {
  Oracle-CDC {
    plugin_output = "customers"
    url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
    source.reader.close.timeout = 120000
    username = "system"
    password = "top_secret"
    database-names = ["ORCLCDB"]
    schema-names = ["DEBEZIUM"]
    table-names = ["ORCLCDB.DEBEZIUM.FULL_TYPES"]
    table-names-config = [
      {
        table = "ORCLCDB.DEBEZIUM.FULL_TYPES"
        primaryKeys = ["ID"]
      }
    ]
  }
}

启用精确一次 CDC​

exactly_once = true 用于默认的 startup.mode = "initial" 路径。只有下游 Sink 也配置了精确一次能力时才建议启用，例如开启 XA 的 JDBC Sink。

env {
  parallelism = 1
  job.mode = "STREAMING"
  checkpoint.interval = 5000
}

source {
  Oracle-CDC {
    plugin_output = "customers"
    username = "system"
    password = "top_secret"
    database-names = ["ORCLCDB"]
    schema-names = ["DEBEZIUM"]
    table-names = ["ORCLCDB.DEBEZIUM.FULL_TYPES"]
    url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
    exactly_once = true
    connection.pool.size = 1
    debezium {
      database.oracle.jdbc.timezoneAsRegion = "false"
    }
  }
}

从时间戳启动​

使用 startup.mode = "timestamp" 时，Oracle CDC 会根据毫秒级 Unix 时间戳解析对应的 Oracle SCN 并从该位置启动。

source {
  Oracle-CDC {
    plugin_output = "customers"
    username = "system"
    password = "top_secret"
    database-names = ["ORCLCDB"]
    schema-names = ["DEBEZIUM"]
    table-names = ["ORCLCDB.DEBEZIUM.FULL_TYPES"]
    url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
    startup.mode = "timestamp"
    startup.timestamp = 1700000000000
    server-time-zone = "UTC"
    debezium {
      database.oracle.jdbc.timezoneAsRegion = "false"
    }
  }
}

配置 Debezium 心跳​

对于变更较少的表，Oracle LogMiner 的 SCN 只有在发生 redo log 变更时才会推进。使用 Debezium 心跳让 SCN 持续向前滚动，便于 checkpoint 定期记录偏移，并让复制延迟可观测。心跳表必须提前在 Oracle 服务端创建。

source {
  Oracle-CDC {
    username = "system"
    password = "top_secret"
    database-names = ["ORCLCDB"]
    schema-names = ["DEBEZIUM"]
    table-names = ["ORCLCDB.DEBEZIUM.FULL_TYPES"]
    url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
    debezium {
      database.oracle.jdbc.timezoneAsRegion = "false"
      heartbeat.interval.ms = 100
      heartbeat.action.query = "INSERT INTO DEBEZIUM.heartbeat (ts) VALUES (SYSTIMESTAMP)"
    }
  }
}

读取没有主键的表​

根据源表能够提供的保证来选择合适的路径：

  • 仅追加（append-only）场景：源表不会产生 UPDATE/DELETE 事件，保持 exactly_once = false 且不声明主键，源端会退回到尽力而为的行标识。在没有可用主键的情况下，connector 无法安全地应用 UPDATE/DELETE 事件。
  • 存在唯一非主键列：通过 table-names-config.primaryKeys 显式声明该列，并设置 exactly_once = true，让快照阶段与 redo log 阶段都使用同一配置主键作为稳定的行标识。
source {
  Oracle-CDC {
    username = "system"
    password = "top_secret"
    database-names = ["ORCLCDB"]
    schema-names = ["DEBEZIUM"]
    url = "jdbc:oracle:thin:@//oracle-host:1521/ORCLCDB"
    table-names = ["ORCLCDB.DEBEZIUM.FULL_TYPES_NO_PRIMARY_KEY"]
    table-names-config = [
      {
        table = "ORCLCDB.DEBEZIUM.FULL_TYPES_NO_PRIMARY_KEY"
        primaryKeys = ["ID"]
      }
    ]
    exactly_once = true
  }
}

没有可用的主键时，connector 无法安全地应用 UPDATE/DELETE 事件。仅在仅追加（append-only）场景下使用此模式。

Schema change 事件过滤​

当 schema-changes.enabled = true 时，可通过 schema-changes.include / schema-changes.exclude 进一步 控制哪些 schema change 事件类型会被发送到下游。过滤只影响“发往下游”的部分。

使用以下 SeaTunnel 统一的规范名称：

规范名称操作
add.column新增列
drop.column删除列
modify.column修改列的类型/属性，列名不变
change.column列重命名，可同时改类型
update.columns上述四种列级变更的分组别名

优先级规则（确定性）：

  1. 若设置了 schema-changes.include，则只有被包含的事件类型才有资格；
  2. 然后应用 schema-changes.exclude；
  3. 当某类型同时出现在两个列表中时，exclude 优先。
source {
  Oracle-CDC {
    # ...
    schema-changes.enabled = true
    schema-changes.include = ["add.column", "drop.column"]
    schema-changes.exclude = ["change.column"]
  }
}

排除 drop.column 时的数据处理方式。 对于被保留的 NOT NULL 列，写入 NULL 会被 sink 拒绝，因此对一个源端已不再供数的 NOT NULL 列排除 drop.column 会在 sink 端失败。

支持以兼容 debezium 的格式发送到 kafka​

必须与 kafka 连接器 sink 配合使用，详情请参阅 兼容 debezium 格式

常见问题​

Oracle CDC 需要哪些数据库权限？​

LogMiner 用户需要以下权限：

GRANT CREATE SESSION TO logminer_user;
GRANT SET CONTAINER TO logminer_user;
GRANT SELECT ON V_$DATABASE TO logminer_user;
GRANT FLASHBACK ANY TABLE TO logminer_user;
GRANT SELECT ANY TABLE TO logminer_user;
GRANT SELECT_CATALOG_ROLE TO logminer_user;
GRANT EXECUTE_CATALOG_ROLE TO logminer_user;
GRANT SELECT ANY TRANSACTION TO logminer_user;
GRANT LOGMINING TO logminer_user;
GRANT CREATE TABLE TO logminer_user;
GRANT LOCK ANY TABLE TO logminer_user;
GRANT CREATE SEQUENCE TO logminer_user;
GRANT EXECUTE ON DBMS_LOGMNR TO logminer_user;
GRANT EXECUTE ON DBMS_LOGMNR_D TO logminer_user;
GRANT SELECT ON V_$LOG TO logminer_user;
GRANT SELECT ON V_$LOG_HISTORY TO logminer_user;
GRANT SELECT ON V_$LOGMNR_LOGS TO logminer_user;
GRANT SELECT ON V_$LOGMNR_CONTENTS TO logminer_user;
GRANT SELECT ON V_$LOGMNR_PARAMETERS TO logminer_user;
GRANT SELECT ON V_$LOGFILE TO logminer_user;
GRANT SELECT ON V_$ARCHIVED_LOG TO logminer_user;
GRANT SELECT ON V_$ARCHIVE_DEST_STATUS TO logminer_user;
GRANT SELECT ON V_$TRANSACTION TO logminer_user;

同时，需要在数据库和表级别开启附加日志：

ALTER DATABASE ADD SUPPLEMENTAL LOG DATA;
ALTER TABLE schema_name.table_name ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS;

Oracle CDC 是否支持多租户（CDB/PDB）数据库？​

支持。将 database-names 设置为 CDB 名称，并将 JDBC URL 指向 CDB 根容器。用户必须是公共用户（以 C## 为前缀），且需在所有容器中以 CONTAINER = ALL 方式授予上述权限。

Oracle CDC 是否支持无主键表？​

默认情况下，Oracle CDC 需要主键。如果表中存在合适的唯一列，可通过 table-names-config 中的 primaryKeys 字段指定自定义主键列。

如何使用自定义快照查询？​

在 debezium 块中配置 Debezium 的 snapshot.select.statement.overrides 属性。SeaTunnel 会先使用该查询，再追加快照分片边界条件，因此查询必须包含已配置表结构和分片键所需的全部列。

debezium {
  snapshot.select.statement.overrides = "DEBEZIUM.FULL_TYPES"
  snapshot.select.statement.overrides.DEBEZIUM.FULL_TYPES = "SELECT * FROM DEBEZIUM.FULL_TYPES WHERE ACTIVE = 1"
}

如何提升 LogMiner 性能？​

首先把它当作数据库和 redo log 调优问题处理。优先复用上面的 LogMiner 配置和 supplemental logging 章节，只为需要采集的表开启日志；只有在确认目标 Oracle CDC 运行时确实支持相应 Debezium 透传属性后，再引入额外调优参数。

支持哪些 Oracle 版本？​

Oracle CDC 支持 Oracle Database 11g、12c、19c 和 21c。对于 12c 及更高版本的多租户配置，需使用 CDB 根连接和公共用户。

另请参阅​

若需要一份面向生产的端到端实践指南，涵盖全量 + 增量同步生命周期、2PC sink 配置、Schema 演进与常见故障排查，请参阅 CDC 生产实战手册。

更新日志​

Change Log
ChangeCommitVersion
[Fix][Connector-V2] Honor Oracle snapshot select overrides (#11768)https://github.com/apache/seatunnel/commit/70faa7ce53.0.0
[Feature][Connector-V2][CDC] Support comment-related schema change events (#11025)https://github.com/apache/seatunnel/commit/ba55ef9653.0.0
[Fix][Connector-CDC] Implement MySQL CDC stop.mode = "specific" (bounded read) (#11618)https://github.com/apache/seatunnel/commit/d7dd5d5f53.0.0
[Feature][Connector-V2][Oracle-CDC] Add SCN specific startup (#11171)https://github.com/apache/seatunnel/commit/3ec61ba153.0.0
[Feature][CDC/JDBC] Add enable_concurrent_read option to skip split analysis for tables without indexes (#10837)https://github.com/apache/seatunnel/commit/844d9c3633.0.0
[Feature][Connector-V2] Foundation for per-connector Debezium version management (staged) (#10799)https://github.com/apache/seatunnel/commit/d617b31303.0.0
[SEATUNNEL-10685] prevent timestamp_ntz from being saved as timestamp_ltz (#10724)https://github.com/apache/seatunnel/commit/872077f643.0.0
[Feature][Connector-V2][CDC] Add include/exclude filtering for schema change event types #11044 (#11108)https://github.com/apache/seatunnel/commit/34940bf663.0.0
[Fix][Connector-V2] Fix Oracle CDC schema cache matching (#11110)https://github.com/apache/seatunnel/commit/c698247693.0.0
[Feature][CDC/JDBC] Add option to disable sampling-based sharding (#10604)https://github.com/apache/seatunnel/commit/e4780bb1f3.0.0
[BugFix][connector-cdc-oracle] Fix table or view doesn't exist in multitables CDB+PDB mode (#10829)https://github.com/apache/seatunnel/commit/36122261f3.0.0
[Feature][Connectors-v2] Support timestamp startup mode for Oracle and SQLServer CDC (#10428)https://github.com/apache/seatunnel/commit/34a57c70b3.0.0