为了账号安全,请及时绑定邮箱和手机立即绑定

使用 DI 访问 Startup.cs 中的 NPGSQL

使用 DI 访问 Startup.cs 中的 NPGSQL

C#
慕仙森 2023-05-13 16:21:26
使用 .NET Core 2.1、NPGSQL、实体框架和 Linux。从 Startups.cs 的 Configure 函数中,我在依赖注入类中调用一个函数,该类又调用另一个依赖注入类,该类使用 Entity Framework + NPGSQL 访问数据库。配置服务:    public void ConfigureServices(IServiceCollection services)    {        services.AddEntityFrameworkNpgsql()        .AddDbContext<MMContext>(options => options.UseNpgsql($"Host='localhost'; Port=1234;Database='mydb';Username='test';Password='test'"))        .BuildServiceProvider();        services.AddTransient<IMusicManager, MusicManager>();        services.AddTransient<IMusicRepo, MusicRepo>();      services.AddMvc()        .SetCompatibilityVersion(CompatibilityVersion.Version_2_1);    }配置功能:    public void Configure(IApplicationBuilder app, IHostingEnvironment env)    {        app.UseMvc();        using (var scope = app.ApplicationServices.GetService<IServiceScopeFactory>().CreateScope())        {            var mm = scope.ServiceProvider.GetRequiredService<IMusicManager>();            mm.DoSomeDBStartupStuff();        }    }音乐管理器实现看起来像这样:    private readonly IMusicRepo _musicStoreRepo;    public MusicManager(IMusicRepo musicStoreRep)    {        _musicStoreRepo = musicStoreRepo;    }    public void DoSomeDBStartupStuff()    {        _musicStoreRepo.InsertSampleStuff();        _musicStoreRepo.CheckThisAndCheckThat();    }音乐库实现看起来像这样:    private readonly MMContext _context;    public MusicRepo(MMContext context)    {        _context = context;    }    public void InsertSampleStuff()    {        _context.Music.AddAsync(new music("abc"));        _context.Music.AddAsync(new music("123"));        _context.SaveChangesAsync();    }MM上下文这是这样实现的:public class MMContext : DbContext{    public MMContext(DbContextOptions<MMContext> options) : base(options) {}    ... OnModelCreating etc...}
查看完整描述

1 回答

?
眼眸繁星

TA贡献1873条经验 获得超9个赞

注意函数中没有等待异步调用void。


public void InsertSampleStuff()

{

    _context.Music.AddAsync(new music("abc"));

    _context.Music.AddAsync(new music("123"));

    _context.SaveChangesAsync();

}

DbContext当您尝试保存这些更改时,这可能会导致线程问题。


要么使函数异步并正确等待这些调用,要么使用同步 API


public void InsertSampleStuff() {

    _context.Music.Add(new music("abc"));

    _context.Music.Add(new music("123"));

    _context.SaveChanges();

}

如果采用异步路线,则考虑将该设置代码移至托管服务中并在那里适当地等待它


查看完整回答
反对 回复 2023-05-13
  • 1 回答
  • 0 关注
  • 109 浏览

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信