Skip to content

Commit b21d6ad

Browse files
committed
quote insert column
1 parent 49532a6 commit b21d6ad

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/connector/src/sink/postgres.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -606,7 +606,7 @@ fn create_insert_sql(
606606
let columns: String = schema
607607
.fields()
608608
.iter()
609-
.map(|field| field.name.clone())
609+
.map(|field| quote_identifier(&field.name))
610610
.join(", ");
611611
let parameters: String = (0..number_of_rows)
612612
.map(|i| {

0 commit comments

Comments
 (0)