jp.terasoluna.fw.batch.ibatissupport
クラス IBatisDbCollectorImpl

java.lang.Object
  上位を拡張 jp.terasoluna.fw.batch.core.AbstractCollector<JobContext>
      上位を拡張 jp.terasoluna.fw.batch.ibatissupport.IBatisDbCollectorImpl
すべての実装されたインタフェース:
Collector<JobContext>

public class IBatisDbCollectorImpl
extends AbstractCollector<JobContext>

iBatisを用いた対象データ取得の実装クラス。

使用上の注意:

1:Nマッピング使用時、iBATISは全てのデータを取得し終わるまで、 RowHandler#handleRow(DataRowHandler#handleRow)に渡したオブジェクトを、 全てiBATIS内部に保持し続けるため、N側のデータ量が大きいとOutOfMemoryErrorが発生する可能性がある。 そのため、1:Nマッピング使用時は1:N専用のコレクタIBatisDb1NRelationCollectorImplを利用すること。


入れ子のクラスの概要
private static class IBatisDbCollectorImpl.QueuePutRowHandler
          Rowハンドラの実装クラス。
 
フィールドの概要
private  QueryRowHandleDAO queryRowHandleDAO
          SqlMapClientデータアクセスObject
private  java.lang.String sql
          対象データ取得用SQL文キー。
 
コンストラクタの概要
IBatisDbCollectorImpl()
           
 
メソッドの概要
protected  CollectorResult doCollect(JobContext jobContext, CollectedDataHandler collectedDataHandler, JobStatus jobStatus)
          対象データ取得処理を実行するメソッド。
 void setQueryRowHandleDAO(QueryRowHandleDAO queryRowHandleDAO)
          SqlMapClientデータアクセスObjectを設定する。
 void setSql(java.lang.String sql)
          対象データ取得用SQL文キーを設定する。
 
クラス jp.terasoluna.fw.batch.core.AbstractCollector から継承されたメソッド
collect, setCollectedDataHandlerFactory
 
クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

フィールドの詳細

sql

private java.lang.String sql
対象データ取得用SQL文キー。


queryRowHandleDAO

private QueryRowHandleDAO queryRowHandleDAO
SqlMapClientデータアクセスObject

コンストラクタの詳細

IBatisDbCollectorImpl

public IBatisDbCollectorImpl()
メソッドの詳細

doCollect

protected CollectorResult doCollect(JobContext jobContext,
                                    CollectedDataHandler collectedDataHandler,
                                    JobStatus jobStatus)
対象データ取得処理を実行するメソッド。

定義:
クラス AbstractCollector<JobContext> 内の doCollect
パラメータ:
jobContext - ジョブコンテキスト
collectedDataHandler - ワーカキュー
jobStatus - 処理状況
戻り値:
コレクタ処理結果

setQueryRowHandleDAO

public void setQueryRowHandleDAO(QueryRowHandleDAO queryRowHandleDAO)
SqlMapClientデータアクセスObjectを設定する。

パラメータ:
queryDAO - SqlMapClientデータアクセスObject

setSql

public void setSql(java.lang.String sql)
対象データ取得用SQL文キーを設定する。

パラメータ:
sql - 対象データ取得用SQL文キー