Merge pull request #23 from Altinity/15-mysql-bigint-to-ch-int64-does…

…nt-work-correct-with-autocreatetables-true-setting Map INT32 Kafka connect to INT256 CH type
Altinity · Jul 31, 2022 · 05f6986 · 05f6986
2 parents b136c6a + 5485a4e
commit 05f6986
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"));
+
 
     }
 }