1

私は現在、現在の非常に醜い jdbc データベース アクセスの代替手段として JPA/Eclipselink を評価しています。状況は次のとおりです。

複数のクライアントが同じデータベースにアクセスし、場合によっては同じデータを編集します。このデータは定期的に更新し、短期間だけキャッシュする必要があります。私の理解から、 @Cache アノテーションはまさにそれを行うべきです。

次のコードは、Vogella の jpa/eclipselink に基づいています。

@Entity
@Cache(expiry = 100)
public class Todo {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    private String summary;
    private String description;
... getter/setter/toString omited
}

public static void main(String[] args) throws InterruptedException {
        EntityManagerFactory factory =
                Persistence.createEntityManagerFactory("mysql");
        EntityManager em = factory.createEntityManager();

        TypedQuery<Todo> q = em.createQuery("SELECT t FROM Todo t", Todo.class);

        List<Todo> todoList = q.getResultList();
        System.out.println("Query 1 read");
        for (int i = 0; i < todoList.size(); i++) {
            System.out.println("1: " + todoList.get(i));
        }

        Thread.sleep(30000);

        TypedQuery<Todo> q2 =
                em.createQuery("SELECT t FROM Todo t", Todo.class);
        // q2.setHint("javax.persistence.cache.storeMode", "REFRESH");

        List<Todo> todoList2 = q2.getResultList();
        System.out.println("Query 2 read");

        for (int i = 0; i < todoList.size(); i++) {
            System.out.println("1: " + todoList.get(i));
            System.out.println("2: " + todoList2.get(i));
            System.out.println(todoList.get(i) == todoList2.get(i));
        }
    }

<?xml version="1.0" encoding="UTF-8"?>
<persistence version="2.0"
    xmlns="http://java.sun.com/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd">


    <persistence-unit name="mysql" transaction-type="RESOURCE_LOCAL">
        <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>
        <exclude-unlisted-classes>false</exclude-unlisted-classes>
        <properties>
            <property name="javax.persistence.jdbc.password" value="" />
            <property name="javax.persistence.jdbc.user" value="root" />
            <property name="javax.persistence.jdbc.driver" value="com.mysql.jdbc.Driver" />
            <property name="javax.persistence.jdbc.url" value="jdbc:mysql://localhost:3306/test" />
            <property name="javax.persistence.ddl-generation" value="create-tables" />
            <property name="javax.persistence.logging.level" value="ALL" />
            <property name="eclipselink.logging.level" value="ALL"/>
        </properties>
    </persistence-unit>
</persistence>

プログラムを実行すると、次の出力が生成されます。

...
[EL Finest]: query: 2013-06-19 14:30:55.897--UnitOfWork(31211079)--Thread(Thread[main,5,main])--Execute query ReadAllQuery(referenceClass=Todo sql="SELECT ID, DESCRIPTION, SUMMARY FROM TODO")
[EL Finest]: connection: 2013-06-19 14:30:55.907--ServerSession(7427424)--Connection(7633596)--Thread(Thread[main,5,main])--Connection acquired from connection pool [default].
[EL Fine]: sql: 2013-06-19 14:30:55.907--ServerSession(7427424)--Connection(7633596)--Thread(Thread[main,5,main])--SELECT ID, DESCRIPTION, SUMMARY FROM TODO
[EL Finest]: connection: 2013-06-19 14:30:55.924--ServerSession(7427424)--Connection(7633596)--Thread(Thread[main,5,main])--Connection released to connection pool [default].
Query 1 read
1: Todo [id=1, summary=s1, description=d1]
1: Todo [id=2, summary=qwet, description=d2]
[EL Finest]: query: 2013-06-19 14:31:25.932--UnitOfWork(31211079)--Thread(Thread[main,5,main])--Execute query ReadAllQuery(referenceClass=Todo sql="SELECT ID, DESCRIPTION, SUMMARY FROM TODO")
[EL Finest]: connection: 2013-06-19 14:31:25.932--ServerSession(7427424)--Connection(7633596)--Thread(Thread[main,5,main])--Connection acquired from connection pool [default].
[EL Fine]: sql: 2013-06-19 14:31:25.932--ServerSession(7427424)--Connection(7633596)--Thread(Thread[main,5,main])--SELECT ID, DESCRIPTION, SUMMARY FROM TODO
[EL Finest]: connection: 2013-06-19 14:31:25.934--ServerSession(7427424)--Connection(7633596)--Thread(Thread[main,5,main])--Connection released to connection pool [default].
Query 2 read
1: Todo [id=1, summary=s1, description=d1]
2: Todo [id=1, summary=s1, description=d1]
true
1: Todo [id=2, summary=qwet, description=d2]
2: Todo [id=2, summary=qwet, description=d2]
true

