實體框架核心1.0 Asp.Net核心中間件或過濾器的mvc工作單元

Question

我使用EF核心1.0（以前稱爲廣告EF7）和ASP.NET核心1.0（以前稱爲ASP.NET 5），用於一個RESTful API 。

我希望有一些工作單元的作用範圍爲http請求，這樣當響應HTTP請求時，對DbContext所做的所有更改都將保存到數據庫中，或者不會保存（例如，如果有一些例外）。

在過去，我使用WebAPI2來實現NHibernate的這個目的，通過使用Action過濾器來開始執行動作的事務，並在執行的動作上結束事務並關閉會話。這其中，我的理解，已經實現了工作單位在http://isbn.directory/book/9781484201107

但是現在推薦我使用Asp.Net核心（與Asp.Net核心的mvc雖然這不應該是相關的）的方式和Entity Framework。

我認爲有插入ASP.NET管道（MVC）之前中間件是做事情的正確方法。因此，請求會去：

管道ASP.NET：MyUnitOfWorkMiddleware ==> MVC控制器==>倉庫==> MVC控制器==> MyUnitOfWorkMiddleware

我想有這個中間件保存的DbContext的如果沒有異常發生，那麼更改，以便在我的存儲庫實現中，我甚至不需要執行dbcontext.SaveChanges()，並且所有內容都將像集中式事務一樣。在僞代碼，我想它會是這樣的：

class MyUnitOfWorkMiddleware 
{ 
    //.. 
    1-get an instance of DbContext for this request. 
    try { 
     2-await the next item in the pipeline. 
     3-dbContext.SaveChanges(); 
    } 
    catch (Exception e) { 
     2.1-rollback changes (simply by ignoring context) 
     2.2-return an http error response 
    } 
} 

這是否有意義？有人有類似的例子嗎？我無法找到任何好的做法或建議。如果我在我的MVC控制器級別上使用這種方法，我將無法訪問數據庫在創建新資源時創建的任何資源ID，因爲在保存dbContext更改之前不會生成ID（稍後在控制器完成執行後，在我的中間件管道中）。如果我需要訪問控制器中新創建的資源ID，該怎麼辦？

任何意見將不勝感激！

更新1：我發現我的做法有問題使用中間件來實現這一點，因爲在中間件的DbContext實例是不一樣的MVC（和存儲庫）一生中。看到問題Entity Framework Core 1.0 DbContext not scoped to http request

更新2：我還沒有找到一個好的解決辦法。基本上這些是我的選擇到目前爲止：

1. 儘快保存DB中的更改。這意味着將其保存在存儲庫實現本身上。這種方法的問題是，對於一個Http請求，可能我想使用幾個存儲庫（即。e：將數據保存在數據庫中，然後將blob上傳到雲存儲），爲了獲得工作單元，我必須實現一個處理多個實體或甚至多個持久性方法的存儲庫（DB和Blob存儲），這會破壞整個目的

2. 執行一個Action Filter，其中我將整個操作執行包裝在一個數據庫事務中。在控制器的動作執行結束時，如果沒有例外，我向數據庫提交chanches，但是如果有例外，我將回滾並放棄上下文。問題在於我的控制器的動作可能需要一個生成的實體的Id，以便將其返回給http客戶端（即：如果我得到一個POST/api/cars，我想返回一個帶有位置標題的201 Accepted，在/ api/cars/123和Id 123創建的新資源將不可用，因爲實體未保存在數據庫中，並且Id仍然是臨時的0）。通過以數據庫生成

   return CreatedAtRoute("GetCarById", new { carId= carSummaryCreated.Id }, carSummaryCreated); //carSummaryCreated.Id would be 0 until the changes are saved in DB

我怎麼可能把整個控制器的動作包裹在一個數據庫事務，並在同一時間有任何可用的標識：例如，在控制器的一個POST命令請求採取行動從控制器的Http Response中返回它？或者.. 是否有任何優雅的方式來覆蓋http響應，並在數據庫更改已被提交後在操作篩選器級別設置Id？

更新3：按nathanaldensr「的評論，我能得到兩全其美的（包裹我的控制器的動作執行的DB交易_ UOW也知道DB前，甚至創造新的資源的ID提交更改）通過使用代碼生成的Guids而不是依賴數據庫來生成Guid。

Answer 1

我也面臨同樣的問題，並不確定遵循哪種方法。 一，我所使用的方法是如下：

public class UnitOfWorkFilter : ActionFilterAttribute 
{ 
    private readonly AppDbContext _dbContext; 

