public class DirectQuerySender extends JdbcQuerySenderBase<Connection>
JdbcQuerySenderBase.QueryTypeHasStatistics.ActionUNP_END, UNP_STARTconnection, paramList| Constructor and Description |
|---|
DirectQuerySender() |
| Modifier and Type | Method and Description |
|---|---|
void |
closeBlock(Connection connection,
PipeLineSession session)
close the resource that is opened by
IBlockEnabledSender.openBlock(PipeLineSession). |
protected void |
closeConnectionForSendMessage(Connection connection,
PipeLineSession session) |
void |
configure()
configure() is called once at startup of the framework in the configure method of the owner of this sender. |
void |
configure(boolean ignoreSQLInjectionWarning) |
void |
configure(IAdapter adapter) |
protected String |
getQuery(Message message)
Obtain a query to be executed.
|
Connection |
openBlock(PipeLineSession session)
open a resource that can be used multiple times when
IBlockEnabledSender.sendMessage(Object, Message, PipeLineSession) is called. |
protected QueryExecutionContext |
prepareStatementSet(Connection connection,
Message message) |
SenderResult |
sendMessage(Connection blockHandle,
Message message,
PipeLineSession session) |
PipeRunResult |
sendMessage(Message message,
PipeLineSession session,
IForwardTarget next) |
protected PipeRunResult |
sendMessageOnConnection(Connection connection,
Message message,
PipeLineSession session,
IForwardTarget next) |
adjustQueryAndParameterListForNamedParameters, canProvideOutputStream, closeStatementSet, convertQuery, executeOtherQuery, executeOtherQuery, executePackageQuery, executeSelectQuery, executeSelectQuery, executeStatementSet, executeUpdateBlobQuery, executeUpdateClobQuery, fillParamArray, getBatchSize, getCallWithRowIdReturned, getConnectionForSendMessage, getQueryExecutionContext, getQueryTypeEnum, getResult, getResult, getResult, getReturnedColumns, getStatement, open, prepareQuery, prepareQueryWithColumnsReturned, prepareQueryWithResultSet, provideOutputStream, setAvoidLocking, setBlobBase64Direction, setBlobCharset, setBlobColumn, setBlobsCompressed, setBlobSessionKey, setBlobSmartGet, setClobColumn, setClobSessionKey, setCloseInputstreamOnExit, setCloseOutputstreamOnExit, setColumnsReturned, setIncludeFieldDefinition, setLockRows, setLockWait, setMaxRows, setNullValue, setOutputFormat, setPackageContent, setPrettyPrint, setQueryType, setResultQuery, setRowIdSessionKey, setScalar, setScalarExtended, setSqlDialect, setStartRow, setStreamCharset, setStreamResultToServlet, setSynchronous, setTrimSpaces, setUseNamedParams, supportsOutputStreamPassThroughaddParameter, close, getParameterList, getTimeout, sendMessage, setTimeout, toStringgetAuthAlias, getConnection, getConnectionWithTimeout, getDatasource, getDatasourceInfo, getDatasourceName, getDbmsSupport, getLogPrefix, getPassword, getPhysicalDestinationName, getUsername, isConnectionsArePooled, isTransacted, iterateOverStatistics, setAuthAlias, setConnectionsArePooled, setDatasourceName, setDbmsSupportFactory, setJmsRealm, setPassword, setTransacted, setUsernamegetContext, getJndiEnv, setAuthentication, setCredentials, setInitialContextFactoryName, setJndiAuthAlias, setJndiContextPrefix, setJndiProperties, setName, setPrincipal, setProviderURL, setSecurityProtocol, setUrlPkgPrefixesclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitconsumesSessionVariableisSynchronous, sendMessageOrThrowgetName, setNamegetApplicationContext, getNamegetConfigurationClassLoadersetApplicationContextgetDomainpublic void configure()
throws ConfigurationException
ISenderconfigure() is called once at startup of the framework in the configure method of the owner of this sender.
Purpose of this method is to check whether the static configuration of the sender is correct.
As much as possible class-instantiating should take place in the configure() or open() method, to improve performance.configure in interface IConfigurableconfigure in interface ISenderconfigure in class JdbcQuerySenderBase<Connection>ConfigurationExceptionpublic void configure(boolean ignoreSQLInjectionWarning)
throws ConfigurationException
ConfigurationExceptionpublic void configure(IAdapter adapter) throws ConfigurationException
ConfigurationExceptionprotected String getQuery(Message message) throws SenderException
JdbcQuerySenderBasegetQuery in class JdbcQuerySenderBase<Connection>SenderExceptionpublic Connection openBlock(PipeLineSession session) throws SenderException, TimeoutException
IBlockEnabledSenderIBlockEnabledSender.sendMessage(Object, Message, PipeLineSession) is called.SenderExceptionTimeoutExceptionpublic void closeBlock(Connection connection, PipeLineSession session) throws SenderException
IBlockEnabledSenderIBlockEnabledSender.openBlock(PipeLineSession). It is important that this method is always called
after processing with the blockHandle ends. It should effectively be called in a finally clause of a try around the openBlock.SenderExceptionprotected void closeConnectionForSendMessage(Connection connection, PipeLineSession session)
closeConnectionForSendMessage in class JdbcQuerySenderBase<Connection>public SenderResult sendMessage(Connection blockHandle, Message message, PipeLineSession session) throws SenderException, TimeoutException
SenderExceptionTimeoutExceptionpublic PipeRunResult sendMessage(Message message, PipeLineSession session, IForwardTarget next) throws SenderException, TimeoutException
SenderExceptionTimeoutExceptionprotected PipeRunResult sendMessageOnConnection(Connection connection, Message message, PipeLineSession session, IForwardTarget next) throws SenderException, TimeoutException
SenderExceptionTimeoutExceptionprotected QueryExecutionContext prepareStatementSet(Connection connection, Message message) throws SenderException
SenderExceptionCopyright © 2023 Frank!Framework. All rights reserved.