()
| 33 | ) |
| 34 | |
| 35 | func createSQLFSTestingDatabase() { |
| 36 | db := database.GetTestingDBSingleton() |
| 37 | if db.DriverName == "maxcompute" { |
| 38 | // maxcompute database is pre created |
| 39 | testDatabaseName = test.GetEnv("SQLFLOW_TEST_DB_MAXCOMPUTE_PROJECT", "test") |
| 40 | } else { |
| 41 | stmt := fmt.Sprintf("CREATE DATABASE IF NOT EXISTS %s;", testDatabaseName) |
| 42 | if _, e := db.Exec(stmt); e != nil { |
| 43 | log.Fatalf("Cannot create sqlfs testing database %s: %v", testDatabaseName, e) |
| 44 | } |
| 45 | } |
| 46 | } |
| 47 | |
| 48 | func TestSQLFSWriterCreate(t *testing.T) { |
| 49 | createSQLFSTestingDatabaseOnce.Do(createSQLFSTestingDatabase) |
nothing calls this directly
no test coverage detected