Как заставить только одну транзакцию в нескольких классах DbContext?

Если вы используете несколько контекстов, каждый из которых использует отдельное соединение, и вы хотите сохранить данные в этом контексте в одной транзакции, вы должны использовать TransactionScope с распределенной транзакцией (MSDTC).

Ваш связанный вопрос не тот случай, потому что в этом сценарии первое соединение не изменяет данные, поэтому его можно закрыть до запуска соединения, в котором данные изменяются. В вашем случае данные одновременно изменяются при нескольких подключениях, для которых требуется двухфазная фиксация и MSDTC.

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

using (var connection = new SqlConnection(connnectionString))
{
    var c1 = new Context(connection);
    var c2 = new Context(connection);

    c1.MyEntities.Add(new MyEntity() { Name = "A" });
    c2.MyEntities.Add(new MyEntity() { Name = "B" });

    connection.Open(); 

    using (var scope = new TransactionScope())
    {
        // This is necessary because DbContext doesnt't contain necessary methods
        ObjectContext obj1 = ((IObjectContextAdapter)c1).ObjectContext;
        obj1.SaveChanges(SaveOptions.DetectChangesBeforeSave);

        ObjectContext obj2 = ((IObjectContextAdapter)c2).ObjectContext;
        obj2.SaveChanges(SaveOptions.DetectChangesBeforeSave);

        scope.Complete();

        // Only after successful commit of both save operations we can accept changes
        // otherwise in rollback caused by second context the changes from the first
        // context will be already accepted = lost

        obj1.AcceptAllChanges();
        obj2.AcceptAllChanges();
    }
}

Конструктор контекста определяется как:

public Context(DbConnection connection) : base(connection,false) { }

Сам образец работал у меня, но у него есть несколько проблем:

• Первое использование контекстов должно выполняться при закрытом соединении. Вот почему я добавляю объекты до открытия соединения.
• Я скорее открываю соединение вручную вне транзакции, но, возможно, это не нужно.
• Оба сохранения изменений успешно выполняются, а Transaction.Current имеет пустой идентификатор распределенной транзакции, поэтому он должен быть локальным.
• Сохранение намного сложнее, и вы должны использовать ObjectContext, потому что DbContext не имеет всех необходимых методов.
• Это не должно работать в каждом сценарии. Даже MSDN утверждает это:

Повышение транзакции до DTC может произойти, когда соединение закрывается и повторно открывается в рамках одной транзакции. Поскольку Entity Framework открывает и закрывает соединение автоматически, вам следует рассмотреть возможность открытия и закрытия соединения вручную, чтобы избежать продвижения транзакции.

Проблема с DbContext API заключается в том, что он закрывает и снова открывает соединение, даже если вы открываете его вручную, поэтому это открытый вопрос, всегда ли API правильно определяет, работает ли он в контексте транзакции и не закрывает соединение.

@Ladislav Mrnka Вы были правы с самого начала: я должен использовать MSDTC.

Я пробовал здесь несколько вещей, включая предоставленный мной пример кода. Я много раз проверял это с измененным зайцем и там, но это не сработает. Ошибка углубляется в то, как работают EF и DbContext, и для того, чтобы это изменить, я, наконец, нашел свой собственный инструмент ORM. Это не так.

Я также поговорил с другом (MVP), который тоже много знает об EF. Мы протестировали некоторые другие вещи здесь, но это не будет работать так, как я хочу. Я закончу с несколькими изолированными транзакциями (я пытался собрать их вместе с моим примером кода), и с этим подходом у меня нет никакого способа принудительно выполнить полный откат автоматически, и мне придется создать много общих /custom код для ручного отката изменений и здесь возникает еще один вопрос: что если такой откат не удался (это не откат, а просто обновление)?

Таким образом, единственный способ, который мы нашли здесь, — это использовать MSDTC и создать некоторые инструменты, помогающие отладить/проверить, включен ли DTC, исправны ли брандмауэры клиент/сервер и все такое прочее.

Спасибо, в любом случае. знак равно

Итак, есть шанс, что это изменится к 19 октября? На всех интертьюбах люди предлагают следующий код, и он не работает:

    (_contextA as IObjectContextAdapter).ObjectContext.Connection.Open();
    (_contextB as IObjectContextAdapter).ObjectContext.Connection.Open();

    using (var transaction = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions{IsolationLevel = IsolationLevel.ReadUncommitted, Timeout = TimeSpan.MaxValue}))
{
    _contextA.SaveChanges();
    _contextB.SaveChanges();

    // Commit the transaction
    transaction.Complete();
}

    // Close open connections
    (_contextA as IObjectContextAdapter).ObjectContext.Connection.Close();
    (_contextB as IObjectContextAdapter).ObjectContext.Connection.Close();

Это серьезное препятствие для реализации одного класса Unit of Work в репозиториях. Любой новый способ обойти это?

Чтобы избежать использования MSDTC (распределенная транзакция):

Это должно заставить вас использовать одно соединение внутри транзакции, а также только одну транзакцию. В противном случае он должен генерировать исключение.

Примечание. Требуется как минимум EF6.

class TransactionsExample 
 { 
    static void UsingExternalTransaction() 
    { 
        using (var conn = new SqlConnection("...")) 
        { 
           conn.Open(); 

           using (var sqlTxn = conn.BeginTransaction(System.Data.IsolationLevel.Snapshot)) 
           { 
               try 
               { 
                   var sqlCommand = new SqlCommand(); 
                   sqlCommand.Connection = conn; 
                   sqlCommand.Transaction = sqlTxn; 
                   sqlCommand.CommandText = 
                       @"UPDATE Blogs SET Rating = 5" + 
                        " WHERE Name LIKE '%Entity Framework%'"; 
                   sqlCommand.ExecuteNonQuery(); 

                   using (var context =  
                     new BloggingContext(conn, contextOwnsConnection: false)) 
                    { 
                        context.Database.UseTransaction(sqlTxn); 

                        var query =  context.Posts.Where(p => p.Blog.Rating >= 5); 
                        foreach (var post in query) 
                        { 
                            post.Title += "[Cool Blog]"; 
                        } 
                       context.SaveChanges(); 
                    } 

                    sqlTxn.Commit(); 
                } 
                catch (Exception) 
                { 
                    sqlTxn.Rollback(); 
                } 
            } 
        } 
    } 
} 

Источник: http://msdn.microsoft.com/en-us/data/dn456843.aspx#existing