Function sqlx_extended_query_errors_recover_after_sync

tests/client_compat.rs:762–795

()

#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
async fn sqlx_extended_query_errors_recover_after_sync() -> Result<()> {
    let server = PgliteServer::temporary_tcp()?;
    let mut conn = sqlx::PgConnection::connect(&server.connection_uri())
        .await
        .context("connect with SQLx")?;

    let parse_err = sqlx::query("SELECT missing FROM missing_table WHERE id = $1")
        .bind(7_i32)
        .fetch_one(&mut conn)
        .await
        .expect_err("undefined table should fail during extended-query parse");
    assert_sqlx_code(&parse_err, "42P01");
    let row = sqlx::query("SELECT 21::int4 AS recovered_after_parse")
        .fetch_one(&mut conn)
        .await
        .context("query after parse error")?;
    assert_eq!(row.try_get::<i32, _>("recovered_after_parse")?, 21);

    let execute_err = sqlx::query("SELECT 10 / $1::int4 AS impossible")
        .bind(0_i32)
        .fetch_one(&mut conn)
        .await
        .expect_err("division by zero should fail during extended-query execute");
    assert_sqlx_code(&execute_err, "22012");
    let row = sqlx::query("SELECT 22::int4 AS recovered_after_execute")
        .fetch_one(&mut conn)
        .await
        .context("query after execute error")?;
    assert_eq!(row.try_get::<i32, _>("recovered_after_execute")?, 22);

    conn.close().await?;
    server.shutdown()?;
    Ok(())
}

#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
async fn sqlx_simple_query_timezone_errors_recover() -> Result<()> {