diff --git a/COPYRIGHT.txt b/COPYRIGHT.txt index 8608f4502..6e66c1f77 100644 --- a/COPYRIGHT.txt +++ b/COPYRIGHT.txt @@ -36,6 +36,7 @@ Ilia Bogdanov Ivan Kovbas Ivan Vucina Jiri Pechanec +Joy Gao Jure Kajzer Listman Gamboa Liu Hanlin diff --git a/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/MySqlAntlrDdlParserTest.java b/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/MySqlAntlrDdlParserTest.java index 959d4af81..714aa817e 100644 --- a/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/MySqlAntlrDdlParserTest.java +++ b/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/MySqlAntlrDdlParserTest.java @@ -379,16 +379,6 @@ public void parseAddPartition() { assertThat(tables.forTable(new TableId(null, null, "flat_view_request_log"))).isNotNull(); } - @Test - @FixFor("DBZ-1113") - public void parseAddMultiplePartitions() { - String ddl = - "CREATE TABLE test (id INT, PRIMARY KEY (id));" - + "ALTER TABLE test ADD PARTITION (PARTITION p1 VALUES LESS THAN (10), PARTITION p_max VALUES LESS THAN MAXVALUE);"; - parser.parse(ddl, tables); - assertThat(tables.size()).isEqualTo(1); - } - @Test @FixFor("DBZ-688") public void parseGeomCollection() { 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 3cd73ffba..3a765ad36 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 @@ -1546,6 +1546,16 @@ public void parsePartitionWithEngine() { assertThat(tables.forTable(new TableId(null, null, "flat_view_request_log"))).isNotNull(); } + @Test + @FixFor("DBZ-1113") + public void parseAddMultiplePartitions() { + String ddl = + "CREATE TABLE test (id INT, PRIMARY KEY (id));" + + "ALTER TABLE test ADD PARTITION (PARTITION p1 VALUES LESS THAN (10), PARTITION p_max VALUES LESS THAN MAXVALUE);"; + parser.parse(ddl, tables); + assertThat(tables.size()).isEqualTo(1); + } + @Test @FixFor("DBZ-767") public void shouldParseChangeColumnAndKeepName() { diff --git a/debezium-ddl-parser/src/main/antlr4/io/debezium/ddl/parser/mysql/generated/MySqlParser.g4 b/debezium-ddl-parser/src/main/antlr4/io/debezium/ddl/parser/mysql/generated/MySqlParser.g4 index 0bd724839..14a27b31f 100644 --- a/debezium-ddl-parser/src/main/antlr4/io/debezium/ddl/parser/mysql/generated/MySqlParser.g4 +++ b/debezium-ddl-parser/src/main/antlr4/io/debezium/ddl/parser/mysql/generated/MySqlParser.g4 @@ -644,7 +644,7 @@ alterSpecification ')' #alterByReorganizePartition | EXCHANGE PARTITION uid WITH TABLE tableName (validationFormat=(WITH | WITHOUT) VALIDATION)? #alterByExchangePartition - | ANALYZE PARTITION (uidList | ALL) #alterByAnalyzePartitiion + | ANALYZE PARTITION (uidList | ALL) #alterByAnalyzePartition | CHECK PARTITION (uidList | ALL) #alterByCheckPartition | OPTIMIZE PARTITION (uidList | ALL) #alterByOptimizePartition | REBUILD PARTITION (uidList | ALL) #alterByRebuildPartition