pyrite/torn-api.rs
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

update sqlx to ^0.7

Browse source
This commit is contained in:
TotallyNot 2023-08-13 18:46:40 +02:00
parent 29639a69aa
commit 2182204e05
2 changed files with 8 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

10
torn-key-pool/src/postgres.rs
View file

@ -205,7 +205,7 @@ where
let mut tx = self.pool.begin().await?;
sqlx::query("set transaction isolation level repeatable read")
.execute(&mut tx)
.execute(&mut *tx)
.await?;
let mut qb = QueryBuilder::new(indoc::indoc! {
@ -258,7 +258,7 @@ where
api_keys.domains"
});
let key = qb.build_query_as().fetch_optional(&mut tx).await?;
let key = qb.build_query_as().fetch_optional(&mut *tx).await?;
tx.commit().await?;
@ -307,7 +307,7 @@ where
let mut tx = self.pool.begin().await?;
sqlx::query("set transaction isolation level repeatable read")
.execute(&mut tx)
.execute(&mut *tx)
.await?;
let mut qb = QueryBuilder::new(indoc::indoc! {
@ -339,7 +339,7 @@ where
qb.push("\norder by uses limit ");
qb.push_bind(self.limit);
let mut keys: Vec<Self::Key> = qb.build_query_as().fetch_all(&mut tx).await?;
let mut keys: Vec<Self::Key> = qb.build_query_as().fetch_all(&mut *tx).await?;
if keys.is_empty() {
tx.commit().await?;
@ -383,7 +383,7 @@ where
"#})
.bind(keys.iter().map(|k| k.id).collect::<Vec<_>>())
.bind(keys.iter().map(|k| k.uses).collect::<Vec<_>>())
.execute(&mut tx)
.execute(&mut *tx)
.await?;
tx.commit().await?;