Блог

Я пытаюсь использовать это для совместного использования подключения к базе данных в нескольких тестах с использованием MSTest v2, в котором, к сожалению, нет таких приспособлений, как xUnit. Поэтому я создал статический класс:

 [TestClass]
static class DbContextFactory
{
    private static string ConnectionString = "Server=(localdb)\MSSQLLocalDB;Initial Catalog=C4S_Test;ConnectRetryCount=0";

    /// <summary>
    /// Exposed connection for making shared transactions across multiple context instances possible
    /// </summary>
    public static DbConnection Connection;

    //called once before tests
    [AssemblyInitialize]
    public static void InitializeDbContext(TestContext context)
    {
        Connection = new SqlConnection(ConnectionString);
        Seed();
        Connection.Open();
    }

    public static C4S_DataContext CreateContext(DbTransaction transaction = null)
    {
        var context =
            new C4S_DataContext(new DbContextOptionsBuilder<C4S_DataContext>().UseSqlServer(Connection)
                .EnableSensitiveDataLogging().Options);

        if (transaction != null)
        {
            context.Database.UseTransaction(transaction);
        }

        return context;
    }

    [AssemblyCleanup]
    public static void Cleanup()
    {
        Connection.Close();
    }

    private static void Seed()
    {
        using (var context = CreateContext())
        {
            context.Database.EnsureDeleted();
            context.Database.EnsureCreated();

            //seed some data

            context.SaveChanges();
        }
    }
  

В тестах я использую C4S_DataContext следующим образом:

 using (var dbContext = DbContextFactory.CreateContext())
{
    //work on dbContext
}
  

Последовательный запуск тестов работает нормально, но их параллельный запуск заканчивается следующим исключением:

     Message: 
    Test method C4S.Model.Services.Tests.PortfolioGruppenServiceTests.GetPortfolioElementeInGruppeOrderedByBezeichnungAppTest threw exception: 
    System.InvalidOperationException: Internal connection fatal error.
  Stack Trace: 
    TdsParser.TryRun(RunBehavior runBehavior, SqlCommand cmdHandler, SqlDataReader dataStream, BulkCopySimpleResultSet bulkCopyHandler, TdsParserStateObject stateObj, Booleanamp; dataReady)
    TdsParser.Run(RunBehavior runBehavior, SqlCommand cmdHandler, SqlDataReader dataStream, BulkCopySimpleResultSet bulkCopyHandler, TdsParserStateObject stateObj)
    TdsParser.DrainData(TdsParserStateObject stateObj)
    TdsParser.ThrowUnsupportedCollationEncountered(TdsParserStateObject stateObj)
    TdsParser.GetCodePage(SqlCollation collation, TdsParserStateObject stateObj)
    TdsParser.TryCommonProcessMetaData(TdsParserStateObject stateObj, _SqlMetaData col)
    TdsParser.TryProcessMetaData(Int32 cColumns, TdsParserStateObject stateObj, _SqlMetaDataSetamp; metaData)
    TdsParser.TryRun(RunBehavior runBehavior, SqlCommand cmdHandler, SqlDataReader dataStream, BulkCopySimpleResultSet bulkCopyHandler, TdsParserStateObject stateObj, Booleanamp; dataReady)
    SqlDataReader.TryConsumeMetaData()
    SqlDataReader.get_MetaData()
    SqlCommand.FinishExecuteReader(SqlDataReader ds, RunBehavior runBehavior, String resetOptionsString)
    SqlCommand.RunExecuteReaderTds(CommandBehavior cmdBehavior, RunBehavior runBehavior, Boolean returnStream, Boolean async, Int32 timeout, Taskamp; task, Boolean asyncWrite, SqlDataReader ds)
    SqlCommand.RunExecuteReader(CommandBehavior cmdBehavior, RunBehavior runBehavior, Boolean returnStream, TaskCompletionSource`1 completion, Int32 timeout, Taskamp; task, Boolean asyncWrite, String method)
    SqlCommand.RunExecuteReader(CommandBehavior cmdBehavior, RunBehavior runBehavior, Boolean returnStream, String method)
    SqlCommand.ExecuteReader(CommandBehavior behavior)
    SqlCommand.ExecuteDbDataReader(CommandBehavior behavior)
    DbCommand.ExecuteReader()
    RelationalCommand.Execute(IRelationalConnection connection, DbCommandMethod executeMethod, IReadOnlyDictionary`2 parameterValues)
    RelationalCommand.ExecuteReader(IRelationalConnection connection, IReadOnlyDictionary`2 parameterValues)
    SqlServerExecutionStrategy.Execute[TState,TResult](TState state, Func`3 operation, Func`3 verifySucceeded)
    Enumerable.TryGetFirst[TSource](IEnumerable`1 source, Booleanamp; found)
    lambda_method(Closure )
    ResultEnumerable`1.GetEnumerator()
    LinqOperatorProvider._TrackEntities[TOut,TIn](IEnumerable`1 results, QueryContext queryContext, IList`1 entityTrackingInfos, IList`1 entityAccessors) MoveNext()
    Enumerable.TryGetFirst[TSource](IEnumerable`1 source, Booleanamp; found)
    Enumerable.First[TSource](IEnumerable`1 source)
    <>c__DisplayClass15_1`1.<CompileQueryCore>b__0(QueryContext qc)
    QueryCompiler.Execute[TResult](Expression query)
    EntityQueryProvider.Execute[TResult](Expression expression)
    Queryable.FirstOrDefault[TSource](IQueryable`1 source, Expression`1 predicate)
  

Я предполагаю проблему параллелизма, но не могу ее решить. Вам также необходимо знать следующее о поведении EF при использовании открытых подключений из документов:

подключение DbConnection Существующее DbConnection, которое будет использоваться для подключения к базе данных. Если соединение находится в открытом состоянии, EF не будет открывать или закрывать соединение. Если соединение находится в закрытом состоянии, EF откроет и закроет соединение по мере необходимости. Источник

Параллельное использование SqlConnection просто не поддерживается, как указано на GitHub