Package org.frankframework.jdbc

Class FixedQuerySender

java.lang.Object

org.frankframework.jndi.JndiBase

org.frankframework.jdbc.JdbcFacade

org.frankframework.jdbc.JdbcSenderBase<H>

org.frankframework.jdbc.JdbcQuerySenderBase<QueryExecutionContext>

org.frankframework.jdbc.FixedQuerySender

All Implemented Interfaces:

AdapterAware, HasPhysicalDestination, IBlockEnabledSender<QueryExecutionContext>, IConfigurable, IConfigurationAware, INamedObject, IScopeProvider, ISender, ISenderWithParameters, IWithParameters, IXAEnabled, HasStatistics, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

Direct Known Subclasses:

ResultSet2FileSender, StoredProcedureQuerySender

public class FixedQuerySender
extends JdbcQuerySenderBase<QueryExecutionContext>

QuerySender that assumes a fixed query, possibly with attributes.

NOTE: See DB2XMLWriter for ResultSet!

Since:

4.1

Author:

Gerrit van Brakel

Parameters

All parameters present are applied to the query to be executed.

Nested Class Summary

Nested classes/interfaces inherited from class org.frankframework.jdbc.JdbcQuerySenderBase

JdbcQuerySenderBase.QueryType

Field Summary

Fields inherited from class org.frankframework.jdbc.JdbcQuerySenderBase

UNP_END, UNP_START

Fields inherited from class org.frankframework.jdbc.JdbcSenderBase

connection, paramList

Fields inherited from class org.frankframework.jndi.JndiBase

log

Constructor Summary

Constructors

Constructor	Description
FixedQuerySender()

Method Summary

Modifier and Type	Method	Description
void	closeBlock(QueryExecutionContext blockHandle, PipeLineSession session)	close the resource that is opened by IBlockEnabledSender.openBlock(PipeLineSession).
protected void	closeStatementSet(QueryExecutionContext statementSet)
void	configure()	configure() is called once at startup of the framework in the configure method of the owner of this sender.
int	getBatchSize()
String	getQuery()
protected String	getQuery(Message message)	Obtain a query to be executed.
QueryExecutionContext	openBlock(PipeLineSession session)	open a resource that can be used multiple times when IBlockEnabledSender.sendMessage(Object, Message, PipeLineSession) is called.
SenderResult	sendMessage(QueryExecutionContext blockHandle, Message message, PipeLineSession session)
void	setBatchSize(int batchSize)	When set larger than 0 and used as a child of an IteratingPipe, then the database calls are made in batches of this size.
void	setQuery(String query)	The SQL query text to be executed each time sendMessage() is called

Methods inherited from class org.frankframework.jdbc.JdbcQuerySenderBase

adjustQueryAndParameterListForNamedParameters, buildDb2XMLWriter, closeConnectionForSendMessage, convertQuery, executeOtherQuery, executeOtherQuery, executePackageQuery, executeSelectQuery, executeSelectQuery, executeStatementSet, executeUpdateBlobQuery, executeUpdateClobQuery, fillParamArray, getBlobBase64Direction, getBlobCharset, getBlobColumn, getBlobSessionKey, getCallWithRowIdReturned, getClobColumn, getClobSessionKey, getColumnsReturned, getColumnsReturnedList, getConnectionForSendMessage, getLockWait, getMaxRows, getNullValue, getOutputFormat, getPackageContent, getQueryExecutionContext, getQueryType, getResult, getResult, getResult, getResultQuery, getReturnedColumns, getRowIdSessionKey, getSqlDialect, getStartRow, getStatement, getStreamCharset, getUpdateStatementResult, getUseNamedParams, isAvoidLocking, isBlobsCompressed, isBlobSmartGet, isCloseInputstreamOnExit, isCloseOutputstreamOnExit, isIncludeFieldDefinition, isLockRows, isPrettyPrint, isScalar, isScalarExtended, isStreamResultToServlet, isSynchronous, isTrimSpaces, open, prepareQuery, prepareQueryWithColumnsReturned, prepareQueryWithResultSet, 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

