(t *testing.T)
| 1357 | } |
| 1358 | |
| 1359 | func TestConnExecParamsPrecanceled(t *testing.T) { |
| 1360 | t.Parallel() |
| 1361 | |
| 1362 | ctx, cancel := context.WithTimeout(context.Background(), 120*time.Second) |
| 1363 | defer cancel() |
| 1364 | |
| 1365 | pgConn, err := pgconn.Connect(ctx, os.Getenv("PGX_TEST_DATABASE")) |
| 1366 | require.NoError(t, err) |
| 1367 | defer closeConn(t, pgConn) |
| 1368 | |
| 1369 | cancel() |
| 1370 | result := pgConn.ExecParams(ctx, "select $1::text", [][]byte{[]byte("Hello, world")}, nil, nil, nil).Read() |
| 1371 | require.Error(t, result.Err) |
| 1372 | assert.True(t, errors.Is(result.Err, context.Canceled)) |
| 1373 | assert.True(t, pgconn.SafeToRetry(result.Err)) |
| 1374 | |
| 1375 | ensureConnValid(t, pgConn) |
| 1376 | } |
| 1377 | |
| 1378 | func TestConnExecParamsEmptySQL(t *testing.T) { |
| 1379 | t.Parallel() |
nothing calls this directly
no test coverage detected