Commit986e055

committed

close sql.DB before creating another one

1 parent7bde3b2 commit986e055Copy full SHA for 986e055

File tree

-2

lines changed

-2

lines changed

Lines changed: 6 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -126,7 +126,10 @@ func (b *Broker) init(t TBSubset) error {`
`126`	`126`	`varpqErr*pq.Error`
`127`	`127`	`ifxerrors.As(err,&pqErr)&&pqErr.Code=="3D000" {`
`128`	`128`	`// database does not exist.`
`129`		`-err=b.createCoderTestingDB(t)`
	`129`	`+ifcloseErr:=coderTestingDB.Close();closeErr!=nil {`
	`130`	`+returnxerrors.Errorf("close postgres connection: %w",closeErr)`
	`131`	`+}`
	`132`	`+err=createCoderTestingDB(t)`
`130`	`133`	`iferr!=nil {`
`131`	`134`	`returnxerrors.Errorf("create coder testing db: %w",err)`
`132`	`135`	`}`
`@@ -135,14 +138,15 @@ func (b *Broker) init(t TBSubset) error {`
`135`	`138`	`returnxerrors.Errorf("open postgres connection: %w",err)`
`136`	`139`	`}`
`137`	`140`	`}elseiferr!=nil {`
	`141`	`+_=coderTestingDB.Close()`
`138`	`142`	`returnxerrors.Errorf("ping '%s' database: %w",CoderTestingDBName,err)`
`139`	`143`	`}`
`140`	`144`	`b.coderTestingDB=coderTestingDB`
`141`	`145`	`b.uuid=uuid.New()`
`142`	`146`	`returnnil`
`143`	`147`	`}`
`144`	`148`
`145`		`-func(b*Broker)createCoderTestingDB(tTBSubset)error {`
	`149`	`+funccreateCoderTestingDB(tTBSubset)error {`
`146`	`150`	`db,err:=sql.Open("postgres",defaultConnectionParams.DSN())`
`147`	`151`	`iferr!=nil {`
`148`	`152`	`returnxerrors.Errorf("open postgres connection: %w",err)`

Comments

(0)