Map INT32 Kafka connect to INT256 CH type

Altinity · Jul 31, 2022 · 5485a4e · 5485a4e
1 parent b136c6a
commit 5485a4e
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/...main/java/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapper.java b/...main/java/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapper.java
@@ -25,7 +25,8 @@ public class ClickHouseDataTypeMapper {
         dataTypesMap.put(new MutablePair(Schema.INT16_SCHEMA.type(), null), ClickHouseDataType.Int16);
         dataTypesMap.put(new MutablePair(Schema.INT8_SCHEMA.type(), null), ClickHouseDataType.Int8);
         dataTypesMap.put(new MutablePair(Schema.INT32_SCHEMA.type(), null), ClickHouseDataType.Int32);
-        dataTypesMap.put(new MutablePair(Schema.INT64_SCHEMA.type(), null), ClickHouseDataType.Int64);
+
+        dataTypesMap.put(new MutablePair(Schema.INT64_SCHEMA.type(), null), ClickHouseDataType.Int256);
 
         // Float
          dataTypesMap.put(new MutablePair(Schema.FLOAT32_SCHEMA.type(), null), ClickHouseDataType.Float32);

diff --git a/src/test/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapperTest.java b/src/test/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapperTest.java
@@ -26,6 +26,9 @@ public void getClickHouseDataType() {
         chDataType = ClickHouseDataTypeMapper.getClickHouseDataType(Schema.INT32_SCHEMA.type(), Date.SCHEMA_NAME);
         Assert.assertTrue(chDataType.name().equalsIgnoreCase("Date32"));
 
+        chDataType = ClickHouseDataTypeMapper.getClickHouseDataType(Schema.INT64_SCHEMA.type(), null);
+        Assert.assertTrue(chDataType.name().equalsIgnoreCase("INT256"));
+
 
     }
 }