gopkg/pgx
2
0
Fork 0
Code Activity

Add a couple error checks

Browse Source
This commit is contained in:
Adam Pantel
2019-11-22 11:51:29 -05:00
parent f989008ad5
commit 167442e66b
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pgxpool/pool_test.go
+4 -1
View File
@@ -196,6 +196,7 @@ func TestConnReleaseChecksMaxConnLifetime(t *testing.T) {
config.MaxConnLifetime = 250 * time.Millisecond config.MaxConnLifetime = 250 * time.Millisecond
db, err := pgxpool.ConnectConfig(context.Background(), config) db, err := pgxpool.ConnectConfig(context.Background(), config)
require.NoError(t, err)
defer db.Close() defer db.Close()
c, err := db.Acquire(context.Background()) c, err := db.Acquire(context.Background())
@@ -240,6 +241,7 @@ func TestPoolBackgroundChecksMaxConnLifetime(t *testing.T) {
config.HealthCheckPeriod = 100 * time.Millisecond config.HealthCheckPeriod = 100 * time.Millisecond
db, err := pgxpool.ConnectConfig(context.Background(), config) db, err := pgxpool.ConnectConfig(context.Background(), config)
require.NoError(t, err)
defer db.Close() defer db.Close()
c, err := db.Acquire(context.Background()) c, err := db.Acquire(context.Background())
@@ -449,7 +451,8 @@ func TestConnReleaseDestroysClosedConn(t *testing.T) {
c, err := pool.Acquire(ctx) c, err := pool.Acquire(ctx)
require.NoError(t, err) require.NoError(t, err)
c.Conn().Close(ctx) err = c.Conn().Close(ctx)
require.NoError(t, err)
assert.EqualValues(t, 1, pool.Stat().TotalConns()) assert.EqualValues(t, 1, pool.Stat().TotalConns())