public class DBCollector<P> extends AbstractCollector<P>
修飾子とタイプ | フィールドと説明 |
---|---|
protected Object |
bindParams
SQLにバインドする値を格納したオブジェクト
|
protected DBCollectorPrePostProcess |
dbCollectorPrePostProcess
DBCollector前後処理
|
protected QueryRowHandleDAO |
queryRowHandleDAO
QueryRowHandleDAO
|
protected Class<? extends QueueingDataRowHandler> |
queueingDataRowHandlerClass
QueueingDataRowHandlerのクラス型
|
protected QueueingDataRowHandler |
rowHandler
QueueingDataRowHandlerインスタンス
|
protected String |
sqlID
実行するSQLのID
|
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(QueryRowHandleDAO queryRowHandleDAO,
String sqlID,
Object bindParams)
DBCollectorコンストラクタ
|
|
DBCollector(QueryRowHandleDAO queryRowHandleDAO,
String sqlID,
Object bindParams,
boolean relation1n)
DBCollectorコンストラクタ
|
|
DBCollector(QueryRowHandleDAO queryRowHandleDAO,
String sqlID,
Object bindParams,
CollectorExceptionHandler exceptionHandler)
DBCollectorコンストラクタ
|
|
DBCollector(QueryRowHandleDAO queryRowHandleDAO,
String sqlID,
Object bindParams,
int queueSize)
DBCollectorコンストラクタ
|
|
DBCollector(QueryRowHandleDAO queryRowHandleDAO,
String sqlID,
Object bindParams,
int queueSize,
boolean relation1n,
CollectorExceptionHandler exceptionHandler,
DBCollectorPrePostProcess dbCollectorPrePostProcess)
DBCollectorコンストラクタ
|
修飾子とタイプ | メソッドと説明 |
---|---|
protected void |
addQueue(DataValueObject dataValueObject)
キューにデータを追加する。
|
Integer |
call() |
protected Object |
clone() |
protected QueueingDataRowHandler |
getDataRowHandler()
getDataRowHandlerメソッド.
|
protected void |
postprocessComplete()
SQL実行後処理
|
protected DBCollectorPrePostProcessStatus |
postprocessException(Throwable th)
SQL実行後処理(例外)
|
protected void |
preprocess()
SQL実行前処理
|
addQueue, afterExecute, beforeExecute, close, closeQuietly, createCurrentQueue, createPreviousQueue, createQueue, createThreadFactory, execute, finalize, getCurrent, getCurrentObject, getExecutor, getNext, getNextObject, getPrevious, getPreviousObject, getQueue, getSleepWait, handleException, handleValidationError, hasNext, isFinish, iterator, next, remove, setFinish, setFinish, setQueueSize, setSleepWait, setVerbose, validate
protected QueryRowHandleDAO queryRowHandleDAO
protected String sqlID
protected Object bindParams
protected QueueingDataRowHandler rowHandler
protected Class<? extends QueueingDataRowHandler> queueingDataRowHandlerClass
protected DBCollectorPrePostProcess dbCollectorPrePostProcess
protected DBCollector()
public DBCollector(QueryRowHandleDAO queryRowHandleDAO, String sqlID, Object bindParams)
queryRowHandleDAO
- QueryRowHandleDAOインスタンスsqlID
- 実行するSQLのIDbindParams
- SQLにバインドする値を格納したオブジェクトpublic DBCollector(QueryRowHandleDAO queryRowHandleDAO, String sqlID, Object bindParams, boolean relation1n)
queryRowHandleDAO
- QueryRowHandleDAOインスタンスsqlID
- 実行するSQLのIDbindParams
- SQLにバインドする値を格納したオブジェクトrelation1n
- 1:Nマッピング使用時はtruepublic DBCollector(QueryRowHandleDAO queryRowHandleDAO, String sqlID, Object bindParams, int queueSize)
queryRowHandleDAO
- QueryRowHandleDAOインスタンスsqlID
- 実行するSQLのIDbindParams
- SQLにバインドする値を格納したオブジェクトqueueSize
- キューのサイズ(1以上を設定すること。0以下は無視)public DBCollector(QueryRowHandleDAO queryRowHandleDAO, String sqlID, Object bindParams, CollectorExceptionHandler exceptionHandler)
queryRowHandleDAO
- QueryRowHandleDAOインスタンスsqlID
- 実行するSQLのIDbindParams
- SQLにバインドする値を格納したオブジェクトexceptionHandler
- 例外ハンドラpublic DBCollector(QueryRowHandleDAO queryRowHandleDAO, String sqlID, Object bindParams, int queueSize, boolean relation1n, CollectorExceptionHandler exceptionHandler, DBCollectorPrePostProcess dbCollectorPrePostProcess)
queryRowHandleDAO
- QueryRowHandleDAOインスタンスsqlID
- 実行するSQLのIDbindParams
- SQLにバインドする値を格納したオブジェクトqueueSize
- キューのサイズ(1以上を設定すること。0以下は無視)relation1n
- 1:Nマッピング使用時はtrueexceptionHandler
- 例外ハンドラdbCollectorPrePostProcess
- DBCollector前後処理public DBCollector(DBCollectorConfig config)
config
- DBCollectorConfig DBCollector設定項目protected void preprocess()
protected DBCollectorPrePostProcessStatus postprocessException(Throwable th)
th
- Throwableprotected void postprocessComplete()
protected QueueingDataRowHandler getDataRowHandler()
protected Object clone() throws CloneNotSupportedException
clone
クラス内 Object
CloneNotSupportedException
protected void addQueue(DataValueObject dataValueObject) throws InterruptedException
AbstractCollector
addQueue
クラス内 AbstractCollector<P>
dataValueObject
- DataValueObjectInterruptedException
Copyright © 2014 NTT DATA Corporation.