Package org.apache.activemq.store.jdbc

Class Statements

  • public class Statements
extends Object

    • 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()

      • getCreateLockSchemaStatements

        public String[] getCreateLockSchemaStatements()

      • 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()

      • setFindAllMessageIdsStatement

        public void setFindAllMessageIdsStatement​(String val)

      • 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()

      • 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

      • setFindNextMessagesByPriorityStatement

        public void setFindNextMessagesByPriorityStatement​(String val)

      • 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)

      • setCreateLockSchemaStatements

        public void setCreateLockSchemaStatements​(String[] createLockSchemaStatments)

      • 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)