From d8e411462ec26ee8644445280fd88734b53a09d0 Mon Sep 17 00:00:00 2001 From: winger Date: Mon, 5 Nov 2018 18:38:44 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0alter=20rename=20=E7=9A=84?= =?UTF-8?q?=E7=B1=BB=E5=9E=8B=E4=B8=BArename?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../otter/canal/parse/inbound/mysql/ddl/DruidDdlParser.java | 1 + 1 file changed, 1 insertion(+) 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 d82e5eff..68f1ff5a 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 @@ -71,6 +71,7 @@ public class DruidDdlParser { DdlResult ddlResult = new DdlResult(); processName(ddlResult, schmeaName, alterTable.getName(), true); processName(ddlResult, schmeaName, ((SQLAlterTableRename) item).getToName(), false); + ddlResult.setType(EventType.RENAME); ddlResults.add(ddlResult); } else if (item instanceof SQLAlterTableAddIndex) { DdlResult ddlResult = new DdlResult();