SF QRep: Fix column casing issues (#1476)

PeerDB-io · Mar 13, 2024 · 0d35904 · 0d35904
1 parent 18cd0f3
commit 0d35904
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/connectors/snowflake/snowflake.go b/flow/connectors/snowflake/snowflake.go
@@ -905,7 +905,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)),
 		})