Package org.frankframework.jdbc

Class AbstractJdbcMessageBrowser<M>

java.lang.Object

org.frankframework.jdbc.JdbcFacade

org.frankframework.jdbc.AbstractJdbcMessageBrowser<M>

All Implemented Interfaces:

FrankElement, HasApplicationContext, HasName, HasPhysicalDestination, IConfigurable, IMessageBrowser<M>, IScopeProvider, IXAEnabled, NameAware, ConfigurableLifecycle, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle

Direct Known Subclasses:

JdbcTableMessageBrowser

public abstract class AbstractJdbcMessageBrowser<M>
extends JdbcFacade
implements IMessageBrowser<M>

JDBC implementation of IMessageBrowser.

Author:

Gerrit van Brakel

Nested Class Summary

Nested classes/interfaces inherited from interface org.frankframework.core.IMessageBrowser

IMessageBrowser.HideMethod, IMessageBrowser.SortOrder, IMessageBrowser.StorageType

Field Summary

Fields

Modifier and Type	Field	Description
protected String	checkCorrelationIdQuery
protected String	checkMessageIdQuery
protected static final String	CONTROL_PROPERTY_PREFIX
protected String	deleteQuery
protected String	getMessageCountQuery
protected static final String	PROPERTY_ASSUME_PRIMARY_KEY_UNIQUE
protected static final String	PROPERTY_USE_PARAMETERS
protected String	selectContextQuery
protected String	selectDataQuery

Fields inherited from class org.frankframework.jdbc.JdbcFacade

log

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
AbstractJdbcMessageBrowser()

Method Summary

Modifier and Type	Method	Description
protected int	applyStandardParameters(PreparedStatement stmt, boolean moreParametersFollow, boolean primaryKeyIsPartOfClause)
protected int	applyStandardParameters(PreparedStatement stmt, String paramValue, boolean primaryKeyIsPartOfClause)
RawMessageWrapper<M>	browseMessage(String storageKey)	Retrieves the message, but does not delete.
void	configure()	Configure this component.
boolean	containsCorrelationId(String correlationId)
boolean	containsMessageId(String originalMessageId)	Check if the storage contains message with the given original messageId (as passed to storeMessage).
void	copyFacadeSettings(JdbcFacade facade)
protected String	createSelector()
void	deleteMessage(String storageKey)	Deletes the message.
IMessageBrowsingIteratorItem	getContext(String storageKey)	Retrieves the message context as an iteratorItem.
protected DataSource	getDatasource()
IMessageBrowsingIterator	getIterator()	Gets an enumeration of messages.
IMessageBrowsingIterator	getIterator(Date startTime, Date endTime, IMessageBrowser.SortOrder order)
protected String	getLogPrefix()
int	getMessageCount()
protected abstract String	getSelectListQuery(IDbmsSupport dbmsSupport, Date startTime, Date endTime, IMessageBrowser.SortOrder order)
protected String	getWhereClause(String clause, boolean primaryKeyIsPartOfClause)
protected abstract RawMessageWrapper<M>	retrieveObject(String storageKey, ResultSet rs, int columnIndex)
void	setCommentField(String string)	The name of the column comments are stored in
void	setCorrelationIdField(String string)	The name of the column correlation-ids are stored in
void	setDateField(String string)	The name of the column the timestamp is stored in
void	setExpiryDateField(String string)	The name of the column the timestamp for expiry is stored in
protected void	setHostField(String hostField)
void	setIdField(String idField)	The name of the column messageIds are stored in
void	setKeyField(String string)	The name of the column that contains the primary key of the table
void	setLabelField(String string)	The name of the column labels are stored in
void	setMessageField(String messageField)	The name of the column message themselves are stored in
protected void	setOperationControls()
void	setOrder(IMessageBrowser.SortOrder value)
void	setPrefix(String string)	Prefix to be prefixed on all database objects (tables, indices, sequences), e.g. to access a different Oracle schema
protected void	setSlotId(String string)
protected void	setSlotIdField(String string)
protected void	setType(String type)
protected void	setTypeField(String typeField)

Methods inherited from class org.frankframework.jdbc.JdbcFacade

getConnection, getConnectionWithTimeout, getDatasourceName, getDbmsSupport, getPassword, getPhysicalDestinationName, isConnectionsArePooled, isRunning, isTransacted, setAuthAlias, setConnectionsArePooled, setDatasourceName, setDbmsSupportFactory, setName, setPassword, setTransacted, setUsername, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, 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.IMessageBrowser

getHideMethod, getHideRegex, getStorageFields, setHideMethod, setHideRegex

Methods inherited from interface org.frankframework.core.IXAEnabled

isTransacted

Methods inherited from interface org.springframework.context.SmartLifecycle

stop

Field Details

deleteQuery

protected String deleteQuery

selectContextQuery

protected String selectContextQuery

selectDataQuery

protected String selectDataQuery

checkMessageIdQuery

protected String checkMessageIdQuery

checkCorrelationIdQuery

protected String checkCorrelationIdQuery

getMessageCountQuery

protected String getMessageCountQuery

CONTROL_PROPERTY_PREFIX

protected static final String CONTROL_PROPERTY_PREFIX

See Also:

• Constant Field Values

PROPERTY_USE_PARAMETERS

protected static final String PROPERTY_USE_PARAMETERS

