如何利用FluentMigrator实现数据库迁移

# 迁移脚本基础库
dotnet add package FluentMigrator

# 迁移脚本运行库
dotnet add package FluentMigrator.Runner

# 针对MySQL的迁移脚本支持库
dotnet add package FluentMigrator.Runner.MySQL

# ADO.NET针对MySQL的驱动器
dotnet add package MySQL.Data

using FluentMigrator;

namespace test
{
 [Migration(20180430121800)]
 public class AddLogTable : Migration
 {
  public override void Up()
  {
   Create.Table("Log")
    .WithColumn("Id").AsInt64().PrimaryKey().Identity()
    .WithColumn("Text").AsString();
  }

  public override void Down()
  {
   Delete.Table("Log");
  }
 }
}

 class Program
 {
  static void Main(string[] args)
  {
   var serviceProvider = CreateServices();

   using (var scope = serviceProvider.CreateScope())
   {
    UpdateDatabase(scope.ServiceProvider);
   }
  }

  private static IServiceProvider CreateServices()
  {
   return new ServiceCollection()
    //添加FluentMigrator基础服务
    .AddFluentMigratorCore()
    .ConfigureRunner(rb => rb
     //添加MySql 5.0支持
     .AddMySql5()
     //配置连接字符串
     .WithGlobalConnectionString("server=localhost;port=3307;Database=abc;UID=root;PWD=123456")
     //检索迁移配置
     .ScanIn(typeof(AddLogTable).Assembly).For.Migrations())
    //启用控制台日志
    .AddLogging(lb => lb.AddFluentMigratorConsole())
    //构建服务提供器
    .BuildServiceProvider(false);
  }

  private static void UpdateDatabase(IServiceProvider serviceProvider)
  {
   //初始化进程内迁移构建器
   var runner = serviceProvider.GetRequiredService<IMigrationRunner>();

   //执行迁移脚本
   runner.MigrateUp();
  }
 }

dotnet tool install -g FluentMigrator.DotNet.Cli

dotnet fm migrate -p mysql -c "server=localhost;port=3307;Database=abc;UID=root;PWD=123456" -a ".\bin\Debug\netcoreapp2.1\test.dll"

[Migration(1)]
public class CreateUserTable : Migration
{
 public override void Up()
 {
  Create.Table("Users");
 }

 public override void Down()
 {
  Delete.Table("Users");
 }
}

Create.Table("Users")
  .WithIdColumn() 
  .WithColumn("Name").AsString().NotNullable();

Create.ForeignKey() 
  .FromTable("Users").ForeignColumn("CompanyId")
  .ToTable("Company").PrimaryColumn("Id");

Alter.Table("Bar")
  .AddColumn("SomeDate")
  .AsDateTime()
  .Nullable();

Alter.Table("Bar")
  .AlterColumn("SomeDate")
  .AsDateTime()
  .NotNullable();

Alter.Column("SomeDate")
  .OnTable("Bar")
  .AsDateTime()
  .NotNullable();

Delete.Table("Users");

Delete.Column("AllowSubscription").Column("SubscriptionDate").FromTable("Users");

Execute.Script("myscript.sql");
Execute.EmbeddedScript("UpdateLegacySP.sql");
Execute.Sql("DELETE TABLE Users");

Rename.Table("Users").To("UsersNew");
Rename.Column("LastName").OnTable("Users").To("Surname");

Insert.IntoTable("Users").Row(new { FirstName = "John", LastName = "Smith" });

Delete.FromTable("Users").AllRows(); //删除所有行
Delete.FromTable("Users").Row(new { FirstName = "John" }); //删除所有FirstName = John的数据行
Delete.FromTable("Users").IsNull("Username"); //删除所有Username为空的数据行

Update.Table("Users").Set(new { Name = "John" }).Where(new { Name = "Johnanna" });

IfDatabase("SqlServer", "Postgres")
  .Create.Table("Users")
  .WithIdColumn()
  .WithColumn("Name").AsString().NotNullable();

IfDatabase("Sqlite")
  .Create.Table("Users")
  .WithColumn("Id").AsInt16().PrimaryKey()
  .WithColumn("Name").AsString().NotNullable();

if (!Schema.Table("Users").Column("FirstName").Exists())
{
  this.Create.Column("FirstName").OnTable("Users").AsAnsiString(128).Nullable();
}

[Profile("Development")]
public class CreateDevSeedData : Migration
{
  public override void Up()
  {
    Insert.IntoTable( "User" ).Row( new
      {
        Username = "devuser1",
        DisplayName = "Dev User"
      });
  }

  public override void Down()
  {
    //empty, not using
  }
}