スレッドがスリープしている間に、データベースの値を変更します。キャッシュ内の値は期限切れになっているはずなので、データベースから新しい値を取得することを期待しています。コードは単に @Cache アノテーションを無視しているようです。type=CacheType.NONE や alwaysRefresh=true など、他のさまざまな設定も試しましたが、何も変更されませんでした。

storeMode-QueryHint を追加すると、クエリは常に結果を更新します。これはまさに私が望んでいるものではなく、エラーが発生しやすい各クエリに追加する必要があるようです。しかし、 Cache アノテーションが無視されるのはまだ奇妙です。

DescriptorCustomizer も使用しようとしましたが、使用しても効果がありません (ブレークポイントでテスト)。

public void customize(ClassDescriptor descriptor) {
        descriptor.alwaysRefreshCache();
        descriptor.alwaysRefreshCacheOnRemote();
        descriptor.disableCacheHits();
        descriptor.disableCacheHitsOnRemote();
    }

アップデート：

私が開発しているシステムについて一言。マスターデータを読み書きするモジュールです。したがって、たとえば、同じユーザーの User-object がメモリ内に 2 回あると、気分が悪くなります。また、@ReadOnly アノテーションをテストした後、@Cache アノテーションの分離パラメーターが機能しているように見えますが、有効期限、常に更新などについてはまだ何もないことに気付きました。

4

1 に答える 1

2

同じ EntityManager インスタンスを使用しています。キャッシュ設定は共有キャッシュに適用されますが、EntityManager は同じオブジェクトを閉じるかクリアするまでメモリ内に保持する必要があります。そうしないと、単純な検索操作で実行中のトランザクションの変更が消去される可能性があります。新しい EntityManager を取得するか、既存のものをクリアすると、必要に応じて EntityManager が共有キャッシュおよび/またはデータベースに移動します。

現在の EM コンテキストでオブジェクトを更新する必要がある場合は、明示的に em.refresh を呼び出すか、クエリ ヒントを使用して、データベース内の既存の変更を消去する必要があります。

各 EM はトランザクション コンテキストを表し、各スレッドは独自の EntityManager を持つ必要があるため、アプリケーションにはエンティティの複数のコピーが既に存在します。EntityManager から読み込まれた特定のインスタンスが現在の変更を常に反映することに依存している場合、問題が発生します。実際に反映できるのは、読み込まれた時点でデータベースにあるものだけです。これが、必要に応じて変更をマージすることが重要である理由であり、アプリケーションでオブジェクトをキャッシュすることはおそらくお勧めできません。代わりに、必要に応じて EntityManagers からオブジェクトにアクセスします。

オブジェクトが必要で、変更を加えていない場合は、EM ではなく共有キャッシュから取得する読み取り専用としてマークし、キャッシュ設定を反映します: http://wiki.eclipse.org/EclipseLink/ UserGuide/JPA/Basic_JPA_Development/Caching/Shared_and_Isolated#Read-Only_Entities . エンティティが共有キャッシュにキャッシュされている場合、これが返されるインスタンスになり、すべての EM が同じオブジェクト インスタンスを返します。エンティティ自体の同時実行の問題を管理するのはアプリ次第です。

于 2013-06-20T14:01:25.883 に答える