diff --git a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlDdlParser.java b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlDdlParser.java index 58bc24316..1ac364c8f 100644 --- a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlDdlParser.java +++ b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlDdlParser.java @@ -969,6 +969,7 @@ protected void parseRenameTable(Marker start) { tokens.consume("TO"); TableId to = parseQualifiedTableName(start); databaseTables.renameTable(from, to); + signalAlterTable(from, to, start); } protected List parseColumnNameList(Marker start) { diff --git a/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/MySqlDdlParserTest.java b/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/MySqlDdlParserTest.java index 7ef279d4e..b7577ed50 100644 --- a/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/MySqlDdlParserTest.java +++ b/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/MySqlDdlParserTest.java @@ -158,7 +158,7 @@ public void shouldParseTestStatements() { parser.parse(readFile("ddl/mysql-test-statements.ddl"), tables); Testing.print(tables); assertThat(tables.size()).isEqualTo(6); // no tables - assertThat(listener.total()).isEqualTo(46); + assertThat(listener.total()).isEqualTo(49); } @Test