Migrator for writing sqlx migration using Rust instead of SQL
| License | Crates Version | Docs |
| :---: | :---: | :---: |
| |
|
|
Supported Databases: - [X] PostgreSQL - [X] SQLite
toml
sqlx_migrator = "0.2.0"
To use sqlxmigrator first you need to implement Operation trait to write your sqlx operation ```rust use sqlxmigrator::error::Error; use sqlxmigrator::operation::Operation; //Its better to use sqlx imported from sqlxmigrator use sqlx_migrator::sqlx;
pub(crate) struct FirstOperation;
impl Operation for FirstOperation { type Database = sqlx::Postgres;
// Up function runs apply migration
async fn up(
&self,
connection: &mut <Self::Database as sqlx::Database>::Connection,
) -> Result<(), Error> {
sqlx::query("CREATE TABLE sample (id INTEGER PRIMARY KEY, name TEXT)")
.execute(connection)
.await?;
Ok(())
}
// down migration runs down migration
async fn down(
&self,
connection: &mut <Self::Database as sqlx::Database>::Connection,
) -> Result<(), Error> {
sqlx::query("DROP TABLE sample").execute(connection).await?;
Ok(())
}
} ```
After creation of operation you can implement Migration struct to create single migration
```rust use sqlxmigrator::error::Error; use sqlxmigrator::migration::Migration; use sqlxmigrator::operation::Operation; use sqlxmigrator::sqlx;
pub(crate) struct FirstMigration;
impl Migration for FirstMigration { type Database = Postgres;
// app where migration lies can be any value
fn app(&self) -> &str {
"main"
}
// name of migration
// Combination of migration app and name must be unique to work properly
fn name(&self) -> &str {
"first_migration"
}
// use operations function to add operation part of migration
fn operations(&self) -> Vec<Box<dyn Operation<Database = Self::Database>>> {
vec![Box::new(FirstOperation)]
}
// Migration trait also have multiple other function see docs for usage
} ```
Now at last you need to create migrator for your database to run migrations ```rust use sqlxmigrator::migrator::Migrator as MigratorTrait; use sqlxmigrator::sqlite::migrator::Migrator;
let uri = std::env::var("DATABASEURL").unwrap(); let pool = sqlx::Pool::connect(&uri).await.unwrap(); let mut migrator = Migrator::new(&pool); migrator.addmigration(FirstMigration); ```
Now you can use two ways to run migrator either directly running migration or creating cli from migrator
For directly run
rust
// use apply all to apply all pending migration
migrator.apply_all().await.unwrap();
// or use revert all to revert all applied migrations
migrator.revert_all().await.unwrap();
Or you can create cli
rust
sqlx_migrator::cli::run(Box::new(migrator)).await.unwrap();