DDD 領域驅動設計－談談 Repository、IUnitOfWork 和 IDbContext 的實踐（3）

来源:http://www.cnblogs.com/xishuai/archive/2016/11/10/ddd-repository-iunitofwork-and-idbcontext-part-3.html
-Advertisement-
Play Games

上一篇：《 "DDD 領域驅動設計－談談 Repository、IUnitOfWork 和 IDbContext 的實踐（2）" 》 這篇文章主要是對 "DDD.Sample" 框架增加 Transaction 事務操作，以及增加了一些必要項目。 雖然現在的 IUnitOfWork 實現中有 Com ...


上一篇：《DDD 領域驅動設計－談談 Repository、IUnitOfWork 和 IDbContext 的實踐（2）》

這篇文章主要是對 DDD.Sample 框架增加 Transaction 事務操作，以及增加了一些必要項目。

雖然現在的 IUnitOfWork 實現中有 Commit 的實現，但也就是使用的 EF SaveChanges，滿足一些簡單操作可以，但一些稍微複雜點的實體操作就不行了，並且 Rollback 也沒有實現。

現在的 UnitOfWork 實現代碼：

public class UnitOfWork : IUnitOfWork
{
    private IDbContext _dbContext;

    public UnitOfWork(IDbContext dbContext)
    {
        _dbContext = dbContext;
    }

    public void RegisterNew<TEntity>(TEntity entity)
        where TEntity : class
    {
        _dbContext.Set<TEntity>().Add(entity);
    }

    public void RegisterDirty<TEntity>(TEntity entity)
        where TEntity : class
    {
        _dbContext.Entry<TEntity>(entity).State = EntityState.Modified;
    }

    public void RegisterClean<TEntity>(TEntity entity)
        where TEntity : class
    {
        _dbContext.Entry<TEntity>(entity).State = EntityState.Unchanged;
    }

    public void RegisterDeleted<TEntity>(TEntity entity)
        where TEntity : class
    {
        _dbContext.Set<TEntity>().Remove(entity);
    }

    public async Task<bool> CommitAsync()
    {
        return await _dbContext.SaveChangesAsync() > 0;
    }

    public void Rollback()
    {
        throw new NotImplementedException();
    }
}

基於上面的實現，比如要處理這樣的一個操作：先添加一個 Teacher，然後再添加一個 Student，Student 實體中有一個 TeacherId，一般實現方式如下：

public async Task<bool> Add(string name)
{
    var teacher = new Teacher { Name = "teacher one" };
    _unitOfWork.RegisterNew(teacher);
    await _unitOfWork.CommitAsync();

    //可能還有一些 web 請求操作，比如 httpClient.Post(tearch); 可能會出選異常。

    var student = new Student { Name = name, TeacherId = teacher.Id };
    _unitOfWork.RegisterNew(student);
    await _unitOfWork.CommitAsync();

    return true;
}

上面的實現可能會出現一些問題，比如添加 Teacher 出現了異常，web 請求出現了異常，添加 Student 出現了異常等，該如何進行處理？所以你可能會增加很多判斷，還有就是異常出現後的修複操作，當需求很複雜的時候，我們基於上面的處理也就會更加複雜，根本原因是並沒有真正的實現 Transaction 事務操作。

如果單獨在 EF 中實現 Transaction 操作，可以使用 TransactionScope，參考文章：在 Entity Framework 中使用事務

TransactionScope 的實現比較簡單，如何在 DDD.Sample 框架中，結合 IUnitOfWork 和 IDbContext 進行使用呢？可能實現方式有很多中，現在我的實現是這樣：

首先，IDbContext 中增加 Database 屬性定義：

public interface IDbContext
{
    Database Database { get; } //add

    DbSet<TEntity> Set<TEntity>()
        where TEntity : class;

    DbEntityEntry<TEntity> Entry<TEntity>(TEntity entity)
        where TEntity : class;

    Task<int> SaveChangesAsync();
}

增加 Database 屬性的目的是，便於我們在 UnitOfWork 中訪問到 Transaction，其實還可以定義這樣的介面：DbContextTransaction BeginTransaction();，但 EF 中的 DbContext 並沒有進行實現，而是需要通過 Database 屬性，所以還需要在 IDbContext 實現中額外實現，另外增加 Database 屬性的好處，還有就是可以在 UnitOfWork 中訪問執行很多的操作，比如執行 SQL 語句等等。

