Function sqlx_query_works

tests/client_compat.rs:561–590

()

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

    let row = sqlx::query("SELECT $1::int4 + 1 AS answer")
        .bind(41_i32)
        .fetch_one(&mut conn)
        .await
        .context("run SQLx parameter query")?;
    assert_eq!(row.try_get::<i32, _>("answer")?, 42);

    sqlx::query("CREATE TABLE items(value TEXT)")
        .execute(&mut conn)
        .await?;
    sqlx::query("INSERT INTO items(value) VALUES ($1)")
        .bind("alpha")
        .execute(&mut conn)
        .await?;
    let row = sqlx::query("SELECT value FROM items WHERE value = $1")
        .bind("alpha")
        .fetch_one(&mut conn)
        .await?;
    assert_eq!(row.try_get::<String, _>("value")?, "alpha");

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

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