From 59723a18837662b73e8d34940d8f1d253bbf0071 Mon Sep 17 00:00:00 2001 From: zy-kkk Date: Sat, 5 Aug 2023 22:23:58 +0800 Subject: [PATCH] [fix](jdbc catalog) getInsertSql to use databaseProperName for column names (#22616) --- .../src/main/java/org/apache/doris/catalog/JdbcTable.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/JdbcTable.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/JdbcTable.java index 06a055ebce..7d7e6d545a 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/catalog/JdbcTable.java +++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/JdbcTable.java @@ -41,6 +41,7 @@ import java.io.IOException; import java.util.Collections; import java.util.List; import java.util.Map; +import java.util.stream.Collectors; @Setter public class JdbcTable extends Table { @@ -102,7 +103,10 @@ public class JdbcTable extends Table { sb.append(databaseProperName(TABLE_TYPE_MAP.get(getTableTypeName()), getExternalTableName())); sb.append("("); - sb.append(String.join(",", insertCols)); + List transformedInsertCols = insertCols.stream() + .map(col -> databaseProperName(TABLE_TYPE_MAP.get(getTableTypeName()), col)) + .collect(Collectors.toList()); + sb.append(String.join(",", transformedInsertCols)); sb.append(")"); sb.append(" VALUES ("); for (int i = 0; i < insertCols.size(); ++i) {