    public UnitOfWorkFilter(AppDbContext dbContext,) 
    { 
     _dbContext = dbContext; 
    } 

    public override void OnActionExecuted(ActionExecutedContext context) 
    { 
     if (!context.HttpContext.Request.Method.Equals("Post", StringComparison.OrdinalIgnoreCase)) 
      return; 
     if (context.Exception == null && context.ModelState.IsValid) 
     { 
      _dbContext.Database.CommitTransaction(); 
     } 
     else 
     { 
      _dbContext.Database.RollbackTransaction(); 
     } 
    } 

    public override void OnActionExecuting(ActionExecutingContext context) 
    { 
     if (!context.HttpContext.Request.Method.Equals("Post", StringComparison.OrdinalIgnoreCase)) 
      return; 
     _dbContext.Database.BeginTransaction(); 
    } 
} 

Answer 2

我的建議，在控制器中使用dbContext.SaveChanges（），因爲它在Web上的所有示例中都有演示。你想要做的事聽起來很花哨，可能會因爲你在帖子末尾猜到的事情而適得其反。而國際海事組織，這是沒有道理的。

關於你提到的第二個問題/任務：

....響應HTTP請求要麼到的DbContext所做的所有修改都會被保存到數據庫中，或沒有將被保存時（如果有例如是一些例外）。

我認爲你需要像'每次請求交易'這樣的東西。這只是一個想法，根本沒有經過測試。我只是把代碼放在一起在此示例中間件：

public class TransactionPerRequestMiddleware 
{ 
    private readonly RequestDelegate next_; 

    public TransactionPerRequestMiddleware(RequestDelegate next) 
    { 
     next_ = next; 
    } 

    public async Task Invoke(HttpContext context, DbContext dbContext) 
    { 
     var transaction = dbContext.Database.BeginTransaction(
      System.Data.IsolationLevel.ReadCommitted); 

     await next_.Invoke(context); 

     if (context.Response.StatusCode == 200) 
     { 
      transaction.Commit(); 
     } 
     else 
     { 
      transaction.Rollback(); 
     } 
    } 
} 

好運

Answer 3

按Entity Framework Core 1.0 DbContext not scoped to http request 我不能使用中間件來實現這一點，因爲該中間件被注入的DbContext的實例不是與MVC執行過程中的DbContext相同（在我的控制器或存儲庫中）。

我不得不採用類似的方法，在控制器的動作執行後使用全局過濾器保存DbContext中的更改。 目前還沒有關於MVC 6中過濾器的官方文檔，所以如果有人對此解決方案感興趣，請參閱下面的過濾器和我將此過濾器設置爲全局的方式，以便它在任何控制器的操作之前執行。

public class UnitOfWorkFilter : ActionFilterAttribute 
{ 
    private readonly MyDbContext _dbContext; 
    private readonly ILogger _logger; 

    public UnitOfWorkFilter(MyDbContext dbContext, ILoggerFactory loggerFactory) 
    { 
     _dbContext = dbContext; 
     _logger = loggerFactory.CreateLogger<UnitOfWorkFilter>(); 
    } 

    public override async Task OnActionExecutionAsync(ActionExecutingContext executingContext, ActionExecutionDelegate next) 
    { 
     var executedContext = await next.Invoke(); //to wait until the controller's action finalizes in case there was an error 
     if (executedContext.Exception == null) 
     { 
      _logger.LogInformation("Saving changes for unit of work"); 
      await _dbContext.SaveChangesAsync(); 
     } 
     else 
     { 
      _logger.LogInformation("Avoid to save changes for unit of work due an exception"); 
     } 
    } 
} 

和過濾器被插入到我的MVC在Startup.cs配置MVC時。

public void ConfigureServices(IServiceCollection services) 
{ 
    //.. 
    //Entity Framework 7 
    services.AddEntityFramework() 
      .AddSqlServer() 
      .AddDbContext<SpeediCargoDbContext>(options => { 
       options.UseSqlServer(Configuration["Data:DefaultConnection:ConnectionString"]); 
      }); 

     //MVC 6 
     services.AddMvc(setup => 
     { 
      setup.Filters.AddService(typeof(UnitOfWorkFilter)); 
     }); 
    //.. 
} 

這仍然留下一個問題（請參閱我的問題上的更新2）。 如果我想讓我的控制器響應一個包含在數據庫中創建的實體標識的201接受的位置標題的http POST請求，該怎麼辦？當控制器的操作完成執行時，更改尚未提交給數據庫，因此創建的實體的Id仍爲0，直到操作篩選器保存更改並且DB生成一個值。