eightequal/AstralRinth
1
0
Fork 0
forked from didirus/AstralRinth
Code Pull Requests Activity

Optimize DB pooling (#328)

Browse Source
This commit is contained in:
Geometrically
2022-03-28 19:39:02 -07:00
committed by GitHub
parent a49dc04f5d
commit a3d5479878
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/database/postgres_database.rs
View File

@@ -1,3 +1,4 @@
use std::time::Duration;
use log::info; use log::info;
use sqlx::migrate::MigrateDatabase; use sqlx::migrate::MigrateDatabase;
use sqlx::postgres::{PgPool, PgPoolOptions}; use sqlx::postgres::{PgPool, PgPoolOptions};
@@ -12,7 +13,7 @@ pub async fn connect() -> Result<PgPool, sqlx::Error> {
dotenv::var("DATABASE_MIN_CONNECTIONS") dotenv::var("DATABASE_MIN_CONNECTIONS")
.ok() .ok()
.and_then(|x| x.parse().ok()) .and_then(|x| x.parse().ok())
.unwrap_or(16), .unwrap_or(0),
) )
.max_connections( .max_connections(
dotenv::var("DATABASE_MAX_CONNECTIONS") dotenv::var("DATABASE_MAX_CONNECTIONS")
@@ -20,6 +21,7 @@ pub async fn connect() -> Result<PgPool, sqlx::Error> {
.and_then(|x| x.parse().ok()) .and_then(|x| x.parse().ok())
.unwrap_or(16), .unwrap_or(16),
) )
.max_lifetime(Some(Duration::from_secs(60 * 60)))
.connect(&database_url) .connect(&database_url)
.await?; .await?;