クラス JpaCursorItemReader<T>
java.lang.ObjectSE
org.springframework.batch.item.ItemStreamSupport
org.springframework.batch.item.support.AbstractItemStreamItemReader<T>
org.springframework.batch.item.support.AbstractItemCountingItemStreamItemReader<T>
org.springframework.batch.item.database.JpaCursorItemReader<T>
- 型パラメーター:
T
- 読むアイテムの種類
- 実装されたすべてのインターフェース:
ItemReader<T>
、ItemStream
、ItemStreamReader<T>
、org.springframework.beans.factory.InitializingBean
public class JpaCursorItemReader<T>
extends AbstractItemCountingItemStreamItemReader<T>
implements org.springframework.beans.factory.InitializingBean
JPA
Query.getResultStream()
に基づく ItemStreamReader
実装。初期化時に JPQL クエリを実行し、AbstractItemCountingItemStreamItemReader.read()
メソッドが呼び出されるときに結果セットを反復処理して、現在の行に対応するオブジェクトを返します。クエリは、setQueryString(String)
を使用して直接設定することも、setQueryProvider(JpaQueryProvider)
経由でクエリプロバイダーを使用して設定することもできます。実装はスレッドセーフではありません。
- 導入:
- 4.3
- 作成者:
- Mahmoud Ben Hassine
コンストラクターのサマリー
メソッドのサマリー
修飾子と型メソッド説明void
protected void
doClose()
AbstractItemCountingItemStreamItemReader.doOpen()
で開いたリソースを閉じます。protected void
doOpen()
入力の読み取りを開始するために必要なリソースを開きます。protected T
doRead()
入力から次の項目を読み取ります。void
setEntityManagerFactory
(jakarta.persistence.EntityManagerFactory entityManagerFactory) JPA エンティティマネージャーファクトリを設定します。void
setParameterValues
(MapSE<StringSE, ObjectSE> parameterValues) クエリの実行に使用するパラメーター値を設定します。void
setQueryProvider
(JpaQueryProvider queryProvider) JPA クエリプロバイダーを設定します。void
setQueryString
(StringSE queryString) JPQL クエリ文字列を設定します。void
update
(ExecutionContext executionContext) 空のExecutionContext
を返します。クラス org.springframework.batch.item.support.AbstractItemCountingItemStreamItemReader から継承されたメソッド
close, getCurrentItemCount, isSaveState, jumpToItem, open, read, setCurrentItemCount, setMaxItemCount, setSaveState
クラス org.springframework.batch.item.ItemStreamSupport から継承されたメソッド
getExecutionContextKey, getName, setExecutionContextName, setName
コンストラクターの詳細
JpaCursorItemReader
public JpaCursorItemReader()新しいJpaCursorItemReader
を作成します。
メソッドの詳細
setEntityManagerFactory
public void setEntityManagerFactory(jakarta.persistence.EntityManagerFactory entityManagerFactory) JPA エンティティマネージャーファクトリを設定します。- パラメーター:
entityManagerFactory
- JPA エンティティマネージャーファクトリ
setQueryProvider
JPA クエリプロバイダーを設定します。- パラメーター:
queryProvider
- JPA クエリプロバイダー
setQueryString
JPQL クエリ文字列を設定します。- パラメーター:
queryString
- JPQL クエリ文字列
setParameterValues
クエリの実行に使用するパラメーター値を設定します。- パラメーター:
parameterValues
- クエリ文字列で使用されるパラメーター名によってキー設定された値。
afterPropertiesSet
- 次で指定:
- インターフェース
org.springframework.beans.factory.InitializingBean
のafterPropertiesSet
- 例外:
ExceptionSE
doOpen
クラスからコピーされた説明:AbstractItemCountingItemStreamItemReader
入力の読み取りを開始するために必要なリソースを開きます。- 次で指定:
- クラス
AbstractItemCountingItemStreamItemReader<T>
のdoOpen
- 例外:
ExceptionSE
- サブクラスがフレームワークによる解釈のためにチェック済み例外をスローできるようにします
doRead
クラスからコピーされた説明:AbstractItemCountingItemStreamItemReader
入力から次の項目を読み取ります。- 次で指定:
- クラス
AbstractItemCountingItemStreamItemReader<T>
のdoRead
- 戻り値:
- データソースが使い果たされた場合、アイテムまたは
null
update
クラスからコピーされた説明:ItemStreamSupport
空のExecutionContext
を返します。- 次で指定:
- インターフェース
ItemStream
のupdate
- オーバーライド:
- クラス
AbstractItemCountingItemStreamItemReader<T>
のupdate
- パラメーター:
executionContext
- 更新される- 例外:
ItemStreamException
- 関連事項:
doClose
protected void doClose()クラスからコピーされた説明:AbstractItemCountingItemStreamItemReader
AbstractItemCountingItemStreamItemReader.doOpen()
で開いたリソースを閉じます。- 次で指定:
- クラス
AbstractItemCountingItemStreamItemReader<T>
のdoClose