如何通过FluentMigrator API仅运行指定版本的单个迁移？

要实现仅执行指定版本的单个迁移（跳过中间版本），需要绕开FluentMigrator默认的按版本顺序执行逻辑，手动定位目标迁移并执行，同时更新迁移历史表标记该版本已完成。具体步骤如下：

核心思路 #

1. 定位目标迁移类：从程序集中找到对应版本号的Migration子类
2. 检查执行状态：确认该版本未被执行过
3. 手动执行迁移：实例化迁移类并调用Up方法，同时通过事务保证原子性
4. 更新迁移历史：向FluentMigrator的元数据表插入记录，避免后续重复执行

代码实现示例 #

假设你已经通过依赖注入配置好了FluentMigrator的服务（如IMigrationRunner、IMigrationProcessor等），以下是完整的实现代码：

using FluentMigrator;
using FluentMigrator.Runner;
using FluentMigrator.Runner.Processors;
using System.Reflection;

public class MigrationExecutor
{
    private readonly IServiceProvider _serviceProvider;

    public MigrationExecutor(IServiceProvider serviceProvider)
    {
        _serviceProvider = serviceProvider;
    }

    public void RunSingleMigration(int targetVersion)
    {
        using var scope = _serviceProvider.CreateScope();
        var runner = scope.ServiceProvider.GetRequiredService<IMigrationRunner>();
        var processor = scope.ServiceProvider.GetRequiredService<IMigrationProcessor>();
        
        // 查找目标版本的迁移类
        var migrationType = Assembly.GetExecutingAssembly()
            .GetTypes()
            .FirstOrDefault(t => t.IsSubclassOf(typeof(Migration)) 
                && t.GetCustomAttribute<MigrationAttribute>()?.Version == targetVersion);

        if (migrationType == null)
        {
            throw new InvalidOperationException($"未找到版本为 {targetVersion} 的迁移");
        }

        // 检查该版本是否已执行
        if (runner.MigrationExists(targetVersion))
        {
            Console.WriteLine($"版本 {targetVersion} 已执行，无需重复操作");
            return;
        }

        // 实例化迁移并执行Up方法
        var migration = (Migration)Activator.CreateInstance(migrationType)!;
        migration.ApplicationContext = scope.ServiceProvider.GetRequiredService<IMigrationContext>();
        
        using var transaction = processor.BeginTransaction();
        try
        {
            migration.Up();
            transaction.Commit();

            // 更新迁移历史表（以SQL Server为例，其他数据库需调整SQL）
            var migrationName = migrationType.Name;
            var createdAt = DateTime.UtcNow;
            processor.Execute($@"
                INSERT INTO __MigrationHistory (Version, Description, CreatedOn)
                VALUES ({targetVersion}, '{migrationName}', '{createdAt:yyyy-MM-dd HH:mm:ss.fff}')
            ");

            Console.WriteLine($"版本 {targetVersion} 的迁移执行成功");
        }
        catch (Exception ex)
        {
            transaction.Rollback();
            throw new InvalidOperationException($"执行版本 {targetVersion} 的迁移失败", ex);
        }
    }
}

关键注意事项 #

• 数据一致性风险：跳过中间版本可能导致数据库状态不符合预期，务必确认业务逻辑允许这种操作
• 元数据表适配：不同数据库的FluentMigrator元数据表结构可能不同，比如PostgreSQL默认表名为fluentmigrationhistory，字段也有差异，需要针对性调整插入SQL
• 依赖注入兼容：如果迁移类有构造函数依赖，需替换Activator.CreateInstance为依赖注入方式创建实例（如scope.ServiceProvider.GetRequiredService(migrationType)）
• 事务保障：必须通过事务包裹迁移执行和元数据更新，避免出现迁移执行成功但元数据未记录的情况

内容的提问来源于stack exchange，提问作者Ghassan Karwchan