org.activemq.store.jdbc.adapter
Class DefaultStatementProvider

java.lang.Object
  org.activemq.store.jdbc.adapter.DefaultStatementProvider

All Implemented Interfaces:

StatementProvider

Direct Known Subclasses:

HsqldbJDBCAdapter.HSQLStatementProvider

public class DefaultStatementProvider
extends Object
implements StatementProvider

Version:

$Revision: 1.1 $

Field Summary

protected String	binaryDataType
protected String	charDataType
protected String	containerNameDataType
protected String	durableSubAcksTableName
protected String	longDataType
protected String	messageTableName
protected String	msgIdDataType
protected String	sequenceDataType
protected String	stringIdDataType
protected String	subscriptionIdDataType
protected String	tablePrefix
protected String	txTableName
protected String	xidDataType

Constructor Summary

DefaultStatementProvider()

Method Summary

String	getAddMessageStatment()
String	getAddXidStatment()
String	getBinaryDataType()
String	getContainerNameDataType()
String	getCreateDurableSubStatment()
String[]	getCreateSchemaStatments()
String	getDeleteMessageStatement()
String	getDeleteOldMessagesStatment()
String	getDeleteSubscriptionStatment()
String[]	getDropSchemaStatments()
String	getDurableSubAcksTableName()
String	getFindAllDurableSubMessagesStatment()
String	getFindAllMessagesStatment()
String	getFindAllXidStatment()
String	getFindDurableSubStatment()
String	getFindExpiredMessagesStatment()
String	getFindLastSequenceIdInAcks()
String	getFindLastSequenceIdInMsgs()
String	getFindMessageAttributesForUpdateStatment()
String	getFindMessageAttributesStatment()
String	getFindMessageSequenceIdStatment()
String	getFindMessageStatment()
String	getLongDataType()
String	getMessageTableName()
String	getMsgIdDataType()
String	getRemoveAllMessagesStatment()
String	getRemoveAllSubscriptionsStatment()
String	getRemoveMessageStatment()
String	getRemoveXidStatment()
String	getSequenceDataType()
String	getSetDeadLetterFlagStatement()
String	getStringIdDataType()
String	getSubscriptionIdDataType()
String	getTablePrefix()
String	getTxTableName()
String	getUpdateDurableSubStatment()
String	getUpdateLastAckOfDurableSub()
String	getUpdateMessageStatment()
String	getXidDataType()
void	setBinaryDataType(String messageDataType)
void	setContainerNameDataType(String containerNameDataType)
void	setDurableSubAcksTableName(String durableSubAcksTableName)
void	setLongDataType(String longDataType)
void	setMessageTableName(String messageTableName)
void	setMsgIdDataType(String msgIdDataType)
void	setSequenceDataType(String sequenceDataType)
void	setStringIdDataType(String stringIdDataType)
void	setSubscriptionIdDataType(String subscriptionIdDataType)
void	setTablePrefix(String tablePrefix)
void	setTxTableName(String txTableName)
void	setXidDataType(String xidDataType)

Methods inherited from class java.lang.Object

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

Field Detail

tablePrefix

protected String tablePrefix

messageTableName

protected String messageTableName

txTableName

protected String txTableName

durableSubAcksTableName

protected String durableSubAcksTableName

binaryDataType

protected String binaryDataType

containerNameDataType

protected String containerNameDataType

xidDataType

protected String xidDataType

msgIdDataType

protected String msgIdDataType

subscriptionIdDataType

protected String subscriptionIdDataType

sequenceDataType

protected String sequenceDataType

charDataType

protected String charDataType

longDataType

protected String longDataType

stringIdDataType

protected String stringIdDataType

Constructor Detail

DefaultStatementProvider

public DefaultStatementProvider()

Method Detail

getCreateSchemaStatments

public String[] getCreateSchemaStatments()

Specified by:

getCreateSchemaStatments in interface StatementProvider

getDropSchemaStatments

public String[] getDropSchemaStatments()

Specified by:

getDropSchemaStatments in interface StatementProvider

getAddMessageStatment

public String getAddMessageStatment()

Specified by:

getAddMessageStatment in interface StatementProvider

getUpdateMessageStatment

public String getUpdateMessageStatment()

Specified by:

getUpdateMessageStatment in interface StatementProvider

getRemoveMessageStatment

public String getRemoveMessageStatment()

Specified by:

getRemoveMessageStatment in interface StatementProvider

getFindMessageSequenceIdStatment

public String getFindMessageSequenceIdStatment()

Specified by:

getFindMessageSequenceIdStatment in interface StatementProvider

getFindMessageStatment

public String getFindMessageStatment()

Specified by:

getFindMessageStatment in interface StatementProvider

getFindMessageAttributesStatment

public String getFindMessageAttributesStatment()

Specified by:

getFindMessageAttributesStatment in interface StatementProvider

getFindMessageAttributesForUpdateStatment

public String getFindMessageAttributesForUpdateStatment()

Specified by:

getFindMessageAttributesForUpdateStatment in interface StatementProvider

getFindAllMessagesStatment

public String getFindAllMessagesStatment()

Specified by:

getFindAllMessagesStatment in interface StatementProvider

getFindLastSequenceIdInMsgs

public String getFindLastSequenceIdInMsgs()