這裡需要說下 IDbContext 定義，我原先的設計初衷是，讓它脫離 EF，作為所有數據操作上下文的定義，但其實實現的時候，還是脫離不了 EF，因為介面返回的類型都在 EF 下，最後 IDbContext 就變成了 EF DbContext 的部分介面定義，所以這部分是需要再進行設計的，但好在有了 IDbContext，可以讓 EF 和 UnitOfWork 隔離開來。

SchoolDbContext 中的實現沒有任何變換，因為繼承的 EF DbContext 已經有了實現，UnitOfWork 改動比較大，代碼如下：

public class UnitOfWork : IUnitOfWork
{
    private IDbContext _dbContext;
    private DbContextTransaction _dbTransaction;

    public UnitOfWork(IDbContext dbContext)
    {
        _dbContext = dbContext;
        _dbTransaction = _dbContext.Database.BeginTransaction();
    }

    public async Task<bool> RegisterNew<TEntity>(TEntity entity)
        where TEntity : class
    {
        _dbContext.Set<TEntity>().Add(entity);
        return await _dbContext.SaveChangesAsync() > 0;
    }

    public async Task<bool> RegisterDirty<TEntity>(TEntity entity)
        where TEntity : class
    {
        _dbContext.Entry<TEntity>(entity).State = EntityState.Modified;
        return await _dbContext.SaveChangesAsync() > 0;
    }

    public async Task<bool> RegisterClean<TEntity>(TEntity entity)
        where TEntity : class
    {
        _dbContext.Entry<TEntity>(entity).State = EntityState.Unchanged;
        return await _dbContext.SaveChangesAsync() > 0;
    }

    public async Task<bool> RegisterDeleted<TEntity>(TEntity entity)
        where TEntity : class
    {
        _dbContext.Set<TEntity>().Remove(entity);
        return await _dbContext.SaveChangesAsync() > 0;
    }

    public void Commit()
    {
        _dbTransaction.Commit();
    }

    public void Rollback()
    {
        _dbTransaction.Rollback();
    }
}

UnitOfWork 構造函數中，根據 DbContext 創建 DbContextTransaction 對象，然後在實體每個操作中，都添加了 SaveChanges，因為我們用了 Transaction，所以在執行 SaveChanges 的時候，並沒有應用到資料庫，但可以獲取到新添加實體的 Id，比如上面示例 Student 中的 TeacherId，並且用 Sql Profiler 可以檢測到執行的 SQL 代碼，當執行 Commit 的時候，數據對應進行更新。

測試代碼：

public async Task<bool> AddWithTransaction(string name)
{
    var teacher = new Teacher { Name = "teacher one" };
    await _unitOfWork.RegisterNew(teacher);

    //可能還有一些 web 請求操作，比如 httpClient.Post(tearch); 可能會出選異常。
    
    var student = new Student { Name = name, TeacherId = teacher.Id };
    await _unitOfWork.RegisterNew(student);

    _unitOfWork.Commit();
    return true;
}

在上面代碼中，首先在沒執行到 Commit 之前，是可以獲取到新添加 Teacher 的 Id，並且如果出現了任何異常，都是可以進行回滾的，當然也可以手動進行 catch 異常，並執行_unitOfWork.Rollback()。

不過上面的實現有一個問題，就是每次實體操作，都用了 Transaction，性能我沒測試，但肯定會有影響，好處就是 IUnitOfWork 基本沒有改動，還是按照官方的定義，只不過部分介面改成了非同步介面。

除了上面的實現，還有一種解決方式，就是在 IUnitOfWork 中增加一個類似 BeginTransaction 的介面，大致實現代碼：

public class UnitOfWork : IUnitOfWork
{
    private IDbContext _dbContext;
    private DbContextTransaction _dbTransaction;

    public UnitOfWork(IDbContext dbContext)
    {
        _dbContext = dbContext;
    }

    //add
    public void BeginTransaction()
    {
        _dbTransaction = _dbContext.Database.BeginTransaction();
    }

    public async Task<bool> RegisterNew<TEntity>(TEntity entity)
        where TEntity : class
    {
        _dbContext.Set<TEntity>().Add(entity);
        if (_dbTransaction != null)
            return await _dbContext.SaveChangesAsync() > 0;
        return true;
    }

    public async Task<bool> RegisterDirty<TEntity>(TEntity entity)
        where TEntity : class
    {
        _dbContext.Entry<TEntity>(entity).State = EntityState.Modified;
        if (_dbTransaction != null)
            return await _dbContext.SaveChangesAsync() > 0;
        return true;
    }

