Struct MigrationRunner 

pub struct MigrationRunner { /* private fields */ }

Migration runner for executing migrations.

Implementations

impl MigrationRunner

pub fn new(migrations: Vec<Migration>) -> Self

Create a new migration runner with the given migrations.

pub fn table_name(self, name: impl Into<String>) -> Self

Set a custom migrations tracking table name.

The name is sanitized to only allow alphanumeric characters and underscores to prevent SQL injection.

pub async fn init<C: Connection>(&self, cx: &Cx, conn: &C) -> Outcome<(), Error>

Ensure the migrations tracking table exists.

pub async fn status<C: Connection>( &self, cx: &Cx, conn: &C, ) -> Outcome<Vec<(String, MigrationStatus)>, Error>

Get the status of all migrations.

pub async fn migrate<C: Connection>( &self, cx: &Cx, conn: &C, ) -> Outcome<Vec<String>, Error>

Apply all pending migrations.

pub async fn rollback<C: Connection>( &self, cx: &Cx, conn: &C, ) -> Outcome<Option<String>, Error>

Rollback the last applied migration.