andras/vault-link
andras/vault-link
Watch
1
0
Fork
You've already forked vault-link
 0
Code Issues Pull requests 18 Projects Releases 55 Packages Wiki Activity Actions 36

Nicer write transaction

Browse source
This commit is contained in:
Andras Schmelczer 2026-09-19 22:04:14 +01:00
commit 4d8fc77665
1 changed files with 5 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

13
sync-server/src/app_state/database.rs
View file

@ -178,14 +178,11 @@ impl Database {
} }
pub async fn create_write_transaction(&self, vault: &VaultId) -> Result<Transaction<'static>> { pub async fn create_write_transaction(&self, vault: &VaultId) -> Result<Transaction<'static>> {
let mut transaction = self.create_readonly_transaction(vault).await?; self.get_connection_pool(vault)
.await?
// sqlx doesn't support immediate transactions for sqlite: https://github.com/launchbadge/sqlx/issues/481 .begin_with("BEGIN IMMEDIATE")
sqlx::query("END; BEGIN IMMEDIATE;") .await
.execute(&mut *transaction) .context("Cannot create write transaction")
.await?;
Ok(transaction)
} }
/// Cleanup idle connection pools that haven't been accessed in more than 5 minutes /// Cleanup idle connection pools that haven't been accessed in more than 5 minutes