Update LogEventConvert.java (alibaba#4653)

fixed issue alibaba#4652, 解决mysql中类型为MEDIUMTEXT的字段的javaType在不同场景的解析不一致的问题
zoemak · Jan 30, 2024 · e1aecbb · e1aecbb
1 parent 43a8c12
commit e1aecbb
Showing 1 changed file with 17 additions and 0 deletions.
diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java
@@ -754,6 +754,23 @@ private boolean parseOneRow(RowData.Builder rowDataBuilder, RowsLogEvent event,
             int javaType = buffer.getJavaType();
             if (buffer.isNull()) {
                 columnBuilder.setIsNull(true);
+
+                // 处理各种类型
+                switch (javaType) {
+                    case Types.BINARY:
+                    case Types.VARBINARY:
+                    case Types.LONGVARBINARY:
+
+                        // https://github.com/alibaba/canal/issues/4652
+                        // mysql binlog中blob/text都处理为blob类型，需要反查table
+                        // meta，按编码解析text
+                        if (fieldMeta != null && isText(fieldMeta.getColumnType())) {
+                            javaType = Types.CLOB;
+                        } else {
+                            javaType = Types.BLOB;
+                        }
+                        break;
+                }
             } else {
                 final Serializable value = buffer.getValue();
                 // 处理各种类型