i/Aether
1
0
Fork 0
mirror of https://github.com/fawney19/Aether.git synced 2026-10-09 18:59:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

test: bound policy migration fixture connection pool

Browse Source
This commit is contained in:
elky
2026-10-05 13:01:05 +08:00
parent e379bd791c
commit 2539439656
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/aether-data/runtime/src/lifecycle/migrate/tests/policy_nulls.rs
+9 -2
View File
@@ -5,7 +5,10 @@ use aether_data_postgres::{
SqlxAuthApiKeySnapshotReadRepository, SqlxManagementTokenRepository, SqlxUserReadRepository, SqlxAuthApiKeySnapshotReadRepository, SqlxManagementTokenRepository, SqlxUserReadRepository,
}; };
use serde_json::{json, Value}; use serde_json::{json, Value};
use sqlx::{migrate::Migrate, query, query_scalar, Connection, PgConnection, PgPool}; use sqlx::{
migrate::Migrate, postgres::PgPoolOptions, query, query_scalar, Connection, PgConnection,
PgPool,
};
use super::{prepare_database_for_startup, ManagedPostgresServer, POSTGRES_MIGRATOR}; use super::{prepare_database_for_startup, ManagedPostgresServer, POSTGRES_MIGRATOR};
use crate::lifecycle::migrate::run_migrations; use crate::lifecycle::migrate::run_migrations;
@@ -80,7 +83,11 @@ async fn postgres_policy_null_migration_preserves_non_null_policies_and_is_idemp
else { else {
return; return;
}; };
let pool = PgPool::connect(server.database_url()) // Queries are sequential; avoid expanding beyond the fixture server's
// connection limit while SQLx returns prior connections asynchronously.
let pool = PgPoolOptions::new()
.max_connections(1)
.connect(server.database_url())
.await .await
.expect("policy fixture pool should connect"); .expect("policy fixture pool should connect");