org.apache.activemq.store.jdbc
Class Statements

java.lang.Object
  extended by org.apache.activemq.store.jdbc.Statements

public class Statements
extends java.lang.Object


Field Summary
protected  java.lang.String binaryDataType
           
protected  java.lang.String containerNameDataType
           
protected  java.lang.String durableSubAcksTableName
           
protected  java.lang.String lockTableName
           
protected  java.lang.String longDataType
           
protected  java.lang.String messageTableName
           
protected  java.lang.String msgIdDataType
           
protected  java.lang.String sequenceDataType
           
protected  java.lang.String stringIdDataType
           
protected  boolean useExternalMessageReferences
           
 
Constructor Summary
Statements()
           
 
Method Summary
 java.lang.String findAllDurableSubMessagesStatement()
           
 java.lang.String getAddMessageStatement()
           
 java.lang.String getBinaryDataType()
           
 java.lang.String getContainerNameDataType()
           
 java.lang.String getCreateDurableSubStatement()
           
 java.lang.String[] getCreateSchemaStatements()
           
 java.lang.String getDeleteOldMessagesStatement()
           
 java.lang.String getDeleteOldMessagesStatementWithPriority()
           
 java.lang.String getDeleteSubscriptionStatement()
           
 java.lang.String getDestinationMessageCountStatement()
           
 java.lang.String getDropAckPKAlterStatementEnd()
           
 java.lang.String[] getDropSchemaStatements()
           
 java.lang.String getDurableSubAcksTableName()
           
 java.lang.String getDurableSubscriberMessageCountStatement()
           
 java.lang.String getDurableSubscriberMessageCountStatementWithPriority()
           
 java.lang.String getFindAllDestinationsStatement()
           
 java.lang.String getFindAllDurableSubMessagesStatement()
           
 java.lang.String getFindAllDurableSubsStatement()
           
 java.lang.String getFindAllMessageIdsStatement()
           
 java.lang.String getFindAllMessagesStatement()
           
 java.lang.String getFindDurableSubMessagesByPriorityStatement()
           
 java.lang.String getFindDurableSubMessagesStatement()
           
 java.lang.String getFindDurableSubStatement()
           
 java.lang.String getFindLastSequenceIdInAcksStatement()
           
 java.lang.String getFindLastSequenceIdInMsgsStatement()
           
 java.lang.String getFindMessageByIdStatement()
           
 java.lang.String getFindMessageSequenceIdStatement()
           
 java.lang.String getFindMessageStatement()
           
 java.lang.String getFindNextMessagesByPriorityStatement()
           
 java.lang.String getFindNextMessagesStatement()
           
 java.lang.String getFullAckTableName()
           
 java.lang.String getFullLockTableName()
           
 java.lang.String getFullMessageTableName()
           
 java.lang.String getInsertDurablePriorityAckStatement()
           
 java.lang.String getLastAckedDurableSubscriberMessageStatement()
           
 java.lang.String getLastProducerSequenceIdStatement()
           
 java.lang.String getLockCreateStatement()
           
 java.lang.String getLockTableName()
           
 java.lang.String getLockUpdateStatement()
           
 java.lang.String getLongDataType()
           
 java.lang.String getMessageTableName()
           
 java.lang.String getMsgIdDataType()
           
 java.lang.String getNextDurableSubscriberMessageStatement()
           
 java.lang.String getRemoveAllMessagesStatement()
           
 java.lang.String getRemoveAllSubscriptionsStatement()
           
 java.lang.String getRemoveMessageStatement()
           
 java.lang.String getSelectDurablePriorityAckStatement()
           
 java.lang.String getSequenceDataType()
           
 java.lang.String getStringIdDataType()
           
 java.lang.String getTablePrefix()
           
 java.lang.String getUpdateDurableLastAckStatement()
           
 java.lang.String getUpdateLastPriorityAckRowOfDurableSubStatement()
           
 java.lang.String getUpdateMessageStatement()
           
 boolean isUseExternalMessageReferences()
           
 boolean isUseLockCreateWhereClause()
           
 void setAddMessageStatement(java.lang.String addMessageStatment)
           
 void setBinaryDataType(java.lang.String messageDataType)
           
 void setContainerNameDataType(java.lang.String containerNameDataType)
           
 void setCreateDurableSubStatement(java.lang.String createDurableSubStatment)
           
 void setCreateSchemaStatements(java.lang.String[] createSchemaStatments)
           
 void setDeleteOldMessagesStatement(java.lang.String deleteOldMessagesStatment)
           
 void setDeleteOldMessagesStatementWithPriority(java.lang.String deleteOldMessagesStatmentWithPriority)
           
 void setDeleteSubscriptionStatement(java.lang.String deleteSubscriptionStatment)
           
 void setDestinationMessageCountStatement(java.lang.String destinationMessageCountStatement)
           
 void setDropAckPKAlterStatementEnd(java.lang.String dropAckPKAlterStatementEnd)
           
 void setDropSchemaStatements(java.lang.String[] dropSchemaStatments)
           
 void setDurableSubAcksTableName(java.lang.String durableSubAcksTableName)
           
 void setDurableSubscriberMessageCountStatement(java.lang.String durableSubscriberMessageCountStatement)
           
 void setDurableSubscriberMessageCountStatementWithPriority(java.lang.String durableSubscriberMessageCountStatementWithPriority)
           
 void setFindAllDestinationsStatement(java.lang.String findAllDestinationsStatment)
           
 void setFindAllDurableSubMessagesStatement(java.lang.String findAllDurableSubMessagesStatment)
           
 void setFindAllDurableSubsStatement(java.lang.String findAllDurableSubsStatment)
           
 void setFindAllMessagesStatement(java.lang.String findAllMessagesStatment)
           
 void setFindDurableSubMessagesStatement(java.lang.String findDurableSubMessagesStatement)
           
 void setFindDurableSubStatement(java.lang.String findDurableSubStatment)
           
 void setFindLastSequenceIdInAcksStatement(java.lang.String findLastSequenceIdInAcks)
           
 void setFindLastSequenceIdInMsgsStatement(java.lang.String findLastSequenceIdInMsgs)
           
 void setFindMessageByIdStatement(java.lang.String findMessageByIdStatement)
           
 void setFindMessageSequenceIdStatement(java.lang.String findMessageSequenceIdStatment)
           
 void setFindMessageStatement(java.lang.String findMessageStatment)
           
 void setFindNextMessagesStatement(java.lang.String findNextMessagesStatement)
           
 void setInsertDurablePriorityAckStatement(java.lang.String insertDurablePriorityAckStatement)
           
 void setLastAckedDurableSubscriberMessageStatement(java.lang.String lastAckedDurableSubscriberMessageStatement)
           
 void setLastProducerSequenceIdStatement(java.lang.String lastProducerSequenceIdStatement)
           
 void setLockCreateStatement(java.lang.String lockCreateStatement)
           
 void setLockTableName(java.lang.String lockTableName)
           
 void setLockUpdateStatement(java.lang.String lockUpdateStatement)
           
 void setLongDataType(java.lang.String longDataType)
           
 void setMessageTableName(java.lang.String messageTableName)
           
 void setMsgIdDataType(java.lang.String msgIdDataType)
           
 void setNextDurableSubscriberMessageStatement(java.lang.String nextDurableSubscriberMessageStatement)
           
 void setRemoveAllMessagesStatement(java.lang.String removeAllMessagesStatment)
           
 void setRemoveAllSubscriptionsStatement(java.lang.String removeAllSubscriptionsStatment)
           
 void setRemoveMessageStatment(java.lang.String removeMessageStatement)
           
 void setSelectDurablePriorityAckStatement(java.lang.String selectDurablePriorityAckStatement)
           
 void setSequenceDataType(java.lang.String sequenceDataType)
           
 void setStringIdDataType(java.lang.String stringIdDataType)
           
 void setTablePrefix(java.lang.String tablePrefix)
           
 void setUpdateDurableLastAckStatement(java.lang.String updateDurableLastAckStatement)
           
 void setUpdateLastPriorityAckRowOfDurableSubStatement(java.lang.String updateLastPriorityAckRowOfDurableSubStatement)
           
 void setUpdateMessageStatement(java.lang.String updateMessageStatment)
           
 void setUseExternalMessageReferences(boolean useExternalMessageReferences)
           
 void setUseLockCreateWhereClause(boolean useLockCreateWhereClause)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

