並行モデル

例：出荷時間クエリ（C＃）

この例は、イベントソーシング用に開発した、出荷、貨物、およびポートの単純な例に基づいています。結果として、この例を深く掘り下げる前に、その例に精通しておく必要があります。ドメインロジックコードはほぼ同じです。

図1：出荷例のドメインオブジェクト。

並行モデルの複雑さの多くは、一時的な並行モデルとアクティブなデータベースの操作に関するものであるため、この例にデータベースを導入しました。データベースへのマッピングには、一般的なNHibernateオブジェクトリレーショナルマッパーを使用しています。実際にはあまり面白くないマッピングの詳細については説明しません。代わりに、リポジトリによってどのようにラップされ、並行モデルのリポジトリとどのように交換されるかに焦点を当てます。

ベースの例と同様に、ドメインモデルへのすべての変更はイベントによって処理されます。船が港に到着すると、到着イベントによって記録されます。

class ArrivalEvent...

  string _port;
  int _ship;  
  internal ArrivalEvent (DateTime occurred, string port, int ship) : base (occurred) {
    this._port = port;
    this._ship = ship;
  } 
  internal Port Port {get {return Port.Find(_port);}}
  internal Ship Ship {get {return Ship.Find(_ship);}}
  
  internal override void Process() {
    Ship.HandleArrival(this);
  }

ベースの例との違いは、この場合、ポートと船は識別子として単純な値で示されていることです。この値は、データベース内の主キーに対応していますが、任意のキーを使用できます。ただし、プロパティは実際のドメインオブジェクトを利用します。常に正しいドメインオブジェクトを取得するために、ドメインオブジェクトクラスで定義されたファインダーメソッドを使用してデータベースからドメインオブジェクトをプルします。

class Port...

  public static Port Find(string s) {
    return (Port) Registry.DB.Find(typeof (Port), s);
  }

ファインダーメソッドは、リポジトリに委任します。ベースケースでは、このリポジトリはNHibernateによってマッピングされたドメインオブジェクトを含むデータベースです。したがって、リポジトリコードはNHibernate APIを使用して、データベース（またはNHibernateのキャッシュ）からオブジェクトをプルします。

class DB...

  public object Find(Type type, object key) {
    return _hibernateSession.Load(type, key);
  }

データマッパーに基づいたほとんどのデータソースと同様に、NHibernateはUnit of Workを使用して、操作するオブジェクトを追跡します。結果として、オブジェクトにデータベースに保存するように指示することはありません。代わりに、Unit of Workをコミットすると、メモリ内でどのオブジェクトが変更されたか、およびそれらをどのように書き出すかを把握します。

この例では、イベントプロセッサでこのトランザクションラッピングを実行します。イベントプロセッサは次のようになります。

class EventProcessor...

  public void Process(DomainEvent e) {
    Registry.DB.BeginTransaction();
    try {
      e.Process();
      InsertToLog(e);
      Registry.DB.Commit();
    } catch (Exception ex) {
      Registry.DB.Rollback();
      LogFailedEvent(e, ex);
    }
  }

これは、Unit of Workをラップするのに常に最適な場所であるとは限りません。それはアプリケーションの性質に依存します。しかし、これは私の例では十分に機能し、また、一時的なクエリを処理するために永続的なリポジトリを簡単に切り替える方法という問題も提示します。

テストケースを通じてこれを見てみましょう

class Tester...

  [Test] 
  public void TemporalQueryForShipsLocation() {
    eProc.Process(new ArrivalEvent(new DateTime(2005,11,2), la, kr));
    eProc.Process(new DepartureEvent(new DateTime(2005,11,5), la, kr ));
    eProc.Process(new ArrivalEvent(new DateTime(2005,11,6), sfo, kr));
    Assert.AreEqual(sfo, Ship.Find(kr).Port.Code);
    eProc.SetToEnd(new DateTime(2005,11,2));
    Assert.AreEqual(la, Ship.Find(kr).Port.Code);
  }

ここでの重要なメソッドはSetToEndです。このメソッドは、インメモリリポジトリを使用するようにリポジトリを変更し、イベントログを再処理して、その日の最後のイベントまでイベントが再生されるようにします。これにより、11月2日の並行モデルが作成されます。

class EventProcessor...

  IList log;
  public void SetToEnd(DateTime date) {
    SynchronizeLog();
    IRepository temporalRepository = new MemoryDB();
    Registry.enableAlternateRepository(temporalRepository);
    foreach (DomainEvent e in log) {
      if (e.Occurred > date) return;
      e.Process();
    }
  }

時間クエリを実行するために、プロセッサはデータベースから完全に切り離されます。この場合、プロセッサはイベントログの独自のコピーを保持します。データベースから離れる前に、データベースに書き込まれたすべてのイベントの完全な記録を持つように、そのログを永続的なログと同期します。

ログが同期されたら、完全にインメモリである新しいリポジトリを作成します。これは、SQLを引き続き使用できるようにする埋め込みインメモリデータベースによってバックアップできます。また、リポジトリインターフェイスを満たす手書きのものにすることもできます。これは非常に単純な例なので、ハッシュテーブルをいくつか使用しました。

class MemoryDB...

  public object Find(Type type, object key) {
    object result = this[type][key];
    if (null == result) 
      throw new ApplicationException ("unable to find: " + key.ToString());
    return result;
  }
  private IDictionary store = new Hashtable();
  private IDictionary this[Type index] {get {return (IDictionary)store[index];}}

インメモリリポジトリは、イベントを処理する前のデータベースと同じ初期状態（この場合はポートと船の参照データを保持）に初期化する必要があります。

