SF QRep: Fix column casing issues (#1476)

PeerDB-io · Mar 12, 2024 · 1514b3a · 1514b3a
1 parent 50646c9
commit 1514b3a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/connectors/snowflake/snowflake.go b/flow/connectors/snowflake/snowflake.go
@@ -871,7 +871,7 @@ func (c *SnowflakeConnector) getTableSchemaForTable(ctx context.Context, tableNa
 	colFields := make([]*protos.FieldDescription, 0, len(qRecordSchema.Fields))
 	for _, field := range qRecordSchema.Fields {
 		colFields = append(colFields, &protos.FieldDescription{
-			Name:         field.Name,
+			Name:         utils.PostgresIdentifierNormalize(field.Name),
 			Type:         string(field.Type),
 			TypeModifier: numeric.MakeNumericTypmod(int32(field.Precision), int32(field.Scale)),
 		})