diff --git a/database/redshift/redshift_test.go b/database/redshift/redshift_test.go index 944a6add3..9ee5cbe64 100644 --- a/database/redshift/redshift_test.go +++ b/database/redshift/redshift_test.go @@ -28,10 +28,19 @@ import ( _ "github.com/golang-migrate/migrate/v4/source/file" ) +const ( + pgPassword = "redshift" +) + var ( - opts = dktest.Options{PortRequired: true, ReadyFunc: isReady} + opts = dktest.Options{ + Env: map[string]string{"POSTGRES_PASSWORD": pgPassword}, + PortRequired: true, + ReadyFunc: isReady, + } + specs = []dktesting.ContainerSpec{ - {ImageName: "postgres:8", Options: opts}, + {ImageName: "migrate/postgres8:8", Options: opts}, } ) @@ -44,7 +53,7 @@ func pgConnectionString(host, port string) string { } func connectionString(schema, host, port string) string { - return fmt.Sprintf("%s://postgres@%s:%s/postgres?sslmode=disable", schema, host, port) + return fmt.Sprintf("%s://postgres:%s@%s:%s/postgres?sslmode=disable", schema, pgPassword, host, port) } func isReady(ctx context.Context, c dktest.ContainerInfo) bool { @@ -192,7 +201,7 @@ func TestFilterCustomQuery(t *testing.T) { t.Fatal(err) } - addr := fmt.Sprintf("postgres://postgres@%v:%v/postgres?sslmode=disable&x-custom=foobar", ip, port) + addr := fmt.Sprintf("postgres://postgres:%s@%v:%v/postgres?sslmode=disable&x-custom=foobar", pgPassword, ip, port) p := &Redshift{} d, err := p.Open(addr) if err != nil { @@ -234,7 +243,7 @@ func TestWithSchema(t *testing.T) { } // re-connect using that schema - d2, err := p.Open(fmt.Sprintf("postgres://postgres@%v:%v/postgres?sslmode=disable&search_path=foobar", ip, port)) + d2, err := p.Open(fmt.Sprintf("postgres://postgres:%s@%v:%v/postgres?sslmode=disable&search_path=foobar", pgPassword, ip, port)) if err != nil { t.Fatal(err) }