如何在使用 Kafka 连接 jdbc 接收器插入 Oracle 表之前将 CLOB 数据转换为 VARCHAR2？答案

【问题标题】：How to convert CLOB data to VARCHAR2 before inserting to Oracle table using Kafka connect jdbc sink?如何在使用 Kafka 连接 jdbc 接收器插入 Oracle 表之前将 CLOB 数据转换为 VARCHAR2？
【发布时间】：2018-06-23 20:37:47
【问题描述】：

你正在使用 Confluent 3.3.0。我正在使用 Kafka jdbc sink 连接器将行插入到我的 Oracle 表中。您可以参考this 问题来了解我的 Java 生产者代码和 Kafka 连接设置。一切正常，但值被插入为 CLOB。我有非常简单的记录，比如 3 个字符串属性。所以我希望这些值作为 VARCHAR2 插入。从Confluent documentation 可以清楚地看出，对于Oracle，字符串被映射到CLOB。我想自定义映射。有什么方法可以将其转换为 VARCHAR2 并插入它？

谢谢。

【问题讨论】：

不知道产品，但是您可以为要映射的字符串设置大小限制吗？ Varchar2 的最大长度为 2000 个字符，如果不受此限制，映射框架可能会自动将字符串映射到 CLOB。

标签： oracle jdbc apache-kafka apache-kafka-connect confluent-platform

【解决方案1】：

使用这个：

cast(to_char(your_clob_column) as varchar2(4000))

【讨论】：

你能告诉我我应该在哪里实现这个吗？
您可以使用您的选择语句来填充列。我的意思是：从 a,b,c 中选择 *****this****** 。