@@ -8,11 +8,11 @@ import (
88"sync"
99"time"
1010
11+ "github.com/google/uuid"
1112"github.com/lib/pq"
1213"golang.org/x/xerrors"
1314
1415"github.com/coder/coder/v2/cryptorand"
15- "github.com/google/uuid"
1616)
1717
1818const CoderTestingDBName = "coder_testing"
@@ -126,7 +126,10 @@ func (b *Broker) init(t TBSubset) error {
126126var pqErr * pq.Error
127127if xerrors .As (err ,& pqErr )&& pqErr .Code == "3D000" {
128128// database does not exist.
129- err = b .createCoderTestingDB (t )
129+ if closeErr := coderTestingDB .Close ();closeErr != nil {
130+ return xerrors .Errorf ("close postgres connection: %w" ,closeErr )
131+ }
132+ err = createCoderTestingDB (t )
130133if err != nil {
131134return xerrors .Errorf ("create coder testing db: %w" ,err )
132135}
@@ -135,14 +138,15 @@ func (b *Broker) init(t TBSubset) error {
135138return xerrors .Errorf ("open postgres connection: %w" ,err )
136139}
137140}else if err != nil {
141+ _ = coderTestingDB .Close ()
138142return xerrors .Errorf ("ping '%s' database: %w" ,CoderTestingDBName ,err )
139143}
140144b .coderTestingDB = coderTestingDB
141145b .uuid = uuid .New ()
142146return nil
143147}
144148
145- func ( b * Broker ) createCoderTestingDB (t TBSubset )error {
149+ func createCoderTestingDB (t TBSubset )error {
146150db ,err := sql .Open ("postgres" ,defaultConnectionParams .DSN ())
147151if err != nil {
148152return xerrors .Errorf ("open postgres connection: %w" ,err )