migrator/
main.rs

1use sqlx::{Connection, PgConnection};
2use sqlx_migrator::Info;
3use sqlx_migrator::cli::MigrationCommand;
4use sqlx_migrator::migrator::Migrator;
5
6mod migrations;
7
8#[tokio::main]
9async fn main() {
10    let database_url = std::env::var("DATABASE_URL").expect("`DATABASE_URL` must be set");
11
12    let mut migrator = Migrator::default();
13    migrator
14        .add_migrations(migrations::migrations())
15        .expect("Failed to load migrations");
16
17    let mut conn = PgConnection::connect(&database_url)
18        .await
19        .expect("Failed to connect to database");
20
21    MigrationCommand::parse_and_run(&mut conn, Box::new(migrator)).await.unwrap();
22}
migrator/main.rs

migrator/
main.rs
