abp vnext封装达梦数据库连接 扩展Volo.Abp.EntityFrameworkCore.Dm

1、修改DbContextFactor public DbContext CreateDbContext(string[] args) { EfCoreEntityExtensionMappings.Configure(); var configuration = BuildConfiguration(); var connectionString = configuration["ConnectionStrings:Default"]; var DBType = configuration["DBType:Default"]; Console.WriteLine("ConnectionString:" + connectionString); IServiceCollection services = new ServiceCollection(); services.AddControllersWithViews(); if (DBType == null || DBType == "MySql") { var builder = new DbContextOptionsBuilder<DbContext>() .UseMySql(configuration.GetConnectionString("Default"), MySqlServerVersion.LatestSupportedServerVersion); return new TestManageDbContext(builder.Options); } else if (DBType != null && DBType == "DM") { Console.WriteLine("AddDbContext"); services.AddDbContextFactory<DbContext>((provider, options) => { options.UseDm(connectionString); options.UseInternalServiceProvider(provider); }); ; services.AddAbpDbContext<DbContext>(options => { }); services.AddEntityFrameworkDm(); var serviceProvider = services.BuildServiceProvider(); var builder = new DbContextOptionsBuilder<DbContext>(); builder.UseDm(connectionString); builder.UseInternalServiceProvider(serviceProvider); builder.UseApplicationServiceProvider(serviceProvider); Console.WriteLine("AddDbContext--------"); return serviceProvider.GetService<DbContext>(); } else { var builder = new DbContextOptionsBuilder<DbContext>(); return new DbContext(builder.Options); } } 2、EntityFrameworkCoreModule [DependsOn(typeof(AbpEntityFrameworkCoreDmModule) )] public override void ConfigureServices(ServiceConfigurationContext context) { var configuration = context.Services.GetConfiguration(); context.Services.AddControllersWithViews(); context.Services.AddAbpDbContext<DbContext>(options => { /* Remove "includeAllEntities: true" to create * default repositories only for aggregate roots */ options.AddDefaultRepositories(includeAllEntities: true); }); var DBType = configuration["DBType:Default"]; // var connectionString = configuration["ConnectionStrings:IspyDB"]; if (DBType == null || DBType == "MySql") { Configure<AbpDbContextOptions>(options => { /* The main point to change your DBMS. * See also PlatformMigrationsDbContextFactory for EF Core tooling. */ options.UseMySQL(); }); } if (DBType == "DM") { Configure<AbpDbContextOptions>(options => { options.Configure(ctx => { if (ctx.ExistingConnection != null) { ctx.DbContextOptions.UseDm(ctx.ExistingConnection); } else { ctx.DbContextOptions.UseDm(ctx.ConnectionString); } }); }); } } 3 HttpApi.Host 项目 HttpApiHostModule public override void ConfigureServices(ServiceConfigurationContext context) { var configuration = context.Services.GetConfiguration(); var DBType = configuration["DBType:Default"]; if (DBType != null && DBType == "DM") { context.Services.AddDbContext<DbContext>(options => { options.UseDm(configuration.GetConnectionString("Default")); }); context.Services.AddDbContextFactory<DbContext>(options => { options.UseDm(configuration.GetConnectionString("Default")); }); Configure<AbpDbContextOptions>(options => { options.Configure(ctx => { if (ctx.ExistingConnection != null) { ctx.DbContextOptions.UseDm(ctx.ExistingConnection); } else { ctx.DbContextOptions.UseDm(ctx.ConnectionString); } }); }); } }