接上一篇 EntityFrameworkCore数据迁移（一）

　　其实上一篇该写的都已经写完了，但是后来又想到两个问题，想了想还是也写出来吧

　　问题一

　　上一篇介绍的迁移过程，都是通过在程序包管理器控制台使用Add-Migration和Update-Database命令执行的，那问题来了，如果是在开发过程中，我可以在VS中这么做，但是在线上环境，我们总不至于在线上服务器也安装个VS吧，那怎么进行迁移呢？

　　这个时候就需要我们自己用代码去执行生成的迁移文件了。

　　接上篇，我们将实体模型和数据迁移部分分到两个项目中，而EFCoreDemo.EntityFrameworkCore.Host项目是控制台项目，正好可以去用代码去执行数据迁移：

　　我们修改Program：　　

class Program  
{  
    static void Main(string\[\] args)  
    {  
        #region 迁移  
        using (var db = new DemoMigrationsDbContextFactory().CreateDbContext(args))  
        {  
            var array = db.Database.GetPendingMigrations();  
            int count = array.Count();  
            if (count == 0)  
            {  
                Console.WriteLine("nothing to migrate,current migrations is up-to-date...");  
            }  
            else  
            {  
                Console.WriteLine($"Pending Migrations：{count}");  
                foreach (var a in array)  
                {  
                    Console.WriteLine($"Migrations：{a}");  
                }

                Console.WriteLine("Do you want to continue?(Y/N)");  
                if (Console.ReadLine().Trim().ToLower() == "y")  
                {  
                    Console.WriteLine("Migrating...");

                    try  
                    {  
                        //执行迁移  
                        db.Database.Migrate();  
                    }  
                    catch (Exception e)  
                    {  
                        Console.WriteLine(e);  
                    }  
                }  
                Console.WriteLine("Completed!!!");  
            }  
        }  
        #endregion

        Console.WriteLine("Press any key to continue...");  
        Console.ReadKey();  
    }  
}

　　注意，上面的程序仅仅只是执行迁移文件，并不是生成迁移，所以开发过程中我们还是需要使用Add-Migration命令生成迁移。

　　另外，还有一个问题需要注意，上一篇中，迁移过程中，我们的数据库连接时写死在DemoMigrationsDbContextFactory类中的，线上库和开发测试库肯定不是同一个库，那怎么去区分？

　　一个想法是将数据库连接写到配置文件中去，这里只是去读取！而这个配置文件可以是json文件，也可以是xml文件，比如是json文件：

　　我们在EFCoreDemo.EntityFrameworkCore.Host中创建一个json文件，比如就叫appsettings.json，然后修改文件属性的输出配置为【如果较新则复制】

　　

　　然后在appsettings.json中添加内容：　　

{
"ConnectionString": {
"Default": "Server=192.168.209.128;Port=3306;Database=demodb;Uid=root;Pwd=123456"
}
}

　　然后修改DemoMigrationsDbContextFactory：　　

public class DemoMigrationsDbContextFactory : IDesignTimeDbContextFactory<MigrationDbContext>  
{  
    public MigrationDbContext CreateDbContext(string\[\] args)  
    {  
        var configuration = BuildConfiguration();

        var builder = new DbContextOptionsBuilder<MigrationDbContext>()  
            .UseMySql(configuration\["ConnectionString:Default"\]);

        return new MigrationDbContext(builder.Options);  
    }

    private static IConfigurationRoot BuildConfiguration()  
    {  
        var builder = new ConfigurationBuilder()  
            .SetBasePath(Directory.GetCurrentDirectory())  
            .AddJsonFile("appsettings.json", optional: false);

        return builder.Build();  
    }  
}

　　最后EFCoreDemo.EntityFrameworkCore.Host的项目结构如下：

　　

　 这样，只需要保证我们上线和开发过程中的这个文件配置不一样就可以了

　　测试一下，先清空数据库，因为先前已经生成了迁移文件，所以可以直接运行，运行后提示有两个迁移可以执行，输入y，回车即可：

　　

　　问题二

　　上一篇中，我创建了两次迁移，第二迁移增加列，修改了列属性，还添加了外键约束，但是我忽略了索引。

　　比如活动记录表中，一般的，一个用户参加活动只会有一条活动记录，因此活动Id和用户Id应该是可以作为一个唯一值索引的，于是乎我修改了ActivityRecordEntityTypeConfiguration：　　

