Struct Migrator 

pub struct Migrator { /* private fields */ }

Implementations

impl Migrator

pub fn new(context: MigrationContext) -> Self

pub fn add_migration(self, migration: Migration) -> Self

pub fn add_migrations(self, migrations: Vec<Migration>) -> Self

pub fn get_migrations(&self) -> &Vec<Migration>

pub fn get_pending_migrations(&self) -> Vec<&Migration>

pub fn get_applied_migrations(&self) -> Vec<&Migration>

pub fn latest_version(&self) -> Option<&str>

pub fn find_migration(&self, version: &str) -> Option<&Migration>

pub fn check_version_conflicts(&self) -> Result<(), DbError>

检测迁移版本冲突（重复版本号）

返回第一个冲突的版本号（如有）。 在 migrate/up/down 等执行方法入口处调用，确保迁移列表无重复版本。

pub async fn migrate(&mut self) -> Result<Vec<String>, DbError>

执行所有待迁移（batch=0）的 up SQL

若数据库方言支持 DDL 事务（PostgreSQL/SQLite），则用事务包裹所有待执行迁移， 任一迁移失败时回滚全部变更，避免部分迁移导致的状态不一致。 不支持 DDL 事务的方言（MySQL/Oracle/SQL Server）逐条执行，失败时保留已执行的变更。

pub async fn rollback(&mut self, version: &str) -> Result<(), DbError>

回滚指定版本（执行 down SQL）

pub async fn up( &mut self, target_version: Option<&str>, ) -> Result<Vec<String>, DbError>

执行到指定版本（包括该版本）

pub async fn down( &mut self, target_version: Option<&str>, ) -> Result<Vec<String>, DbError>

回滚到指定版本（执行该版本之后所有迁移的 down SQL）

pub async fn reset(&mut self) -> Result<Vec<String>, DbError>

重置：回滚所有已执行的迁移，然后重新执行

pub async fn refresh(&mut self) -> Result<Vec<String>, DbError>

刷新：回滚所有已执行的迁移，然后重新执行

pub fn progress(&self) -> MigrationProgress

获取迁移进度