Methods inherited from class org.frankframework.jdbc.JdbcSenderBase

addParameter, close, getAdapter, getConnection, getParameterList, getTimeout, sendMessage, setAdapter, setConfigurationMetrics, setTimeout, toString

Methods inherited from class org.frankframework.jdbc.JdbcFacade

getAuthAlias, getConnectionWithTimeout, getDatasource, getDataSourceFactory, getDatasourceInfo, getDatasourceName, getDbmsSupport, getDomain, getLogPrefix, getPassword, getPhysicalDestinationName, getUsername, isConnectionsArePooled, isTransacted, setAuthAlias, setConnectionsArePooled, setDataSourceFactory, setDatasourceName, setDbmsSupportFactory, setJmsRealm, setPassword, setTransacted, setUsername

Methods inherited from class org.frankframework.jndi.JndiBase

getApplicationContext, getAuthentication, getConfigurationClassLoader, getContext, getCredentials, getInitialContextFactoryName, getJmsRealmName, getJndiAuthAlias, getJndiContextPrefix, getJndiEnv, getJndiProperties, getName, getPrincipal, getProviderURL, getSecurityProtocol, getUrlPkgPrefixes, setApplicationContext, setAuthentication, setCredentials, setInitialContextFactoryName, setJndiAuthAlias, setJndiContextPrefix, setJndiProperties, setName, setPrincipal, setProviderURL, setSecurityProtocol, setUrlPkgPrefixes

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.context.ApplicationContextAware

setApplicationContext

Methods inherited from interface org.frankframework.core.IConfigurationAware

getApplicationContext, getName

Methods inherited from interface org.frankframework.core.INamedObject

getName, setName

Methods inherited from interface org.frankframework.core.IScopeProvider

getConfigurationClassLoader

Methods inherited from interface org.frankframework.core.ISender

sendMessageOrThrow

Methods inherited from interface org.frankframework.core.ISenderWithParameters

consumesSessionVariable

Constructor Details

FixedQuerySender

public FixedQuerySender()

Method Details

configure

public void configure()
               throws ConfigurationException

Description copied from interface: 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.

Specified by:

configure in interface IConfigurable

Specified by:

configure in interface ISender

Overrides:

configure in class JdbcQuerySenderBase<QueryExecutionContext>

Throws:

ConfigurationException

getQuery

protected String getQuery(Message message)

Description copied from class: JdbcQuerySenderBase

Obtain a query to be executed. Method-stub to be overridden in descender-classes.

Specified by:

getQuery in class JdbcQuerySenderBase<QueryExecutionContext>

openBlock

public QueryExecutionContext openBlock(PipeLineSession session)
                                throws SenderException,
TimeoutException

Description copied from interface: IBlockEnabledSender

open a resource that can be used multiple times when IBlockEnabledSender.sendMessage(Object, Message, PipeLineSession) is called.

Throws:

SenderException

TimeoutException

closeBlock

public void closeBlock(QueryExecutionContext blockHandle,
 PipeLineSession session)

Description copied from interface: IBlockEnabledSender

close the resource that is opened by 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.

closeStatementSet

protected void closeStatementSet(QueryExecutionContext statementSet)

Overrides:

closeStatementSet in class JdbcQuerySenderBase<QueryExecutionContext>

sendMessage

public SenderResult sendMessage(QueryExecutionContext blockHandle,
 Message message,
 PipeLineSession session)
                         throws SenderException,
TimeoutException

Throws:

SenderException

TimeoutException

setQuery

public void setQuery(String query)

The SQL query text to be executed each time sendMessage() is called

setBatchSize

public void setBatchSize(int batchSize)

When set larger than 0 and used as a child of an IteratingPipe, then the database calls are made in batches of this size. Only for queryType=other.

Default value

0

getQuery

public String getQuery()

getBatchSize

public int getBatchSize()

Overrides:

getBatchSize in class JdbcQuerySenderBase<QueryExecutionContext>