public class DirectQuerySender extends JdbcQuerySenderBase<Connection>
JdbcQuerySenderBase.QueryType
HasStatistics.Action
UNP_END, UNP_START
connection, 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, supportsOutputStreamPassThrough
addParameter, close, getParameterList, getTimeout, sendMessage, setTimeout, toString
getAuthAlias, getConnection, getConnectionWithTimeout, getDatasource, getDatasourceInfo, getDatasourceName, getDbmsSupport, getLogPrefix, getPassword, getPhysicalDestinationName, getUsername, isConnectionsArePooled, isTransacted, iterateOverStatistics, setAuthAlias, setConnectionsArePooled, setDatasourceName, setDbmsSupportFactory, setJmsRealm, setPassword, setTransacted, setUsername
getContext, getJndiEnv, setAuthentication, setCredentials, setInitialContextFactoryName, setJndiAuthAlias, setJndiContextPrefix, setJndiProperties, setName, setPrincipal, setProviderURL, setSecurityProtocol, setUrlPkgPrefixes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
consumesSessionVariable
isSynchronous, sendMessageOrThrow
getName, setName
getApplicationContext, getName
getConfigurationClassLoader
setApplicationContext
getDomain
public void configure() throws ConfigurationException
ISender
configure()
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 IConfigurable
configure
in interface ISender
configure
in class JdbcQuerySenderBase<Connection>
ConfigurationException
public void configure(boolean ignoreSQLInjectionWarning) throws ConfigurationException
ConfigurationException
public void configure(IAdapter adapter) throws ConfigurationException
ConfigurationException
protected String getQuery(Message message) throws SenderException
JdbcQuerySenderBase
getQuery
in class JdbcQuerySenderBase<Connection>
SenderException
public Connection openBlock(PipeLineSession session) throws SenderException, TimeoutException
IBlockEnabledSender
IBlockEnabledSender.sendMessage(Object, Message, PipeLineSession)
is called.SenderException
TimeoutException
public void closeBlock(Connection connection, PipeLineSession session) throws SenderException
IBlockEnabledSender
IBlockEnabledSender.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.SenderException
protected void closeConnectionForSendMessage(Connection connection, PipeLineSession session)
closeConnectionForSendMessage
in class JdbcQuerySenderBase<Connection>
public SenderResult sendMessage(Connection blockHandle, Message message, PipeLineSession session) throws SenderException, TimeoutException
SenderException
TimeoutException
public PipeRunResult sendMessage(Message message, PipeLineSession session, IForwardTarget next) throws SenderException, TimeoutException
SenderException
TimeoutException
protected PipeRunResult sendMessageOnConnection(Connection connection, Message message, PipeLineSession session, IForwardTarget next) throws SenderException, TimeoutException
SenderException
TimeoutException
protected QueryExecutionContext prepareStatementSet(Connection connection, Message message) throws SenderException
SenderException
Copyright © 2023 Frank!Framework. All rights reserved.