public class ResultSet2FileSender extends FixedQuerySender
JdbcQuerySenderBase.QueryTypeHasStatistics.Action| Modifier and Type | Field and Description |
|---|---|
protected byte[] |
eolArray |
UNP_END, UNP_STARTconnection, 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, prepareStatementSet, sendMessage, sendMessage, sendMessageOnConnection, setBatchSize, setQueryadjustQueryAndParameterListForNamedParameters, closeConnectionForSendMessage, convertQuery, executeOtherQuery, executeOtherQuery, executePackageQuery, executeSelectQuery, executeSelectQuery, executeUpdateBlobQuery, executeUpdateClobQuery, fillParamArray, getBatchSize, getCallWithRowIdReturned, getConnectionForSendMessage, getQueryExecutionContext, getQueryTypeEnum, getResult, getResult, getResult, getReturnedColumns, getStatement, open, prepareQuery, 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, supportsOutputStreamPassThroughaddParameter, close, getParameterList, getTimeout, sendMessage, setTimeout, toStringgetAuthAlias, getConnection, getConnectionWithTimeout, getDatasource, getDatasourceInfo, getDatasourceName, getDbmsSupport, getLogPrefix, getPassword, getPhysicalDestinationName, getUsername, isConnectionsArePooled, isTransacted, iterateOverStatistics, setAuthAlias, setConnectionsArePooled, setDatasourceName, setDbmsSupportFactory, setJmsRealm, setPassword, setTransacted, setUsernamegetContext, getJndiEnv, setAuthentication, setCredentials, setInitialContextFactoryName, setJndiAuthAlias, setJndiContextPrefix, setJndiProperties, setName, setPrincipal, setProviderURL, setSecurityProtocol, setUrlPkgPrefixesclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitconsumesSessionVariableisSynchronous, sendMessageOrThrowgetName, setNamegetApplicationContext, getNamegetConfigurationClassLoadersetApplicationContextgetDomainpublic void configure()
throws ConfigurationException
ISenderconfigure() 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 IConfigurableconfigure in interface ISenderconfigure in class FixedQuerySenderConfigurationExceptionprotected PipeRunResult executeStatementSet(QueryExecutionContext queryExecutionContext, Message message, PipeLineSession session, IForwardTarget next) throws SenderException, TimeoutException
executeStatementSet in class JdbcQuerySenderBase<QueryExecutionContext>SenderExceptionTimeoutExceptionpublic 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.