跳到主要内容
版本：Next

Oracle CDC

Oracle CDC 源连接器

支持这些引擎​

SeaTunnel Zeta
Flink

关键特性​

描述​

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

注意​

Debezium Oracle 连接器不依赖于连续挖掘选项。连接器负责检测日志切换并自动调整要挖掘的日志，这是连续挖掘选项为您自动执行的操作。 因此，您不能在 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 中启用 Oracle CDC（变更数据捕获）使用 Logminer（这是 Oracle 提供的内置工具），请按照以下步骤操作：

在没有 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"，并授予其读取表和日志的权限。

变更日志​