|
||||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |
java.lang.Objectjp.terasoluna.fw.collector.AbstractCollector<P>
jp.terasoluna.fw.collector.db.DBCollector<P>
public class DBCollector<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 から継承されたフィールド |
---|
beginning, 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 から継承されたメソッド |
---|
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 |
フィールドの詳細 |
---|
protected jp.terasoluna.fw.dao.QueryRowHandleDAO queryRowHandleDAO
protected String sqlID
protected Object bindParams
protected QueueingDataRowHandler rowHandler
protected Class<? extends QueueingDataRowHandler> queueingDataRowHandlerClass
protected DBCollectorPreprocess dbCollectorPreprocess
protected DBCollectorPostprocess dbCollectorPostprocess
コンストラクタの詳細 |
---|
protected DBCollector()
public DBCollector(jp.terasoluna.fw.dao.QueryRowHandleDAO queryRowHandleDAO, String sqlID, Object bindParams)
queryRowHandleDAO
- QueryRowHandleDAOインスタンスsqlID
- 実行するSQLのIDbindParams
- SQLにバインドする値を格納したオブジェクトpublic DBCollector(jp.terasoluna.fw.dao.QueryRowHandleDAO queryRowHandleDAO, String sqlID, Object bindParams, boolean relation1n)
queryRowHandleDAO
- QueryRowHandleDAOインスタンスsqlID
- 実行するSQLのIDbindParams
- SQLにバインドする値を格納したオブジェクトrelation1n
- 1:Nマッピング使用時はtruepublic DBCollector(jp.terasoluna.fw.dao.QueryRowHandleDAO queryRowHandleDAO, String sqlID, Object bindParams, int queueSize)
queryRowHandleDAO
- QueryRowHandleDAOインスタンスsqlID
- 実行するSQLのIDbindParams
- SQLにバインドする値を格納したオブジェクトqueueSize
- キューのサイズ(1以上を設定すること。0以下は無視)public DBCollector(jp.terasoluna.fw.dao.QueryRowHandleDAO queryRowHandleDAO, String sqlID, Object bindParams, CollectorExceptionHandler exceptionHandler)
queryRowHandleDAO
- QueryRowHandleDAOインスタンスsqlID
- 実行するSQLのIDbindParams
- SQLにバインドする値を格納したオブジェクトexceptionHandler
- 例外ハンドラpublic DBCollector(jp.terasoluna.fw.dao.QueryRowHandleDAO queryRowHandleDAO, String sqlID, Object bindParams, int queueSize, boolean relation1n, CollectorExceptionHandler exceptionHandler, DBCollectorPreprocess dbCollectorPreprocess, DBCollectorPostprocess dbCollectorPostprocess)
queryRowHandleDAO
- QueryRowHandleDAOインスタンスsqlID
- 実行するSQLのIDbindParams
- SQLにバインドする値を格納したオブジェクトqueueSize
- キューのサイズ(1以上を設定すること。0以下は無視)relation1n
- 1:Nマッピング使用時はtrueexceptionHandler
- 例外ハンドラdbCollectorPreprocess
- DBCollector前処理dbCollectorPostprocess
- DBCollector後処理public DBCollector(DBCollectorConfig config)
config
- DBCollectorConfig DBCollector設定項目メソッドの詳細 |
---|
public Integer call() throws Exception
Exception
protected QueueingDataRowHandler getDataRowHandler()
protected Object clone() throws CloneNotSupportedException
Object
内の clone
CloneNotSupportedException
protected void addQueue(DataValueObject dataValueObject) throws InterruptedException
AbstractCollector
の記述:
AbstractCollector<P>
内の addQueue
dataValueObject
- DataValueObject
InterruptedException
|
||||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |