diff --git a/sqlg-postgres-parent/sqlg-postgres-dialect/src/main/java/org/umlg/sqlg/sql/dialect/PostgresDialect.java b/sqlg-postgres-parent/sqlg-postgres-dialect/src/main/java/org/umlg/sqlg/sql/dialect/PostgresDialect.java index 776345080..8996d69b0 100644 --- a/sqlg-postgres-parent/sqlg-postgres-dialect/src/main/java/org/umlg/sqlg/sql/dialect/PostgresDialect.java +++ b/sqlg-postgres-parent/sqlg-postgres-dialect/src/main/java/org/umlg/sqlg/sql/dialect/PostgresDialect.java @@ -1138,11 +1138,17 @@ private void flushElementPropertyCache(SqlgGraph sqlgGra Map keyPropertyTypeMap = new HashMap<>(); for (String key : keys) { PropertyType propertyType = sqlgGraph.getTopology().getTableFor(schemaTable.withPrefix(forVertices ? VERTEX_PREFIX : EDGE_PREFIX)).get(key); + if (keys.size() == 1 && propertyType.getPostFixes().length > 0) { + sql.append("("); + } keyPropertyTypeMap.put(key, propertyType); appendKeyForBatchUpdate(propertyType, sql, key, false); if (count++ < keys.size()) { sql.append(", "); } + if (keys.size() == 1 && propertyType.getPostFixes().length > 0) { + sql.append(")"); + } } if (keys.size() > 1) { sql.append(")");