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 e3c06678b..4effd91c2 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 @@ -1861,7 +1861,7 @@ flushStatement killStatement : KILL connectionFormat=(CONNECTION | QUERY)? - decimalLiteral+ + (decimalLiteral+ | mysqlVariable) ; loadIndexIntoCache diff --git a/debezium-ddl-parser/src/test/resources/mysql/examples/kill.sql b/debezium-ddl-parser/src/test/resources/mysql/examples/kill.sql new file mode 100644 index 000000000..a18e5a221 --- /dev/null +++ b/debezium-ddl-parser/src/test/resources/mysql/examples/kill.sql @@ -0,0 +1,8 @@ +#begin +KILL CONNECTION 12345; +KILL QUERY 12345; +KILL CONNECTION @conn_variable; +KILL QUERY @query_variable; +KILL CONNECTION @@global_variable; +KILL QUERY @@global_variable; +#end