nablarch.fw.reader

クラス DatabaseTableQueueReader

java.lang.Object

nablarch.fw.reader.DatabaseTableQueueReader

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

DataReader<SqlRow>

public class DatabaseTableQueueReader
extends Object
implements DataReader<SqlRow>

データベースのテーブルを擬似的にキューのように扱うデータリーダ。

本リーダはデータベースのテーブルをキューのように扱えるようにするため、 処理対象レコードが存在しない場合でも#hasNext(nablarch.fw.ExecutionContext)は 常にtrueを返却し、処理対象が存在するように振る舞う。 これにより、データが存在しない場合でも#read(nablarch.fw.ExecutionContext)が呼び出され、 テーブルの最新情報を取得し直すことが可能となる。

本リーダは、処理対象レコードが存在しない場合、再度最新の情報を取得する。 この際に、他のスレッドで処理中のレコードが未処理のまま残っている可能性がある。 このため、各スレッドで処理中のレコードをヒープ上に保持し、 読み込んだ対象が他のスレッドで処理中のレコードではないことを確認する。

対象のレコードが、他のスレッドで処理中である場合には、次のレコードを読み込み再度チェックを行う。 対象のレコードが、他のスレッドで処理中でない場合には、読み込んだレコードをクライアントに返却する。

作成者:

hisaaki sioiri

関連項目:

DatabaseRecordReader

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

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

DataReader.NoMoreRecord

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

コンストラクタ

コンストラクタと説明
DatabaseTableQueueReader(DatabaseRecordReader originalReader, int waitTime, String... primaryKeys) データベースをキューとして扱うリーダを生成する。

メソッドのサマリー

修飾子とタイプ	メソッドと説明
protected static void	writeLog(nablarch.fw.reader.DatabaseTableQueueReader.InputDataIdentifier inputDataIdentifier) 要求の識別情報をログに出力する。

インタフェースから継承されたメソッド nablarch.fw.DataReader

close, hasNext, read

コンストラクタの詳細

DatabaseTableQueueReader

@Published
public DatabaseTableQueueReader(DatabaseRecordReader originalReader,
                                           int waitTime,
                                           String... primaryKeys)

データベースをキューとして扱うリーダを生成する。

パラメータ:

originalReader - データベースレコードリーダ

waitTime - データが存在しない場合の待機時間（ミリ秒）

primaryKeys - レコードを一意に識別する主キーのカラム名

メソッドの詳細

writeLog

@Published
protected static void writeLog(nablarch.fw.reader.DatabaseTableQueueReader.InputDataIdentifier inputDataIdentifier)

要求の識別情報をログに出力する。

識別情報に個人情報等のようにログに出力すべきではない項目が含まれる場合には、 本メソッドをオーバーライドしマスク処理などを実施後にログ出力を行うこと。

パラメータ:

inputDataIdentifier - 要求識別情報