From 69374ea424469a5ff9fc06566ca1dfdad2801cb7 Mon Sep 17 00:00:00 2001 From: jake Date: Sat, 24 Oct 2020 00:18:07 -0600 Subject: [PATCH] use sqlx for migrations --- src/entity/gateway/postgres/postgres.rs | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/entity/gateway/postgres/postgres.rs b/src/entity/gateway/postgres/postgres.rs index c26650f..2a32d0d 100644 --- a/src/entity/gateway/postgres/postgres.rs +++ b/src/entity/gateway/postgres/postgres.rs @@ -31,8 +31,11 @@ pub struct PostgresGateway { impl PostgresGateway { pub fn new(host: &str, dbname: &str, username: &str, password: &str) -> PostgresGateway { - // the postgres dep can be removed once refinery supports sqlx - let mut conn = Client::connect(&format!("host='{}' dbname='{}' user='{}' password='{}'", host, dbname, username, password), NoTls).unwrap(); + let mut conn = refinery::config::Config::new(refinery::config::ConfigDbType::Postgres) + .set_db_host(&host) + .set_db_user(&username) + .set_db_pass(&password) + .set_db_name(&dbname); embedded::migrations::runner().run(&mut conn).unwrap(); let pool = async_std::task::block_on(async move {