jp.terasoluna.fw.batch.ibatissupport
クラス IBatisDb1NRelationCollectorImpl.QueuePutRowHandler

java.lang.Object
  上位を拡張 jp.terasoluna.fw.batch.ibatissupport.IBatisDb1NRelationCollectorImpl.QueuePutRowHandler
すべての実装されたインタフェース:
DataRowHandler
含まれているクラス:
IBatisDb1NRelationCollectorImpl

private static class IBatisDb1NRelationCollectorImpl.QueuePutRowHandler
extends java.lang.Object
implements DataRowHandler

Rowハンドラの実装クラス。


フィールドの概要
private  int collected
          対象データ取得数。
private  CollectedDataHandler collectedDataHandler
          対象データ取得を処理するハンドラ。
private  JobStatus jobStatus
          処理状況。
private  java.lang.Object prevRow
          前回handleRowメソッドに渡されたオブジェクト
 
コンストラクタの概要
IBatisDb1NRelationCollectorImpl.QueuePutRowHandler(CollectedDataHandler collectedDataHandler, JobStatus jobStatus)
          コンストラクタ。
 
メソッドの概要
 void delayCollect()
          前回handleRowメソッドに渡されたRowデータをキューに格納する。
 int getCollected()
          対象データ取得数を取得する。
 void handleRow(java.lang.Object row)
          Rowハンドラメソッド。
 
クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

フィールドの詳細

collected

private int collected
対象データ取得数。


collectedDataHandler

private CollectedDataHandler collectedDataHandler
対象データ取得を処理するハンドラ。


jobStatus

private JobStatus jobStatus
処理状況。


prevRow

private java.lang.Object prevRow
前回handleRowメソッドに渡されたオブジェクト

コンストラクタの詳細

IBatisDb1NRelationCollectorImpl.QueuePutRowHandler

public IBatisDb1NRelationCollectorImpl.QueuePutRowHandler(CollectedDataHandler collectedDataHandler,
                                                          JobStatus jobStatus)
コンストラクタ。

パラメータ:
collectedDataHandler - 対象データ取得を格納するワーカキュー
jobStatus - 処理状況
メソッドの詳細

handleRow

public void handleRow(java.lang.Object row)
Rowハンドラメソッド。 前回メソッドに渡されたRowデータをキューに格納する。 DBから取得したRowデータをprevRowに格納する。

定義:
インタフェース DataRowHandler 内の handleRow
パラメータ:
row - DBから取得したRow

delayCollect

public void delayCollect()
前回handleRowメソッドに渡されたRowデータをキューに格納する。

Rowデータ(prevRow)は 全データの取得が終わるまでiBATISに保持され続けるという特性を考慮し、 メモリの肥大化を最小限に抑えるため、 prevRowのシャローコピーをキューに格納し、 prevRowの全プロパティを初期化(同クラスの新規インスタンスからプロパティをコピー)する。


getCollected

public int getCollected()
対象データ取得数を取得する。

戻り値:
対象データ取得数