Details
-
Bug
-
Resolution: Done
-
Major
-
1.2.0.Beta2
-
None
Description
Connecting Debezium to an empty MySQL database and executing this:
CREATE FUNCTION myfunc(a INT) RETURNS INT BEGIN DECLARE result INT; SET result = UTC_TIMESTAMP; RETURN result; END;
causes Debezium to fail with this error:
org.apache.kafka.connect.errors.ConnectException: io.debezium.text.ParsingException: no viable alternative at input 'CREATE DEFINER=`root`@`%` FUNCTION `myfunc`(a INT) RETURNS int(11)\nBEGIN\n DECLARE result INT;\n SET result = UTC_TIMESTAMP;'
at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:298)
at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:101)
...
The function works fine in MySQL. Adding parenthesis at the end of the function name makes it work for Debezium, but MySQL also accepts the function name without the parenthesis. Try, for instance `SELECT UTC_TIMESTAMP;`.
The following patch fixes the problem for me, but again (as in DBZ-2153), I'm not sure this is the proper place to do this fix:
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 3aaf1ab4..0cbf0b57 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
@@ -2188,7 +2188,7 @@ functionCall
specificFunction
: (
CURRENT_DATE | CURRENT_TIME | CURRENT_TIMESTAMP
- | CURRENT_USER | LOCALTIME
+ | CURRENT_USER | LOCALTIME | UTC_TIMESTAMP
) #simpleFunctionCall
| CONVERT '(' expression separator=',' convertedDataType ')' #dataTypeFunctionCall
| CONVERT '(' expression USING charsetName ')' #dataTypeFunctionCall