messageTableName

protected java.lang.String messageTableName

durableSubAcksTableName

protected java.lang.String durableSubAcksTableName

lockTableName

protected java.lang.String lockTableName

binaryDataType

protected java.lang.String binaryDataType

containerNameDataType

protected java.lang.String containerNameDataType

msgIdDataType

protected java.lang.String msgIdDataType

sequenceDataType

protected java.lang.String sequenceDataType

longDataType

protected java.lang.String longDataType

stringIdDataType

protected java.lang.String stringIdDataType

useExternalMessageReferences

protected boolean useExternalMessageReferences
Constructor Detail

Statements

public Statements()
Method Detail

getCreateSchemaStatements

public java.lang.String[] getCreateSchemaStatements()

getDropAckPKAlterStatementEnd

public java.lang.String getDropAckPKAlterStatementEnd()

setDropAckPKAlterStatementEnd

public void setDropAckPKAlterStatementEnd(java.lang.String dropAckPKAlterStatementEnd)

getDropSchemaStatements

public java.lang.String[] getDropSchemaStatements()

getAddMessageStatement

public java.lang.String getAddMessageStatement()

getUpdateMessageStatement

public java.lang.String getUpdateMessageStatement()

getRemoveMessageStatement

public java.lang.String getRemoveMessageStatement()