See Also:

• Constant Field Values

PROPERTY_ASSUME_PRIMARY_KEY_UNIQUE

protected static final String PROPERTY_ASSUME_PRIMARY_KEY_UNIQUE

See Also:

• Constant Field Values

Constructor Details

AbstractJdbcMessageBrowser

public AbstractJdbcMessageBrowser()

Method Details

getLogPrefix

protected String getLogPrefix()

Overrides:

getLogPrefix in class JdbcFacade

setOperationControls

protected void setOperationControls()

copyFacadeSettings

public void copyFacadeSettings(JdbcFacade facade)
                        throws JdbcException

Throws:

JdbcException

getDatasource

@Nonnull
protected DataSource getDatasource()
                            throws JdbcException

Overrides:

getDatasource in class JdbcFacade

Throws:

JdbcException

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 JdbcFacade

Throws:

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

getSelectListQuery

protected abstract String getSelectListQuery(IDbmsSupport dbmsSupport,
 Date startTime,
 Date endTime,
 IMessageBrowser.SortOrder order)

getWhereClause

protected String getWhereClause(String clause,
 boolean primaryKeyIsPartOfClause)

createSelector

protected String createSelector()

applyStandardParameters

protected int applyStandardParameters(PreparedStatement stmt,
 boolean moreParametersFollow,
 boolean primaryKeyIsPartOfClause)
                               throws SQLException

Throws:

SQLException

applyStandardParameters

protected int applyStandardParameters(PreparedStatement stmt,
 String paramValue,
 boolean primaryKeyIsPartOfClause)
                               throws SQLException

Throws:

SQLException

getIterator

public IMessageBrowsingIterator getIterator()
                                     throws ListenerException

Description copied from interface: IMessageBrowser

Gets an enumeration of messages. This includes setting up connections, sessions etc.

Specified by:

getIterator in interface IMessageBrowser<M>

Throws:

ListenerException

getIterator

public IMessageBrowsingIterator getIterator(Date startTime,
 Date endTime,
 IMessageBrowser.SortOrder order)
                                     throws ListenerException

Specified by:

getIterator in interface IMessageBrowser<M>

Throws:

ListenerException

deleteMessage

public void deleteMessage(String storageKey)
                   throws ListenerException

Description copied from interface: IMessageBrowser

Deletes the message.

Specified by:

deleteMessage in interface IMessageBrowser<M>

Throws:

ListenerException

retrieveObject

protected abstract RawMessageWrapper<M> retrieveObject(String storageKey,
 ResultSet rs,
 int columnIndex)
                                                throws SQLException,
JdbcException

Throws:

SQLException

JdbcException

getMessageCount

public int getMessageCount()
                    throws ListenerException

Specified by:

getMessageCount in interface IMessageBrowser<M>

Throws:

ListenerException

containsMessageId

public boolean containsMessageId(String originalMessageId)
                          throws ListenerException

Description copied from interface: IMessageBrowser

Check if the storage contains message with the given original messageId (as passed to storeMessage).

Specified by:

containsMessageId in interface IMessageBrowser<M>

Throws:

ListenerException

containsCorrelationId

public boolean containsCorrelationId(String correlationId)
                              throws ListenerException

Specified by:

containsCorrelationId in interface IMessageBrowser<M>

Throws:

ListenerException

getContext

public IMessageBrowsingIteratorItem getContext(String storageKey)
                                        throws ListenerException

Description copied from interface: IMessageBrowser

Retrieves the message context as an iteratorItem. The result can be used in the methods above that use an iteratorItem. Use this method as try-with-resources to close the connections.

Specified by:

getContext in interface IMessageBrowser<M>

Throws:

ListenerException

browseMessage

public RawMessageWrapper<M> browseMessage(String storageKey)
                                   throws ListenerException

Description copied from interface: IMessageBrowser

Retrieves the message, but does not delete.

Specified by:

browseMessage in interface IMessageBrowser<M>

Throws:

ListenerException

setKeyField

public void setKeyField(String string)

The name of the column that contains the primary key of the table

Default value

MESSAGEKEY

setIdField

public void setIdField(String idField)

The name of the column messageIds are stored in

Default value

MESSAGEID

setCorrelationIdField

public void setCorrelationIdField(String string)

The name of the column correlation-ids are stored in

Default value

CORRELATIONID

setMessageField

public void setMessageField(String messageField)

The name of the column message themselves are stored in

Default value

MESSAGE

setDateField

public void setDateField(String string)

The name of the column the timestamp is stored in

Default value

MESSAGEDATE

setCommentField

public void setCommentField(String string)

The name of the column comments are stored in

Default value

COMMENTS

setExpiryDateField

public void setExpiryDateField(String string)

The name of the column the timestamp for expiry is stored in

Default value

EXPIRYDATE

setLabelField

public void setLabelField(String string)

The name of the column labels are stored in

Default value

LABEL

setSlotIdField

protected void setSlotIdField(String string)

setTypeField

protected void setTypeField(String typeField)

setHostField

protected void setHostField(String hostField)

setPrefix

public void setPrefix(String string)

Prefix to be prefixed on all database objects (tables, indices, sequences), e.g. to access a different Oracle schema

setSlotId

protected void setSlotId(String string)

setType

protected void setType(String type)

setOrder

public void setOrder(IMessageBrowser.SortOrder value)