(conn: &mut sqlx::PgConnection, value: i32)
| 5013 | } |
| 5014 | |
| 5015 | async fn run_sqlx_scalar_query(conn: &mut sqlx::PgConnection, value: i32) -> Result<()> { |
| 5016 | let row = sqlx::query("SELECT $1::int4 + 1 AS answer") |
| 5017 | .bind(value) |
| 5018 | .fetch_one(conn) |
| 5019 | .await |
| 5020 | .context("run SQLx scalar query")?; |
| 5021 | let answer: i32 = row.try_get("answer").context("read SQLx answer")?; |
| 5022 | ensure!(answer == value + 1, "SQLx query returned {answer}"); |
| 5023 | Ok(()) |
| 5024 | } |
| 5025 | |
| 5026 | async fn run_sqlx_vector_query(conn: &mut sqlx::PgConnection) -> Result<()> { |
| 5027 | let row = sqlx::query("SELECT '[1,2,3]'::vector <-> '[1,2,4]'::vector AS distance") |
no test coverage detected