Specified by:

getFindLastSequenceIdInMsgs in interface StatementProvider

getFindLastSequenceIdInAcks

public String getFindLastSequenceIdInAcks()

Specified by:

getFindLastSequenceIdInAcks in interface StatementProvider

getAddXidStatment

public String getAddXidStatment()

Specified by:

getAddXidStatment in interface StatementProvider

getRemoveXidStatment

public String getRemoveXidStatment()

Specified by:

getRemoveXidStatment in interface StatementProvider

getFindAllXidStatment

public String getFindAllXidStatment()

Specified by:

getFindAllXidStatment in interface StatementProvider

getCreateDurableSubStatment

public String getCreateDurableSubStatment()

Specified by:

getCreateDurableSubStatment in interface StatementProvider

getUpdateDurableSubStatment

public String getUpdateDurableSubStatment()

Specified by:

getUpdateDurableSubStatment in interface StatementProvider

getFindDurableSubStatment

public String getFindDurableSubStatment()

Specified by:

getFindDurableSubStatment in interface StatementProvider

getUpdateLastAckOfDurableSub

public String getUpdateLastAckOfDurableSub()

Specified by:

getUpdateLastAckOfDurableSub in interface StatementProvider

getDeleteSubscriptionStatment

public String getDeleteSubscriptionStatment()

Specified by:

getDeleteSubscriptionStatment in interface StatementProvider

getFindAllDurableSubMessagesStatment

public String getFindAllDurableSubMessagesStatment()

Specified by:

getFindAllDurableSubMessagesStatment in interface StatementProvider

getRemoveAllMessagesStatment

public String getRemoveAllMessagesStatment()

Specified by:

getRemoveAllMessagesStatment in interface StatementProvider

getRemoveAllSubscriptionsStatment

public String getRemoveAllSubscriptionsStatment()

Specified by:

getRemoveAllSubscriptionsStatment in interface StatementProvider

getDeleteOldMessagesStatment

public String getDeleteOldMessagesStatment()

Specified by:

getDeleteOldMessagesStatment in interface StatementProvider

getFindExpiredMessagesStatment

public String getFindExpiredMessagesStatment()

Specified by:

getFindExpiredMessagesStatment in interface StatementProvider

getSetDeadLetterFlagStatement

public String getSetDeadLetterFlagStatement()

Specified by:

getSetDeadLetterFlagStatement in interface StatementProvider

getDeleteMessageStatement

public String getDeleteMessageStatement()

Specified by:

getDeleteMessageStatement in interface StatementProvider

getContainerNameDataType

public String getContainerNameDataType()

Returns:

Returns the containerNameDataType.

setContainerNameDataType

public void setContainerNameDataType(String containerNameDataType)

Parameters:

containerNameDataType - The containerNameDataType to set.

getBinaryDataType

public String getBinaryDataType()

Returns:

Returns the messageDataType.

setBinaryDataType

public void setBinaryDataType(String messageDataType)

Parameters:

messageDataType - The messageDataType to set.

getMessageTableName

public String getMessageTableName()

Returns:

Returns the messageTableName.

setMessageTableName

public void setMessageTableName(String messageTableName)

Parameters:

messageTableName - The messageTableName to set.

getMsgIdDataType

public String getMsgIdDataType()

Returns:

Returns the msgIdDataType.

setMsgIdDataType

public void setMsgIdDataType(String msgIdDataType)

Parameters:

msgIdDataType - The msgIdDataType to set.

getSequenceDataType

public String getSequenceDataType()

Returns:

Returns the sequenceDataType.

setSequenceDataType

public void setSequenceDataType(String sequenceDataType)

Parameters:

sequenceDataType - The sequenceDataType to set.

getTablePrefix

public String getTablePrefix()

Specified by:

getTablePrefix in interface StatementProvider

Returns:

Returns the tablePrefix.

setTablePrefix

public void setTablePrefix(String tablePrefix)

Specified by:

setTablePrefix in interface StatementProvider

Parameters:

tablePrefix - The tablePrefix to set.

getTxTableName

public String getTxTableName()

Returns:

Returns the txTableName.

setTxTableName

public void setTxTableName(String txTableName)

Parameters:

txTableName - The txTableName to set.

getXidDataType

public String getXidDataType()

Returns:

Returns the xidDataType.

setXidDataType

public void setXidDataType(String xidDataType)

Parameters:

xidDataType - The xidDataType to set.

getDurableSubAcksTableName

public String getDurableSubAcksTableName()

Returns:

Returns the durableSubAcksTableName.

setDurableSubAcksTableName

public void setDurableSubAcksTableName(String durableSubAcksTableName)

Parameters:

durableSubAcksTableName - The durableSubAcksTableName to set.

getSubscriptionIdDataType

public String getSubscriptionIdDataType()

Returns:

Returns the subscriptionIdDataType.

setSubscriptionIdDataType

public void setSubscriptionIdDataType(String subscriptionIdDataType)

Parameters:

subscriptionIdDataType - The subscriptionIdDataType to set.

getLongDataType

public String getLongDataType()

setLongDataType

public void setLongDataType(String longDataType)

getStringIdDataType

public String getStringIdDataType()

setStringIdDataType

public void setStringIdDataType(String stringIdDataType)