diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/antlr/listener/ColumnDefinitionParserListener.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/antlr/listener/ColumnDefinitionParserListener.java index f7f42677c..5acedc2e0 100644 --- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/antlr/listener/ColumnDefinitionParserListener.java +++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/antlr/listener/ColumnDefinitionParserListener.java @@ -272,6 +272,11 @@ else if (ctx.native_datatype_element().CLOB() != null) { .jdbcType(Types.CLOB) .type("CLOB"); } + else if (ctx.native_datatype_element().NCLOB() != null) { + columnEditor + .jdbcType(Types.NCLOB) + .type("NCLOB"); + } else if (ctx.native_datatype_element().RAW() != null) { columnEditor .jdbcType(OracleTypes.RAW)