org.apache.activemq.store.jdbc
Class Statements

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

public class Statements
extends Object


Field Summary
protected  String binaryDataType
           
protected  String containerNameDataType
           
protected  String durableSubAcksTableName
           
protected  String lockTableName
           
protected  String longDataType
           
protected  String messageTableName
           
protected  String msgIdDataType
           
protected  String sequenceDataType
           
protected  String stringIdDataType
           
protected  boolean useExternalMessageReferences
           
 
Constructor Summary
Statements()
           
 
Method Summary
 String findAllDurableSubMessagesStatement()
           
 String getAddMessageStatement()
           
 String getBinaryDataType()
           
 String getClearDurableLastAckInTxStatement()
           
 String getClearXidFlagStatement()
           
 String getContainerNameDataType()
           
 String getCreateDurableSubStatement()
           
 String[] getCreateSchemaStatements()
           
 String getCurrentDateTime()
           
 String getDeleteOldMessagesStatementWithPriority()
           
 String getDeleteSubscriptionStatement()
           
 String getDestinationMessageCountStatement()
           
 String getDropAckPKAlterStatementEnd()
           
 String[] getDropSchemaStatements()
           
 String getDurableSubAcksTableName()
           
 String getDurableSubscriberMessageCountStatement()
           
 String getDurableSubscriberMessageCountStatementWithPriority()
           
 String getFindAcksPendingOutcomeStatement()
           
 String getFindAllDestinationsStatement()
           
 String getFindAllDurableSubMessagesStatement()
           
 String getFindAllDurableSubsStatement()
           
 String getFindAllMessageIdsStatement()
           
 String getFindAllMessagesStatement()
           
 String getFindDurableSubMessagesByPriorityStatement()
           
 String getFindDurableSubMessagesStatement()
           
 String getFindDurableSubStatement()
           
 String getFindLastSequenceIdInAcksStatement()
           
 String getFindLastSequenceIdInMsgsStatement()
           
 String getFindMessageByIdStatement()
           
 String getFindMessageSequenceIdStatement()
           
 String getFindMessageStatement()
           
 String getFindNextMessagesByPriorityStatement()
           
 String getFindNextMessagesStatement()
           
 String getFindOpsPendingOutcomeStatement()
           
 String getFindXidByIdStatement()
           
 String getFullAckTableName()
           
 String getFullLockTableName()
           
 String getFullMessageTableName()
           
 String getInsertDurablePriorityAckStatement()
           
 String getLastAckedDurableSubscriberMessageStatement()
           
 String getLastProducerSequenceIdStatement()
           
 String getLeaseObtainStatement()
           
 String getLeaseOwnerStatement()
           
 String getLeaseUpdateStatement()
           
 String getLockCreateStatement()
           
 String getLockTableName()
           
 String getLockUpdateStatement()
           
 String getLongDataType()
           
 String getMessageTableName()
           
 String getMsgIdDataType()
           
 String getNextDurableSubscriberMessageStatement()
           
 String getRemoveAllMessagesStatement()
           
 String getRemoveAllSubscriptionsStatement()
           
 String getRemoveMessageStatement()
           
 String getSelectDurablePriorityAckStatement()
           
 String getSequenceDataType()
           
 String getStringIdDataType()
           
 String getTablePrefix()
           
 String getUpdateDurableLastAckInTxStatement()
           
 String getUpdateDurableLastAckStatement()
           
 String getUpdateDurableLastAckWithPriorityInTxStatement()
           
 String getUpdateDurableLastAckWithPriorityStatement()
           
 String getUpdateLastPriorityAckRowOfDurableSubStatement()
           
 String getUpdateMessageStatement()
           
 String getUpdateXidFlagStatement()
           
 boolean isUseExternalMessageReferences()
           
 boolean isUseLockCreateWhereClause()
           
 void setAddMessageStatement(String addMessageStatment)
           
 void setBinaryDataType(String messageDataType)
           
 void setClearDurableLastAckInTxStatement(String clearDurableLastAckInTxStatement)
           
 void setClearXidFlagStatement(String clearXidFlagStatement)
           
 void setContainerNameDataType(String containerNameDataType)
           
 void setCreateDurableSubStatement(String createDurableSubStatment)
           
 void setCreateSchemaStatements(String[] createSchemaStatments)
           
 void setCurrentDateTimeStatement(String currentDateTimeStatement)
           
 void setDeleteOldMessagesStatementWithPriority(String deleteOldMessagesStatementWithPriority)
           
 void setDeleteSubscriptionStatement(String deleteSubscriptionStatment)
           
 void setDestinationMessageCountStatement(String destinationMessageCountStatement)
           
 void setDropAckPKAlterStatementEnd(String dropAckPKAlterStatementEnd)
           
 void setDropSchemaStatements(String[] dropSchemaStatments)
           
 void setDurableSubAcksTableName(String durableSubAcksTableName)
           
 void setDurableSubscriberMessageCountStatement(String durableSubscriberMessageCountStatement)
           
 void setDurableSubscriberMessageCountStatementWithPriority(String durableSubscriberMessageCountStatementWithPriority)
           
 void setFindAcksPendingOutcomeStatement(String findAcksPendingOutcomeStatement)
           
 void setFindAllDestinationsStatement(String findAllDestinationsStatment)
           
 void setFindAllDurableSubMessagesStatement(String findAllDurableSubMessagesStatment)
           
 void setFindAllDurableSubsStatement(String findAllDurableSubsStatment)
           
 void setFindAllMessagesStatement(String findAllMessagesStatment)
           
 void setFindDurableSubMessagesStatement(String findDurableSubMessagesStatement)
           
 void setFindDurableSubStatement(String findDurableSubStatment)
           
 void setFindLastSequenceIdInAcksStatement(String findLastSequenceIdInAcks)
           
 void setFindLastSequenceIdInMsgsStatement(String findLastSequenceIdInMsgs)
           
 void setFindMessageByIdStatement(String findMessageByIdStatement)
           
 void setFindMessageSequenceIdStatement(String findMessageSequenceIdStatment)
           
 void setFindMessageStatement(String findMessageStatment)
           
 void setFindNextMessagesStatement(String findNextMessagesStatement)
           
 void setFindOpsPendingOutcomeStatement(String findOpsPendingOutcomeStatement)
           
 void setFindXidByIdStatement(String findXidByIdStatement)
           
 void setInsertDurablePriorityAckStatement(String insertDurablePriorityAckStatement)
           
 void setLastAckedDurableSubscriberMessageStatement(String lastAckedDurableSubscriberMessageStatement)
           
 void setLastProducerSequenceIdStatement(String lastProducerSequenceIdStatement)
           
 void setLeaseObtainStatement(String leaseObtainStatement)
           
 void setLeaseOwnerStatement(String leaseOwnerStatement)
           
 void setLeaseUpdateStatement(String leaseUpdateStatement)
           
 void setLockCreateStatement(String lockCreateStatement)
           
 void setLockTableName(String lockTableName)
           
 void setLockUpdateStatement(String lockUpdateStatement)
           
 void setLongDataType(String longDataType)
           
 void setMessageTableName(String messageTableName)
           
 void setMsgIdDataType(String msgIdDataType)
           
 void setNextDurableSubscriberMessageStatement(String nextDurableSubscriberMessageStatement)
           
 void setRemoveAllMessagesStatement(String removeAllMessagesStatment)
           
 void setRemoveAllSubscriptionsStatement(String removeAllSubscriptionsStatment)
           
 void setRemoveMessageStatment(String removeMessageStatement)
           
 void setSelectDurablePriorityAckStatement(String selectDurablePriorityAckStatement)
           
 void setSequenceDataType(String sequenceDataType)
           
 void setStringIdDataType(String stringIdDataType)
           
 void setTablePrefix(String tablePrefix)
           
 void setUpdateDurableLastAckInTxStatement(String updateDurableLastAckInTxStatement)
           
 void setUpdateDurableLastAckStatement(String updateDurableLastAckStatement)
           
 void setUpdateDurableLastAckWithPriorityInTxStatement(String updateDurableLastAckWithPriorityInTxStatement)
           
 void setUpdateDurableLastAckWithPriorityStatement(String updateDurableLastAckWithPriorityStatement)
           
 void setUpdateLastPriorityAckRowOfDurableSubStatement(String updateLastPriorityAckRowOfDurableSubStatement)
           
 void setUpdateMessageStatement(String updateMessageStatment)
           
 void setUpdateXidFlagStatement(String updateXidFlagStatement)
           
 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 String messageTableName

