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 Connection |
getConnectionForSendMessage(Connection blockHandle) |
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. |
SenderResult |
sendMessage(Connection blockHandle,
Message message,
PipeLineSession session) |
PipeRunResult |
sendMessage(Message message,
PipeLineSession session,
IForwardTarget next) |
adjustQueryAndParameterListForNamedParameters, canProvideOutputStream, closeStatementSet, convertQuery, executeOtherQuery, executeOtherQuery, executePackageQuery, executeSelectQuery, executeSelectQuery, executeStatementSet, executeUpdateBlobQuery, executeUpdateClobQuery, fillParamArray, getBatchSize, getCallWithRowIdReturned, getQueryExecutionContext, getQueryTypeEnum, getResult, getResult, getResult, getReturnedColumns, getStatement, open, prepareQuery, prepareStatementSet, provideOutputStream, sendMessageOnConnection, 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 Connection getConnectionForSendMessage(Connection blockHandle) throws JdbcException, TimeoutException
getConnectionForSendMessage in class JdbcQuerySenderBase<Connection>JdbcExceptionTimeoutExceptionprotected void closeConnectionForSendMessage(Connection connection, PipeLineSession session) throws JdbcException, TimeoutException
closeConnectionForSendMessage in class JdbcQuerySenderBase<Connection>JdbcExceptionTimeoutExceptionpublic SenderResult sendMessage(Connection blockHandle, Message message, PipeLineSession session) throws SenderException, TimeoutException
SenderExceptionTimeoutExceptionpublic PipeRunResult sendMessage(Message message, PipeLineSession session, IForwardTarget next) throws SenderException, TimeoutException
SenderExceptionTimeoutExceptionCopyright © 2023 Frank!Framework. All rights reserved.