fix:

1、ck filterValue NPE protection 2、mysql version NPE protection
tapdata · Aug 25, 2023 · 7c248b4 · 7c248b4
1 parent 65fb32f
commit 7c248b4
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/...re-build-parent/mysql-core/src/main/java/io/tapdata/connector/mysql/bean/MysqlColumn.java b/...re-build-parent/mysql-core/src/main/java/io/tapdata/connector/mysql/bean/MysqlColumn.java
@@ -3,6 +3,7 @@
 import io.tapdata.common.CommonColumn;
 import io.tapdata.entity.schema.TapField;
 import io.tapdata.entity.utils.DataMap;
+import io.tapdata.kit.EmptyKit;
 
 
 /**
@@ -33,7 +34,7 @@ public MysqlColumn withVersion(String version) {
 
     @Override
     protected Boolean isNullable() {
-        if ("5.6".compareTo(version) > 0) {
+        if (EmptyKit.isNull(version) || "5.6".compareTo(version) > 0) {
             return true;
         }
         return "YES".equals(this.nullable);

diff --git a/...-connector/src/main/java/io/tapdata/connector/clickhouse/dml/ClickhouseWriteRecorder.java b/...-connector/src/main/java/io/tapdata/connector/clickhouse/dml/ClickhouseWriteRecorder.java
@@ -90,6 +90,9 @@ protected String getDeleteSql(Map<String, Object> before, boolean containsNull)
 
     @Override
     protected Object filterValue(Object value, String dataType) {
+        if (EmptyKit.isNull(dataType)) {
+            return value;
+        }
         if (dataType.contains("Int")) {
             if (value instanceof Float) {
                 return ((Float) value).intValue();