(flink-cdc) branch master updated: [FLINK-38641][cdc/mysql] Unquote double quotes from default values on MySQL (#4171)

[kunni]

This is an automated email from the ASF dual-hosted git repository.

kunni pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git


The following commit(s) were added to refs/heads/master by this push:
     new 25fa95e8b [FLINK-38641][cdc/mysql] Unquote double quotes from default 
values on MySQL (#4171)
25fa95e8b is described below

commit 25fa95e8b0125713ca7cbeffd264606559d013ba
Author: Junbo Wang <beryllw...@gmail.com>
AuthorDate: Tue Nov 18 15:38:43 2025 +0800

    [FLINK-38641][cdc/mysql] Unquote double quotes from default values on MySQL 
(#4171)
---
 .../connector/mysql/antlr/listener/DefaultValueParserListener.java    | 4 +++-
 .../apache/flink/cdc/connectors/mysql/table/MySqlConnectorITCase.java | 2 +-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/antlr/listener/DefaultValueParserListener.java
 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/antlr/listener/DefaultValueParserListener.java
index 8a956123e..563d7b10a 100644
--- 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/antlr/listener/DefaultValueParserListener.java
+++ 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/antlr/listener/DefaultValueParserListener.java
@@ -95,7 +95,9 @@ public class DefaultValueParserListener extends 
MySqlParserBaseListener {
     }
 
     private String unquote(String stringLiteral) {
-        if (stringLiteral != null && stringLiteral.startsWith("'") && 
stringLiteral.endsWith("'")) {
+        if (stringLiteral != null
+                && ((stringLiteral.startsWith("'") && 
stringLiteral.endsWith("'"))
+                        || (stringLiteral.startsWith("\"") && 
stringLiteral.endsWith("\"")))) {
             return stringLiteral.substring(1, stringLiteral.length() - 1);
         }
         return stringLiteral;
diff --git 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlConnectorITCase.java
 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlConnectorITCase.java
index 0d89e8ba5..54bbd8481 100644
--- 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlConnectorITCase.java
+++ 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlConnectorITCase.java
@@ -1514,7 +1514,7 @@ class MySqlConnectorITCase extends MySqlSourceTestBase {
                             + "     double_c DOUBLE DEFAULT ' 25',\n"
                             + "     double_un_c DOUBLE UNSIGNED DEFAULT ' 
26',\n"
                             + "     double_un_z_c DOUBLE UNSIGNED ZEROFILL 
DEFAULT ' 27',\n"
-                            + "     tiny_un_c TINYINT UNSIGNED DEFAULT ' 28 '"
+                            + "     tiny_un_c TINYINT UNSIGNED DEFAULT \" 28 
\""
                             + " );");
         }
         actualRows.addAll(fetchRows(iterator, expected.length - 2));