Package org.frankframework.jdbc

Class ResultSet2FileSender

java.lang.Object

org.frankframework.jdbc.JdbcFacade

org.frankframework.jdbc.AbstractJdbcSender<QueryExecutionContext>

org.frankframework.jdbc.AbstractJdbcQuerySender<QueryExecutionContext>

org.frankframework.jdbc.FixedQuerySender

org.frankframework.jdbc.ResultSet2FileSender

All Implemented Interfaces:

FrankElement, HasApplicationContext, HasName, HasPhysicalDestination, IBlockEnabledSender<QueryExecutionContext>, IConfigurable, IScopeProvider, ISender, ISenderWithParameters, IWithParameters, IXAEnabled, NameAware, ConfigurableLifecycle, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle

public class ResultSet2FileSender
extends FixedQuerySender

QuerySender that writes each row in a ResultSet to a file.

Author:

Peter Leeuwenburgh

Nested Class Summary

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

AbstractJdbcQuerySender.QueryType

Field Summary

Fields

Modifier and Type	Field	Description
protected byte[]	eolArray

Fields inherited from class org.frankframework.jdbc.AbstractJdbcQuerySender

UNP_END, UNP_START

Fields inherited from class org.frankframework.jdbc.AbstractJdbcSender

connection, paramList

Fields inherited from class org.frankframework.jdbc.JdbcFacade

log

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
ResultSet2FileSender()

Method Summary

Modifier and Type	Method	Description
void	configure()	Configure this component.
protected SenderResult	executeStatementSet(QueryExecutionContext queryExecutionContext, Message message, PipeLineSession session)
void	setAppend(boolean b)	If set true and the file already exists, the resultset rows are written to the end of the file.
void	setFilenameSessionKey(String filenameSessionKey)	Key of session variable that contains the name of the file to use.
void	setMaxRecordsSessionKey(String maxRecordsSessionKey)	If set (and >=0), this session key contains the maximum number of records which are processed.
void	setStatusFieldType(String statusFieldType)	type of the optional status field which is set after the row is written to the file: timestamp

Methods inherited from class org.frankframework.jdbc.FixedQuerySender

closeBlock, closeStatementSet, getQuery, openBlock, sendMessage, setBatchSize, setQuery

Methods inherited from class org.frankframework.jdbc.AbstractJdbcQuerySender

adjustQueryAndParameterListForNamedParameters, buildDb2XMLWriter, closeConnectionForSendMessage, convertQuery, executeOtherQuery, executeOtherQuery, executePackageQuery, executeSelectQuery, executeUpdateBlobQuery, executeUpdateClobQuery, fillParamArray, getBatchSize, getCallWithRowIdReturned, getConnectionForSendMessage, getQueryExecutionContext, getResult, getResult, getReturnedColumns, getStatement, getUpdateStatementResult, prepareQuery, prepareQueryWithColumnsReturned, prepareQueryWithResultSet, setAvoidLocking, setBlobBase64Direction, setBlobCharset, setBlobColumn, setBlobsCompressed, setBlobSessionKey, setBlobSmartGet, setClobColumn, setClobSessionKey, setCloseOutputstreamOnExit, setColumnsReturned, setIncludeFieldDefinition, setLockRows, setLockWait, setMaxRows, setNullValue, setOutputFormat, setPackageContent, setPrettyPrint, setQueryType, setResultQuery, setRowIdSessionKey, setScalar, setScalarExtended, setSqlDialect, setStartRow, setStreamCharset, setSynchronous, setTrimSpaces, setUseNamedParams, start

Methods inherited from class org.frankframework.jdbc.AbstractJdbcSender

addParameter, getConnection, getParameterList, sendMessage, setTimeout, stop, toString

Methods inherited from class org.frankframework.jdbc.JdbcFacade

getConnectionWithTimeout, getDatasource, getDatasourceName, getDbmsSupport, getLogPrefix, getPassword, getPhysicalDestinationName, isConnectionsArePooled, isRunning, isTransacted, setAuthAlias, setConnectionsArePooled, setDatasourceName, setDbmsSupportFactory, setName, setPassword, setTransacted, setUsername

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.lifecycle.ConfigurableLifecycle

getPhase, isAutoStartup, isConfigured

Methods inherited from interface org.frankframework.core.FrankElement

addConfigWarning

Methods inherited from interface org.frankframework.core.HasApplicationContext

getApplicationContext, getConfigurationClassLoader

Methods inherited from interface org.frankframework.core.HasName

getName

Methods inherited from interface org.frankframework.core.ISender

isSynchronous, sendMessageOrThrow

Methods inherited from interface org.frankframework.core.ISenderWithParameters

consumesSessionVariable

Methods inherited from interface org.frankframework.core.NameAware

setName

Methods inherited from interface org.springframework.context.SmartLifecycle

stop

Field Details

eolArray

protected byte[] eolArray

Constructor Details

ResultSet2FileSender

public ResultSet2FileSender()

Method Details

configure

public void configure()
               throws ConfigurationException

Description copied from interface: IConfigurable

Configure this component.

configure() is called once at startup of the framework in the configure method of the owner of this IConfigurable. Purpose of this method is to check whether the static configuration of the object is correct. As much as possible class-instantiating should take place in the configure(), to improve performance.

In the case of a container, this will propagate the configure signal to all components that apply.

Specified by:

configure in interface IConfigurable

Overrides:

configure in class FixedQuerySender

Throws:

ConfigurationException - in case it was not able to configure the component.

executeStatementSet

protected SenderResult executeStatementSet(@Nonnull
 QueryExecutionContext queryExecutionContext,
 @Nonnull
 Message message,
 @Nonnull
 PipeLineSession session)
                                    throws SenderException

Overrides:

executeStatementSet in class AbstractJdbcQuerySender<QueryExecutionContext>

Throws:

SenderException

setStatusFieldType

public void setStatusFieldType(String statusFieldType)

type of the optional status field which is set after the row is written to the file: timestamp

setFilenameSessionKey

public void setFilenameSessionKey(String filenameSessionKey)

Key of session variable that contains the name of the file to use.

setAppend

public void setAppend(boolean b)

If set true and the file already exists, the resultset rows are written to the end of the file.

Default value

false

setMaxRecordsSessionKey

public void setMaxRecordsSessionKey(String maxRecordsSessionKey)

If set (and >=0), this session key contains the maximum number of records which are processed. If query contains a group field (3), then also following records with the same group field value as the last record are processed