请问 有没有人做过通过pg的协议 oracle cdc 的数据到tbase上

通过PostgreSQL协议直接进行Oracle CDC数据到TBase的迁移并未在提供的知识库资料中直接提及。不过，根据资料内容，我们可以采用间接方式实现这一需求，即利用Apache Flink作为中间桥梁来完成数据同步任务。

解决方案概述

1. 使用Flink CDC从Oracle捕获变更数据：

   • 配置Flink作业以使用Oracle CDC Connector，确保提供正确的Oracle数据库连接信息（如hostname、port、username、password、database-name和schema-name），并指定需要同步的表名或模式。
   • 注意：由于Oracle LogMiner限制，需确保表名和列名长度不超过30个字符。

2. 配置Flink作业将数据写入TBase：

   • 虽然直接针对TBase的Sink配置未在文档中明确给出，但你可以自定义Flink Sink或者如果TBase支持JDBC连接，可以尝试使用Flink JDBC Connector来实现数据写入TBase的操作。
   • 自定义Sink时，需要实现与TBase兼容的数据写入逻辑，确保数据格式与TBase的要求相匹配。

实施步骤简述

从Oracle读取CDC数据

• 准备环境：确保Flink版本支持CDC功能，并在$FLINK_HOME/lib目录下添加Oracle CDC依赖。
• 配置参数：按照示例设置oracle-conf参数，包括数据库连接信息及要同步的表的过滤条件。

写入TBase

• 选择Sink：决定是开发自定义Sink还是使用现有Connector（如适用）。
• 配置Sink参数：根据所选Sink类型，配置相应的连接信息，如地址、用户名、密码等。

注意事项

• 表结构映射：确保Oracle源表与TBase目标表之间有恰当的字段映射。
• 性能考量：监控数据同步过程中的性能，特别是当处理大量数据或高频率变更时，可能需要调整Flink作业的并行度和资源分配。
• 错误处理：实施过程中需关注日志，及时解决如字段名称大小写不一致导致的“file is not a valid field name”等问题。

结论

虽然没有直接通过PostgreSQL协议操作的案例，但借助Flink CDC能力，结合适当的Sink配置或自定义开发，可以实现从Oracle CDC到TBase的数据迁移。请依据具体需求和环境调整实施方案。