durableSubAcksTableName

protected String durableSubAcksTableName

lockTableName

protected String lockTableName

binaryDataType

protected String binaryDataType

containerNameDataType

protected String containerNameDataType

msgIdDataType

protected String msgIdDataType

sequenceDataType

protected String sequenceDataType

longDataType

protected String longDataType

stringIdDataType

protected String stringIdDataType

useExternalMessageReferences

protected boolean useExternalMessageReferences
Constructor Detail

Statements

public Statements()
Method Detail

getCreateSchemaStatements

public String[] getCreateSchemaStatements()

getDropAckPKAlterStatementEnd

public String getDropAckPKAlterStatementEnd()

setDropAckPKAlterStatementEnd

public void setDropAckPKAlterStatementEnd(String dropAckPKAlterStatementEnd)

getDropSchemaStatements

public String[] getDropSchemaStatements()

getAddMessageStatement

public String getAddMessageStatement()

getUpdateMessageStatement

public String getUpdateMessageStatement()

getRemoveMessageStatement

public String getRemoveMessageStatement()

getFindMessageSequenceIdStatement

public String getFindMessageSequenceIdStatement()

getFindMessageStatement

public String getFindMessageStatement()

getFindMessageByIdStatement

public String getFindMessageByIdStatement()

getFindXidByIdStatement

