nablarch.fw.batch.ee.chunk

Class BaseDatabaseItemReader

java.lang.Object

javax.batch.api.chunk.AbstractItemReader

nablarch.fw.batch.ee.chunk.BaseDatabaseItemReader

All Implemented Interfaces:

javax.batch.api.chunk.ItemReader

Direct Known Subclasses:

DatabaseItemReader

@Published
public abstract class BaseDatabaseItemReader
extends javax.batch.api.chunk.AbstractItemReader

データベースを入力とするItemReaderの抽象クラス。

本リーダを継承することで、リーダ専用のコネクションを使用してデータを読み込むことができる。

DB製品によっては、トランザクション制御時にカーソルが閉じられてしまうため、リーダ専用のコネクションを使用して読み込みを行っている。

Constructor Summary

Constructors

Constructor and Description
BaseDatabaseItemReader()

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	doClose() リーダの終了処理（リソースの解放など）を行う。
protected abstract void	doOpen(java.io.Serializable checkpoint) データベースからのデータ読み込みを行う。
void	open(java.io.Serializable checkpoint)

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

checkpointInfo, readItem

Methods inherited from class java.lang.Object

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

Constructor Detail

BaseDatabaseItemReader

public BaseDatabaseItemReader()

Method Detail

open

public final void open(java.io.Serializable checkpoint)
                throws java.lang.Exception

Specified by:

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

Overrides:

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

Throws:

java.lang.Exception

close

public final void close()
                 throws java.lang.Exception

Specified by:

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

Overrides:

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

Throws:

java.lang.Exception

doOpen

protected abstract void doOpen(java.io.Serializable checkpoint)
                        throws java.lang.Exception

データベースからのデータ読み込みを行う。

Parameters:

checkpoint - チェックポイント

Throws:

java.lang.Exception - 発生した例外

doClose

protected void doClose()
                throws java.lang.Exception

リーダの終了処理（リソースの解放など）を行う。

Throws:

java.lang.Exception - 発生した例外