From 45b003d5f86c1109aee5ba723c698993e72dcf0c Mon Sep 17 00:00:00 2001 From: Malcolmjian Date: Tue, 15 Aug 2023 17:32:44 +0800 Subject: [PATCH] [mysql] quota the field names when executing mysql query (#2381) (#2388) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: DESKTOP-TQDONF3\狗狗jian (cherry picked from commit f7df47e2eeb9989fc7a433068062dc982f482012) --- .../cdc/connectors/mysql/source/utils/StatementUtils.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/utils/StatementUtils.java b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/utils/StatementUtils.java index 6f445fb89..13dc4b90f 100644 --- a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/utils/StatementUtils.java +++ b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/utils/StatementUtils.java @@ -244,7 +244,7 @@ public class StatementUtils { RowType pkRowType, StringBuilder sql, String predicate) { for (Iterator fieldNamesIt = pkRowType.getFieldNames().iterator(); fieldNamesIt.hasNext(); ) { - sql.append(fieldNamesIt.next()).append(predicate); + sql.append(quote(fieldNamesIt.next())).append(predicate); if (fieldNamesIt.hasNext()) { sql.append(" AND "); } @@ -255,7 +255,7 @@ public class StatementUtils { StringBuilder sql = new StringBuilder(); for (Iterator fieldNamesIt = pkRowType.getFieldNames().iterator(); fieldNamesIt.hasNext(); ) { - sql.append(fieldNamesIt.next()); + sql.append(quote(fieldNamesIt.next())); if (fieldNamesIt.hasNext()) { sql.append(" , "); } @@ -267,7 +267,7 @@ public class StatementUtils { StringBuilder sql = new StringBuilder(); for (Iterator fieldNamesIt = pkRowType.getFieldNames().iterator(); fieldNamesIt.hasNext(); ) { - sql.append("MAX(" + fieldNamesIt.next() + ")"); + sql.append("MAX(" + quote(fieldNamesIt.next()) + ")"); if (fieldNamesIt.hasNext()) { sql.append(" , "); }