From cabdb525405d5913fa1b274da0fd2b75b304a86c Mon Sep 17 00:00:00 2001 From: Andras Schmelczer Date: Sun, 8 Dec 2024 15:15:15 +0000 Subject: [PATCH] Create DB --- backend/sync_server/src/database.rs | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/backend/sync_server/src/database.rs b/backend/sync_server/src/database.rs index 28828ffa..257a82f4 100644 --- a/backend/sync_server/src/database.rs +++ b/backend/sync_server/src/database.rs @@ -1,10 +1,13 @@ +use std::str::FromStr; + use anyhow::{Context, Result}; use models::{ DocumentId, DocumentVersionId, DocumentVersionWithoutContent, StoredDocumentVersion, VaultId, }; +use sqlx::sqlite::SqliteConnectOptions; use sqlx::types::chrono::Utc; pub mod models; -use sqlx::{sqlite::SqlitePoolOptions, Executor, Pool, Sqlite}; +use sqlx::{sqlite::SqlitePoolOptions, Pool, Sqlite}; use crate::config::database_config::DatabaseConfig; @@ -17,10 +20,13 @@ pub type Transaction<'a> = sqlx::Transaction<'a, Sqlite>; impl Database { pub async fn try_new(config: &DatabaseConfig) -> Result { + let connection_options = + SqliteConnectOptions::from_str(&config.sqlite_url)?.create_if_missing(true); + let pool = SqlitePoolOptions::new() .max_connections(config.max_connections) .test_before_acquire(true) - .connect(&config.sqlite_url) + .connect_with(connection_options) .await .with_context(|| { format!(