From 929a9210c9f6f7b74f20edf811476bd5b1a99602 Mon Sep 17 00:00:00 2001 From: tolaini Date: Fri, 23 Apr 2021 22:19:59 +0200 Subject: [PATCH] Treat SQL CHAR type as STRING Avoid truncating strings when inserting into CHAR columns --- .../apache/nifi/serialization/record/util/DataTypeUtils.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/nifi-commons/nifi-record/src/main/java/org/apache/nifi/serialization/record/util/DataTypeUtils.java b/nifi-commons/nifi-record/src/main/java/org/apache/nifi/serialization/record/util/DataTypeUtils.java index ede34753100e..8e0c2e2e897d 100644 --- a/nifi-commons/nifi-record/src/main/java/org/apache/nifi/serialization/record/util/DataTypeUtils.java +++ b/nifi-commons/nifi-record/src/main/java/org/apache/nifi/serialization/record/util/DataTypeUtils.java @@ -1957,8 +1957,6 @@ public static DataType getDataTypeFromSQLTypeValue(final int sqlType) { return RecordFieldType.BOOLEAN.getDataType(); case Types.TINYINT: return RecordFieldType.BYTE.getDataType(); - case Types.CHAR: - return RecordFieldType.CHAR.getDataType(); case Types.DATE: return RecordFieldType.DATE.getDataType(); case Types.DOUBLE: @@ -1971,6 +1969,7 @@ public static DataType getDataTypeFromSQLTypeValue(final int sqlType) { return RecordFieldType.INT.getDataType(); case Types.SMALLINT: return RecordFieldType.SHORT.getDataType(); + case Types.CHAR: case Types.VARCHAR: case Types.LONGNVARCHAR: case Types.LONGVARCHAR: