reverting previous sfTypeToQValueKind map

PeerDB-io · Oct 4, 2023 · 90954c5 · 90954c5
1 parent 85db75b
commit 90954c5
Showing 1 changed file with 13 additions and 1 deletion.
diff --git a/flow/connectors/snowflake/qvalue_convert.go b/flow/connectors/snowflake/qvalue_convert.go
@@ -37,16 +37,28 @@ var qValueKindToSnowflakeTypeMap = map[qvalue.QValueKind]string{
 }
 
 var snowflakeTypeToQValueKindMap = map[string]qvalue.QValueKind{
-	"FLOAT":         qvalue.QValueKindFloat64,
+	"INT":           qvalue.QValueKindInt32,
+	"BIGINT":        qvalue.QValueKindInt64,
+	"FLOAT":         qvalue.QValueKindFloat32,
+	"DOUBLE":        qvalue.QValueKindFloat64,
+	"REAL":          qvalue.QValueKindFloat64,
+	"VARCHAR":       qvalue.QValueKindString,
+	"CHAR":          qvalue.QValueKindString,
 	"TEXT":          qvalue.QValueKindString,
 	"BOOLEAN":       qvalue.QValueKindBoolean,
+	"DATETIME":      qvalue.QValueKindTimestamp,
 	"TIMESTAMP":     qvalue.QValueKindTimestamp,
 	"TIMESTAMP_NTZ": qvalue.QValueKindTimestamp,
 	"TIMESTAMP_TZ":  qvalue.QValueKindTimestampTZ,
 	"TIME":          qvalue.QValueKindTime,
 	"DATE":          qvalue.QValueKindDate,
+	"BLOB":          qvalue.QValueKindBytes,
+	"BYTEA":         qvalue.QValueKindBytes,
 	"BINARY":        qvalue.QValueKindBytes,
+	"FIXED":         qvalue.QValueKindNumeric,
 	"NUMBER":        qvalue.QValueKindNumeric,
+	"DECIMAL":       qvalue.QValueKindNumeric,
+	"NUMERIC":       qvalue.QValueKindNumeric,
 	"VARIANT":       qvalue.QValueKindJSON,
 }