andras/reconcile
1
0
Fork 0
Code Issues Pull requests 5 Projects Releases Packages Wiki Activity Actions

Create DB

Browse source
This commit is contained in:
Andras Schmelczer 2024-12-08 15:15:15 +00:00
parent d5a5367e1e
commit cabdb52540
No known key found for this signature in database
GPG key ID: FC8F2C3D3D1A718C
1 changed files with 8 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

10
backend/sync_server/src/database.rs
View file

@ -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<Self> {
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!(