[fix](group commit) Fix syntax error when insert into table which column names contain keyword (#33322)

This commit is contained in:
meiyi
2024-04-08 08:44:02 +08:00
committed by yiguolei
parent d667df2d06
commit 741d4ff97e
3 changed files with 45 additions and 1 deletions

View File

@ -91,7 +91,7 @@ public class GroupCommitPlanner {
}
TStreamLoadPutRequest streamLoadPutRequest = new TStreamLoadPutRequest();
if (targetColumnNames != null) {
streamLoadPutRequest.setColumns(String.join(",", targetColumnNames));
streamLoadPutRequest.setColumns("`" + String.join("`,`", targetColumnNames) + "`");
if (targetColumnNames.stream().anyMatch(col -> col.equalsIgnoreCase(Column.SEQUENCE_COL))) {
streamLoadPutRequest.setSequenceCol(Column.SEQUENCE_COL);
}