[hotfix-#1816][connector-oracle] fix NullPointerException when oracle…

… blob field is null
DTStack · Sep 14, 2023 · f7f79da · f7f79da
1 parent 2fb4967
commit f7f79da
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...cle/src/main/java/com/dtstack/chunjun/connector/oracle/converter/OracleSyncConverter.java b/...cle/src/main/java/com/dtstack/chunjun/connector/oracle/converter/OracleSyncConverter.java
@@ -35,6 +35,7 @@
 import com.dtstack.chunjun.element.column.FloatColumn;
 import com.dtstack.chunjun.element.column.IntColumn;
 import com.dtstack.chunjun.element.column.LongColumn;
+import com.dtstack.chunjun.element.column.NullColumn;
 import com.dtstack.chunjun.element.column.ShortColumn;
 import com.dtstack.chunjun.element.column.StringColumn;
 import com.dtstack.chunjun.element.column.TimestampColumn;
@@ -275,7 +276,8 @@ protected IDeserializationConverter createInternalConverter(LogicalType type) {
  wrapIntoNullableExternalConverter(
  ISerializationConverter serializationConverter, LogicalType type) {
  return (val, index, statement) -> {
- if (((ColumnRowData) val).getField(index) == null) {
+ if (((ColumnRowData) val).getField(index) == null
+ || ((ColumnRowData) val).getField(index) instanceof NullColumn) {
  try {
  final int sqlType =
  JdbcTypeUtil.typeInformationToSqlType(