Function sqlx_bind_errors_recover_after_sync

tests/client_compat.rs:93–126

()

#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
async fn sqlx_bind_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 invalid_int = sqlx::query("SELECT $1::int4 AS value")
        .bind("not_an_int")
        .fetch_one(&mut conn)
        .await
        .expect_err("invalid int text should fail while binding a typed parameter");
    assert_sqlx_code(&invalid_int, "22P02");
    let row = sqlx::query("SELECT 31::int4 AS recovered_after_invalid_bind")
        .fetch_one(&mut conn)
        .await
        .context("query after invalid bind value")?;
    assert_eq!(row.try_get::<i32, _>("recovered_after_invalid_bind")?, 31);

    let wrong_param_count = sqlx::query("SELECT $1::int4 + $2::int4 AS value")
        .bind(1_i32)
        .fetch_one(&mut conn)
        .await
        .expect_err("missing parameter should fail during extended-query bind");
    assert_sqlx_code(&wrong_param_count, "08P01");
    let row = sqlx::query("SELECT 32::int4 AS recovered_after_param_count")
        .fetch_one(&mut conn)
        .await
        .context("query after wrong parameter count")?;
    assert_eq!(row.try_get::<i32, _>("recovered_after_param_count")?, 32);

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

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