use getObject instead of getString

apache · Jul 5, 2022 · e4475dc · e4475dc
1 parent b9cc8eb
commit e4475dc
Showing 1 changed file with 0 additions and 8 deletions.
diff --git a/...ain/java/com/ververica/cdc/connectors/mysql/debezium/task/MySqlSnapshotSplitReadTask.java b/...ain/java/com/ververica/cdc/connectors/mysql/debezium/task/MySqlSnapshotSplitReadTask.java
@@ -307,14 +307,6 @@ else if (actualColumn.jdbcType() == Types.TINYINT
             // We thus need to use getObject() to identify if the value was provided and if yes then
             // read it again to get correct scale
             return rs.getObject(fieldNo) == null ? null : rs.getInt(fieldNo);
-        }
-        // DBZ-2673
-        // It is necessary to check the type names as types like ENUM and SET are
-        // also reported as JDBC type char
-        else if ("CHAR".equals(actualColumn.typeName())
-                || "VARCHAR".equals(actualColumn.typeName())
-                || "TEXT".equals(actualColumn.typeName())) {
-            return rs.getString(fieldNo);
         } else {
             return rs.getObject(fieldNo);
         }