Merge pull request #3 from FindHotel/fix-snowflake-stage-import

Fix snowflake stage import
FindHotel · Jul 20, 2020 · 1c3997a · 1c3997a
2 parents 07c4f1f + 1054866
commit 1c3997a
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/VERSION b/VERSION
@@ -1 +1 @@
-0.13.2
+0.13.3
diff --git a/pkg/snowflake/stage.go b/pkg/snowflake/stage.go
@@ -191,7 +191,7 @@ func (sb *StageBuilder) Describe() string {
 
 // Show returns the SQL query that will show a stage.
 func (sb *StageBuilder) Show() string {
-	return fmt.Sprintf(`SHOW STAGES LIKE '%v' IN DATABASE "%v"`, sb.name, sb.db)
+	return fmt.Sprintf(`SHOW STAGES LIKE '%v' IN SCHEMA "%v"."%v"`, sb.name, sb.db, sb.schema)
 }
 
 type stage struct {

diff --git a/pkg/snowflake/stage_test.go b/pkg/snowflake/stage_test.go
@@ -104,5 +104,5 @@ func TestStageDescribe(t *testing.T) {
 func TestStageShow(t *testing.T) {
 	r := require.New(t)
 	s := Stage("test_stage", "test_db", "test_schema")
-	r.Equal(s.Show(), `SHOW STAGES LIKE 'test_stage' IN DATABASE "test_db"`)
+	r.Equal(s.Show(), `SHOW STAGES LIKE 'test_stage' IN SCHEMA "test_db"."test_schema"`)
 }