Entity Framework Core：如何在迁移中查询数据库？

MigrationBuilder本身没有提供直接的查询方法，但可以通过以下几种方式实现“先查询再更新”的需求：

1. 直接执行SQL更新语句（推荐，适合批量/复杂场景） #

最直接高效的方式是用ExecuteSqlRaw或ExecuteSqlInterpolated执行包含查询逻辑的SQL更新语句，把查询和更新合并成一个操作，避免多次数据库交互。

示例1：单表条件更新 #

比如更新Users表中邮箱为空的用户，将IsActive设为false：

migrationBuilder.ExecuteSqlRaw(@"
    UPDATE Users
    SET IsActive = 0
    WHERE Email IS NULL
");

示例2：关联表条件更新 #

如果需要基于其他表的数据筛选更新目标，可使用JOIN或EXISTS子句：

migrationBuilder.ExecuteSqlRaw(@"
    UPDATE u
    SET u.IsActive = 0
    FROM Users u
    JOIN InactiveProfiles ip ON u.Id = ip.UserId
    WHERE ip.LastLoginDate < DATEADD(year, -2, GETDATE())
");

2. 使用临时DbContext查询后执行UpdateData（适合少量数据） #

如果需要在C#逻辑中处理查询结果再更新，可以创建临时的DbContext实例，用迁移的连接字符串连接数据库，查询出需要更新的键，再逐个调用UpdateData。

示例： #

protected override void Up(MigrationBuilder migrationBuilder)
{
    // 创建临时DbContext，使用当前迁移的连接字符串
    using var context = new YourDbContext(new DbContextOptionsBuilder<YourDbContext>()
        .UseSqlServer(migrationBuilder.ConnectionString)
        .Options);

    // 查询需要更新的用户ID列表
    var targetUserIds = context.Users
        .Where(u => u.CreatedAt < new DateTime(2020, 1, 1) && u.IsActive)
        .Select(u => u.Id)
        .ToList();

    // 逐个更新符合条件的记录
    foreach (var userId in targetUserIds)
    {
        migrationBuilder.UpdateData(
            table: "Users",
            keyColumn: "Id",
            keyValue: userId,
            column: "IsActive",
            value: false);
    }
}

⚠️ 注意：这种方式会生成多条独立的UPDATE语句，数据量大时效率极低，仅适合少量数据的场景。

3. 执行外部SQL脚本（适合超复杂逻辑） #

如果查询和更新逻辑非常复杂，可以把逻辑写在独立的SQL脚本文件中，然后用migrationBuilder.Sql()执行整个脚本：

migrationBuilder.Sql(File.ReadAllText(@"Scripts/UpdateInactiveUsers.sql"));

关键注意事项 #

• 迁移必须是幂等的：确保多次执行迁移不会导致重复更新或数据异常，可通过添加条件判断（比如WHERE子句中排除已更新的记录）实现。
• 避免在迁移中处理复杂业务逻辑：迁移是部署环节的操作，应尽量简洁稳定，复杂逻辑建议放在应用启动时处理或单独的维护脚本中。

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