From 2752413f297ef63a76e8d0b067694ab5f5c56a7d Mon Sep 17 00:00:00 2001
From: Kaushik Iska <iska.kaushik@gmail.com>
Date: Tue, 28 Nov 2023 14:47:57 -0500
Subject: [PATCH] quote the columns for exclusion to preserve case sensitivity
 (#733)

---
 flow/workflows/snapshot_flow.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/flow/workflows/snapshot_flow.go b/flow/workflows/snapshot_flow.go
index 1c08a40fac..ae12ecc7a4 100644
--- a/flow/workflows/snapshot_flow.go
+++ b/flow/workflows/snapshot_flow.go
@@ -145,7 +145,11 @@ func (s *SnapshotFlowExecution) cloneTable(
 	if len(mapping.Exclude) != 0 {
 		for _, v := range s.config.TableNameSchemaMapping {
 			if v.TableIdentifier == srcName {
-				from = strings.Join(maps.Keys(v.Columns), ",")
+				cols := maps.Keys(v.Columns)
+				for i, col := range cols {
+					cols[i] = fmt.Sprintf(`"%s"`, col)
+				}
+				from = strings.Join(cols, ",")
 				break
 			}
 		}