public class ActivityRecordEntityTypeConfiguration : BaseEntityTypeConfiguration<ActivityRecord>  
{  
    /// <summary>  
    /// 配置实体类型  
    /// </summary>  
    /// <param name="builder"></param>  
    public override void Configure(EntityTypeBuilder<ActivityRecord> builder)  
    {  
        base.Configure(builder);

        builder.HasIndex(p => new { p.ActivityId, p.AccountId }).IsUnique(true);  
        builder.HasOne(p => p.Activity).WithMany().HasForeignKey(p => p.ActivityId);  
        builder.HasOne(p => p.Account).WithMany().HasForeignKey(p => p.AccountId);  
    }  
}

　　然后执行Add-Migration和Update-Database，出乎我意料的是竟然报错了！

　　

　 看了一下，这里抛出异常时：Cannot drop index 'IX_demo_activityrecord_ActivityId': needed in a foreign key constraint

　　这里是说，删除索引时，因为存在外键约束，所以需要先删除外键才能再删除索引！

　　回想上一篇，我在再次迁移的时候，为ActivityRecord增加了外键约束，打开对应的迁移文件alter_20200727，很容易发现

public partial class alter\_20200727 : Migration  
{  
    protected override void Up(MigrationBuilder migrationBuilder)  
    {  
        //以上省略...

        migrationBuilder.CreateIndex(  
            name: "IX\_demo\_activityrecord\_AccountId",  
            table: "demo\_activityrecord",  
            column: "AccountId");

        migrationBuilder.CreateIndex(  
            name: "IX\_demo\_activityrecord\_ActivityId",  
            table: "demo\_activityrecord",  
            column: "ActivityId");

        migrationBuilder.AddForeignKey(  
            name: "FK\_demo\_activityrecord\_demo\_account\_AccountId",  
            table: "demo\_activityrecord",  
            column: "AccountId",  
            principalTable: "demo\_account",  
            principalColumn: "Id",  
            onDelete: ReferentialAction.Cascade);

        migrationBuilder.AddForeignKey(  
            name: "FK\_demo\_activityrecord\_demo\_activity\_ActivityId",  
            table: "demo\_activityrecord",  
            column: "ActivityId",  
            principalTable: "demo\_activity",  
            principalColumn: "Id",  
            onDelete: ReferentialAction.Cascade);  
    }

    protected override void Down(MigrationBuilder migrationBuilder)  
    {  
        //省略...  
    }  
}

　　原来，mysql创建外键约束的时候，默认会将约束列设置成索引（非唯一值索引），用以提高搜素速度，而这个索引是和外键绑定的！

　　打开我们我们新建的迁移文件alter_20200728：　　

public partial class alter\_20200728 : Migration  
{  
    protected override void Up(MigrationBuilder migrationBuilder)  
    {  
        migrationBuilder.DropIndex(  
            name: "IX\_demo\_activityrecord\_ActivityId",  
            table: "demo\_activityrecord");

        migrationBuilder.CreateIndex(  
            name: "IX\_demo\_activityrecord\_ActivityId\_AccountId",  
            table: "demo\_activityrecord",  
            columns: new\[\] { "ActivityId", "AccountId" },  
            unique: true);  
    }

    protected override void Down(MigrationBuilder migrationBuilder)  
    {  
        migrationBuilder.DropIndex(  
            name: "IX\_demo\_activityrecord\_ActivityId\_AccountId",  
            table: "demo\_activityrecord");

        migrationBuilder.CreateIndex(  
            name: "IX\_demo\_activityrecord\_ActivityId",  
            table: "demo\_activityrecord",  
            column: "ActivityId");  
    }  
}

　　其中，Up方法中是先删除索引在创建新的索引，这就是迁移发生异常的原因！

　　假如之前的迁移已经全部更新到线上，但是现在迁移又报错了，那怎办？

　　我们的第一反应是，先到数据库自行把相关的外键约束和索引删除，在执行迁移，执行完成之后再去数据库把外键约束添加上！

　　千万不到这么做！

　　宁可以后开发放弃使用迁移也不要这么做，原因有二：

　　第一、如果是要更新到线上，而删除约束，再执行迁移，这之间有时间差，如果有异常数据进来，可能导致约束加不回去了。如果这样，还不如直接全部使用SQL脚本执行！

　　第二、本来我们只需要一个空的数据库，然后执行一次迁移就能初始化完成，然后系统就可以在这个库上运作起来，而手动改数据库后，可能导致迁移不能一次执行

　　遇到这种问题，个人比较喜欢去修改迁移文件，比如这个问题，既然是删除索引时报错，那就可以把删除索引的语句注释掉：　　

public partial class alter\_20200728 : Migration  
{  
    protected override void Up(MigrationBuilder migrationBuilder)  
    {  
        //migrationBuilder.DropIndex(  
        //    name: "IX\_demo\_activityrecord\_ActivityId",  
        //    table: "demo\_activityrecord");

        migrationBuilder.CreateIndex(  
            name: "IX\_demo\_activityrecord\_ActivityId\_AccountId",  
            table: "demo\_activityrecord",  
            columns: new\[\] { "ActivityId", "AccountId" },  
            unique: true);  
    }

