Skip to content

Commit

Permalink
deprecated old test case. Now invalid object will be detected in conn…
Browse files Browse the repository at this point in the history
…ection
  • Loading branch information
smtakeda committed Nov 17, 2017
1 parent 7e6d467 commit ac33a92
Showing 1 changed file with 0 additions and 70 deletions.
70 changes: 0 additions & 70 deletions driver_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -439,76 +439,6 @@ func TestCRUD(t *testing.T) {
})
}

func TestSchemaWarehouseIncludingSpace(t *testing.T) {
newSchemaName := "TEST SCHEMA"
newWarehouseName := "TEST WAREHOUSE"
canCreateWarehouse := false
runTests(t, dsn, func(dbt *DBTest) {
dbt.mustExec(fmt.Sprintf(`CREATE OR REPLACE SCHEMA "%v"`, newSchemaName))
_, err := dbt.db.Exec(fmt.Sprintf(`CREATE OR REPLACE WAREHOUSE "%v"`, newWarehouseName))
if err != nil {
if derr, ok := err.(*SnowflakeError); ok {
if derr.Number != 3001 {
t.Fatalf("failed to create warehouse with unexpected error. %v", derr)
}
} else {
t.Fatalf("failed to create warehouse with unexpected error. %v", err)
}
} else {
canCreateWarehouse = true
}
})
newDSN := fmt.Sprintf("%s:%s@%s/%s/%s", user, pass, host, dbname, url.QueryEscape(newSchemaName))
parameters := url.Values{}
parameters.Add("warehouse", newWarehouseName)
if protocol != "" {
parameters.Add("protocol", protocol)
}
if account != "" {
parameters.Add("account", account)
}
newDSN += "?" + parameters.Encode()
db, err := sql.Open("snowflake", newDSN)
if err != nil {
t.Fatalf("failed to connect. DSN: %v", newDSN)
}
defer db.Close()
rows, err := db.Query("SELECT CURRENT_SCHEMA(), CURRENT_WAREHOUSE()")
if err != nil {
t.Fatalf("failed to query. %v", err)
}
defer rows.Close()
if !rows.Next() {
t.Fatal("failed to get the current database")
}
var gotSchemaName sql.NullString
var gotWarehouseName sql.NullString
if err := rows.Scan(&gotSchemaName, &gotWarehouseName); err != nil {
t.Fatalf("failed to scan schema and warehouse names. err: %v", err)
}
if !gotSchemaName.Valid || gotSchemaName.String != newSchemaName {
t.Fatalf("failed to match schema name. expected: %v, got: %v", newSchemaName, gotSchemaName)
}
if !gotWarehouseName.Valid || gotWarehouseName.String != newWarehouseName {
t.Fatalf("failed to match warehouse name. expected: %v, got: %v", newWarehouseName, gotWarehouseName)
}
runTests(t, dsn, func(dbt *DBTest) {
if canCreateWarehouse {
_, err := dbt.db.Exec(fmt.Sprintf(`DROP WAREHOUSE IF EXISTS "%v"`, newWarehouseName))
if err != nil {
if derr, ok := err.(*SnowflakeError); ok {
if derr.Number != 3001 {
t.Fatalf("failed to drop warehouse with unexpected error. %v", derr)
}
} else {
t.Fatalf("failed to drop warehouse with unexpected error. %v", err)
}
}
}
dbt.mustExec(fmt.Sprintf(`DROP SCHEMA IF EXISTS "%v"`, newSchemaName))
})
}

func TestInt(t *testing.T) {
runTests(t, dsn, func(dbt *DBTest) {
types := []string{"INT", "INTEGER"}
Expand Down

0 comments on commit ac33a92

Please sign in to comment.