jp.terasoluna.fw.collector.db
クラス DBCollector<P>

java.lang.Object
  上位を拡張 jp.terasoluna.fw.collector.AbstractCollector<P>
      上位を拡張 jp.terasoluna.fw.collector.db.DBCollector<P>
すべての実装されたインタフェース:
Closeable, Cloneable, Iterable<P>, Callable<Integer>, Iterator<P>, Collector<P>
直系の既知のサブクラス:
DBValidateCollector

public class DBCollector<P>
extends AbstractCollector<P>

DBCollector
独立した別スレッドを起動し、QueryRowHandleDAOを非同期で実行する。


フィールドの概要
protected  Object bindParams
          SQLにバインドする値を格納したオブジェクト
protected  DBCollectorPostprocess dbCollectorPostprocess
          DBCollector後処理
protected  DBCollectorPreprocess dbCollectorPreprocess
          DBCollector前処理
protected  jp.terasoluna.fw.dao.QueryRowHandleDAO queryRowHandleDAO
          QueryRowHandleDAO
protected  Class<? extends QueueingDataRowHandler> queueingDataRowHandlerClass
          QueueingDataRowHandlerのクラス型
protected  QueueingDataRowHandler rowHandler
          QueueingDataRowHandlerインスタンス
protected  String sqlID
          実行するSQLのID
 
クラス jp.terasoluna.fw.collector.AbstractCollector から継承されたフィールド
acquireDataCount, beginning, child, CURRENT_QUEUE_CHECK_SIZE, currentQueue, DEFAULT_QUEUE_SIZE, DEFAULT_SLEEP_WAIT, exceptionHandler, finish, fo, PREVIOUS_QUEUE_CHECK_SIZE, previousQueue, queue, queueSize, sleepWait, validationErrorHandler, validator, verboseLog
 
コンストラクタの概要
protected DBCollector()
          DBCollectorコンストラクタ
  DBCollector(DBCollectorConfig config)
          DBCollectorコンストラクタ
  DBCollector(jp.terasoluna.fw.dao.QueryRowHandleDAO queryRowHandleDAO, String sqlID, Object bindParams)
          DBCollectorコンストラクタ
  DBCollector(jp.terasoluna.fw.dao.QueryRowHandleDAO queryRowHandleDAO, String sqlID, Object bindParams, boolean relation1n)
          DBCollectorコンストラクタ
  DBCollector(jp.terasoluna.fw.dao.QueryRowHandleDAO queryRowHandleDAO, String sqlID, Object bindParams, CollectorExceptionHandler exceptionHandler)
          DBCollectorコンストラクタ
  DBCollector(jp.terasoluna.fw.dao.QueryRowHandleDAO queryRowHandleDAO, String sqlID, Object bindParams, int queueSize)
          DBCollectorコンストラクタ
  DBCollector(jp.terasoluna.fw.dao.QueryRowHandleDAO queryRowHandleDAO, String sqlID, Object bindParams, int queueSize, boolean relation1n, CollectorExceptionHandler exceptionHandler, DBCollectorPreprocess dbCollectorPreprocess, DBCollectorPostprocess dbCollectorPostprocess)
          DBCollectorコンストラクタ
 
メソッドの概要
protected  void addQueue(DataValueObject dataValueObject)
          キューにデータを追加する。
 Integer call()
           
protected  Object clone()
           
protected  QueueingDataRowHandler getDataRowHandler()
          getDataRowHandlerメソッド.
 
クラス jp.terasoluna.fw.collector.AbstractCollector から継承されたメソッド
addQueue, close, closeQuietly, createCurrentQueue, createPreviousQueue, createQueue, execute, finalize, getCurrent, getExecutor, getNext, getPrevious, getQueue, getSleepWait, handleException, handleValidationError, hasNext, isFinish, iterator, next, remove, setFinish, setFinish, setQueueSize, setSleepWait, setVerbose, validate
 
クラス java.lang.Object から継承されたメソッド
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

フィールドの詳細

queryRowHandleDAO

protected jp.terasoluna.fw.dao.QueryRowHandleDAO queryRowHandleDAO
QueryRowHandleDAO


sqlID

protected String sqlID
実行するSQLのID


bindParams

protected Object bindParams
SQLにバインドする値を格納したオブジェクト


rowHandler

