GithubBackup/bili-sync
1
0
Fork 0
mirror of https://github.com/amtoaer/bili-sync.git synced 2026-09-05 07:28:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: 放宽数据库连接池的连接数和获取时间,避免 time out 错误 (#87)

Browse Source
This commit is contained in:
ᴀᴍᴛᴏᴀᴇʀ
2024-04-29 13:46:22 +08:00
committed by GitHub
parent f81d9fc6eb
commit e732e7d616
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/database.rs
+7 -2
View File
@@ -1,13 +1,18 @@
use anyhow::Result; use anyhow::Result;
use migration::{Migrator, MigratorTrait}; use migration::{Migrator, MigratorTrait};
use sea_orm::{Database, DatabaseConnection}; use sea_orm::{ConnectOptions, Database, DatabaseConnection};
use tokio::fs; use tokio::fs;
use crate::config::CONFIG_DIR; use crate::config::CONFIG_DIR;
pub async fn database_connection() -> Result<DatabaseConnection> { pub async fn database_connection() -> Result<DatabaseConnection> {
let target = CONFIG_DIR.join("data.sqlite"); let target = CONFIG_DIR.join("data.sqlite");
fs::create_dir_all(&*CONFIG_DIR).await?; fs::create_dir_all(&*CONFIG_DIR).await?;
Ok(Database::connect(format!("sqlite://{}?mode=rwc", target.to_str().unwrap())).await?) let mut option = ConnectOptions::new(format!("sqlite://{}?mode=rwc", target.to_str().unwrap()));
option
.max_connections(100)
.min_connections(5)
.acquire_timeout(std::time::Duration::from_secs(90));
Ok(Database::connect(option).await?)
} }
pub async fn migrate_database(connection: &DatabaseConnection) -> Result<()> { pub async fn migrate_database(connection: &DatabaseConnection) -> Result<()> {