Package nablarch.fw.batch.ee.chunk

Class BaseDatabaseItemReader

java.lang.Object
jakarta.batch.api.chunk.AbstractItemReader
nablarch.fw.batch.ee.chunk.BaseDatabaseItemReader
All Implemented Interfaces:
jakarta.batch.api.chunk.ItemReader
@Published public abstract class BaseDatabaseItemReader extends jakarta.batch.api.chunk.AbstractItemReader
データベースを入力とするItemReaderの抽象クラス。

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

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

  • Constructor Details

    • BaseDatabaseItemReader

      public BaseDatabaseItemReader()

  • Method Details

    • open

      public final void open(Serializable checkpoint) throws Exception
      Specified by:
      open in interface jakarta.batch.api.chunk.ItemReader
      Overrides:
      open in class jakarta.batch.api.chunk.AbstractItemReader
      Throws:
      Exception

    • close

      public final void close() throws Exception
      Specified by:
      close in interface jakarta.batch.api.chunk.ItemReader
      Overrides:
      close in class jakarta.batch.api.chunk.AbstractItemReader
      Throws:
      Exception

    • doOpen

      protected abstract void doOpen(Serializable checkpoint) throws Exception
      データベースからのデータ読み込みを行う。
      Parameters:
      checkpoint - チェックポイント
      Throws:
      Exception - 発生した例外

    • doClose

      protected void doClose() throws Exception
      リーダの終了処理（リソースの解放など）を行う。
      Throws:
      Exception - 発生した例外