flinkcdc 对接oracle 12c, url 直连的pdb容器？

在使用 Flink CDC 对接 Oracle 12c 的 PDB 容器时，可能会遇到一些权限或配置上的问题。以下是基于知识库资料的详细操作步骤和注意事项，帮助您解决直连 PDB 容器的问题。

1. 确认 Oracle 数据库的权限配置

为了确保 Flink CDC 能够正确连接到 Oracle 12c 的 PDB 容器，需要为迁移用户授予必要的权限。以下是具体步骤：

1.1 切换到 CDB$ROOT 容器

执行以下 SQL 语句，切换到根容器 CDB$ROOT：

ALTER SESSION SET CONTAINER=CDB$ROOT;

1.2 创建 Common 用户并授予权限

• 创建 Common 用户：Common 用户可以连接到根容器（CDB$ROOT）以及任何有权限的 PDB。
• 授予权限：为 Common 用户授予 DBA 权限，并确保其对 SYS.USER$ 表具有读取权限。

执行以下 SQL 语句：

-- 授予 DBA 权限
GRANT DBA TO C##XXX CONTAINER=ALL;

-- 授予对 SYS.USER$ 表的读权限
GRANT SELECT ON SYS.USER$ TO C##XXX CONTAINER=ALL;

注意：C##XXX 是您创建的 Common 用户名，请根据实际情况替换。

2. 配置 Flink CDC 连接 Oracle 数据库

在 Flink CDC 中，连接 Oracle 数据库时需要提供正确的 JDBC URL 和相关参数。以下是关键配置说明：

2.1 JDBC URL 格式

Flink CDC 使用 JDBC 协议连接 Oracle 数据库，JDBC URL 的格式如下：

jdbc:oracle:thin:@//<hostname>:<port>/<service_name>

• <hostname>：Oracle 数据库的主机地址。
• <port>：Oracle 数据库的监听端口（默认为 1521）。
• <service_name>：PDB 容器的服务名。

例如：

jdbc:oracle:thin:@//192.168.1.100:1521/ORCLPDB1

2.2 配置 Flink CDC 参数

在 Flink SQL 或配置文件中，设置以下参数以连接 Oracle 数据库：

CREATE TABLE source_table (
    ...
) WITH (
    'connector' = 'oracle-cdc',
    'hostname' = '<hostname>',
    'port' = '<port>',
    'username' = 'C##XXX', -- Common 用户名
    'password' = '<password>',
    'database-name' = '<service_name>', -- PDB 容器的服务名
    'schema-name' = '<schema_name>', -- 源表所在的 Schema
    'table-name' = '<table_name>' -- 源表名
);

3. 常见问题排查

如果按照上述步骤仍无法成功连接 Oracle 12c 的 PDB 容器，请检查以下内容：

3.1 检查用户权限

• 确保 Common 用户已正确创建，并且具有 DBA 权限和对 SYS.USER$ 表的读权限。
• 如果权限不足，重新执行权限授予语句。

3.2 检查 PDB 容器状态

• 确保目标 PDB 容器处于 OPEN 状态。可以通过以下 SQL 查询 PDB 状态：

SELECT NAME, OPEN_MODE FROM V$PDBS;

• 如果 PDB 容器未打开，执行以下命令将其打开：

ALTER PLUGGABLE DATABASE <pdb_name> OPEN;

3.3 检查网络连接

• 确保 Flink 集群能够访问 Oracle 数据库的主机和端口。
• 使用工具（如 tnsping 或 telnet）测试网络连通性。

3.4 检查 Flink CDC 版本

• 确保使用的 Flink CDC 版本支持 Oracle 12c。如果不支持，建议升级到最新版本。

4. 其他注意事项

• DATE 类型处理：如果源表中包含 DATE 类型字段，建议在 Flink SQL 中将其映射为 TIMESTAMP 类型，以避免数据类型不兼容问题。
• 并发数与连接池大小：如果连接数打满，建议降低作业并发数或调整连接池大小。

通过以上步骤，您可以正确配置 Flink CDC 以对接 Oracle 12c 的 PDB 容器。如果仍有问题，请提供更多错误信息以便进一步分析。