实体框架异步问题上下文还是查询？

Question

我对下面的查询有异步问题。我有单例上下文，我正在尝试执行以下查询：

var query = await (from parent in Context.ParentTable
                   join child in Context.ChildTable
                   on parent.ID equals child.ID
                   into allResult
                   from ResultValue in allResult.DefaultIfEmpty()
                   where ResultValue.TenantId == tenantId
                   select new Result
                   {
                      Code = parent.Code,
                      Type = parent.Type,
                      ID = ResultValue == null ? 0 : ResultValue.Id
                   }).ToListAsync();

我的单例上下文如下所示：

public class BaseRepository
{
    private readonly IConfigurationContextFactory configurationContextFactory;

    private IConfigurationContext context;

    protected IConfigurationContext Context
    {
        get
        {
            return context ?? (context = configurationContextFactory.Context);
        }
    }

    public BaseRepository(IConfigurationContextFactory configurationContextFactory)
    {
        this.configurationContextFactory = configurationContextFactory;
    }
}

配置上下文工厂返回如下上下文：

private ConfigurationContext Get()
{
    logger.WriteEntrySync(LogLevel.Information,
                          null != context ? "Config Context: Using existing context." : "Config Context: Wiil create new context.");
    return context ?? (context = new ConfigurationContext(connectionString));
}

在这我得到间歇性问题与以下错误：

在上一个异步操作完成之前，在此上下文上启动了第二个操作。使用“await”确保在该上下文上调用另一个方法之前已完成任何异步操作。任何实例成员都不能保证线程安全。

Answer 1

DbContext应该为一个业务事务（工作单元）而存在，不能多也不能少。业务事务通常是请求、页面或表单。DbContext不是线程安全的，它保留一个内部实体缓存并跟踪更改，因此您不能在多个请求中共享它。

您确实需要阅读实体框架文档：使用DbContext。

我不会为每个存储库创建一个实例，因为一个业务事务可以操作多个存储库。

您可以在存储库中注入上下文：

public class BaseRepository
{
    private IConfigurationContext context;
    public BaseRepository(IConfigurationContext context)
    {
        this.context = context;
    }
    //...
}

更改您的工厂，以便每次都创建一个实例：

public interface IConfigurationContextFactory
{
    IConfigurationContext CreateContext();
}

// ...
public ConfigurationContext CreateContext()
{
    return new ConfigurationContext(connectionString);
}

然后配置依赖解析程序，以每工作单元注入一个IConfigurationContext。假设您正在开发一个ASP。NET应用程序使用unity。

container.RegisterType<IConfigurationContext>(
    //Instance per http request (unit of work)
    new PerRequestLifetimeManager(),
    //Create using factory
    new InjectionFactory(c => c.Resolve<IConfigurationContextFactory>.CreateContext()));

当需要时，不要忘记在业务事务结束时调用SaveChangesSync：操作成功，修改需要持久化。

Answer 2

我有单例语境

这是你的问题DbContext不是线程安全的，设计为一次执行一个查询。由于您正在共享您的数据库上下文，您可能试图同时调用另一个查询，这在数据库上下文中是不合法的。

您甚至可以在ToListAsync的备注中看到：

不支持在同一上下文实例上执行多个活动操作。使用“await”确保在该上下文上调用另一个方法之前已完成任何异步操作。

您应该做的是不要通过全局单例重复使用您的上下文，每次您想要查询数据库时都要创建一个新的上下文。

编辑：

不要通过工厂方法获取单个上下文，只需为每个查询分配一个新的上下文：

using (var context = new ConfigurationContext(connectionString))
{
    var query = await (from feature in context.Features
                join featureFlag in context.FeatureFlags
                on feature.FeatureId equals featureFlag.FeatureId
                into allFeatures
                from featureFlagValue in allFeatures.DefaultIfEmpty()
                where featureFlagValue.TenantId == tenantId
                select new BusinessEntities.FeatureFlag
                {
                   Code = feature.Code,
                   Type = feature.Type,
                   FeatureFlagId = featureFlagValue == null ? 0 : featureFlagValue.FeatureFlagId
                }).ToListAsync();
}