alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-425 Fix ALTER column for changing default value

Browse Source
This commit is contained in:
Jiri Pechanec 2017-11-13 15:01:13 +01:00 committed by Gunnar Morling
parent 39577b091c
commit 6db4e9b599
2 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlDdlParser.java
View File

@ -1229,7 +1229,7 @@ protected void parseAlterSpecification(Marker start, TableEditor table, Consumer
}
tokens.consume(); // column name
if (!tokens.canConsume("DROP", "DEFAULT")) {
tokens.consume("SET", "DEFAULT");
tokens.consume("SET");
parseDefaultClause(start);
}
} else if (tokens.canConsume("CHANGE")) {

8
debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/MySqlDdlParserTest.java
View File

@ -1293,6 +1293,14 @@ public void shouldParseAlterTableStatementWithColumnNamedColumnWithColumnWord()
assertThat(mytableColumnNames).containsOnly("def");
}
@Test
@FixFor("DBZ-425")
public void shouldParseAlterTableAlterDefaultColumnValue() {
String ddl = "CREATE TABLE t ( c1 DEC(2) NOT NULL, c2 FIXED(1,0) NOT NULL);";
ddl += "ALTER TABLE t ALTER c1 SET DEFAULT 13;";
parser.parse(ddl, tables);
}
@Test
public void parseDdlForDecAndFixed() {
String ddl = "CREATE TABLE t ( c1 DEC(2) NOT NULL, c2 FIXED(1,0) NOT NULL);";