public abstract class JdbcIteratingPipeBase extends StringIteratorPipe implements HasPhysicalDestination
Modifier and Type | Class and Description |
---|---|
protected class |
JdbcIteratingPipeBase.MixedQuerySender |
IteratingPipe.ItemCallback, IteratingPipe.StopReason
MessageSendingPipe.LinkMethod
HasStatistics.Action
Modifier and Type | Field and Description |
---|---|
protected JdbcIteratingPipeBase.MixedQuerySender |
querySender |
MAX_ITEMS_REACHED_FORWARD, msgTransformerPool, STOP_CONDITION_MET_FORWARD
INPUT_VALIDATOR_NAME_PREFIX, INPUT_VALIDATOR_NAME_SUFFIX, INPUT_WRAPPER_NAME_PREFIX, INPUT_WRAPPER_NAME_SUFFIX, MAX_RETRY_INTERVAL, MESSAGE_LOG_NAME_PREFIX, MESSAGE_LOG_NAME_SUFFIX, MIN_RETRY_INTERVAL, msgLog, OUTPUT_VALIDATOR_NAME_PREFIX, OUTPUT_VALIDATOR_NAME_SUFFIX, OUTPUT_WRAPPER_NAME_PREFIX, OUTPUT_WRAPPER_NAME_SUFFIX, PIPE_CLEAR_TIMEOUT_MONITOR_EVENT, PIPE_EXCEPTION_MONITOR_EVENT, PIPE_TIMEOUT_MONITOR_EVENT
AUTOMATIC_STREAMING
parameterNamesMustBeUnique
log
LONG_DURATION_MONITORING_EVENT, MESSAGE_SIZE_MONITORING_EVENT, PIPE_EXCEPTION_MONITORING_EVENT
Constructor and Description |
---|
JdbcIteratingPipeBase() |
Modifier and Type | Method and Description |
---|---|
void |
addParameter(Parameter p)
Add a parameter to the list of parameters
|
void |
configure()
checks for correct configuration of forward
|
protected abstract IDataIterator<String> |
getIterator(IDbmsSupport dbmsSupport,
Connection conn,
ResultSet rs) |
protected IDataIterator<String> |
getIterator(Message message,
PipeLineSession session,
Map<String,Object> threadContext) |
String |
getPhysicalDestinationName() |
void |
setAvoidLocking(boolean avoidLocking) |
void |
setBlobCharset(String charset)
Deprecated.
|
void |
setBlobsCompressed(boolean compressed) |
void |
setBlobSmartGet(boolean isSmartBlob) |
void |
setDatasourceName(String datasourceName) |
void |
setJmsRealm(String jmsRealmName)
Deprecated.
|
void |
setLockRows(boolean b) |
void |
setLockWait(int i) |
void |
setQuery(String query)
The SQL query text to be excecuted each time sendMessage() is called.
|
void |
setSqlDialect(String string) |
void |
setTrimSpaces(boolean b) |
void |
setUseNamedParams(Boolean b) |
void |
start()
Perform necessary action to start the pipe.
|
void |
stop()
Perform necessary actions to stop the
Pipe .For instance, closing JMS connections, DBMS connections etc. |
createItemCallBack, getKey, setBlockPrefix, setBlockSize, setBlockSuffix, setCombineBlocks, setEndPosition, setEscapeXml, setLinePrefix, setLineSuffix, setStartPosition
canStreamToNextPipe, getItem, getStopConditionTp, itemToMessage, iterateOverInput, iterateOverStatistics, provideOutputStream, sendMessage, setAddInputToResult, setCloseIteratorOnExit, setCollectResults, setIgnoreExceptions, setItemNoSessionKey, setMaxChildThreads, setMaxItems, setNamespaceDefs, setOmitXmlDeclaration, setOutputType, setParallel, setRemoveDuplicates, setRemoveXmlDeclarationInResults, setSender, setStopConditionXPathExpression, setStyleSheetName, setXpathExpression
canProvideOutputStream, consumesSessionVariable, doPipe, hasSizeStatistics, increaseRetryIntervalAndWait, preserve, propagateName, setAuditTrailNamespaceDefs, setAuditTrailSessionKey, setAuditTrailXPath, setCheckRootTag, setCheckXmlWellFormed, setCorrelationIDNamespaceDefs, setCorrelationIDSessionKey, setCorrelationIDStyleSheet, setCorrelationIDXPath, setExceptionOnResult, setHideMethod, setHideRegex, setInputValidator, setInputWrapper, setLabelNamespaceDefs, setLabelStyleSheet, setLabelXPath, setLinkMethod, setListener, setMaxRetries, setMessageLog, setName, setOutputValidator, setOutputWrapper, setPresumedTimeOutInterval, setResultOnTimeOut, setRetryMaxInterval, setRetryMinInterval, setRetryNamespaceDefs, setRetryXPath, setStreamResultToServlet, setStubFilename, setStubFileName, setTimeOutOnResult, setUseInputForExtract, supportsOutputStreamPassThrough
getNextPipe, getTargetStream, isStreamingActive, provideOutputStream, setStreamingActive
getParameterValue, setIfParam, setIfValue, setOnlyIfSessionKey, setOnlyIfValue, setSkipOnEmptyInput, setUnlessSessionKey, setUnlessValue, skipPipe
createBean, findForward, getAdapter, getEventSourceName, getForwards, getInSizeStatDummyObject, getOutSizeStatDummyObject, getParameterList, registerEvent, registerForward, setApplicationContext, setChompCharSize, setDurationThreshold, setElementToMove, setElementToMoveChain, setElementToMoveSessionKey, setEmptyInputReplacement, setGetInputFromFixedValue, setGetInputFromSessionKey, setLocker, setLogIntermediaryResults, setMaxThreads, setPreserveInput, setRemoveCompactMsgNamespaces, setRestoreMovedElements, setSecLogSessionKeys, setSizeStatistics, setStoreResultInSessionKey, setWriteToSecLog, throwEvent
configureTransactionAttributes, isTransacted, isTransacted, setTransacted, setTransactionTimeout
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getDomain
getName
getChompCharSize, getDurationThreshold, getElementToMove, getElementToMoveChain, getElementToMoveSessionKey, getEmptyInputReplacement, getGetInputFromFixedValue, getGetInputFromSessionKey, getLocker, getSecLogSessionKeys, getStoreResultInSessionKey, isPreserveInput, isRemoveCompactMsgNamespaces, isRestoreMovedElements, isWriteToSecLog, setPipeLine, throwEvent
getMaxThreads
getApplicationContext, getName
getConfigurationClassLoader
getName
getTransactionAttribute, getTransactionTimeout, getTxDef, setTransactionAttribute
protected JdbcIteratingPipeBase.MixedQuerySender querySender
public void configure() throws ConfigurationException
FixedForwardPipe
configure
in interface IConfigurable
configure
in interface IPipe
configure
in class StringIteratorPipe
ConfigurationException
public void start() throws PipeStartException
IPipe
IPipe.configure()
method, for each start and stop command of the
adapter.start
in interface IPipe
start
in class MessageSendingPipe
PipeStartException
public void stop()
IPipe
Pipe
.stop
in interface IPipe
stop
in class MessageSendingPipe
protected abstract IDataIterator<String> getIterator(IDbmsSupport dbmsSupport, Connection conn, ResultSet rs) throws SenderException
SenderException
protected IDataIterator<String> getIterator(Message message, PipeLineSession session, Map<String,Object> threadContext) throws SenderException
getIterator
in class IteratingPipe<String>
SenderException
public void addParameter(Parameter p)
AbstractPipe
addParameter
in class AbstractPipe
public String getPhysicalDestinationName()
getPhysicalDestinationName
in interface HasPhysicalDestination
@Deprecated @ConfigurationWarning(value="We discourage the use of jmsRealms for datasources. To specify a datasource other then the default, use the datasourceName attribute directly, instead of referring to a realm") public void setJmsRealm(String jmsRealmName)
public void setQuery(String query)
@ReferTo(value=FixedQuerySender.class) public void setDatasourceName(String datasourceName)
@ReferTo(value=FixedQuerySender.class) public void setUseNamedParams(Boolean b)
@ReferTo(value=FixedQuerySender.class) public void setTrimSpaces(boolean b)
@ReferTo(value=FixedQuerySender.class) public void setSqlDialect(String string)
@ReferTo(value=FixedQuerySender.class) public void setLockRows(boolean b)
@ReferTo(value=FixedQuerySender.class) public void setLockWait(int i)
@ReferTo(value=FixedQuerySender.class) public void setAvoidLocking(boolean avoidLocking)
@ReferTo(value=JdbcQuerySenderBase.class) @Deprecated public void setBlobCharset(String charset)
@ReferTo(value=JdbcQuerySenderBase.class) public void setBlobSmartGet(boolean isSmartBlob)
@ReferTo(value=JdbcQuerySenderBase.class) public void setBlobsCompressed(boolean compressed)
Copyright © 2023 Frank!Framework. All rights reserved.