如何在ASP.NET EF Core迁移中通过C#代码实现Homes表数据转换？

你可以直接在迁移的Up方法中使用ADO.NET原生操作完成数据转换，无需依赖DbContext，具体实现步骤如下：

步骤1：生成添加新列的迁移 #

先通过EF Core工具生成添加PublicDescription列的迁移，迁移类的Up方法会自动生成添加列的基础代码。

步骤2：在迁移中嵌入C#数据转换逻辑 #

在迁移的Up方法里，通过MigrationBuilder.CreateConnection()获取数据库连接，然后用ADO.NET完成数据的读取、处理与更新：

public partial class AddPublicDescriptionToHomes : Migration
{
    protected override void Up(MigrationBuilder migrationBuilder)
    {
        // 1. 添加新列（根据你的数据库类型调整字段定义）
        migrationBuilder.AddColumn<string>(
            name: "PublicDescription",
            table: "Homes",
            type: "nvarchar(max)",
            nullable: true);

        // 2. 执行C#逻辑的数据转换
        using (var connection = migrationBuilder.CreateConnection())
        {
            connection.Open();

            // 读取所有需要处理的行
            using (var readCommand = connection.CreateCommand())
            {
                readCommand.CommandText = "SELECT Id, Description FROM Homes";
                using (var reader = readCommand.ExecuteReader())
                {
                    while (reader.Read())
                    {
                        // 读取字段值（注意匹配你的实际字段类型，比如Id是int就用GetInt32）
                        var id = reader.GetGuid(reader.GetOrdinal("Id"));
                        var description = reader.IsDBNull(reader.GetOrdinal("Description"))
                            ? null
                            : reader.GetString(reader.GetOrdinal("Description"));

                        // 调用脱敏方法处理内容
                        var redactedDesc = RedactSensitiveInfo(description);

                        // 更新当前行的PublicDescription列
                        using (var updateCommand = connection.CreateCommand())
                        {
                            updateCommand.CommandText = @"
                                UPDATE Homes 
                                SET PublicDescription = @RedactedDesc 
                                WHERE Id = @HomeId";
                            // 添加参数避免SQL注入
                            updateCommand.Parameters.Add(new SqlParameter("@RedactedDesc", redactedDesc ?? (object)DBNull.Value));
                            updateCommand.Parameters.Add(new SqlParameter("@HomeId", id));
                            updateCommand.ExecuteNonQuery();
                        }
                    }
                }
            }
        }
    }

    protected override void Down(MigrationBuilder migrationBuilder)
    {
        // 回滚操作：删除新增列
        migrationBuilder.DropColumn(
            name: "PublicDescription",
            table: "Homes");
    }

    // 你的脱敏方法，可迁移到此处或引用公共静态工具类
    private string RedactSensitiveInfo(string input)
    {
        if (string.IsNullOrWhiteSpace(input)) return input;
        // 替换为你的实际脱敏逻辑，比如隐藏手机号、邮箱等敏感信息
        return Regex.Replace(input, @"\d{11}", "***********");
    }
}

重要注意事项 #

• 脱敏方法独立性：确保RedactSensitiveInfo不依赖DbContext或应用DI容器中的服务，迁移环境是独立运行的，无法访问应用层的依赖。
• 大数据量优化：如果Homes表数据量较大，不要一次性读取所有行，改用分页查询（如OFFSET ... FETCH NEXT ...）分批处理，避免内存溢出。
• 字段类型匹配：根据你的实际数据库字段类型调整读取和参数设置（比如Id为int时用GetInt32，字符串类型对应数据库的nvarchar/varchar）。
• 事务保障：EF Core迁移默认在事务中执行，若转换过程中出错，所有操作会自动回滚，无需手动处理事务。

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