Hibernateの 'session.flush'でのマルチスレッディング

Question

まず、これはおそらく既製ですか？

Hibernate 3.6、JDBC batch_size 500、 200.000エンティティ上のHiloジェネレータを使用します。

私の例では、56秒かかるリクエストがあり、セッションで200,000のエンティティを作成しています。したがって、session.flush()コマンドは、％100に1つのCPUコアしかない56秒間に32秒かかる。

更新が必要なエンティティのリストを取得し、SQLステートメントを作成する方法はありますか。たとえば、4つのスレッドですか？

Answer 1

flush()は、基本的にすべての保留中のSQL INSERTステートメントを基本接続を使用してデータベースに送信しているため、異なるスレッドではflush()とすることはできません。 JDBC接続はスレッドセーフではありません。つまり、4つの異なる接続と4つの異なるトランザクションを使用する必要があります。 1つのトランザクションですべての挿入が必要な場合は、ここで行うことはできません。

4つの別々のトランザクションで暮らすことができる場合は、スレッドプールを作成し、レコードを小さなバッチで保存してください。プールは複数のスレッドにまたがってINSERT操作を配布します。

また、これが本当に役に立ちますか？私はflush()がCPUバインドではなく、I/Oまたはネットワークにバインドされていると思います。しかし、あなたの経験は100％の使用とは違うので、私は間違っているかもしれません。また、ステートレスセッション、生のJDBC /ネイティブクエリ、バッチ挿入などを使用してINSERTを最適化してみてください。別々のスレッドに分割する方がはるかに難しいです。