database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](jdbc catalog) getInsertSql to use databaseProperName for column names (#22616)

Browse Source
This commit is contained in:
zy-kkk
2023-08-05 22:23:58 +08:00
committed by GitHub
parent 7839a0e708
commit 59723a1883
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
fe/fe-core/src/main/java/org/apache/doris/catalog/JdbcTable.java
View File

@ -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<String> 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) {