Oracle CDC(XStream)配置

概述

　　CDC（Change Data Capture），即数据变更抓取，通过为源端数据源开启CDC，可实现数据源的实时数据同步以及数据表的物理删除同步。

前提条件

• Oracle数据库为11.2.0.4/12.1.0.2或以上版本。
• Oracle数据库需具备OGG License（无需安装OGG）。
• 若Oracle数据库为主备模式，不支持使用Oracle备库。

建议由数据库管理员进行CDC功能的配置操作

1、在命令行工具中执行以下命令以sys用户连接到数据库。

sqlplus /nolog
CONNECT sys/password@host:port AS SYSDBA;

其中：

• password为数据库sys用户的密码，可向数据库管理员获取。
• host为数据库实例所在服务器的IP地址，请根据实际情况设置。
• port为数据库实例所使用的端口，请根据实际情况设置。

2、开启Xstream

alter system set enable_goldengate_replication=true;

3、检查日志归档是否已开启。

archive log list;

"Database log mode: No Archive Mode"，说明日志归档未开启，继续执行下一步。

"Database log mode: Archive Mode"，说明日志归档已开启，直接跳过下一步骤。

4、配置归档日志参数。

alter system set db_recovery_file_dest_size = 100G;
alter system set db_recovery_file_dest = '/opt/oracle/oradata/recovery_area' scope=spfile;

其中：

• 100G为日志文件存储空间的大小，请根据实际情况设置。
• /opt/oracle/oradata/recovery_area为日志存储路径，请根据实际规划设置，但须确保路径提前创建。

5、开启日志归档。

须知：

• 开启日志归档功能需重启数据库，重启期间将导致业务中断，请谨慎操作。
• 归档日志会占用较多的磁盘空间，若磁盘空间满了会影响业务，请定期清理过期归
• 档日志。

shutdown immediate;
startup mount;
alter database archivelog;
alter database open;

6、确认日志归档是否已成功开启。

archive log list;

当回显打印"Database log mode: Archive Mode"，说明日志归档已开启。

7、创建XStream管理员用户并配置权限。

CREATE TABLESPACE xstream_adm_tbs DATAFILE '/opt/oracle/oradata/orcl/xstream_adm_tbs.dbf' SIZE 25M REUSE AUTOEXTEND ON MAXSIZE UNLIMITED;
CREATE USER xstrmadmin IDENTIFIED BY password DEFAULT TABLESPACE xstream_adm_tbs QUOTA UNLIMITED ON xstream_adm_tbs;
GRANT CREATE SESSION TO xstrmadmin;
BEGIN
   DBMS_XSTREAM_AUTH.GRANT_ADMIN_PRIVILEGE(
      grantee                 => 'xstrmadmin',
      privilege_type          => 'CAPTURE',
      grant_select_privileges => TRUE
   );
END;

其中：

• xstream_adm_tbs为XStream管理员用户的表空间名，请根据实际规划设置。
• /opt/oracle/oradata/orcl/xstream_adm_tbs.dbf为XStream管理员用户的表空间文件，请根据实际规划设置。
• xstrmadmin为XStream管理员用户名，请根据实际规划设置。
• password为XStream管理员用户密码，请根据实际规划设置。

8、创建外部连接数据库的用户并配置权限。

CREATE TABLESPACE xstream_tbs DATAFILE '/opt/oracle/oradata/orcl/xstream_tbs.dbf' SIZE 25M REUSE AUTOEXTEND ON MAXSIZE UNLIMITED;
CREATE USER xstrm IDENTIFIED BY password DEFAULT TABLESPACE xstream_tbs QUOTA UNLIMITED ON xstream_tbs;
GRANT CREATE SESSION TO xstrm;
GRANT SELECT ON V_$DATABASE to xstrm;
GRANT FLASHBACK ANY TABLE TO xstrm;
GRANT SELECT ANY TABLE to xstrm;
GRANT LOCK ANY TABLE TO xstrm;
grant select_catalog_role to xstrm;

其中：

• xstream_tbs为外部连接用户的表空间名，请根据实际规划设置。
• /opt/oracle/oradata/orcl/xstream_tbs.dbf为外部连接用户的表空间文件，请根据实际规划设置。
• xstrm为外部连接用户名，请根据实际规划设置。
• password为外部连接用户密码，请根据实际规划设置。

9、修改日志记录参数。

alter database add supplemental log data (all) columns;

10、创建XStream出站服务器。

　　一个XStream出站服务器只能在一个集成任务中使用，若该数据库需要用于多个集成任务，需创建多个XStream出站服务器。

以xstrmadmin用户连接到数据库实例。

sqlplus xstrmadmin/password@host:port/SID

创建XStream出站服务器。

DECLARE
  tables DBMS_UTILITY.UNCL_ARRAY;
  schemas DBMS_UTILITY.UNCL_ARRAY;
BEGIN
   tables(1) := NULL;
   schemas(1) := 'scott';
   DBMS_XSTREAM_ADM.CREATE_OUTBOUND(
      server_name => 'dbzxout',
      table_names => tables,
      schema_names => schemas
   );
END;

其中：

• scott为要同步数据表所在的schemas，即CDC需要抓取哪个schemas下的数据，请根据实际情况设置。
• dbzxout为出站服务器名称，需保证唯一，请根据实际规划设置。

11、允许xstrm用户连接XStream出站服务器。

sqlplus sys/password@host:port/SID as sysdba

BEGIN
  DBMS_XSTREAM_ADM.ALTER_OUTBOUND(
    server_name => 'dbzxout',
    connect_user => 'xstrm'
  );
END;