public String getFindXidByIdStatement()

getFindAllMessagesStatement

public String getFindAllMessagesStatement()

getFindAllMessageIdsStatement

public String getFindAllMessageIdsStatement()

getFindLastSequenceIdInMsgsStatement

public String getFindLastSequenceIdInMsgsStatement()

getLastProducerSequenceIdStatement

public String getLastProducerSequenceIdStatement()

getFindLastSequenceIdInAcksStatement

public String getFindLastSequenceIdInAcksStatement()

getCreateDurableSubStatement

public String getCreateDurableSubStatement()

getFindDurableSubStatement

public String getFindDurableSubStatement()

getFindAllDurableSubsStatement

public String getFindAllDurableSubsStatement()

getUpdateLastPriorityAckRowOfDurableSubStatement

public String getUpdateLastPriorityAckRowOfDurableSubStatement()

getDeleteSubscriptionStatement

public String getDeleteSubscriptionStatement()

getFindAllDurableSubMessagesStatement

public String getFindAllDurableSubMessagesStatement()

getFindDurableSubMessagesStatement

public String getFindDurableSubMessagesStatement()

getFindDurableSubMessagesByPriorityStatement

public String getFindDurableSubMessagesByPriorityStatement()

findAllDurableSubMessagesStatement

public String findAllDurableSubMessagesStatement()

getNextDurableSubscriberMessageStatement

public String getNextDurableSubscriberMessageStatement()

getDurableSubscriberMessageCountStatement

public String getDurableSubscriberMessageCountStatement()
Returns:
the durableSubscriberMessageCountStatement

getDurableSubscriberMessageCountStatementWithPriority

public String getDurableSubscriberMessageCountStatementWithPriority()

getFindAllDestinationsStatement

public String getFindAllDestinationsStatement()

getRemoveAllMessagesStatement

public String getRemoveAllMessagesStatement()

getRemoveAllSubscriptionsStatement

public String getRemoveAllSubscriptionsStatement()

getDeleteOldMessagesStatementWithPriority

public String getDeleteOldMessagesStatementWithPriority()

getLockCreateStatement

public String getLockCreateStatement()

getLeaseObtainStatement

public String getLeaseObtainStatement()

getCurrentDateTime

public String getCurrentDateTime()

getLeaseUpdateStatement

