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 AbstractJdbcQuerySender

AbstractJdbcQuerySender.QueryType

Field Summary

Fields

Modifier and Type	Field	Description
protected byte[]	eolArray

Fields inherited from class AbstractJdbcQuerySender

UNP_END, UNP_START

Fields inherited from class AbstractJdbcSender

connection, paramList

Fields inherited from class 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(@NonNull QueryExecutionContext queryExecutionContext, @NonNull Message message, @NonNull 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 FixedQuerySender

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

Methods inherited from class AbstractJdbcQuerySender

adjustQueryAndParameterListForNamedParameters, buildDb2XMLWriter, closeConnectionForSendMessage, convertQuery, executeOtherQuery, executeOtherQuery, executePackageQuery, executeSelectQuery, executeUpdateBlobQuery, executeUpdateClobQuery, fillParamArray, getBatchSize, getCallWithRowIdReturned, getConnectionForSendMessage, getQueryExecutionContext, getResult, getReturnedColumns, getStatement, getUpdateStatementResult, prepareQuery, prepareQueryWithColumnsReturned, prepareQueryWithResultSet, setAvoidLocking, setBlobBase64Direction, setBlobCharset, setBlobColumn, setBlobsCompressed, setBlobSessionKey, setBlobSmartGet, setClobColumn, setClobSessionKey, 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 AbstractJdbcSender

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

Methods inherited from class JdbcFacade

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

Methods inherited from class Object

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

Methods inherited from interface org.springframework.context.ApplicationContextAware

setApplicationContext

Methods inherited from interface ConfigurableLifecycle

getPhase, isAutoStartup, isConfigured

Methods inherited from interface FrankElement

addConfigWarning

Methods inherited from interface HasApplicationContext

getApplicationContext, getConfigurationClassLoader

Methods inherited from interface HasName

getName

Methods inherited from interface ISender

isSynchronous, sendMessageOrThrow

Methods inherited from interface ISenderWithParameters

consumesSessionVariable

Methods inherited from interface NameAware

setName

Methods inherited from interface org.springframework.context.SmartLifecycle

isPauseable, 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