nablarch.fw.reader

クラス ResumeDataReader<TData>

java.lang.Object

nablarch.fw.reader.ResumeDataReader<TData>

型パラメータ:

TData - このクラスが読み込んだデータの型

すべての実装されたインタフェース:

DataReader<TData>

public class ResumeDataReader<TData>
extends java.lang.Object
implements DataReader<TData>

ファイルを読み込むデータリーダをラップして、レジューム機能を追加するデータリーダ。

本クラスは、ラップしたデータリーダのreadメソッドの実行回数を、 正常に処理できたポイントとして実行管理テーブルに保存する。
正常に処理できたポイントは業務処理がコミットされるタイミングで保存される。 業務処理が失敗しトランザクションがロールバックされる場合、正常に処理できたポイントの保存は行われない。
障害発生時などに処理を再実行する場合、本クラスは正常に処理できたポイントまでのファイル読み込み（業務処理）をスキップし、 再開ポイント(正常に処理できたポイントの次のポイント)からファイル読み込みを再開する。
そのため、再開ポイント以前のデータに対してパッチを当てた際は、正常に処理できたポイントを0クリアする必要がある。
なお、FileBatchActionを継承したバッチ業務アクションを作成する場合は、 FileBatchActionがデフォルトでValidatableFileDataReaderをラップしたResumeDataReaderを生成するので、 アプリケーションプログラマが上記２つのオブジェクトを生成するコードを実装する必要はない。

関連項目:

FileDataReader, ResumePointManager

ネストされたクラスのサマリー

インタフェースから継承されたネストされたクラス/インタフェース nablarch.fw.DataReader

DataReader.NoMoreRecord

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
ResumeDataReader()

メソッドのサマリー

修飾子とタイプ	メソッドと説明
void	close(ExecutionContext ctx) このリーダの利用を停止し、内部的に保持している各種リソースを解放する。
boolean	hasNext(ExecutionContext ctx) 次に読み込むデータが存在するかどうかを返却する。
protected int	loadResumePoint() 正常に処理できたポイントを取得する。
TData	read(ExecutionContext ctx) レジューム機能を追加するデータリーダからデータを読み込む。
protected void	readToResumePoint(ExecutionContext ctx) レジューム機能が有効になっている場合、正常に処理できたポイントまでのレジュームを行う。
protected void	saveResumePoint() 正常に処理できたポイントを保存する。
ResumeDataReader<TData>	setSourceReader(DataReader<TData> sourceReader) レジューム機能を追加するデータリーダを設定する。

クラスから継承されたメソッド java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

コンストラクタの詳細

ResumeDataReader

public ResumeDataReader()

メソッドの詳細

read

public TData read(ExecutionContext ctx)

レジューム機能を追加するデータリーダからデータを読み込む。

データを読み込んだ回数を正常に処理できたポイントとして実行管理テーブルに保存し、 処理再開時にはその次のポイントから読み込みを再開する。
トランザクションループ制御ハンドラの設定により一定件数ごとにコミットを行なっている場合は、 コミット前の最後の処理で正常に処理できたポイントを実行管理テーブルに保存する。
次に読み込むデータが存在しない場合はnullを返す。

定義:

read インタフェース内 DataReader<TData>

パラメータ:

ctx - 実行コンテキスト

戻り値:

入力データオブジェクト

hasNext

public boolean hasNext(ExecutionContext ctx)

次に読み込むデータが存在するかどうかを返却する。

定義:

hasNext インタフェース内 DataReader<TData>

パラメータ:

ctx - 実行コンテキスト

戻り値:

次に読み込むデータが存在する場合はtrue

close

public void close(ExecutionContext ctx)

このリーダの利用を停止し、内部的に保持している各種リソースを解放する。

定義:

close インタフェース内 DataReader<TData>

パラメータ:

ctx - 実行コンテキスト

readToResumePoint

protected void readToResumePoint(ExecutionContext ctx)

レジューム機能が有効になっている場合、正常に処理できたポイントまでのレジュームを行う。

パラメータ:

ctx - 実行コンテキスト

例外:

java.lang.IllegalStateException - 次に読み込むデータが存在しない場合

loadResumePoint

protected int loadResumePoint()

正常に処理できたポイントを取得する。

レジューム機能が無効になっている場合は0を返す。

戻り値:

正常に処理できたポイント

saveResumePoint

protected void saveResumePoint()

正常に処理できたポイントを保存する。

レジューム機能が無効になっている場合は何もしない。

setSourceReader

public ResumeDataReader<TData> setSourceReader(DataReader<TData> sourceReader)

レジューム機能を追加するデータリーダを設定する。

パラメータ:

sourceReader - レジューム機能を追加するデータリーダ

戻り値:

このオブジェクト自体