public class ResultSet2FileSender extends FixedQuerySender
JdbcQuerySenderBase.QueryType
HasStatistics.Action
Modifier and Type | Field and Description |
---|---|
protected byte[] |
eolArray |
UNP_END, UNP_START
connection, paramList
Constructor and Description |
---|
ResultSet2FileSender() |
Modifier and Type | Method and Description |
---|---|
void |
configure()
configure() is called once at startup of the framework in the configure method of the owner of this sender. |
protected PipeRunResult |
executeStatementSet(QueryExecutionContext queryExecutionContext,
Message message,
PipeLineSession session,
IForwardTarget next) |
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 |
setFileNameSessionKey(String filenameSessionKey)
Deprecated.
|
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
|
canProvideOutputStream, closeBlock, closeStatementSet, getQuery, openBlock, sendMessage, sendMessage, setBatchSize, setQuery
adjustQueryAndParameterListForNamedParameters, closeConnectionForSendMessage, convertQuery, executeOtherQuery, executeOtherQuery, executePackageQuery, executeSelectQuery, executeSelectQuery, 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 FixedQuerySender
ConfigurationException
protected PipeRunResult executeStatementSet(@Nonnull QueryExecutionContext queryExecutionContext, @Nonnull Message message, @Nonnull PipeLineSession session, @Nullable IForwardTarget next) throws SenderException, TimeoutException
executeStatementSet
in class JdbcQuerySenderBase<QueryExecutionContext>
SenderException
TimeoutException
public void setStatusFieldType(String statusFieldType)
@Deprecated @ConfigurationWarning(value="attribute \'fileNameSessionKey\' is replaced with \'filenameSessionKey\'") public void setFileNameSessionKey(String filenameSessionKey)
public void setFilenameSessionKey(String filenameSessionKey)
public void setAppend(boolean b)
true
and the file already exists, the resultset rows are written to the end of the file.public void setMaxRecordsSessionKey(String maxRecordsSessionKey)
query
contains a group field (3), then also following records with the same group field value as the last record are processedCopyright © 2023 Frank!Framework. All rights reserved.