From 3c20fd09ad2199eaf8b6d09fbb35dc0b24572b74 Mon Sep 17 00:00:00 2001 From: flowell Date: Sat, 9 Oct 2021 14:28:56 +0800 Subject: [PATCH] =?UTF-8?q?fix=20issue=20#3839:=20=E4=BF=AE=E5=A4=8Dalter?= =?UTF-8?q?=20table=20character=20set=E7=B1=BB=E5=9E=8BDDL=E8=AF=AD?= =?UTF-8?q?=E5=8F=A5=E8=A7=A3=E6=9E=90BUG=20(#3840)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../otter/canal/parse/inbound/mysql/ddl/DruidDdlParser.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/ddl/DruidDdlParser.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/ddl/DruidDdlParser.java index a65a7fb5..2ca62687 100644 --- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/ddl/DruidDdlParser.java +++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/ddl/DruidDdlParser.java @@ -66,6 +66,12 @@ public class DruidDdlParser { ddlResults.add(ddlResult); } else if (statement instanceof SQLAlterTableStatement) { SQLAlterTableStatement alterTable = (SQLAlterTableStatement) statement; + if (alterTable.getTableOptions().size() > 0) { + DdlResult ddlResult = new DdlResult(); + processName(ddlResult, schmeaName, alterTable.getName(), false); + ddlResult.setType(EventType.ALTER); + ddlResults.add(ddlResult); + } for (SQLAlterTableItem item : alterTable.getItems()) { if (item instanceof SQLAlterTableRename) { DdlResult ddlResult = new DdlResult();