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 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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
DefaultStatementProvider
public DefaultStatementProvider()
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)
Copyright © 2004-2010 Protique, Ltd.. All Rights Reserved.