getFindMessageSequenceIdStatement

public java.lang.String getFindMessageSequenceIdStatement()

getFindMessageStatement

public java.lang.String getFindMessageStatement()

getFindMessageByIdStatement

public java.lang.String getFindMessageByIdStatement()

getFindAllMessagesStatement

public java.lang.String getFindAllMessagesStatement()

getFindAllMessageIdsStatement

public java.lang.String getFindAllMessageIdsStatement()

getFindLastSequenceIdInMsgsStatement

public java.lang.String getFindLastSequenceIdInMsgsStatement()

getLastProducerSequenceIdStatement

public java.lang.String getLastProducerSequenceIdStatement()

getFindLastSequenceIdInAcksStatement

public java.lang.String getFindLastSequenceIdInAcksStatement()

getCreateDurableSubStatement

public java.lang.String getCreateDurableSubStatement()

getFindDurableSubStatement

public java.lang.String getFindDurableSubStatement()

getFindAllDurableSubsStatement

public java.lang.String getFindAllDurableSubsStatement()

getUpdateLastPriorityAckRowOfDurableSubStatement

public java.lang.String getUpdateLastPriorityAckRowOfDurableSubStatement()

getDeleteSubscriptionStatement

public java.lang.String getDeleteSubscriptionStatement()

getFindAllDurableSubMessagesStatement

public java.lang.String getFindAllDurableSubMessagesStatement()

getFindDurableSubMessagesStatement

public java.lang.String getFindDurableSubMessagesStatement()

getFindDurableSubMessagesByPriorityStatement

public java.lang.String getFindDurableSubMessagesByPriorityStatement()

findAllDurableSubMessagesStatement

public java.lang.String findAllDurableSubMessagesStatement()

getNextDurableSubscriberMessageStatement

public java.lang.String getNextDurableSubscriberMessageStatement()

getDurableSubscriberMessageCountStatement

public java.lang.String getDurableSubscriberMessageCountStatement()
Returns:
the durableSubscriberMessageCountStatement

getDurableSubscriberMessageCountStatementWithPriority

public java.lang.String getDurableSubscriberMessageCountStatementWithPriority()

getFindAllDestinationsStatement

public java.lang.String getFindAllDestinationsStatement()

getRemoveAllMessagesStatement

public java.lang.String getRemoveAllMessagesStatement()

getRemoveAllSubscriptionsStatement

public java.lang.String getRemoveAllSubscriptionsStatement()

getDeleteOldMessagesStatementWithPriority

public java.lang.String getDeleteOldMessagesStatementWithPriority()

getDeleteOldMessagesStatement

public java.lang.String getDeleteOldMessagesStatement()

getLockCreateStatement

public java.lang.String getLockCreateStatement()

getLockUpdateStatement

public java.lang.String getLockUpdateStatement()

getDestinationMessageCountStatement

public java.lang.String getDestinationMessageCountStatement()
Returns:
the destinationMessageCountStatement

getFindNextMessagesStatement

public java.lang.String getFindNextMessagesStatement()
Returns:
the findNextMessagesStatement

getFindNextMessagesByPriorityStatement

public java.lang.String getFindNextMessagesByPriorityStatement()
Returns:
the findNextMessagesStatement

