From 7f827f13d6897d02a6cc5897bc47f5147b9ef513 Mon Sep 17 00:00:00 2001 From: Sebastian Bruckner Date: Tue, 18 Jan 2022 14:57:23 +0100 Subject: [PATCH] DBZ-4561: Add flush table[s] grammer for all open tables --- .../io/debezium/ddl/parser/mysql/generated/MySqlParser.g4 | 4 ++-- .../src/test/resources/mysql/examples/ddl_flush.sql | 2 ++ 2 files changed, 4 insertions(+), 2 deletions(-) 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 bb9e302a9..e184d840c 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 @@ -1855,8 +1855,8 @@ flushOption | USER_RESOURCES | TABLES (WITH READ LOCK)? ) #simpleFlushOption | RELAY LOGS channelOption? #channelFlushOption - | TABLES tables flushTableOption? #tableFlushOption - | TABLE tables flushTableOption? #tableFlushOption + | TABLES tables? flushTableOption? #tableFlushOption + | TABLE tables? flushTableOption? #tableFlushOption ; flushTableOption diff --git a/debezium-ddl-parser/src/test/resources/mysql/examples/ddl_flush.sql b/debezium-ddl-parser/src/test/resources/mysql/examples/ddl_flush.sql index ed086473a..c99e5dfa6 100644 --- a/debezium-ddl-parser/src/test/resources/mysql/examples/ddl_flush.sql +++ b/debezium-ddl-parser/src/test/resources/mysql/examples/ddl_flush.sql @@ -4,12 +4,14 @@ flush local hosts; flush hosts, status; -- Table flushing +flush tables; flush local tables Foo; flush tables Foo, Bar; flush tables Foo, Bar for export; flush tables Foo, Bar with read lock; -- 'FLUSH TABLE' is an alias for 'FLUSH TABLES' (https://dev.mysql.com/doc/refman/8.0/en/flush.html) +flush table; flush local table Foo; flush TABLE Foo, Bar; flush table Foo, Bar for export;