    public async Task<bool> RegisterClean<TEntity>(TEntity entity)
        where TEntity : class
    {
        _dbContext.Entry<TEntity>(entity).State = EntityState.Unchanged;
        if (_dbTransaction != null)
            return await _dbContext.SaveChangesAsync() > 0;
        return true;
    }

    public async Task<bool> RegisterDeleted<TEntity>(TEntity entity)
        where TEntity : class
    {
        _dbContext.Set<TEntity>().Remove(entity);
        if (_dbTransaction != null)
            return await _dbContext.SaveChangesAsync() > 0;
        return true;
    }

    public async Task<bool> Commit()
    {
        if (_dbTransaction == null)
            return await _dbContext.SaveChangesAsync() > 0;
        else
            _dbTransaction.Commit();
        return true;
    }

    public void Rollback()
    {
        if (_dbTransaction != null)
            _dbTransaction.Rollback();
    }
}

上面這種實現方式就解決了第一種方式的問題，需要使用 Transaction 的時候，直接在操作之前調用 BeginTransaction 就行了，但不好的地方就是改動了 IUnitOfWork 的介面定義。

除了上面兩種實現方式，大家如果有更好的解決方案，歡迎提出。

另外，DDD.Sample 增加和改動了一些東西：

  • 增加 DDD.Sample.Domain.DomainEvents、DDD.Sample.Domain.DomainServices 和 DDD.Sample.Domain.ValueObjects。
  • 從 DDD.Sample.Domain 分離出 DDD.Sample.Domain.Repository.Interfaces。
  • 增加 DDD.Sample.BootStrapper，執行 Startup.Configure 用於系統啟動的配置。
  • 去除 IEntity，在 IAggregateRoot 中添加 Id 屬性定義。

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • iOS柱狀圖的繪製
    前段時間公司要求做一個統計，用swift3.0寫的，因此整理了一下demo，直接上圖 代碼下載地址：https://github.com/minyahui/MYHChartView ...
  • php自定義錯誤日誌
    項目中需要對定義錯誤日誌及時處理， 那麼就需要修改自定義錯誤日誌的輸出方式（寫日誌、發郵件、發簡訊） 一. register_shutdown_function(array('phperror','shutdown_function')); //定義PHP程式執行完成後執行的函數 函數可實現當程式執 ...
  • Spring ApplicationContext 簡解
    ApplicationContext是對BeanFactory的擴展，實現BeanFactory的所有功能，並添加了事件傳播，國際化，資源文件處理等。 configure locations：（CONFIG_LOCATION_DELIMITERS = ",; \t\n" ）分割多個配置文件。 ref ...
  • php fastcgi_finish_request用法
    項目中一直有用到fastcgi_finish_request，感覺很實用。 用法： if(function_exists('fastcgi_finish_request')) fastcgi_finish_request(); 只要代碼運行到這個位置，就已經斷開請求返回參數給客戶端了。 接下來的代碼 ...
  • Webwork 學習之路【08】結合實戰簡析Controller 配置
    雖然現在 MVC 框架層出不窮，但做為 Struts 前身的 webwork。 其經典程度不亞於貝利之於足球，雙 11 之於淘寶特賣。 本篇將結合 webwork controller 配置文件 xwork.xml 的配置項淺析。 來一起看看當年叱吒風雨的 mvc 框架是怎樣滿足變更的業務需求。 1 ...
  • Java列表
    Java列表踩過的坑 其中subList是RandomAccessSubList，不是序列化的列表，不可以加入tair。 加入tair測試代碼 Java中怎樣把數組轉換為ArrayList? 方法二的方式不太好，因為 asList() 返回的列表的大小是固定的。事實上，返回的列表不是 java.ut ...
  • MyBatis源碼分析（一）開篇
    源碼學習的好處不用多說，Mybatis源碼量少、邏輯簡單，將寫個系列文章來學習。 ...
  • 網站三層架構學習之一 分層式結構
    可是今年來了以後，老師讓做即墨公司的語音項目，一直進行的是windows編程，沒有接觸網站方面的。現在項目基本做完了，開始ASP.NET的學習了。 現在petshop的最新版本已經出到了4.0，下載安裝完成，把Web作為啟動項目，ctrl+F5,運行，出現了激動人心的petshop網站頁面，整體風格 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類