    protected override void Down(MigrationBuilder migrationBuilder)  
    {  
        migrationBuilder.DropIndex(  
            name: "IX\_demo\_activityrecord\_ActivityId\_AccountId",  
            table: "demo\_activityrecord");

        //migrationBuilder.CreateIndex(  
        //    name: "IX\_demo\_activityrecord\_ActivityId",  
        //    table: "demo\_activityrecord",  
        //    column: "ActivityId");  
    }  
}

　　这里需要注意的是，Up和Down两个方法建议同步修改！

　　修改后执行再执行Update-Database就通过了：

　　

　　这里只是一种处理方式，当然还可以根据提示，先删除外键约束，再删除索引，接着加上外键约束：　　

public partial class alter\_20200728 : Migration  
{  
    protected override void Up(MigrationBuilder migrationBuilder)  
    {  
        //删除外键约束  
        migrationBuilder.DropForeignKey(  
            name: "FK\_demo\_activityrecord\_demo\_account\_AccountId",  
            table: "demo\_activityrecord"  
            );

        //删除外键约束  
        migrationBuilder.DropForeignKey(  
            name: "FK\_demo\_activityrecord\_demo\_activity\_ActivityId",  
            table: "demo\_activityrecord"  
            );

        migrationBuilder.DropIndex(  
            name: "IX\_demo\_activityrecord\_ActivityId",  
            table: "demo\_activityrecord");

        migrationBuilder.CreateIndex(  
            name: "IX\_demo\_activityrecord\_ActivityId\_AccountId",  
            table: "demo\_activityrecord",  
            columns: new\[\] { "ActivityId", "AccountId" },  
            unique: true);

        //添加外键约束  
        migrationBuilder.AddForeignKey(  
            name: "FK\_demo\_activityrecord\_demo\_account\_AccountId",  
            table: "demo\_activityrecord",  
            column: "AccountId",  
            principalTable: "demo\_account",  
            principalColumn: "Id",  
            onDelete: ReferentialAction.Cascade);

        //添加外键约束  
        migrationBuilder.AddForeignKey(  
            name: "FK\_demo\_activityrecord\_demo\_activity\_ActivityId",  
            table: "demo\_activityrecord",  
            column: "ActivityId",  
            principalTable: "demo\_activity",  
            principalColumn: "Id",  
            onDelete: ReferentialAction.Cascade);  
    }

    protected override void Down(MigrationBuilder migrationBuilder)  
    {  
        //删除外键约束  
        migrationBuilder.DropForeignKey(  
            name: "FK\_demo\_activityrecord\_demo\_account\_AccountId",  
            table: "demo\_activityrecord"  
            );

        //删除外键约束  
        migrationBuilder.DropForeignKey(  
            name: "FK\_demo\_activityrecord\_demo\_activity\_ActivityId",  
            table: "demo\_activityrecord"  
            );

        migrationBuilder.DropIndex(  
            name: "IX\_demo\_activityrecord\_ActivityId\_AccountId",  
            table: "demo\_activityrecord");

        migrationBuilder.CreateIndex(  
            name: "IX\_demo\_activityrecord\_ActivityId",  
            table: "demo\_activityrecord",  
            column: "ActivityId");

        //添加外键约束  
        migrationBuilder.AddForeignKey(  
            name: "FK\_demo\_activityrecord\_demo\_account\_AccountId",  
            table: "demo\_activityrecord",  
            column: "AccountId",  
            principalTable: "demo\_account",  
            principalColumn: "Id",  
            onDelete: ReferentialAction.Cascade);

        //添加外键约束  
        migrationBuilder.AddForeignKey(  
            name: "FK\_demo\_activityrecord\_demo\_activity\_ActivityId",  
            table: "demo\_activityrecord",  
            column: "ActivityId",  
            principalTable: "demo\_activity",  
            principalColumn: "Id",  
            onDelete: ReferentialAction.Cascade);  
    }  
}

　　总之，使用数据迁移时，要注意以下几点：

1、可以手动去改数据库中数据，但是尽量不要手动去改数据库结构

2、如果迁移过程抛出异常，应先通过修改迁移文件来解决问题

3、对于多次生成的迁移，尽量确保对一个空库，只需要指定一个Update-Database将所有迁移更新至数据库，系统就能在这个库中运作起来

　　最后，补上测试项目的代码: https://pan.baidu.com/s/1D1chtNWDEA2pZQqtvrqAGg 提取码: epwm