Skip to content

Commit 3c20fd0

Browse files
authored
fix issue #3839: 修复alter table character set类型DDL语句解析BUG (#3840)
1 parent eef3bd9 commit 3c20fd0

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/ddl/DruidDdlParser.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,12 @@ public static List<DdlResult> parse(String queryString, String schmeaName) {
6666
ddlResults.add(ddlResult);
6767
} else if (statement instanceof SQLAlterTableStatement) {
6868
SQLAlterTableStatement alterTable = (SQLAlterTableStatement) statement;
69+
if (alterTable.getTableOptions().size() > 0) {
70+
DdlResult ddlResult = new DdlResult();
71+
processName(ddlResult, schmeaName, alterTable.getName(), false);
72+
ddlResult.setType(EventType.ALTER);
73+
ddlResults.add(ddlResult);
74+
}
6975
for (SQLAlterTableItem item : alterTable.getItems()) {
7076
if (item instanceof SQLAlterTableRename) {
7177
DdlResult ddlResult = new DdlResult();

0 commit comments

Comments
 (0)