Skip to content

Commit

Permalink
fix: use namespace as identifier for snowflake queries instead of add…
Browse files Browse the repository at this point in the history
…ing database into it
  • Loading branch information
achettyiitr committed Sep 22, 2022
1 parent 3a2e75c commit d2c7827
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions warehouse/snowflake/snowflake.go
Original file line number Diff line number Diff line change
Expand Up @@ -132,9 +132,7 @@ func ColumnsWithDataTypes(columns map[string]string, prefix string) string {

// schemaIdentifier returns [DATABASE_NAME].[NAMESPACE] format to access the schema directly.
func (sf *HandleT) schemaIdentifier() string {
DatabaseName := warehouseutils.GetConfigValue(SFDbName, sf.Warehouse)
return fmt.Sprintf(`"%s"."%s"`,
DatabaseName,
return fmt.Sprintf(`"%s"`,
sf.Namespace,
)
}
Expand Down

0 comments on commit d2c7827

Please sign in to comment.