public abstract class Result2LobWriterBase extends ResultWriter implements org.springframework.context.ApplicationContextAware
resultHandler
that writes the transformed record to a LOB.Modifier and Type | Field and Description |
---|---|
protected Map<String,Connection> |
openConnections |
protected Map<String,Object> |
openLobHandles |
protected Map<String,ResultSet> |
openResultSets |
protected FixedQuerySender |
querySender |
log, paramList
Constructor and Description |
---|
Result2LobWriterBase() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure() |
protected Writer |
createWriter(PipeLineSession session,
String streamId) |
String |
finalizeResult(PipeLineSession session,
String streamId,
boolean error)
Called when all records in the original file are handled.
|
protected abstract Object |
getLobHandle(IDbmsSupport dbmsSupport,
ResultSet rs) |
String |
getPhysicalDestinationName() |
protected abstract Writer |
getWriter(IDbmsSupport dbmsSupport,
Object lobHandle,
ResultSet rs) |
void |
open() |
void |
setDatasourceName(String datasourceName) |
void |
setJmsRealm(String jmsRealmName) |
void |
setQuery(String query)
The SQL query text
|
protected abstract void |
updateLob(IDbmsSupport dbmsSupport,
Object lobHandle,
ResultSet rs) |
closeBlock, closeDocument, closeRecordType, getWriter, handleResult, openBlock, openDocument, openRecordType, replacePattern, setBlockNamePattern, setOnCloseBlock, setOnCloseDocument, setOnOpenBlock, setOnOpenDocument, writeNewLine
addParameter, getParameterList, hasPrefix, isDefault, setBlockByRecordType, setDefault, setName, setPipe, setPrefix, setSuffix
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
setApplicationContext
isBlockByRecordType
getName
getApplicationContext, getName
getConfigurationClassLoader
protected Map<String,Connection> openConnections
protected FixedQuerySender querySender
public void configure() throws ConfigurationException
configure
in interface IConfigurable
configure
in class AbstractResultHandler
ConfigurationException
public void open() throws SenderException
open
in interface IResultHandler
open
in class AbstractResultHandler
SenderException
public void close() throws SenderException
close
in interface IResultHandler
close
in class AbstractResultHandler
SenderException
protected abstract Object getLobHandle(IDbmsSupport dbmsSupport, ResultSet rs) throws SenderException
SenderException
protected abstract Writer getWriter(IDbmsSupport dbmsSupport, Object lobHandle, ResultSet rs) throws SenderException
SenderException
protected abstract void updateLob(IDbmsSupport dbmsSupport, Object lobHandle, ResultSet rs) throws SenderException
SenderException
protected Writer createWriter(PipeLineSession session, String streamId) throws Exception
createWriter
in class ResultWriter
Exception
public String finalizeResult(PipeLineSession session, String streamId, boolean error) throws Exception
IResultHandler
finalizeResult
in interface IResultHandler
finalizeResult
in class ResultWriter
session
- current PipeLineSessionstreamId
- identification of the original file/stream/message containing the untransformed recordsException
public void setQuery(String query)
@ReferTo(value=FixedQuerySender.class) public void setDatasourceName(String datasourceName)
@ReferTo(value=FixedQuerySender.class) public String getPhysicalDestinationName()
@ReferTo(value=FixedQuerySender.class) public void setJmsRealm(String jmsRealmName)
Copyright © 2023 Frank!Framework. All rights reserved.