public String getLeaseUpdateStatement()

getLeaseOwnerStatement

public String getLeaseOwnerStatement()

getLockUpdateStatement

public String getLockUpdateStatement()

getDestinationMessageCountStatement

public String getDestinationMessageCountStatement()
Returns:
the destinationMessageCountStatement

getFindNextMessagesStatement

public String getFindNextMessagesStatement()
Returns:
the findNextMessagesStatement

getFindNextMessagesByPriorityStatement

public String getFindNextMessagesByPriorityStatement()
Returns:
the findNextMessagesStatement

getLastAckedDurableSubscriberMessageStatement

public String getLastAckedDurableSubscriberMessageStatement()
Returns:
the lastAckedDurableSubscriberMessageStatement

getSelectDurablePriorityAckStatement

public String getSelectDurablePriorityAckStatement()

getInsertDurablePriorityAckStatement

public String getInsertDurablePriorityAckStatement()

getUpdateDurableLastAckStatement

public String getUpdateDurableLastAckStatement()

getUpdateDurableLastAckInTxStatement

public String getUpdateDurableLastAckInTxStatement()

getUpdateDurableLastAckWithPriorityStatement

public String getUpdateDurableLastAckWithPriorityStatement()

getUpdateDurableLastAckWithPriorityInTxStatement

public String getUpdateDurableLastAckWithPriorityInTxStatement()

getClearDurableLastAckInTxStatement

public String getClearDurableLastAckInTxStatement()

getFindOpsPendingOutcomeStatement

public String getFindOpsPendingOutcomeStatement()

getFindAcksPendingOutcomeStatement

public String getFindAcksPendingOutcomeStatement()

getUpdateXidFlagStatement

public String getUpdateXidFlagStatement()

getClearXidFlagStatement

public String getClearXidFlagStatement()

getFullMessageTableName

public String getFullMessageTableName()

getFullAckTableName

public String getFullAckTableName()

getFullLockTableName

public String getFullLockTableName()

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()
Returns:
Returns the tablePrefix.

setTablePrefix

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

getDurableSubAcksTableName

public String getDurableSubAcksTableName()
Returns:
Returns the durableSubAcksTableName.

setDurableSubAcksTableName

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

getLockTableName

public String getLockTableName()

setLockTableName

public void setLockTableName(String lockTableName)

getLongDataType

public String getLongDataType()

setLongDataType

public void setLongDataType(String longDataType)

getStringIdDataType

public String getStringIdDataType()

setStringIdDataType

public void setStringIdDataType(String stringIdDataType)

setUseExternalMessageReferences

public void setUseExternalMessageReferences(boolean useExternalMessageReferences)

isUseExternalMessageReferences

public boolean isUseExternalMessageReferences()

setAddMessageStatement

public void setAddMessageStatement(String addMessageStatment)

setCreateDurableSubStatement

public void setCreateDurableSubStatement(String createDurableSubStatment)

setCreateSchemaStatements

public void setCreateSchemaStatements(String[] createSchemaStatments)

setDeleteOldMessagesStatementWithPriority

public void setDeleteOldMessagesStatementWithPriority(String deleteOldMessagesStatementWithPriority)

setDeleteSubscriptionStatement

public void setDeleteSubscriptionStatement(String deleteSubscriptionStatment)

setDropSchemaStatements

public void setDropSchemaStatements(String[] dropSchemaStatments)

setFindAllDestinationsStatement

public void setFindAllDestinationsStatement(String findAllDestinationsStatment)

setFindAllDurableSubMessagesStatement

public void setFindAllDurableSubMessagesStatement(String findAllDurableSubMessagesStatment)

setFindAllDurableSubsStatement

public void setFindAllDurableSubsStatement(String findAllDurableSubsStatment)

setFindAllMessagesStatement

public void setFindAllMessagesStatement(String findAllMessagesStatment)

setFindDurableSubStatement

public void setFindDurableSubStatement(String findDurableSubStatment)

setFindLastSequenceIdInAcksStatement

public void setFindLastSequenceIdInAcksStatement(String findLastSequenceIdInAcks)

