如何用EF Core 6.0批量回滚多客户端同架构数据库的最后一次迁移？

完全可以通过代码实现批量回滚操作，不需要依赖CLI手动执行。核心思路是针对每个数据库，先获取其已应用的迁移记录，定位到最后一次迁移，再回滚到该迁移的上一个版本（或初始状态）。

实现代码示例 #

你可以基于现有的批量迁移代码，修改核心逻辑为回滚操作：

var databaseNames = ... // 数据库名称列表
var connString = app.Configuration.GetConnectionString(nameof(DbContextMaster));

Parallel.ForEach(databaseNames, databaseName =>
{
    var optionsBuilder = new DbContextOptionsBuilder<DbContextMaster>();
    optionsBuilder.UseNpgsql(connString.Replace("[databasename]", databaseName), SetupMigrationTable);
    using var context = new DbContextMaster(optionsBuilder.Options);
    
    try
    {
        context.Database.OpenConnection();
        var appliedMigrations = context.Database.GetAppliedMigrations().ToList();
        
        if (appliedMigrations.Count == 0)
        {
            // 无已应用迁移，无需操作
            return;
        }

        // 获取最后一次已应用的迁移
        var lastAppliedMigration = appliedMigrations.Last();
        // 获取项目中所有定义的迁移（按时间戳排序）
        var allMigrations = context.Database.GetMigrations().ToList();
        var lastAppliedIndex = allMigrations.IndexOf(lastAppliedMigration);

        if (lastAppliedIndex > 0)
        {
            // 回滚到上一个迁移版本
            var targetMigration = allMigrations[lastAppliedIndex - 1];
            context.Database.Migrate(targetMigration);
        }
        else
        {
            // 已应用的是第一个迁移，回滚到初始状态（删除所有表）
            // 若不需要删除数据库，可替换为 context.Database.Migrate(null)
            context.Database.EnsureDeleted();
        }
    }
    catch (Exception e)
    {
        // 异常处理逻辑：记录日志、标记失败数据库等
    }
    finally
    {
        if (context.Database.CanConnect())
        {
            context.Database.CloseConnection();
        }
    }
});

关键逻辑说明 #

• GetAppliedMigrations()：从数据库的__EFMigrationsHistory表读取已成功应用的迁移记录。
• GetMigrations()：获取项目中所有已定义的迁移文件（按生成时的时间戳排序）。
• Migrate(targetMigration)：将数据库迁移到指定的目标版本，传入上一个迁移名称即可完成回滚。
• 针对第一个迁移的回滚：若需要彻底清空数据库，使用EnsureDeleted()；若仅移除迁移记录但保留空表，可使用Migrate(null)（需确认业务需求）。

注意事项 #

1. 并行处理风险：并行操作多个数据库时，需确保数据库服务器能承受并发压力，可根据实际情况调整并行度（如Parallel.ForEach的ParallelOptions参数）。
2. 迁移文件一致性：确保所有数据库对应的项目迁移文件完整且一致，若已应用的迁移不在本地迁移列表中，会导致索引查找失败，需添加额外的异常处理逻辑。
3. 数据安全：回滚操作会修改数据库结构，执行前建议备份目标数据库，尤其是回滚第一个迁移时的EnsureDeleted()会直接删除数据库。
4. 资源释放：使用using语句自动释放DbContext资源，避免连接泄漏。

内容的提问来源于stack exchange，提问作者Working Pickle