protected QueueingDataRowHandler rowHandler
QueueingDataRowHandlerインスタンス


queueingDataRowHandlerClass

protected Class<? extends QueueingDataRowHandler> queueingDataRowHandlerClass
QueueingDataRowHandlerのクラス型


dbCollectorPreprocess

protected DBCollectorPreprocess dbCollectorPreprocess
DBCollector前処理


dbCollectorPostprocess

protected DBCollectorPostprocess dbCollectorPostprocess
DBCollector後処理

コンストラクタの詳細

DBCollector

protected DBCollector()
DBCollectorコンストラクタ


DBCollector

public DBCollector(jp.terasoluna.fw.dao.QueryRowHandleDAO queryRowHandleDAO,
                   String sqlID,
                   Object bindParams)
DBCollectorコンストラクタ

パラメータ:
queryRowHandleDAO - QueryRowHandleDAOインスタンス
sqlID - 実行するSQLのID
bindParams - SQLにバインドする値を格納したオブジェクト

DBCollector

public DBCollector(jp.terasoluna.fw.dao.QueryRowHandleDAO queryRowHandleDAO,
                   String sqlID,
                   Object bindParams,
                   boolean relation1n)
DBCollectorコンストラクタ

パラメータ:
queryRowHandleDAO - QueryRowHandleDAOインスタンス
sqlID - 実行するSQLのID
bindParams - SQLにバインドする値を格納したオブジェクト
relation1n - 1:Nマッピング使用時はtrue

DBCollector

public DBCollector(jp.terasoluna.fw.dao.QueryRowHandleDAO queryRowHandleDAO,
                   String sqlID,
                   Object bindParams,
                   int queueSize)
DBCollectorコンストラクタ

パラメータ:
queryRowHandleDAO - QueryRowHandleDAOインスタンス
sqlID - 実行するSQLのID
bindParams - SQLにバインドする値を格納したオブジェクト
queueSize - キューのサイズ(1以上を設定すること。0以下は無視)

DBCollector

public DBCollector(jp.terasoluna.fw.dao.QueryRowHandleDAO queryRowHandleDAO,
                   String sqlID,
                   Object bindParams,
                   CollectorExceptionHandler exceptionHandler)
DBCollectorコンストラクタ

パラメータ:
queryRowHandleDAO - QueryRowHandleDAOインスタンス
sqlID - 実行するSQLのID
bindParams - SQLにバインドする値を格納したオブジェクト
exceptionHandler - 例外ハンドラ

DBCollector

public DBCollector(jp.terasoluna.fw.dao.QueryRowHandleDAO queryRowHandleDAO,
                   String sqlID,
                   Object bindParams,
                   int queueSize,
                   boolean relation1n,
                   CollectorExceptionHandler exceptionHandler,
                   DBCollectorPreprocess dbCollectorPreprocess,
                   DBCollectorPostprocess dbCollectorPostprocess)
DBCollectorコンストラクタ

パラメータ:
queryRowHandleDAO - QueryRowHandleDAOインスタンス
sqlID - 実行するSQLのID
bindParams - SQLにバインドする値を格納したオブジェクト
queueSize - キューのサイズ(1以上を設定すること。0以下は無視)
relation1n - 1:Nマッピング使用時はtrue
exceptionHandler - 例外ハンドラ
dbCollectorPreprocess - DBCollector前処理
dbCollectorPostprocess - DBCollector後処理

DBCollector

public DBCollector(DBCollectorConfig config)
DBCollectorコンストラクタ

パラメータ:
config - DBCollectorConfig DBCollector設定項目
メソッドの詳細

call

public Integer call()
             throws Exception
例外:
Exception

getDataRowHandler

protected QueueingDataRowHandler getDataRowHandler()
getDataRowHandlerメソッド.

戻り値:
QueueingDataRowHandler

clone

protected Object clone()
                throws CloneNotSupportedException
オーバーライド:
クラス Object 内の clone
例外:
CloneNotSupportedException

addQueue

protected void addQueue(DataValueObject dataValueObject)
                 throws InterruptedException
クラス AbstractCollector の記述:
キューにデータを追加する。

オーバーライド:
クラス AbstractCollector<P> 内の addQueue
パラメータ:
dataValueObject - DataValueObject
例外:
InterruptedException


Copyright © 2012. All Rights Reserved.