getLastAckedDurableSubscriberMessageStatement

public java.lang.String getLastAckedDurableSubscriberMessageStatement()
Returns:
the lastAckedDurableSubscriberMessageStatement

getSelectDurablePriorityAckStatement

public java.lang.String getSelectDurablePriorityAckStatement()

getInsertDurablePriorityAckStatement

public java.lang.String getInsertDurablePriorityAckStatement()

getUpdateDurableLastAckStatement

public java.lang.String getUpdateDurableLastAckStatement()

getFullMessageTableName

public java.lang.String getFullMessageTableName()

getFullAckTableName

public java.lang.String getFullAckTableName()

getFullLockTableName

public java.lang.String getFullLockTableName()

getContainerNameDataType

public java.lang.String getContainerNameDataType()
Returns:
Returns the containerNameDataType.

setContainerNameDataType

public void setContainerNameDataType(java.lang.String containerNameDataType)
Parameters:
containerNameDataType - The containerNameDataType to set.

getBinaryDataType

public java.lang.String getBinaryDataType()
Returns:
Returns the messageDataType.

setBinaryDataType

public void setBinaryDataType(java.lang.String messageDataType)
Parameters:
messageDataType - The messageDataType to set.

getMessageTableName

public java.lang.String getMessageTableName()
Returns:
Returns the messageTableName.

setMessageTableName

public void setMessageTableName(java.lang.String messageTableName)
Parameters:
messageTableName - The messageTableName to set.

getMsgIdDataType

public java.lang.String getMsgIdDataType()
Returns:
Returns the msgIdDataType.

setMsgIdDataType

public void setMsgIdDataType(java.lang.String msgIdDataType)
Parameters:
msgIdDataType - The msgIdDataType to set.

getSequenceDataType

public java.lang.String getSequenceDataType()
Returns:
Returns the sequenceDataType.

setSequenceDataType

public void setSequenceDataType(java.lang.String sequenceDataType)
Parameters:
sequenceDataType - The sequenceDataType to set.

getTablePrefix

public java.lang.String getTablePrefix()
Returns:
Returns the tablePrefix.

setTablePrefix

public void setTablePrefix(java.lang.String tablePrefix)
Parameters:
tablePrefix - The tablePrefix to set.

getDurableSubAcksTableName

public java.lang.String getDurableSubAcksTableName()
Returns:
Returns the durableSubAcksTableName.

setDurableSubAcksTableName

public void setDurableSubAcksTableName(java.lang.String durableSubAcksTableName)
Parameters:
durableSubAcksTableName - The durableSubAcksTableName to set.

getLockTableName

public java.lang.String getLockTableName()

setLockTableName

public void setLockTableName(java.lang.String lockTableName)

getLongDataType

public java.lang.String getLongDataType()

setLongDataType

public void setLongDataType(java.lang.String longDataType)

getStringIdDataType

public java.lang.String getStringIdDataType()

setStringIdDataType

public void setStringIdDataType(java.lang.String stringIdDataType)

setUseExternalMessageReferences

public void setUseExternalMessageReferences(boolean useExternalMessageReferences)

isUseExternalMessageReferences

public boolean isUseExternalMessageReferences()

setAddMessageStatement

public void setAddMessageStatement(java.lang.String addMessageStatment)

setCreateDurableSubStatement

public void setCreateDurableSubStatement(java.lang.String createDurableSubStatment)

setCreateSchemaStatements

public void setCreateSchemaStatements(java.lang.String[] createSchemaStatments)

setDeleteOldMessagesStatement

public void setDeleteOldMessagesStatement(java.lang.String deleteOldMessagesStatment)

setDeleteOldMessagesStatementWithPriority

public void setDeleteOldMessagesStatementWithPriority(java.lang.String deleteOldMessagesStatmentWithPriority)

setDeleteSubscriptionStatement

public void setDeleteSubscriptionStatement(java.lang.String deleteSubscriptionStatment)

setDropSchemaStatements

public void setDropSchemaStatements(java.lang.String[] dropSchemaStatments)

setFindAllDestinationsStatement

public void setFindAllDestinationsStatement(java.lang.String findAllDestinationsStatment)

setFindAllDurableSubMessagesStatement

public void setFindAllDurableSubMessagesStatement(java.lang.String findAllDurableSubMessagesStatment)

setFindAllDurableSubsStatement

