ラピッド開発フレームワークのコーディング（パート2 CQRS）

プレストーリー

特効薬？

誰かがCQRSについて聞いたことがありますか？

ああ、いくつの抽象化が便利か（過去の意見）

• ソースコードの「膨張」、問題は、多くの場合、ファサード層、通信層などのタイ層の追加が原因で発生します。
• 複数のレイヤーレベルの背後に詳細を非表示にします。

• 密接に関連するメソッドのサポートと拡張
• 大きなオブジェクトでテストするのは難しい

public interface IUserService { void Add(string name); void Delete(string id); List<User> Fetch(Criteries criteries); }
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

1. VCS（バージョン管理システム）の競合が少ない
2. クラス検索はメソッドよりも簡単です
3. UserServiceを部分的に分割する必要がなくなりました。1つをナビゲートするのが難しいためです）
4. コマンドとクエリから形成されたバグトラッカーの問題
5. アジャイルのスプリントは、コマンドとクエリから形成されます
6. 小さなオブジェクトのテスト

私たちの実装

ディスパッチャー

• プッシュ-コマンドを実行します
• クエリ-クエリを実行します

 public ActionResult Test() { var dispatcher = IoCFactory.Instance.TryResolve<IDispatcher>(); var id = dispatcher.Query(new GetIdQuery()); dispatcher.Push(new DeleteEntityByIdCommand(id)); return something ActionResult; }
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

 new DeactivateEntityCommand().Execute(); // without transaction and connection dispatcher.Push(new DeactivateEntityCommand()); // open transaction and connection
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

メッセージ

• コマンド-ReadCommitted
• クエリ-ReadUncommitted（読み取り専用）

 Repository.Save(new entity())
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

 Repository.GetById<TEntity>(id); Repository.Query(whereSpecification: spec, orderSpecification:spec, paginatedSpecification:spec)
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

 var entityFromDb = Repository.GetById<TEntity>(id); entityFromDb.Title = "New title"; // tracking
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

 Repository.Delete<TEntity>(id);
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

 public class OnAuditEvent : IEvent { public string Message { get; set; } }
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

 public class AuditSubscriber : IEventSubscriber<OnAuditEvent> { readonly IRepository repository; public AuditSubscriber(IRepository repository) { this.repository = repository; } public void Subscribe(OnAuditEvent @event) { this.repository.Save(new Audit { Message = @event.Message }); } public void Dispose() { } }
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

 EventBroker.Publish(new OnAuditEvent { Message = "New product {0} by {1}".F(Title, Price) });
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

問い合わせ

 public class GetProductsQuery : QueryBase<List<GetProductsQuery.Response>> { public class Response { public string Title { get; set; } public string Price { get; set; } } public string Title { get; set; } public decimal? From { get; set; } public decimal? To { get; set; } protected override List<Response> ExecuteResult() { return Repository.Query(whereSpecification: new ProductByTitleWhere(this.Title) .And(new ProductBetweenPriceWhere(this.From, this.To))) .Select(product => new Response { Title = product.Title, Price = product.Price.ToString("C") }) .ToList(); } }
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

 return Repository.Query<Product>();
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

 dispatcher.Query(new GetProductsQuery()) .Select(r=> new { Amount = r.Orders.Sum(r=>r.Price))
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

コマンド

 public class AddProductCommand : CommandBase { public string Title { get; set; } public decimal Price { get; set; } public override void Execute() { var product = new Product { Title = Title, Price = Price } Repository.Save(product); Result = product.Id; } }
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

キリング機能

コンポジット

 public ActionResult Save(Step1Command step1,Step2Command step2,Step3Command step3) { dispatcher.Push(composite => { composite.Quote(step1); composite.Quote(step2); composite.Quote(step3); }); return IncodingResult.Success(); }
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

 public ActionResult Save(Step1Command step1,Step2Command step2,Step3Command step3) { dispatcher.Push(composite => { composite.Quote(step1,new MessageExecuteSetting { OnAfter = () => { step2.Id = step1.Result; step3.Id = step1.Result; } }); composite.Quote(step2); composite.Quote(step3);}); }
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

ホットスワップ接続文字列

 dispatcher.Query(query, new MessageExecuteSetting { Connection = new SqlConnection(currentConnectionString) });
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

レガシーシステム

 dispatcher.Query(query, new MessageExecuteSetting { DataBaseInstance = "Instance 2" });
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

おわりに