ABP框架——集成Mysql

本文轉載自查看原文 2020-05-18 17:20 500 .net core/ mysql/ abp

最近公司很多業務都要求上雲，雲上的數據庫購買了mysql（估計是應為便宜吧），所以我用abp框架開發的應用都要逐步切換到mysql。經過一陣摸索踩坑，總算是切換成功了，所以先記錄下方便后續切換使用，也順便分享給有需要的朋友。

一、集成MySQL

其實集成mysql主要是參照官方文檔進行就可以了（官方文檔：https://aspnetboilerplate.com/Pages/Documents/EF-Core-MySql-Integration），這里也是簡單描述下關鍵步驟：

（1）安裝Pomelo.EntityFrameworkCore.MySql

安裝Pomelo.EntityFrameworkCore.MySqlNuGet包到*.EntityFrameworkCore 項目上

（2）配置DBContext

替換YourProjectNameDbContextConfigurer.cs文件，將“UseSqlServer”替換為“UseMySql”，如下

 1     public static class WeChatDbContextConfigurer
 2     {
 3         public static void Configure(DbContextOptionsBuilder<WeChatDbContext> builder, string connectionString)
 4         {
 5             builder.UseMySql(connectionString);
 6         }
 7 
 8         public static void Configure(DbContextOptionsBuilder<WeChatDbContext> builder, DbConnection connection)
 9         {
10             builder.UseMySql(connection);
11         }
12     }

（3）配置鏈接字符串

修改appsettings.json中的數據庫鏈接，如:

{
  "ConnectionStrings": {
    "Default": "server=127.0.0.1;uid=root;pwd=1234;database=mysqldemodb"
  },
  ...
}

（4）修改Program.cs

修改防止EF Core調用Program.BuildWebHost()，需要將BuildWebHost函數改名，錄入改成InitWebHost。（不重命名的話，運行將會報錯。詳情請參考：https://github.com/dotnet/efcore/issues/9076）如下

 1     public class Program
 2     {
 3         public static void Main(string[] args)
 4         {
 5             InitWebHost(args).Run();
 6         }
 7 
 8         public static IWebHost InitWebHost(string[] args)
 9         {
10             return WebHost.CreateDefaultBuilder(args)
11                 .UseStartup<Startup>()
12                 .Build();
13         }
14     }

（5）創建數據庫

刪除Migrations文件價下面所有文件，打開程序包管理控制台，選擇默認項目*.EntityFrameworkCore，執行命令“ add-migration Initial_Migration ”

，如下

再執行命令“update-database”更新到數據庫即可

二、集成HangFire

（1）卸載默認hangfire

卸載之前NuGet中abp默認安裝的hangfire包，並注釋Module中默認將hangfire的后台任務的注入代碼。（如之前沒有使用sqlserver的hangfire，次步驟可忽略）

[DependsOn(typeof (AbpHangfireAspNetCoreModule))]
public class MyProjectWebModule : AbpModule
{
    public override void PreInitialize()
    {
         //注釋hangfire
        //Configuration.BackgroundJobs.UseHangfire();             
    }

    //...
}

（2）項目引用NuGet包（ Hangfire.AspNetCore，Hangfire.MySql.Core）

（3）修改startup.cs類

 1    public IServiceProvider ConfigureServices(IServiceCollection services)
 2         {
 3             //........
 4             //配置msql下的hangfire
 5             services.AddHangfire(x => x.UseStorage(new MySqlStorage(
 6                 _appConfiguration.GetConnectionString("Default"),
 7                     new MySqlStorageOptions
 8                     {
 9                         TransactionIsolationLevel = IsolationLevel.ReadCommitted, // 事務隔離級別。默認是讀取已提交。
10                         QueuePollInterval = TimeSpan.FromSeconds(15),             //- 作業隊列輪詢間隔。默認值為15秒。
11                         JobExpirationCheckInterval = TimeSpan.FromHours(1),       //- 作業到期檢查間隔（管理過期記錄）。默認值為1小時。
12                         CountersAggregateInterval = TimeSpan.FromMinutes(5),      //- 聚合計數器的間隔。默認為5分鍾。
13                         PrepareSchemaIfNecessary = true,                          //- 如果設置為true，則創建數據庫表。默認是true。
14                         DashboardJobListLimit = 50000,                            //- 儀表板作業列表限制。默認值為50000。
15                         TransactionTimeout = TimeSpan.FromMinutes(1),           //- 交易超時。默認為1分鍾。
16                         TablePrefix = "Hangfire"
17                     }
18                 )));
19              //........
20         }

1          public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory loggerFactory)
2          {
3              app.UseHangfireServer();  //啟用hangfire服務
4              app.UseHangfireDashboard(); //使用hangfire面板
5          }