实体框架中的一个事务中的多个数据库

Question

我在实体框架中为两个不同的数据库创建了两个不同的上下文。现在我正在尝试在单个事务中更新这些数据库。我的代码是这样的：

public class LPO_BLL
{
    internal Context1 _context1 = null;
    internal Context2 _Context2 = null;

    public LPO_Detail_BLL(Context1 context1, Context2 context2)
    {
        _context1 = context1;
        _context2 = context2;
    }

    public void Insert(PM_LPO lpo, LPO_Transaction lpo_transaction)
    {
        using (TransactionScope transaction = new TransactionScope())
        {
            _context1.LPO.Add(lpo);
            _context1.SaveChanges();

            _context2.LPO_Transaction.Add(lpo_transaction);
            _context2.SaveChanges();  // I am getting error here...

            transaction.Complete();
        }
    }
}

在 UI 项目中，我将其称为：

LPO lpo = new LPO();
//setting properties of lpo

LPO_Transaction lpo_trans = new LPO_Transaction();
//setting properties of lpo_trans

Context1 _context1 = new Context1();
//Opening _context1 connection and etc

Context2 _context2 = new Context2();
//Opening _context2 connection and etc

LPO_BLL lpo_bll = new LPO_BLL(_context1, _context2);

lpo_bll.Insert(lpo,lpo_trans);

目前，我收到错误： 基础提供商在 EnlistTransaction 上失败

在互联网上搜索了最后 3 个小时并尝试了不同的点击和试用方法后，我决定将它放在 SO 上。到目前为止，我发现这两个链接更接近一点：

http://social.msdn.microsoft.com/Forums/en-US/3ccac6f7-6513-4c87-828a-00e0b88285bc/the-underlying-provider-failed-on-enlisttransaction?forum=adodotnetentityframework

TransactionScope - The underlying provider failed on EnlistTransaction. MSDTC being aborted

Answer 1

并非所有数据库提供者都支持分布式事务。

使用事务作用域将尝试在由 MSDTC 管理的分布式事务中登记数据库事务。如果您的提供者不支持这一点，它将失败。

SQL Server 和 Oracle 提供程序支持分布式事务。但许多其他 EF 提供商却没有。

如果您的数据库提供商不支持这一点，您将不得不使用不同的或放弃使用事务。

如果您使用的是 SQL Server 2005，它应该可以工作，但是：

• MSDTC 服务必须正在运行（在“服务”中的“控制面板”中查找）。
• 连接字符串必须足以让 MSDTC 工作

看this SO Q&A: confusion about transactions and msdtc。

注意：服务的名称是MSDTC。所以你可以运行net start msdtc 或net stop msdtc。如果您在控制面板中查找它，您会找到一个描述性名称，如“分布式事务协调器”或一个本地化名称，如“Coordinador de transacciones distribuidas”。奇怪的是，没有办法在本地服务的控制面板列表中显示名称列。

Answer 2

您必须在 DbContext 中使用 ObjectContext 才能使用带有参数的 SaveChanges：

public class EntityDBContext: DbContext, IObjectContextAdapter
{
    ObjectContext IObjectContextAdapter.ObjectContext {
        get { 
           return (this as IObjectContextAdapter).ObjectContext;
        }
    }
}

然后在您的 Insert 方法中，使用：

public void Insert(PM_LPO lpo, LPO_Transaction lpo_transaction)
{
    using (TransactionScope transaction = new TransactionScope())
    {

         context1.ObjectContext.SaveChanges(false);
         context2.ObjectContext.SaveChanges(false);

         _context1.LPO.Add(lpo);
         _context2.LPO_Transaction.Add(lpo_transaction);       

         transaction.Complete();

         context1.ObjectContext.AcceptAllChanges();
         context2.ObjectContext.AcceptAllChanges();

    }
}

Answer 3

对于多个数据库集，应使用 Savechange(false) 和 AcceptAllChanges()。

 public void Insert(PM_LPO lpo, LPO_Transaction lpo_transaction)
{
    using (TransactionScope transaction = new TransactionScope())
    {

         context1.SaveChanges(false);
         context2.SaveChanges(false);

        _context1.LPO.Add(lpo);
        _context2.LPO_Transaction.Add(lpo_transaction);       

        transaction.Complete();

       context1.AcceptAllChanges();
       context2.AcceptAllChanges();

    }
}