class MemoryDB...

  public void Initialize() {
    store[typeof(Ship)] = new Hashtable();
    store[typeof(Cargo)] = new Hashtable();
    store[typeof(Port)] = new Hashtable();
    Insert(new Port("SFO", "San Francisco", "US"));
    Insert(new Port("LAX", "Los Angeles", "US"));
    Insert(new Port("YVR", "Vancouver", "CA"));
    Insert (new Port("XXX", "out to sea", "XX"));
    Insert(new Ship("King Roy", 1));
  }

一時リポジトリを設定したら、レジストリに実際のリポジトリの代わりに使用を開始するように指示します。

class Registry...

  internal static void enableAlternateRepository(IRepository arg) {
    instance._repository = arg;
    arg.Initialize();
  }

これで、ドメインモデル内のレジストリへのすべての呼び出しで、インメモリレジストリが使用されます。この設計では、NHibernateが通常データベースリポジトリ内に配置されるため、並行モデルにはhibernateをまったく使用しません。オブジェクトはメモリに表示され、リポジトリによってそこに保持されます。

インメモリリポジトリがセットアップされたら、ログから、対象日以前に発生したすべてのイベントを順番に処理します。完了すると、リクエストされた日の終わり時点での世界の状態を表すインメモリリポジトリが作成されます。ドメインオブジェクトに対するクエリは、その日付を反映します。

通常のデータベースに戻すには、一時的なインメモリリポジトリを通常のリポジトリ接続と入れ替えるだけです。

class Registry...

  internal static void restoreBaseRepository() {
    instance._repository = instance._baseRepository;
  }

例：ベースモデルとの比較（C#）

パラレルモデルの多くの用途では、一度に1つのモデルのみを操作します。更新を含む一般的な処理はベースモデルで行い、履歴クエリや仮説クエリ用のパラレルモデルを構築します。常に1つのパラレルモデルのみが使用されます。このスキームは比較的シンプルで、多くのSFプロットを悩ませるパラレルユニバース間の同一性に関する問題を回避します。

しかし、2つを組み合わせることが理にかなう場合もあります。出荷の例のつまらないユーモアを覚えていれば、書籍販売業者がカナダを非常に恐れており、「eh」でテキストを汚染するリスクがあることを知っているでしょう。時々、特に厄介な「eh」の感染が発生すると想像してみましょう。そのような感染が発生した港に停泊している船の貨物は、高リスクとしてマークする必要があります。もちろん、このようなことは当日には判明しないため、その日に港に何があったかを把握する必要があります。

この問題を表現するためのテストケースを以下に示します。

class Tester...

  [Test]
  public void HighRiskDayFlagsAllCargo() {
    eProc.Process(new RegisterCargoEvent(new DateTime(2005,1,1), "UML Distilled", "UML", "LAX" ));
    eProc.Process(new RegisterCargoEvent(new DateTime(2005,1,1), "Planning XP", "PXP", "LAX" ));
    eProc.Process(new RegisterCargoEvent(new DateTime(2005,1,1), "Analysis Patterns", "AP", "LAX" ));
    eProc.Process(new RegisterCargoEvent(new DateTime(2005,1,1), "P of EAA", "eaa", "LAX" ));
    eProc.Process(new ArrivalEvent(new DateTime(2005,11,2), la, kr));
    eProc.Process(new LoadEvent(new DateTime(2005,5,11),"PXP", 1));
    eProc.Process(new LoadEvent(new DateTime(2005,5,11),"AP", 1));
    eProc.Process(new ArrivalEvent(new DateTime(2005,11,9), yvr, kr));
    eProc.Process(new ArrivalEvent(new DateTime(2005,11,12), la, kr));
    eProc.Process(new ContagionEvent(new DateTime(2005,11,10), yvr));
    Assert.IsTrue(Cargo.Find("PXP").IsHighRisk, "PXP should be high risk");
    Assert.IsTrue(Cargo.Find("AP").IsHighRisk, "AP should be high risk");
    Assert.IsFalse(Cargo.Find("UML").IsHighRisk, "UML should NOT be high risk");
    Assert.IsFalse(Cargo.Find("eaa").IsHighRisk, "UML should NOT be high risk");
    Assert.IsFalse(Cargo.Find(refact).IsHighRisk, "UML should NOT be high risk");
  }

新しいイベントで感染症を記述します。

class ContagionEvent...

  internal class ContagionEvent : DomainEvent
  {
    string _portID;
    public ContagionEvent(DateTime occurred, string port) : base(occurred) {
      this._portID = port;
    }
    Port Port {get {return Port.Find(_portID);}}

internal override void Process() {
  Registry.EventProcessor.SetToEnd(Occurred);
  ArrayList infectedCargos = new ArrayList();
  foreach (Ship s in Port.Ships) infectedCargos.AddRange(s.Cargos);
  Registry.restoreBaseRepository();
  foreach (Cargo c in infectedCargos) {
    Cargo actualCargo = Cargo.Find(c.RegistrationCode);
    actualCargo.IsHighRisk = true;
  }
}

この場合、イベントのprocessメソッドにかなり多くの動作があることに気づくでしょう。これは、ドメインモデルをパラレルモデルについて知らないようにしたいと考えたためです。したがって、イベントは感染の日付のための一時的なパラレルモデルを作成し、影響を受ける貨物を調べるクエリを実行し、世界をベースモデルに戻し、更新を渡す必要があります。ドメインモデルは、各パラレルモデル内でロジックを実行しますが、それほど多くはありません。

真剣に検討すべきもう1つの方法は、貨物を高リスクとしてマークするための新しいイベントを作成することです。この場合、感染イベントは一時的なパラレルモデルで影響を受ける貨物を見つけ、これらの貨物を高リスクとしてマークするイベントを作成します。この2番目のイベントはベース状態で実行されます。これを書いている時点では、どちらのアプローチが適切か確信がありません。