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 MemoryTableMeta#processTableElement bug

Browse Source
This commit is contained in:
wuwo
2018-11-13 11:14:37 +08:00
parent fcaf8e88f8
commit 3f8cdafea3
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/MemoryTableMeta.java
View File

@@ -213,6 +213,7 @@ public class MemoryTableMeta implements TableMetaTSDB {
fieldMeta.setNullable(true); fieldMeta.setNullable(true);
} else if (constraint instanceof SQLColumnPrimaryKey) { } else if (constraint instanceof SQLColumnPrimaryKey) {
fieldMeta.setKey(true); fieldMeta.setKey(true);
fieldMeta.setNullable(false);
} else if (constraint instanceof SQLColumnUniqueKey) { } else if (constraint instanceof SQLColumnUniqueKey) {
fieldMeta.setUnique(true); fieldMeta.setUnique(true);
} }
@@ -225,6 +226,7 @@ public class MemoryTableMeta implements TableMetaTSDB {
String name = getSqlName(pk.getExpr()); String name = getSqlName(pk.getExpr());
FieldMeta field = tableMeta.getFieldMetaByName(name); FieldMeta field = tableMeta.getFieldMetaByName(name);
field.setKey(true); field.setKey(true);
field.setNullable(false);
} }
} else if (element instanceof MySqlUnique) { } else if (element instanceof MySqlUnique) {
MySqlUnique column = (MySqlUnique) element; MySqlUnique column = (MySqlUnique) element;