Skip to content

Commit e9f833b

Browse files
committed
close db properly
1 parent 118bf98 commit e9f833b

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

cli/server.go

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2363,10 +2363,8 @@ func ConnectToPostgres(ctx context.Context, logger slog.Logger, driver string, d
23632363
if !version.Next() {
23642364
// it's critical we assign to the err variable, otherwise the defer statement
23652365
// that runs db.Close() will not execute it
2366-
if err = version.Err(); err != nil {
2367-
return nil, xerrors.Errorf("no rows returned for version select: %w", err)
2368-
}
2369-
return nil, xerrors.Errorf("no rows returned for version select")
2366+
err = xerrors.Errorf("no rows returned for version select: %w", version.Err())
2367+
return nil, err
23702368
}
23712369
var versionNum int
23722370
err = version.Scan(&versionNum)
@@ -2375,7 +2373,8 @@ func ConnectToPostgres(ctx context.Context, logger slog.Logger, driver string, d
23752373
}
23762374

23772375
if versionNum < 130000 {
2378-
return nil, xerrors.Errorf("PostgreSQL version must be v13.0.0 or higher! Got: %d", versionNum)
2376+
err = xerrors.Errorf("PostgreSQL version must be v13.0.0 or higher! Got: %d", versionNum)
2377+
return nil, err
23792378
}
23802379
logger.Debug(ctx, "connected to postgresql", slog.F("version", versionNum))
23812380

0 commit comments

Comments
 (0)