Giới thiệu
Tôi thường gặp các câu hỏi về việc triển khai CQRS (Command Query Responsibility Segregation) pattern. Thậm chí thường xuyên hơn, tôi thấy các cuộc thảo luận về việc truy cập cơ sở dữ liệu ORM hoặc thuần SQL cái nào là tốt hơn.
Trong bài viết này tôi muốn giới thiệu với các bạn làm thế nào có thể nhanh chóng triển khai ứng dụng REST API với CQRS pattern sử dụng .NET Core. Tôi ngay lập tức chỉ ra rằng đây là phiên bản CQRS đơn giản nhất. Việc cập nhật Write Model ngay lập tức cập nhật Read Model, vì vậy chúng ta sẽ không có sự thống nhất cuối cùng ở đây. Tuy nhiên, nhiều ứng dụng không cần sự thống nhất cuối cùng, trong khi đó việc chia logic của việc ghi và đọc sử dụng chia làm 2 model là được khuyến khích và hiệu quả hơn trong hầu hết các giải pháp.
Đặc biệt trong bài viết này tôi đã chuẩn bị demo, ứng dụng hoạt động đầy đủ, xem source code trên Github.
Mục đích của tôi
Dưới đây là cái đích mà tôi muốn đạt được trong ứng dụng demo:
- Rõ ràng việc chia tách và cô lập Write Model và Read Model.
- Nhận dữ liệu sử dụng Read Model nên nhanh nhất có thể.
- Write Model nên được triển khai với các tiếp cận DDD (Domain Driven Design). Cấp độ của việc triển khai DDD nên phụ thuộc trên mức độ phức tạp của domain.
- Logic ứng dụng nên được tách biệt với giao diện người dùng (GUI) .
- Chọn các thư viện (libraries) cẩn thận, nổi tiếng và được hỗ trợ.
Thiết kế
Flow giữa các thành phần trông giống như thế này:
Như bạn có thể thấy xử lý cho việc đọc là khá đơn giản bởi vì chúng ta nên làm query dữ liệu nhanh nhất có thể. Chúng ta không cần ở đây các tầng abstractions và các tiếp cận rắc rối. Nhận các đối số từ query object, thực thi câu lệnh thuần SQL đối với cơ sở dữ liệu và trả về dữ liệu. Đó là tất cả những điều phải làm.
Nó là khác việt với trường hợp ghi. Việc ghi thường yêu cầu nhiều hơn các công nghệ nâng cáo bởi vì chúng ta cần thực thi một số logic, làm một vài tính toán hoặc đơn giản là kiểm tra các điều kiện (đặc biệt là những thứ không thay đổi). Với công cụ ORM với theo dõi các thay đổi (change tracking) và sử dụng Repository Pattern chúng ta có thể giữ để Domain Model nguyên vẹn.
Giải pháp
Read model
Biểu đồ bên dưới biểu diễn flow giữa các thành phần được sử dụng để xử lý các hoạt động yêu cầu đọc dữ liệu:
Giao diện người dùng có trách nhiệm cho việc tạo ra Query object:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 | <span class="token comment">/// Get customer order details.</span> <span class="token comment">/// </summary></span> <span class="token comment">/// <param name="orderId">Order ID.</param></span> <span class="token punctuation">[</span><span class="token class-name">Route</span><span class="token punctuation">(</span><span class="token string">"{customerId}/orders/{orderId}"</span><span class="token punctuation">)</span><span class="token punctuation">]</span> <span class="token punctuation">[</span><span class="token class-name">HttpGet</span><span class="token punctuation">]</span> <span class="token punctuation">[</span><span class="token class-name">ProducesResponseType</span><span class="token punctuation">(</span><span class="token keyword">typeof</span><span class="token punctuation">(</span>OrderDetailsDto<span class="token punctuation">)</span><span class="token punctuation">,</span> <span class="token punctuation">(</span><span class="token keyword">int</span><span class="token punctuation">)</span>HttpStatusCode<span class="token punctuation">.</span>OK<span class="token punctuation">)</span><span class="token punctuation">]</span> <span class="token keyword">public</span> <span class="token keyword">async</span> Task<span class="token operator"><</span>IActionResult<span class="token operator">></span> <span class="token function">GetCustomerOrderDetails</span><span class="token punctuation">(</span> <span class="token punctuation">[</span><span class="token class-name">FromRoute</span><span class="token punctuation">]</span><span class="token class-name">Guid</span> orderId<span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">var</span> orderDetails <span class="token operator">=</span> <span class="token keyword">await</span> _mediator<span class="token punctuation">.</span><span class="token function">Send</span><span class="token punctuation">(</span><span class="token keyword">new</span> <span class="token class-name">GetCustomerOrderDetailsQuery</span><span class="token punctuation">(</span>orderId<span class="token punctuation">)</span><span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token keyword">return</span> <span class="token function">Ok</span><span class="token punctuation">(</span>orderDetails<span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token punctuation">}</span> |
1 2 3 4 5 6 7 8 9 10 | <span class="token keyword">internal</span> <span class="token keyword">class</span> <span class="token class-name">GetCustomerOrderDetailsQuery</span> <span class="token punctuation">:</span> <span class="token class-name">IRequest</span><span class="token operator"><</span>OrderDetailsDto<span class="token operator">></span> <span class="token punctuation">{</span> <span class="token keyword">public</span> <span class="token class-name">Guid</span> OrderId <span class="token punctuation">{</span> <span class="token keyword">get</span><span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token keyword">public</span> <span class="token function">GetCustomerOrderDetailsQuery</span><span class="token punctuation">(</span><span class="token class-name">Guid</span> orderId<span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">this</span><span class="token punctuation">.</span>OrderId <span class="token operator">=</span> orderId<span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token punctuation">}</span> |
Tiếp theo, query handler xử lý query:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 | <span class="token keyword">internal</span> <span class="token keyword">class</span> <span class="token class-name">GetCustomerOrderDetialsQueryHandler</span> <span class="token punctuation">:</span> <span class="token class-name">IRequestHandler</span><span class="token operator"><</span>GetCustomerOrderDetailsQuery<span class="token punctuation">,</span> OrderDetailsDto<span class="token operator">></span> <span class="token punctuation">{</span> <span class="token keyword">private</span> <span class="token keyword">readonly</span> <span class="token class-name">ISqlConnectionFactory</span> _sqlConnectionFactory<span class="token punctuation">;</span> <span class="token keyword">public</span> <span class="token function">GetCustomerOrderDetialsQueryHandler</span><span class="token punctuation">(</span><span class="token class-name">ISqlConnectionFactory</span> sqlConnectionFactory<span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_sqlConnectionFactory <span class="token operator">=</span> sqlConnectionFactory<span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token keyword">public</span> <span class="token keyword">async</span> Task<span class="token operator"><</span>OrderDetailsDto<span class="token operator">></span> <span class="token function">Handle</span><span class="token punctuation">(</span><span class="token class-name">GetCustomerOrderDetailsQuery</span> request<span class="token punctuation">,</span> <span class="token class-name">CancellationToken</span> cancellationToken<span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">using</span> <span class="token punctuation">(</span><span class="token keyword">var</span> connection <span class="token operator">=</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_sqlConnectionFactory<span class="token punctuation">.</span><span class="token function">GetOpenConnection</span><span class="token punctuation">(</span><span class="token punctuation">)</span><span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">const</span> <span class="token keyword">string</span> sql <span class="token operator">=</span> <span class="token string">"SELECT "</span> <span class="token operator">+</span> <span class="token string">"[Order].[Id], "</span> <span class="token operator">+</span> <span class="token string">"[Order].[IsRemoved], "</span> <span class="token operator">+</span> <span class="token string">"[Order].[Value] "</span> <span class="token operator">+</span> <span class="token string">"FROM orders.v_Orders AS [Order] "</span> <span class="token operator">+</span> <span class="token string">"WHERE [Order].Id = @OrderId"</span><span class="token punctuation">;</span> <span class="token keyword">var</span> order <span class="token operator">=</span> <span class="token keyword">await</span> connection<span class="token punctuation">.</span><span class="token generic-method"><span class="token function">QuerySingleOrDefaultAsync</span><span class="token punctuation"><</span><span class="token class-name">OrderDetailsDto</span><span class="token punctuation">></span></span><span class="token punctuation">(</span>sql<span class="token punctuation">,</span> <span class="token keyword">new</span> <span class="token punctuation">{</span>request<span class="token punctuation">.</span>OrderId<span class="token punctuation">}</span><span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token keyword">const</span> <span class="token keyword">string</span> sqlProducts <span class="token operator">=</span> <span class="token string">"SELECT "</span> <span class="token operator">+</span> <span class="token string">"[Order].[ProductId] AS [Id], "</span> <span class="token operator">+</span> <span class="token string">"[Order].[Quantity], "</span> <span class="token operator">+</span> <span class="token string">"[Order].[Name] "</span> <span class="token operator">+</span> <span class="token string">"FROM orders.v_OrderProducts AS [Order] "</span> <span class="token operator">+</span> <span class="token string">"WHERE [Order].OrderId = @OrderId"</span><span class="token punctuation">;</span> <span class="token keyword">var</span> products <span class="token operator">=</span> <span class="token keyword">await</span> connection<span class="token punctuation">.</span><span class="token generic-method"><span class="token function">QueryAsync</span><span class="token punctuation"><</span><span class="token class-name">ProductDto</span><span class="token punctuation">></span></span><span class="token punctuation">(</span>sqlProducts<span class="token punctuation">,</span> <span class="token keyword">new</span> <span class="token punctuation">{</span> request<span class="token punctuation">.</span>OrderId <span class="token punctuation">}</span><span class="token punctuation">)</span><span class="token punctuation">;</span> order<span class="token punctuation">.</span>Products <span class="token operator">=</span> products<span class="token punctuation">.</span><span class="token function">AsList</span><span class="token punctuation">(</span><span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token keyword">return</span> order<span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token punctuation">}</span> <span class="token punctuation">}</span> |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 | <span class="token keyword">public</span> <span class="token keyword">class</span> <span class="token class-name">SqlConnectionFactory</span> <span class="token punctuation">:</span> <span class="token class-name">ISqlConnectionFactory</span><span class="token punctuation">,</span> IDisposable <span class="token punctuation">{</span> <span class="token keyword">private</span> <span class="token keyword">readonly</span> <span class="token keyword">string</span> _connectionString<span class="token punctuation">;</span> <span class="token keyword">private</span> <span class="token class-name">IDbConnection</span> _connection<span class="token punctuation">;</span> <span class="token keyword">public</span> <span class="token function">SqlConnectionFactory</span><span class="token punctuation">(</span><span class="token keyword">string</span> connectionString<span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_connectionString <span class="token operator">=</span> connectionString<span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token keyword">public</span> <span class="token class-name">IDbConnection</span> <span class="token function">GetOpenConnection</span><span class="token punctuation">(</span><span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">if</span> <span class="token punctuation">(</span><span class="token keyword">this</span><span class="token punctuation">.</span>_connection <span class="token operator">==</span> <span class="token keyword">null</span> <span class="token operator">||</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_connection<span class="token punctuation">.</span>State <span class="token operator">!=</span> ConnectionState<span class="token punctuation">.</span>Open<span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_connection <span class="token operator">=</span> <span class="token keyword">new</span> <span class="token class-name">SqlConnection</span><span class="token punctuation">(</span>_connectionString<span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_connection<span class="token punctuation">.</span><span class="token function">Open</span><span class="token punctuation">(</span><span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token keyword">return</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_connection<span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token keyword">public</span> <span class="token keyword">void</span> <span class="token function">Dispose</span><span class="token punctuation">(</span><span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">if</span> <span class="token punctuation">(</span><span class="token keyword">this</span><span class="token punctuation">.</span>_connection <span class="token operator">!=</span> <span class="token keyword">null</span> <span class="token operator">&&</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_connection<span class="token punctuation">.</span>State <span class="token operator">==</span> ConnectionState<span class="token punctuation">.</span>Open<span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_connection<span class="token punctuation">.</span><span class="token function">Dispose</span><span class="token punctuation">(</span><span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token punctuation">}</span> <span class="token punctuation">}</span> |
Điều trước tiên là mở kết nối cơ sở dữ liệu và để đạt được điều đó chúng ta sử dụng class SqlConnectionFactory. Đây là class được resolve bởi IoCContainer với HTTP request lifetime scope như vậy chúng ta chắc chắc rằng, chúng ta chỉ sử dụng một kết nối cơ sở dữ liệu trong khi xử ý request.
Điều thứ hai là chuẩn bị và thực thi các câu lệnh thuần SQL đối với cơ sở dữ liệu. Tôi cố gắng không tham chiếu các bảng trực tiếp và thay vào đó tham chiếu đến các view của cơ sở dữ liệu. Đây là một cách tốt để tạo ra abstraction và tách ứng dụng của chúng ta ra khỏi cấu trúc cơ sở dữ liệu (database schema) bởi vì tôi muốn ẩn đi bên trong cơ sở dữ liệu nhiều nhất có thể.
Về việc thực thi SQL tôi sử dụng thư viện nhỏ ORM Dapper bởi vì hầu hết nó nhanh như native ADO.NET và không có sẵn các API. Tóm lại, nó làm cái gì cần làm và nó làm rất tốt.
Write model
Biểu đồ bên dưới biểu diễn flow xử lý hoạt động ghi:
Việc xử lý yêu cầu ghi bắt đầu tương tự với với việc đọc nhưng chúng ta tạo Command object thay vì query object:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 | <span class="token comment">/// <summary></span> <span class="token comment">/// Add customer order.</span> <span class="token comment">/// </summary></span> <span class="token comment">/// <param name="customerId">Customer ID.</param></span> <span class="token comment">/// <param name="request">Products list.</param></span> <span class="token punctuation">[</span><span class="token class-name">Route</span><span class="token punctuation">(</span><span class="token string">"{customerId}/orders"</span><span class="token punctuation">)</span><span class="token punctuation">]</span> <span class="token punctuation">[</span><span class="token class-name">HttpPost</span><span class="token punctuation">]</span> <span class="token punctuation">[</span><span class="token class-name">ProducesResponseType</span><span class="token punctuation">(</span><span class="token punctuation">(</span><span class="token keyword">int</span><span class="token punctuation">)</span>HttpStatusCode<span class="token punctuation">.</span>Created<span class="token punctuation">)</span><span class="token punctuation">]</span> <span class="token keyword">public</span> <span class="token keyword">async</span> Task<span class="token operator"><</span>IActionResult<span class="token operator">></span> <span class="token function">AddCustomerOrder</span><span class="token punctuation">(</span> <span class="token punctuation">[</span><span class="token class-name">FromRoute</span><span class="token punctuation">]</span><span class="token class-name">Guid</span> customerId<span class="token punctuation">,</span> <span class="token punctuation">[</span><span class="token class-name">FromBody</span><span class="token punctuation">]</span><span class="token class-name">CustomerOrderRequest</span> request<span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">await</span> _mediator<span class="token punctuation">.</span><span class="token function">Send</span><span class="token punctuation">(</span><span class="token keyword">new</span> <span class="token class-name">AddCustomerOrderCommand</span><span class="token punctuation">(</span>customerId<span class="token punctuation">,</span> request<span class="token punctuation">.</span>Products<span class="token punctuation">)</span><span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token keyword">return</span> <span class="token function">Created</span><span class="token punctuation">(</span><span class="token keyword">string</span><span class="token punctuation">.</span>Empty<span class="token punctuation">,</span> <span class="token keyword">null</span><span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token punctuation">}</span> |
Tiếp theo, CommandHandler được triệu gọi:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 | <span class="token keyword">public</span> <span class="token keyword">class</span> <span class="token class-name">AddCustomerOrderCommandHandler</span> <span class="token punctuation">:</span> <span class="token class-name">IRequestHandler</span><span class="token operator"><</span>AddCustomerOrderCommand<span class="token operator">></span> <span class="token punctuation">{</span> <span class="token keyword">private</span> <span class="token keyword">readonly</span> <span class="token class-name">ICustomerRepository</span> _customerRepository<span class="token punctuation">;</span> <span class="token keyword">private</span> <span class="token keyword">readonly</span> <span class="token class-name">IProductRepository</span> _productRepository<span class="token punctuation">;</span> <span class="token keyword">public</span> <span class="token function">AddCustomerOrderCommandHandler</span><span class="token punctuation">(</span> <span class="token class-name">ICustomerRepository</span> customerRepository<span class="token punctuation">,</span> <span class="token class-name">IProductRepository</span> productRepository<span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_customerRepository <span class="token operator">=</span> customerRepository<span class="token punctuation">;</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_productRepository <span class="token operator">=</span> productRepository<span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token keyword">public</span> <span class="token keyword">async</span> Task<span class="token operator"><</span>Unit<span class="token operator">></span> <span class="token function">Handle</span><span class="token punctuation">(</span><span class="token class-name">AddCustomerOrderCommand</span> request<span class="token punctuation">,</span> <span class="token class-name">CancellationToken</span> cancellationToken<span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">var</span> customer <span class="token operator">=</span> <span class="token keyword">await</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_customerRepository<span class="token punctuation">.</span><span class="token function">GetByIdAsync</span><span class="token punctuation">(</span>request<span class="token punctuation">.</span>CustomerId<span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token keyword">var</span> selectedProducts <span class="token operator">=</span> request<span class="token punctuation">.</span>Products<span class="token punctuation">.</span><span class="token function">Select</span><span class="token punctuation">(</span>x <span class="token operator">=</span><span class="token operator">></span> <span class="token keyword">new</span> <span class="token class-name">OrderProduct</span><span class="token punctuation">(</span>x<span class="token punctuation">.</span>Id<span class="token punctuation">,</span> x<span class="token punctuation">.</span>Quantity<span class="token punctuation">)</span><span class="token punctuation">)</span><span class="token punctuation">.</span><span class="token function">ToList</span><span class="token punctuation">(</span><span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token keyword">var</span> allProducts <span class="token operator">=</span> <span class="token keyword">await</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_productRepository<span class="token punctuation">.</span><span class="token function">GetAllAsync</span><span class="token punctuation">(</span><span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token keyword">var</span> order <span class="token operator">=</span> <span class="token keyword">new</span> <span class="token class-name">Order</span><span class="token punctuation">(</span>selectedProducts<span class="token punctuation">,</span> allProducts<span class="token punctuation">)</span><span class="token punctuation">;</span> customer<span class="token punctuation">.</span><span class="token function">AddOrder</span><span class="token punctuation">(</span>order<span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token keyword">await</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_customerRepository<span class="token punctuation">.</span>UnitOfWork<span class="token punctuation">.</span><span class="token function">CommitAsync</span><span class="token punctuation">(</span>cancellationToken<span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token keyword">return</span> Unit<span class="token punctuation">.</span>Value<span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token punctuation">}</span> |
Command handler trông khác với Query handler. Ở đây, chúng ta sử dụng cấp độ cao hơn của abstraction, sử dụng cách tiếp cận DDD với Aggregates và Entities. Chúng ta cần nó là bởi vì trường hợp này những vấn đề cần giải quyết thường phức tạp hơn phía đọc dữ liệu. Command handler gọi phương thức tổng hợp, lưu các thay đổi vào cơ sở dữ liệu.
Customer aggregate được định nghĩa như sau:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 | <span class="token keyword">public</span> <span class="token keyword">class</span> <span class="token class-name">Customer</span> <span class="token punctuation">:</span> <span class="token class-name">Entity</span> <span class="token punctuation">{</span> <span class="token keyword">public</span> <span class="token class-name">Guid</span> Id <span class="token punctuation">{</span> <span class="token keyword">get</span><span class="token punctuation">;</span> <span class="token keyword">private</span> <span class="token keyword">set</span><span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token keyword">private</span> <span class="token keyword">readonly</span> List<span class="token operator"><</span>Order<span class="token operator">></span> _orders<span class="token punctuation">;</span> <span class="token keyword">private</span> <span class="token function">Customer</span><span class="token punctuation">(</span><span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_orders <span class="token operator">=</span> <span class="token keyword">new</span> <span class="token generic-method"><span class="token function">List</span><span class="token punctuation"><</span><span class="token class-name">Order</span><span class="token punctuation">></span></span><span class="token punctuation">(</span><span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token keyword">public</span> <span class="token keyword">void</span> <span class="token function">AddOrder</span><span class="token punctuation">(</span><span class="token class-name">Order</span> order<span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_orders<span class="token punctuation">.</span><span class="token function">Add</span><span class="token punctuation">(</span>order<span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token keyword">this</span><span class="token punctuation">.</span><span class="token function">AddDomainEvent</span><span class="token punctuation">(</span><span class="token keyword">new</span> <span class="token class-name">OrderAddedEvent</span><span class="token punctuation">(</span>order<span class="token punctuation">)</span><span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token keyword">public</span> <span class="token keyword">void</span> <span class="token function">ChangeOrder</span><span class="token punctuation">(</span><span class="token class-name">Guid</span> orderId<span class="token punctuation">,</span> List<span class="token operator"><</span>OrderProduct<span class="token operator">></span> products<span class="token punctuation">,</span> IReadOnlyCollection<span class="token operator"><</span>Product<span class="token operator">></span> allProducts<span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">var</span> order <span class="token operator">=</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_orders<span class="token punctuation">.</span><span class="token function">Single</span><span class="token punctuation">(</span>x <span class="token operator">=</span><span class="token operator">></span> x<span class="token punctuation">.</span>Id <span class="token operator">==</span> orderId<span class="token punctuation">)</span><span class="token punctuation">;</span> order<span class="token punctuation">.</span><span class="token function">Change</span><span class="token punctuation">(</span>products<span class="token punctuation">,</span> allProducts<span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token keyword">this</span><span class="token punctuation">.</span><span class="token function">AddDomainEvent</span><span class="token punctuation">(</span><span class="token keyword">new</span> <span class="token class-name">OrderChangedEvent</span><span class="token punctuation">(</span>order<span class="token punctuation">)</span><span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token keyword">public</span> <span class="token keyword">void</span> <span class="token function">RemoveOrder</span><span class="token punctuation">(</span><span class="token class-name">Guid</span> orderId<span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">var</span> order <span class="token operator">=</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_orders<span class="token punctuation">.</span><span class="token function">Single</span><span class="token punctuation">(</span>x <span class="token operator">=</span><span class="token operator">></span> x<span class="token punctuation">.</span>Id <span class="token operator">==</span> orderId<span class="token punctuation">)</span><span class="token punctuation">;</span> order<span class="token punctuation">.</span><span class="token function">Remove</span><span class="token punctuation">(</span><span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token keyword">this</span><span class="token punctuation">.</span><span class="token function">AddDomainEvent</span><span class="token punctuation">(</span><span class="token keyword">new</span> <span class="token class-name">OrderRemovedEvent</span><span class="token punctuation">(</span>order<span class="token punctuation">)</span><span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token punctuation">}</span> |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 | <span class="token keyword">public</span> <span class="token keyword">class</span> <span class="token class-name">Order</span> <span class="token punctuation">:</span> <span class="token class-name">Entity</span> <span class="token punctuation">{</span> <span class="token keyword">public</span> <span class="token class-name">Guid</span> Id <span class="token punctuation">{</span> <span class="token keyword">get</span><span class="token punctuation">;</span> <span class="token keyword">private</span> <span class="token keyword">set</span><span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token keyword">private</span> <span class="token keyword">bool</span> _isRemoved<span class="token punctuation">;</span> <span class="token keyword">private</span> <span class="token keyword">decimal</span> _value<span class="token punctuation">;</span> <span class="token keyword">private</span> List<span class="token operator"><</span>OrderProduct<span class="token operator">></span> _orderProducts<span class="token punctuation">;</span> <span class="token keyword">private</span> <span class="token function">Order</span><span class="token punctuation">(</span><span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_orderProducts <span class="token operator">=</span> <span class="token keyword">new</span> <span class="token generic-method"><span class="token function">List</span><span class="token punctuation"><</span><span class="token class-name">OrderProduct</span><span class="token punctuation">></span></span><span class="token punctuation">(</span><span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_isRemoved <span class="token operator">=</span> <span class="token keyword">false</span><span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token keyword">public</span> <span class="token function">Order</span><span class="token punctuation">(</span>List<span class="token operator"><</span>OrderProduct<span class="token operator">></span> orderProducts<span class="token punctuation">,</span> IReadOnlyCollection<span class="token operator"><</span>Product<span class="token operator">></span> allProducts<span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">this</span><span class="token punctuation">.</span>Id <span class="token operator">=</span> Guid<span class="token punctuation">.</span><span class="token function">NewGuid</span><span class="token punctuation">(</span><span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_orderProducts <span class="token operator">=</span> orderProducts<span class="token punctuation">;</span> <span class="token keyword">this</span><span class="token punctuation">.</span><span class="token function">CalculateOrderValue</span><span class="token punctuation">(</span>allProducts<span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token keyword">internal</span> <span class="token keyword">void</span> <span class="token function">Change</span><span class="token punctuation">(</span>List<span class="token operator"><</span>OrderProduct<span class="token operator">></span> products<span class="token punctuation">,</span> IReadOnlyCollection<span class="token operator"><</span>Product<span class="token operator">></span> allProducts<span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">foreach</span> <span class="token punctuation">(</span><span class="token keyword">var</span> product <span class="token keyword">in</span> products<span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">var</span> orderProduct <span class="token operator">=</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_orderProducts<span class="token punctuation">.</span><span class="token function">SingleOrDefault</span><span class="token punctuation">(</span>x <span class="token operator">=</span><span class="token operator">></span> x<span class="token punctuation">.</span>ProductId <span class="token operator">==</span> product<span class="token punctuation">.</span>ProductId<span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token keyword">if</span> <span class="token punctuation">(</span>orderProduct <span class="token operator">!=</span> <span class="token keyword">null</span><span class="token punctuation">)</span> <span class="token punctuation">{</span> orderProduct<span class="token punctuation">.</span><span class="token function">ChangeQuantity</span><span class="token punctuation">(</span>product<span class="token punctuation">.</span>Quantity<span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token keyword">else</span> <span class="token punctuation">{</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_orderProducts<span class="token punctuation">.</span><span class="token function">Add</span><span class="token punctuation">(</span>product<span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token punctuation">}</span> <span class="token keyword">var</span> existingProducts <span class="token operator">=</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_orderProducts<span class="token punctuation">.</span><span class="token function">ToList</span><span class="token punctuation">(</span><span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token keyword">foreach</span> <span class="token punctuation">(</span><span class="token keyword">var</span> existingProduct <span class="token keyword">in</span> existingProducts<span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">var</span> product <span class="token operator">=</span> products<span class="token punctuation">.</span><span class="token function">SingleOrDefault</span><span class="token punctuation">(</span>x <span class="token operator">=</span><span class="token operator">></span> x<span class="token punctuation">.</span>ProductId <span class="token operator">==</span> existingProduct<span class="token punctuation">.</span>ProductId<span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token keyword">if</span> <span class="token punctuation">(</span>product <span class="token operator">==</span> <span class="token keyword">null</span><span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_orderProducts<span class="token punctuation">.</span><span class="token function">Remove</span><span class="token punctuation">(</span>existingProduct<span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token punctuation">}</span> <span class="token keyword">this</span><span class="token punctuation">.</span><span class="token function">CalculateOrderValue</span><span class="token punctuation">(</span>allProducts<span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token keyword">internal</span> <span class="token keyword">void</span> <span class="token function">Remove</span><span class="token punctuation">(</span><span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_isRemoved <span class="token operator">=</span> <span class="token keyword">true</span><span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token keyword">private</span> <span class="token keyword">void</span> <span class="token function">CalculateOrderValue</span><span class="token punctuation">(</span>IReadOnlyCollection<span class="token operator"><</span>Product<span class="token operator">></span> allProducts<span class="token punctuation">)</span> <span class="token punctuation">{</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_value <span class="token operator">=</span> <span class="token keyword">this</span><span class="token punctuation">.</span>_orderProducts<span class="token punctuation">.</span><span class="token function">Sum</span><span class="token punctuation">(</span>x <span class="token operator">=</span><span class="token operator">></span> x<span class="token punctuation">.</span>Quantity <span class="token operator">*</span> allProducts<span class="token punctuation">.</span><span class="token function">Single</span><span class="token punctuation">(</span>y <span class="token operator">=</span><span class="token operator">></span> y<span class="token punctuation">.</span>Id <span class="token operator">==</span> x<span class="token punctuation">.</span>ProductId<span class="token punctuation">)</span><span class="token punctuation">.</span>Price<span class="token punctuation">)</span><span class="token punctuation">;</span> <span class="token punctuation">}</span> <span class="token punctuation">}</span> |
Kiến trúc
Cấu trúc Solution được thiết kế dựa trên Onion Architecture nổi tiếp như hình bên dưới:
Có 3 projects được định nghĩa:
- API project với API endpoints và logic ứng dụng (command và query handlers) sử dụng cách tiếp cận Feature Folders
- Domain project với Domain Model
- Infrastructure project – tích hợp với cơ sở dữ liệu.
Tổng kết
Trong bài viết này tôi đã cố gắng trình bày cách đơn giản nhất để triển khai CQRS pattern sử dụng thuần SQL để xử lý bên Read model và cách tiếp cận DDD cho việc triển khai phía Write Model. Làm như vậy chúng ta có thể đạt được nhiều hơn việc chia tách của các mối quan tâm mà không làm mất đi tốc độ của việc phát triển. Chi phí cho giải pháp này là rất thấp và nó trả lại kết quả rất nhanh chóng.
Tôi không miêu tả triển khai DDD một cách chi tiết, như vậy tôi khuyên các bạn một lần nữa xem lại source code ứng dụng demo và có thể sử dụng nó như một phần khởi đầu ứng dụng của bạn.
Cảm ơn các bạn đã chú ý theo dõi.
Bài viết được dịch từ nguồn:
http://www.kamilgrzybek.com/design/simple-cqrs-implementation-with-raw-sql-and-ddd/