nablarch.fw.reader

Class DatabaseTableQueueReader

java.lang.Object

nablarch.fw.reader.DatabaseTableQueueReader

All Implemented Interfaces:

nablarch.fw.DataReader<SqlRow>

public class DatabaseTableQueueReader
extends java.lang.Object
implements nablarch.fw.DataReader<SqlRow>

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

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

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

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

Author:

hisaaki sioiri

See Also:

DatabaseRecordReader

Constructor Summary

Constructors

Constructor and Description
DatabaseTableQueueReader(DatabaseRecordReader originalReader, int waitTime, java.lang.String... primaryKeys) データベースをキューとして扱うリーダを生成する。

Method Summary

Modifier and Type	Method and Description
protected void	writeLog(nablarch.fw.reader.DatabaseTableQueueReader.InputDataIdentifier inputDataIdentifier) 要求の識別情報をログに出力する。 識別情報に個人情報等のようにログに出力すべきではない項目が含まれる場合には、 本メソッドをオーバーライドしマスク処理などを実施後にログ出力を行うこと。

Constructor Detail

DatabaseTableQueueReader

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

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

Parameters:

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

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

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

Method Detail

writeLog

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

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

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

Parameters:

inputDataIdentifier - 要求識別情報