(t *testing.T)
| 1194 | } |
| 1195 | |
| 1196 | func TestConnExecContextPrecanceled(t *testing.T) { |
| 1197 | t.Parallel() |
| 1198 | |
| 1199 | ctx, cancel := context.WithTimeout(context.Background(), 120*time.Second) |
| 1200 | defer cancel() |
| 1201 | |
| 1202 | pgConn, err := pgconn.Connect(ctx, os.Getenv("PGX_TEST_DATABASE")) |
| 1203 | require.NoError(t, err) |
| 1204 | defer closeConn(t, pgConn) |
| 1205 | |
| 1206 | cancel() |
| 1207 | _, err = pgConn.Exec(ctx, "select 'Hello, world'").ReadAll() |
| 1208 | assert.Error(t, err) |
| 1209 | assert.True(t, errors.Is(err, context.Canceled)) |
| 1210 | assert.True(t, pgconn.SafeToRetry(err)) |
| 1211 | |
| 1212 | ensureConnValid(t, pgConn) |
| 1213 | } |
| 1214 | |
| 1215 | func TestConnExecParams(t *testing.T) { |
| 1216 | t.Parallel() |
nothing calls this directly
no test coverage detected