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 - 発生した例外