Function tokio_postgres_extended_query_works

tests/client_compat.rs:17–46

()

#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
async fn tokio_postgres_extended_query_works() -> Result<()> {
    let server = PgliteServer::temporary_tcp()?;
    let (client, connection) = tokio_postgres::connect(&server.connection_uri(), NoTls)
        .await
        .context("connect with tokio-postgres")?;
    let connection_task = tokio::spawn(connection);

    let row = client
        .query_one("SELECT $1::int4 + 1 AS answer", &[&41_i32])
        .await
        .context("run tokio-postgres parameter query")?;
    assert_eq!(row.get::<_, i32>("answer"), 42);

    client
        .batch_execute(
            "CREATE TABLE items(value TEXT);
             INSERT INTO items(value) VALUES ('alpha');",
        )
        .await?;
    let row = client
        .query_one("SELECT value FROM items WHERE value = $1", &[&"alpha"])
        .await
        .context("run tokio-postgres table query")?;
    assert_eq!(row.get::<_, &str>(0), "alpha");

    drop(client);
    wait_for_tokio_postgres(connection_task).await?;
    server.shutdown()?;
    Ok(())
}

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