public void setFindAllDurableSubsStatement(java.lang.String findAllDurableSubsStatment)

setFindAllMessagesStatement

public void setFindAllMessagesStatement(java.lang.String findAllMessagesStatment)

setFindDurableSubStatement

public void setFindDurableSubStatement(java.lang.String findDurableSubStatment)

setFindLastSequenceIdInAcksStatement

public void setFindLastSequenceIdInAcksStatement(java.lang.String findLastSequenceIdInAcks)

setFindLastSequenceIdInMsgsStatement

public void setFindLastSequenceIdInMsgsStatement(java.lang.String findLastSequenceIdInMsgs)

setFindMessageSequenceIdStatement

public void setFindMessageSequenceIdStatement(java.lang.String findMessageSequenceIdStatment)

setFindMessageStatement

public void setFindMessageStatement(java.lang.String findMessageStatment)

setFindMessageByIdStatement

public void setFindMessageByIdStatement(java.lang.String findMessageByIdStatement)

setRemoveAllMessagesStatement

public void setRemoveAllMessagesStatement(java.lang.String removeAllMessagesStatment)

setRemoveAllSubscriptionsStatement

public void setRemoveAllSubscriptionsStatement(java.lang.String removeAllSubscriptionsStatment)

setRemoveMessageStatment

public void setRemoveMessageStatment(java.lang.String removeMessageStatement)

setUpdateLastPriorityAckRowOfDurableSubStatement

public void setUpdateLastPriorityAckRowOfDurableSubStatement(java.lang.String updateLastPriorityAckRowOfDurableSubStatement)

setUpdateMessageStatement

public void setUpdateMessageStatement(java.lang.String updateMessageStatment)

isUseLockCreateWhereClause

public boolean isUseLockCreateWhereClause()

setUseLockCreateWhereClause

public void setUseLockCreateWhereClause(boolean useLockCreateWhereClause)

setLockCreateStatement

public void setLockCreateStatement(java.lang.String lockCreateStatement)

setLockUpdateStatement

public void setLockUpdateStatement(java.lang.String lockUpdateStatement)

setFindDurableSubMessagesStatement

public void setFindDurableSubMessagesStatement(java.lang.String findDurableSubMessagesStatement)
Parameters:
findDurableSubMessagesStatement - the findDurableSubMessagesStatement to set

setNextDurableSubscriberMessageStatement

public void setNextDurableSubscriberMessageStatement(java.lang.String nextDurableSubscriberMessageStatement)
Parameters:
nextDurableSubscriberMessageStatement - the nextDurableSubscriberMessageStatement to set

setDurableSubscriberMessageCountStatement

public void setDurableSubscriberMessageCountStatement(java.lang.String durableSubscriberMessageCountStatement)
Parameters:
durableSubscriberMessageCountStatement - the durableSubscriberMessageCountStatement to set

setDurableSubscriberMessageCountStatementWithPriority

public void setDurableSubscriberMessageCountStatementWithPriority(java.lang.String durableSubscriberMessageCountStatementWithPriority)

setFindNextMessagesStatement

public void setFindNextMessagesStatement(java.lang.String findNextMessagesStatement)
Parameters:
findNextMessagesStatement - the findNextMessagesStatement to set

setDestinationMessageCountStatement

public void setDestinationMessageCountStatement(java.lang.String destinationMessageCountStatement)
Parameters:
destinationMessageCountStatement - the destinationMessageCountStatement to set

setLastAckedDurableSubscriberMessageStatement

public void setLastAckedDurableSubscriberMessageStatement(java.lang.String lastAckedDurableSubscriberMessageStatement)
Parameters:
lastAckedDurableSubscriberMessageStatement - the lastAckedDurableSubscriberMessageStatement to set

setLastProducerSequenceIdStatement

public void setLastProducerSequenceIdStatement(java.lang.String lastProducerSequenceIdStatement)

setSelectDurablePriorityAckStatement

public void setSelectDurablePriorityAckStatement(java.lang.String selectDurablePriorityAckStatement)

setInsertDurablePriorityAckStatement

public void setInsertDurablePriorityAckStatement(java.lang.String insertDurablePriorityAckStatement)

setUpdateDurableLastAckStatement

public void setUpdateDurableLastAckStatement(java.lang.String updateDurableLastAckStatement)


Copyright © 2005-2011. All Rights Reserved.