Skip to content

Commit e722421

Browse files
committed
opt: optimize sqlx connection parameters
1 parent 837e227 commit e722421

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

src/storage/sqlx/mod.rs

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
use std::{any::Any, collections::HashMap};
1+
use std::{any::Any, collections::HashMap, time::Duration};
22

33
use serde::Deserialize;
44
use serde_json::Value;
@@ -203,7 +203,12 @@ impl SqlxBackend {
203203

204204
pool.close().await;
205205

206-
let pool = sqlx::AnyPool::connect_lazy(database_url)?;
206+
let pool = sqlx::any::AnyPoolOptions::new()
207+
.max_connections(100)
208+
.idle_timeout(Duration::from_secs(300))
209+
.max_lifetime(Duration::from_secs(1800))
210+
.acquire_timeout(Duration::from_secs(5))
211+
.connect_lazy(database_url)?;
207212

208213
let lock = SqlxBackendLock::new(&pool, db_scheme.as_str(), 1);
209214
Ok(SqlxBackend { pool, table_name: table_name.to_string(), db_scheme, lock })

0 commit comments

Comments
 (0)