chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(project): no need to process tinyint(1) specially #631

Browse Source
This commit is contained in:
wanshao
2020-02-28 14:34:30 +08:00
parent beaca165d0
commit 30a1b067a8
1 changed files with 0 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java
View File

@@ -718,8 +718,6 @@ public class LogEventConvert extends AbstractCanalLifeCycle implements BinlogPar
isBinary = true; isBinary = true;
} else if (StringUtils.containsIgnoreCase(fieldMeta.getColumnType(), "BINARY")) { } else if (StringUtils.containsIgnoreCase(fieldMeta.getColumnType(), "BINARY")) {
isBinary = true; 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即可 // 对象为number类型，直接valueof即可
columnBuilder.setValue(String.valueOf(value)); columnBuilder.setValue(String.valueOf(value));
} }
if (isSingleBit && javaType == Types.TINYINT) {
javaType = Types.BIT;
}
break; break;
case Types.REAL: // float case Types.REAL: // float
case Types.DOUBLE: // double case Types.DOUBLE: // double