From 30a1b067a81a2ffc9c640051b3fc5b4caa0d180d Mon Sep 17 00:00:00 2001 From: wanshao <344277934@qq.com> Date: Fri, 28 Feb 2020 14:34:30 +0800 Subject: [PATCH] fix(project): no need to process tinyint(1) specially #631 --- .../canal/parse/inbound/mysql/dbsync/LogEventConvert.java | 6 ------ 1 file changed, 6 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 index 8c9c763e..524f9089 100644 --- 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 @@ -718,8 +718,6 @@ public class LogEventConvert extends AbstractCanalLifeCycle implements BinlogPar isBinary = true; } else if (StringUtils.containsIgnoreCase(fieldMeta.getColumnType(), "BINARY")) { isBinary = true; - } else if (StringUtils.containsIgnoreCase(fieldMeta.getColumnType(), "TINYINT(1)")) { - isSingleBit = true; } } @@ -774,10 +772,6 @@ public class LogEventConvert extends AbstractCanalLifeCycle implements BinlogPar // 对象为number类型,直接valueof即可 columnBuilder.setValue(String.valueOf(value)); } - - if (isSingleBit && javaType == Types.TINYINT) { - javaType = Types.BIT; - } break; case Types.REAL: // float case Types.DOUBLE: // double