setFindLastSequenceIdInMsgsStatement

public void setFindLastSequenceIdInMsgsStatement(String findLastSequenceIdInMsgs)

setFindMessageSequenceIdStatement

public void setFindMessageSequenceIdStatement(String findMessageSequenceIdStatment)

setFindMessageStatement

public void setFindMessageStatement(String findMessageStatment)

setFindMessageByIdStatement

public void setFindMessageByIdStatement(String findMessageByIdStatement)

setRemoveAllMessagesStatement

public void setRemoveAllMessagesStatement(String removeAllMessagesStatment)

setRemoveAllSubscriptionsStatement

public void setRemoveAllSubscriptionsStatement(String removeAllSubscriptionsStatment)

setRemoveMessageStatment

public void setRemoveMessageStatment(String removeMessageStatement)

setUpdateLastPriorityAckRowOfDurableSubStatement

public void setUpdateLastPriorityAckRowOfDurableSubStatement(String updateLastPriorityAckRowOfDurableSubStatement)

setUpdateMessageStatement

public void setUpdateMessageStatement(String updateMessageStatment)

isUseLockCreateWhereClause

public boolean isUseLockCreateWhereClause()

setUseLockCreateWhereClause

public void setUseLockCreateWhereClause(boolean useLockCreateWhereClause)

setLockCreateStatement

public void setLockCreateStatement(String lockCreateStatement)

setLockUpdateStatement

public void setLockUpdateStatement(String lockUpdateStatement)

setFindDurableSubMessagesStatement

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

setNextDurableSubscriberMessageStatement

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

setDurableSubscriberMessageCountStatement

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

setDurableSubscriberMessageCountStatementWithPriority

public void setDurableSubscriberMessageCountStatementWithPriority(String durableSubscriberMessageCountStatementWithPriority)

setFindNextMessagesStatement

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

setDestinationMessageCountStatement

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

setLastAckedDurableSubscriberMessageStatement

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

setLastProducerSequenceIdStatement

public void setLastProducerSequenceIdStatement(String lastProducerSequenceIdStatement)

setSelectDurablePriorityAckStatement

public void setSelectDurablePriorityAckStatement(String selectDurablePriorityAckStatement)

setInsertDurablePriorityAckStatement

public void setInsertDurablePriorityAckStatement(String insertDurablePriorityAckStatement)

setUpdateDurableLastAckStatement

public void setUpdateDurableLastAckStatement(String updateDurableLastAckStatement)

setUpdateXidFlagStatement

public void setUpdateXidFlagStatement(String updateXidFlagStatement)

setFindOpsPendingOutcomeStatement

public void setFindOpsPendingOutcomeStatement(String findOpsPendingOutcomeStatement)

setClearXidFlagStatement

public void setClearXidFlagStatement(String clearXidFlagStatement)

setUpdateDurableLastAckInTxStatement

public void setUpdateDurableLastAckInTxStatement(String updateDurableLastAckInTxStatement)

setFindAcksPendingOutcomeStatement

public void setFindAcksPendingOutcomeStatement(String findAcksPendingOutcomeStatement)

setClearDurableLastAckInTxStatement

public void setClearDurableLastAckInTxStatement(String clearDurableLastAckInTxStatement)

setUpdateDurableLastAckWithPriorityStatement

public void setUpdateDurableLastAckWithPriorityStatement(String updateDurableLastAckWithPriorityStatement)

setUpdateDurableLastAckWithPriorityInTxStatement

public void setUpdateDurableLastAckWithPriorityInTxStatement(String updateDurableLastAckWithPriorityInTxStatement)

setFindXidByIdStatement

public void setFindXidByIdStatement(String findXidByIdStatement)

setLeaseObtainStatement

public void setLeaseObtainStatement(String leaseObtainStatement)

setCurrentDateTimeStatement

public void setCurrentDateTimeStatement(String currentDateTimeStatement)

setLeaseUpdateStatement

public void setLeaseUpdateStatement(String leaseUpdateStatement)

setLeaseOwnerStatement

public void setLeaseOwnerStatement(String leaseOwnerStatement)


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.