Oracle TopLink Grid Coherenceの読取り構成

2.1 読取りオブジェクト

Coherenceの読取り構成では、エンティティの読取り問合せはすべてCoherenceのキャッシュへ送られます。 問合せの処理時間を削減するため、TopLink Gridは、データ・グリッド全体で問合せの並列処理をサポートします。 Coherenceにはオブジェクト形式のデータが含まれており、データベースとの通信やオブジェクト構築で発生するやり取りを削減します。

たとえば、主キーベースのJPQL問合せとともに EntityManager.find（主キーベース）を実行すると、 適切なCoherenceのキャッシュを取得できます。 任意のJPQL問合せ（動的または名前付きの問合せ）は関連するCoherenceのフィルタへ変換され、フィルタに適合するオブジェクトを取得するため に使用されます。

読取りは、Coherenceのキャッシュのオブジェクトのみに実行されます。そのため、 CacheLoaderの構成 は非定型の問合せ処理に影響を与えることはありません。つまり、データベースへの問合せはおこなわれません。 ただし、問合せ単位であれば、以下の例に示す oracle.eclipselink.coherence.integrated.querying.IgnoreDefaultRedirectorク ラスを使って、Coherenceではなくデータベースへ直接問合せを送ることも可能です。

query.setHint(QueryHints.QUERY_REDIRECTOR, new IgnoreDefaultRedirector());
            


          

データベース問合せで取得したすべてのオブジェクトは、次の問合せで利用できるようCoherenceに追加されます。 この構成はデフォルトで、Coherenceを介してエンティティのすべての問合せを解決します。そのため、Coherenceのキャッシュはすべての問 合せ対象のデータによってウォーミングする必要があります。

CacheStoreには、Coherenceの読取り構成との互換性はありません。これは、EclipseLinkが すべてのデータベース更新を実行し、更新オブジェクトをCoherenceへ伝播するからです。 CacheStoreを使 用すると、Coherenceは書き込まれたばかりのオブジェクトを再度書き込もうとしてしまいます。

2.2 書込みオブジェクト

Coherenceの読取り構成では、TopLinkがデータベースのすべての書込み（挿入、更新、削除）を実行します。 そのあと、Coherenceのキャッシュはデータベースへの変更を反映するよう更新されます。 TopLinkは、大量のデータを書き込む際にいくつかのパフォーマンス機能を提供します。 たとえばバッチの書込み、パラメータのバインド、ストアド・プロシージャのサポート、および文の命令があり、データベースの制約に合致することを保証しま す。

このアプローチは、2つの長所をいずれも生かすことができます。 1つはデータベースの更新が効率的に実行されること、 そしてもう1つはCoherenceのデータ・グリッド全体に対して問合せを並列実行できることです。後 者では、データベースに個々の問合せを直接送ることもできます。

3.1 IDによるオブジェクトの問合せ

Coherenceから特定のID（キー）を使ってオブジェクトを取得する場合、 em.find(Entity.class, ID)を使用します。 ここでは、特定のIDをもった従業員を検索します。

private Employee employeeFind(EntityManager em, int id) {
            


  Employee employee =  null;
            


    employee = em.find(Employee.class, id);
            


  return employee;}
            


          

たとえば、 em.find(Employee.class, 8)は 8と いうキーをもったオブジェクトをCoherence Employeeのキャッシュから取得しま す。

キャッシュに指定されたIDが含まれていない場合は、データベースにオブジェクトがあるかを問い合わせるよう、Coherenceの CacheLoaderを 構成することもできます。

3.2 条件によるオブジェクトの問合せ

Coherenceから特定の選択条件に一致するオブジェクトを取得する場合、 em.createQuery("...")を 使用します。ここでは、特定の名前をもつ従業員を検索します。

private Employee employeeFind(EntityManager em, String name) {
            


  Employee employee =  null;
            


  employee = (Employee)em.createQuery("select e from Employee e where e.name = :name").setParameter("name", name).getSingleResult();
            


  return employee;
            


}
            


          

たとえば、 em.createQuery("select e from Employee e where e.name='John'")は、Coherenceの Employeeキャッ シュから Johnという 名前のオブジェクト を取得します。

3.3 オブジェクトの永続化

データベースにオブジェクトを挿入してからCoherenceキャッシュ内のオブジェクトと置き換えるには、 em.persist(Object)を 使用します。 ここでは、新しい従業員を追加します。

private void employeeAdd(EntityManager em, String name) {
            


  Employee employee = new Employee(name);
            


  em.getTransaction().begin();
            


  em.persist(employee);
            


  em.getTransaction().commit();
            


}
            


          

たとえば、サンプルの employeeAddメソッドをパラメータの John( employeeAdd(em, "John"))で呼び出すと、コミット時にTopLinkは INSERT文を実行し、データベースにオブジェ クトの Johnを追加します。 そのあと、Coherenceキャッシュ内にある主キー下でオブジェクトが置き換えられます。

3.4 オブジェクトの更新

データベースにオブジェクトを更新してからCoherenceキャッシュ内に更新オブジェクトを挿入するには、 em.merge(Object)を 使用します。 ここでは、特定のIDをもつ従業員を検索し、従業員の名前を変更します。

private void employeeRename(EntityManager em, int id, String newName) {
            


  Employee employee = employeeFind(em, id);
            


  if (employee != null) {
            


    em.getTransaction().begin();
            


    employee.setName(newName);
            


    em.merge(employee);
            


    em.getTransaction().commit();   
            


  }
            


}
            


          

たとえば、サンプルの employeeRename(em, 8, "John")メソッドを呼び出すと、 TopLinkは 8のIDをもつオブジェクトのためにデータベースに対してUPDATE文を実行 し、従業員の名前を Johnに変更します。 コミット・トランザクションが成功すると、更新されたオブジェクトはCoherenceキャッシュ内にある主キー下にて、古いオブジェクトと置き換えられ ます。