当请求进入application中的方法时 会开启一个工作单元 这里面调用不同的DbContext 会默认使用第一次调用的DbContext
需要手动开启工作单元来隔离两个不同的DbContext进行操作
ABP中出现这个问题 看看方法是不是异步的 返回类型是不是Task
1.比如自己封装了一个开启工作单元的方法
public async Task NewUnitOfWork(Func<Task> Func)
{
using (var unitOfWork = unitOfWorkManager.Begin(TransactionScopeOption.RequiresNew))
{
try
{
await Func.Invoke();
await unitOfWork.CompleteAsync();
}
catch (DbUpdateException)
{ throw new UserFriendlyException("当前记录已经被使用");
}
catch (Exception ex)
{
throw new UserFriendlyException(ex.Message);
}
}
}
2.这个委托里面会写对数据库的查询操作 都是异步的 调用这个委托的时候 也是通过 await调用的 委托的返回值类型就要写Task 不然就会报上面的错误
await delUnitOfWork.NewUnitOfWork(async () =>
{
distributorGroupModel = await customerGroupGroupRepository.GetAll()
.Where(t => t.Name == "经销商")
.Where(t => t.IsSystem == true)
.FirstOrDefaultAsync();
if (distributorGroupModel == null)
{
throw new UserFriendlyException("初始化数据不存在");
}
customer = await customerRepository.GetAsync(input.Id.Value);
});
添加DbContext 配置连接字符串方式
1.在Web项目的Startup入口配置Dbcontext连接字符串
这三种写法一样 都是获取配置文件中的连接字符串
2.非Web项目 不存在Startup入口 可以在EF的Moduel中配置连接字符串 这个参数可以 直接写连接字符串
如果这种方式报错 就改成下面这样
3.在MyDbContext中重写OnConfiguring进行配置连接字符串
可以通过注入IConfigurationRoot对象来获取appsetting.json配置文件
private readonly IConfigurationRoot _appConfiguration;
public Startup(IHostingEnvironment env)
{
_appConfiguration = env.GetAppConfiguration();
}
这个GetAppConfiguration是扩展方法 写在 Web.Core层 所以Application层，Core层，EF层不能引用Web.Core层 所以不能调用这个扩展方法 通过这种方式调用 其实上面那个扩展方法里面就是调用了下面这个方法
private readonly IConfigurationRoot _appConfiguration;
public IMSEntityFrameworkModule(IHostingEnvironment env)
{
_appConfiguration = AppConfigurations.Get(env.ContentRootPath, env.EnvironmentName, env.IsDevelopment());
}
protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
{ // 从 appsetting.json 中获取配置信息
var config = new ConfigurationBuilder()
.SetBasePath(Directory.GetCurrentDirectory())
.AddJsonFile("appsettings.json")
.Build(); optionsBuilder.UseSqlServer(config.GetConnectionString("DefaultConnection"));
}
protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
{
base.OnConfiguring(optionsBuilder);
configuration = ConfigManager.LoadConfig("appsettings.json");
optionsBuilder.UseSqlServer(configuration["ConnectionStrings"]);
}