diff --git a/src/main/java/org/springframework/data/jdbc/core/SqlGenerator.java b/src/main/java/org/springframework/data/jdbc/core/SqlGenerator.java index dedde14396..20a5a3ba05 100644 --- a/src/main/java/org/springframework/data/jdbc/core/SqlGenerator.java +++ b/src/main/java/org/springframework/data/jdbc/core/SqlGenerator.java @@ -260,7 +260,9 @@ private String createInsertSql(Set additionalColumns) { columnNamesForInsert.addAll(additionalColumns); String tableColumns = String.join(", ", columnNamesForInsert); - String parameterNames = columnNamesForInsert.stream().collect(Collectors.joining(", :", ":", "")); + String parameterNames = columnNamesForInsert.stream()// + .map(n -> String.format(":%s", n))// + .collect(Collectors.joining(", ")); return String.format(insertTemplate, entity.getTableName(), tableColumns, parameterNames); }