Oracle TopLink Grid： Oracle Coherenceの読取り/書込み構成

2.1 読取りオブジェクト

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

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

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

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


          

データベース問合せで取得したすべてのオブジェクトは、次の問合せで利用できるようCoherenceに追加されます。 この構成は、Coherenceを介してエンティティのすべての問合せを解決します。そのため、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ま たは CacheStoreを構成することもできます。

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

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

private Employee employeeFind(EntityManager em, String name) {
            


  Employee employee =  null;
            


  employee = (Employee)em.createQuery("select p from Employee p where p.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)を使用しま す。 コミット時に、TopLinkは主キー下でCoherenceのキャッシュ内のオブジェクトを置き換えます。 ここでは、新しい従業員を追加します。

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は主キー下で新規Employeeオブジェクトの Johnを追加します。

CacheStoreが Employeeクラス向けに構成されて いる場合、TopLinkは INSERT文を実行してデータベースにオブジェクトを追加します。

3.4 オブジェクトの更新

オブジェクトを更新するには、Java Persistence APIを使用します。 トランザクションでは、エンティティに対して問合せや修正をおこなうか、分離されたエンティティ同士をマージできます。 トランザクションをコミットすると変更が適用され、Coherence内に更新オブジェクトが挿入されます。

この例では分離された従業員の名前を変更し、永続化コンテンツへ戻して統合します（ここでは簡潔を優先してエラー・チェックは省略します）。 トランザクションがコミットされると、Coherenceは更新されます。

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


  Employee employee = employeeFind(em, id);
            


  employee.setName(newName);
            


  em.getTransaction().begin();
            


  em.merge(employee);
            


  em.getTransaction().commit();
            


  }
            


          

この例では、管理された従業員の名前を変更しました（ここでも同様に簡潔さを優先してエラー・チェックは省略します）。 トランザクションがコミットされると、Coherenceは更新されます。

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


  em.getTransaction().begin();
            


  Employee employee = employeeFind(em, id);
            


  employee.setName(newName);
            


  em.getTransaction().commit();
            


  }
            


          

たとえば、サンプルの employeeRename(em, 8, "John")メソッドでいずれかを呼び出すと、 TopLinkは主キー下でCoherenceのキャッシュ内に更新オブジェクトを挿入し、古いオブジェクトと置き換えます。

CacheStoreが Employeeクラス向けに構成されて いる場合、TopLinkは UPDATE文を実行してデータベースにオブジェクトを追加します。