nablarch.etl

Class DatabaseItemReader

java.lang.Object

javax.batch.api.chunk.AbstractItemReader

nablarch.fw.batch.ee.chunk.BaseDatabaseItemReader

nablarch.etl.DatabaseItemReader

All Implemented Interfaces:

javax.batch.api.chunk.ItemReader

@Named
 @Dependent
public class DatabaseItemReader
extends BaseDatabaseItemReader

指定されたSELECT文を使ってテーブルから取得したレコードの読み込みを行うAbstractItemReaderの実装クラス。

Constructor Summary

Constructors

Constructor and Description
DatabaseItemReader(javax.batch.runtime.context.JobContext jobContext, javax.batch.runtime.context.StepContext stepContext, ProgressManager progressManager, StepConfig stepConfig) コンストラクタ。

Method Summary

Modifier and Type	Method and Description
void	doOpen(java.io.Serializable checkpoint) テーブルにアクセスして指定されたSELECT文を使ってレコードを取得する。
java.lang.Object	readItem()

Methods inherited from class nablarch.fw.batch.ee.chunk.BaseDatabaseItemReader

close, doClose, open

Methods inherited from class javax.batch.api.chunk.AbstractItemReader

checkpointInfo

Methods inherited from class java.lang.Object

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

Constructor Detail

DatabaseItemReader

@Inject
public DatabaseItemReader(javax.batch.runtime.context.JobContext jobContext,
                                  javax.batch.runtime.context.StepContext stepContext,
                                  ProgressManager progressManager,
                                  StepConfig stepConfig)

コンストラクタ。

Parameters:

jobContext - JobContext

stepContext - StepContext

progressManager - ProgressManager

stepConfig - ステップ設定

Method Detail

doOpen

public void doOpen(java.io.Serializable checkpoint)
            throws java.sql.SQLException

テーブルにアクセスして指定されたSELECT文を使ってレコードを取得する。

Specified by:

doOpen in class BaseDatabaseItemReader

Parameters:

checkpoint - チェックポイント

Throws:

java.sql.SQLException

readItem

public java.lang.Object readItem()

Specified by:

readItem in interface javax.batch.api.chunk.ItemReader

Specified by:

readItem in class javax.batch.api.chunk.AbstractItemReader