fix(pg-migration): db_url fetch

This commit is contained in:
2025-02-16 17:21:02 +00:00
parent 3e790cd18a
commit 4d1c210986

View File

@@ -89,7 +89,7 @@ fn run_app() -> Result<(), i32> {
Ok(()) Ok(())
} }
Some(("migrate", sub_m)) => { Some(("migrate", sub_m)) => {
let db_url = matches.get_one::<String>("db_url").unwrap(); let db_url = sub_m.get_one::<String>("db_url").unwrap();
let set_vars: Vec<String> = sub_m let set_vars: Vec<String> = sub_m
.get_many::<String>("set") .get_many::<String>("set")
.map(|vals| vals.cloned().collect()) .map(|vals| vals.cloned().collect())
@@ -99,8 +99,8 @@ fn run_app() -> Result<(), i32> {
let force = sub_m.get_flag("force"); let force = sub_m.get_flag("force");
apply_migrations(&mut client, migration_dir, db_url, force, &set_vars) apply_migrations(&mut client, migration_dir, db_url, force, &set_vars)
} }
Some(("fetch", _)) => { Some(("fetch", sub_m)) => {
let db_url = matches.get_one::<String>("db_url").unwrap(); let db_url = sub_m.get_one::<String>("db_url").unwrap();
let mut client = Client::connect(db_url, NoTls).expect("DB connection failed"); let mut client = Client::connect(db_url, NoTls).expect("DB connection failed");
init_db(&mut client, &inherits); init_db(&mut client, &inherits);
fetch_migrations(&mut client, migration_dir); fetch_migrations(&mut client, migration_dir);