我有两个表。我正在使用实体框架更新这些表。这是我的代码
public bool UpdateTables()
{
UpdateTable1();
UpdateTable2();
}
如果任何表更新操作失败,其他不应该提交,我如何在实体框架中实现这一点?
using (TransactionScope transaction = new TransactionScope())
{
bool success = false;
try
{
//your code here
UpdateTable1();
UpdateTable2();
transaction.Complete();
success = true;
}
catch (Exception ex)
{
// Handle errors and deadlocks here and retry if needed.
// Allow an UpdateException to pass through and
// retry, otherwise stop the execution.
if (ex.GetType() != typeof(UpdateException))
{
Console.WriteLine("An error occured. "
+ "The operation cannot be retried."
+ ex.Message);
break;
}
}
if (success)
context.AcceptAllChanges();
else
Console.WriteLine("The operation could not be completed");
// Dispose the object context.
context.Dispose();
}
使用事务范围
public bool UpdateTables()
{
using (System.Transactions.TransactionScope sp = new System.Transactions.TransactionScope())
{
UpdateTable1();
UpdateTable2();
sp.Complete();
}
}
您还需要添加System。交易到您的项目参考
当您在上下文中调用SaveChanges()时,不需要使用TransactionScope:Entity Framework自动强制执行事务。
public bool UpdateTables()
{
using(var context = new MyDBContext())
{
// use context to UpdateTable1();
// use context to UpdateTable2();
context.SaveChanges();
}
}
您可以这样做。。。。
using (TransactionScope ts = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions { IsolationLevel = System.Transactions.IsolationLevel.RepeatableRead }))
{
using (YeagerTechEntities DbContext = new YeagerTechEntities())
{
Category category = new Category();
category.CategoryID = cat.CategoryID;
category.Description = cat.Description;
// more entities here with updates/inserts
// the DbContext.SaveChanges method will save all the entities in their corresponding EntityState
DbContext.Entry(category).State = EntityState.Modified;
DbContext.SaveChanges();
ts.Complete();
}
}