SQLX documentation表示以下内容:
execute查询终结器返回受影响的行数(如果有)，并删除所有收到的结果. 此外，还有fetch、fetch_one、fetch_optional和fetch_all个接收结果.从
sqlx::query返回的Query类型将从数据库返回Row<'conn>.可以访问列值 按序号或按名字加row.get().由于Row在连接上保留了不变的borrow ，因此只有一个Row个可能同时存在.
有没有办法既拿到rows_affected行又拿到排自己的？
我try 在有意回滚的事务中运行相同的查询两次，但当我收到SQL语句时，我已经处于事务的中间，并且我不能并行运行两个事务.
有没有办法不用运行两次就能完成呢？
我使用Rust、最新的SQLX和Postgres作为数据库.
您还需要futures个 crate :
[dependencies]
futures = { version = "0.3.28", default-features = false }
sqlx = { version = "0.7.2", features = ["runtime-tokio", "postgres"] }
然后你可以像这样搞恶作剧:
use futures::stream::StreamExt;
use sqlx::{postgres::PgPoolOptions, Either, PgPool, Row};
#[tokio::main]
async fn main() {
# ...
do_query(
&pool,
"INSERT INTO todos (description) VALUES ('One'), ('Two') RETURNING id",
)
.await;
do_query(&pool, "DELETE FROM todos").await;
}
async fn do_query(pool: &PgPool, query: &str) {
let prefix = query.split_whitespace().next().unwrap();
let mut results = sqlx::query(query).fetch_many(pool);
while let Some(result) = results.next().await {
let either = result.unwrap();
match either {
Either::Left(res) => {
let num = res.rows_affected();
println!("[{prefix}] affected {num} rows");
}
Either::Right(row) => {
let num = row.len();
println!("[{prefix}] fetched {num} rows");
}
}
}
}
它会回来的
[INSERT] fetched 1 rows
[INSERT] fetched 1 rows
[INSERT] affected 2 rows
[DELETE] affected 2 rows