mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-01-06 13:43:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Add DENDRITE_SKIP_DB_TESTS environment variable to bring @kegsay joy

Browse source
This commit is contained in:
Neil Alexander 2022-05-03 17:31:26 +01:00
parent f0e1359723
commit d5d788f315
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 11 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
test/db.go
View file

@ -33,6 +33,15 @@ var DBTypeSQLite DBType = 1
var DBTypePostgres DBType = 2 var DBTypePostgres DBType = 2
var Quiet = false var Quiet = false
var Required = os.Getenv("DENDRITE_SKIP_DB_TESTS") == ""
func fatalError(t *testing.T, format string, args ...interface{}) {
if Required {
t.Fatalf(format, args...)
} else {
t.Skipf(format, args...)
}
}
func createLocalDB(t *testing.T, dbName string) { func createLocalDB(t *testing.T, dbName string) {
if !Quiet { if !Quiet {
@ -45,14 +54,14 @@ func createLocalDB(t *testing.T, dbName string) {
} }
err := createDB.Run() err := createDB.Run()
if err != nil { if err != nil {
t.Skipf("createLocalDB returned error: %s", err) fatalError(t, "createLocalDB returned error: %s", err)
} }
} }
func createRemoteDB(t *testing.T, dbName, user, connStr string) { func createRemoteDB(t *testing.T, dbName, user, connStr string) {
db, err := sql.Open("postgres", connStr+" dbname=postgres") db, err := sql.Open("postgres", connStr+" dbname=postgres")
if err != nil { if err != nil {
t.Skipf("failed to open postgres conn with connstr=%s : %s", connStr, err) fatalError(t, "failed to open postgres conn with connstr=%s : %s", connStr, err)
} }
_, err = db.Exec(fmt.Sprintf(`CREATE DATABASE %s;`, dbName)) _, err = db.Exec(fmt.Sprintf(`CREATE DATABASE %s;`, dbName))
if err != nil { if err != nil {