0

我正在向数据库中插入一条记录,如下所示:

class Transaction
{
   int Id;
}

我想要的是,当我插入这个对象时,我想创建另一条记录,如下所示:

class TransactionUpdate
{
   int StartingTransactionId;
   int EndingTransactionId;
}

到目前为止,我在 DbContext 上的 SaveChanges 中有一个循环,它采用将要创建的新 Transaction 对象并创建 TransationUpdate 对象并将这些对象附加到 DbContext。

public override int SaveChanges()
 {
   foreach(var entry in this.ChangeTracker.Entries())
   {
     if(entry.Entity is Transaction)
     {
       var update = new TransactionUpdate();
       update.StartingTransactionId = ((Transaction)entry.Entity).PreviousTransactionId;
       update.EndingTransactionId = ((Transaction)entry.Entity).Id; // This is zero because the entity has not been inserted.
       this.TransactionUpdates.Add(update);
     }
   }
 }

问题是,我无法正确创建 TransactionUpdate,因为我没有“EndingTransactionId”,或者我当前插入的交易的 Id。

我怎么解决这个问题?

非常感谢。

解决了

我已经完成了 Ladislav 的建议,现在正在创建一个要添加的项目列表,以及对插入它们所需的对象的引用。因此:

    public override int SaveChanges()
    {
        var transactionUpdatesToAdd = new List<Tuple<TransactionUpdate, Transaction>>();

        foreach (var entry in this.ChangeTracker.Entries<Transaction>())
        {
            if (entry.State == EntityState.Added)
            {
                var update = new TransactionUpdate();
                update.StartingTransactionId = ((Transaction)entry.Entity).PreviousTransactionId;
                transactionUpdatesToAdd.Add(new Tuple<TransactionUpdate, Transaction>(update, entry.Entity));
            }
        }

        using(var scope = new TransactionScope())
        {
         // Save new Transactions
         base.SaveChanges();

         // Update TransactionUpdates with new IDs
         foreach (var updateData in transactionUpdatesToAdd)
         {
             updateData.Item1.EndingTransactionId = updateData.Item2.Id;
             this.TransactionUpdates.Add(updateData.Item1);
         }

         // Insert the new TransactionUpdate entities.
         return base.SaveChanges();
        }
4

2 回答 2

1

根据您的描述,我猜您正在数据库中使用自动生成的 ID。在上下文中执行之前,您不会收到此 Id SaveChanges。您必须将操作分为两个单独的修改:

public override int SaveChanges()  
{  
   // call base context saving operation to insert all Transactions
   base.SaveChanges();

   foreach(var entry in this.ChangeTracker.Entries())    
   {      
      if(entry.Entity is Transaction)      
      {        
         var update = new TransactionUpdate();        
         update.StartingTransactionId = ((Transaction)entry.Entity).PreviousTransactionId;        
         update.EndingTransactionId = ((Transaction)entry.Entity).Id;      
         this.TransactionUpdates.Add(update);      
      }    
   }

   // save changes again to insert all TransactionUpdates
   base.SaveChanges();  
} 

您应该将其包装成TransactionScope将整个保存为原子操作。

于 2011-02-01T11:59:13.937 回答
0

如果您还没有插入 TransactionId,那么无论如何您的对象中都有它。将您的对象作为参数传递给重载方法 SaveChanges 并使用它来传递 Id

于 2011-02-01T11:51:28.763 回答