Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> store >> jdbc >> [ adapter overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---

org.activemq.store.jdbc.adapter
Class DefaultStatementProvider  

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

All Implemented Interfaces:

org.activemq.store.jdbc.StatementProvider

Direct Known Subclasses:

HsqldbJDBCAdapter.HSQLStatementProvider

---

public class DefaultStatementProvider

extends java.lang.Object

implements org.activemq.store.jdbc.StatementProvider

Version:

$Revision: 1.1 $

---

Field Summary
protected  java.lang.String	binaryDataType
protected  java.lang.String	charDataType
protected  java.lang.String	containerNameDataType
protected  java.lang.String	durableSubAcksTableName
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  java.lang.String	subscriptionIdDataType
protected  java.lang.String	tablePrefix
protected  java.lang.String	txTableName
protected  java.lang.String	xidDataType

 

Constructor Summary

DefaultStatementProvider()

 

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

 

Methods inherited from class java.lang.Object

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

 

Field Detail

tablePrefix

protected java.lang.String tablePrefix

---

messageTableName

protected java.lang.String messageTableName

---

txTableName

protected java.lang.String txTableName

---

durableSubAcksTableName

protected java.lang.String durableSubAcksTableName

---

binaryDataType

protected java.lang.String binaryDataType

---

containerNameDataType

protected java.lang.String containerNameDataType

---

xidDataType

protected java.lang.String xidDataType

---

msgIdDataType

protected java.lang.String msgIdDataType

---

subscriptionIdDataType

protected java.lang.String subscriptionIdDataType

---

sequenceDataType

protected java.lang.String sequenceDataType

---

charDataType

protected java.lang.String charDataType

---

longDataType

protected java.lang.String longDataType

---

stringIdDataType

protected java.lang.String stringIdDataType

Constructor Detail

DefaultStatementProvider

public DefaultStatementProvider()

Method Detail

getCreateSchemaStatments

public java.lang.String[] getCreateSchemaStatments()

Specified by:

getCreateSchemaStatments in interface org.activemq.store.jdbc.StatementProvider

---

getDropSchemaStatments

public java.lang.String[] getDropSchemaStatments()

Specified by:

getDropSchemaStatments in interface org.activemq.store.jdbc.StatementProvider

---

getAddMessageStatment

public java.lang.String getAddMessageStatment()

Specified by:

getAddMessageStatment in interface org.activemq.store.jdbc.StatementProvider

---

getUpdateMessageStatment

public java.lang.String getUpdateMessageStatment()

Specified by:

getUpdateMessageStatment in interface org.activemq.store.jdbc.StatementProvider

---

getRemoveMessageStatment

public java.lang.String getRemoveMessageStatment()

Specified by:

getRemoveMessageStatment in interface org.activemq.store.jdbc.StatementProvider

---

getFindMessageSequenceIdStatment

public java.lang.String getFindMessageSequenceIdStatment()

Specified by:

getFindMessageSequenceIdStatment in interface org.activemq.store.jdbc.StatementProvider

---

getFindMessageStatment

public java.lang.String getFindMessageStatment()

Specified by:

getFindMessageStatment in interface org.activemq.store.jdbc.StatementProvider

---

getFindMessageAttributesStatment

public java.lang.String getFindMessageAttributesStatment()

Specified by:

getFindMessageAttributesStatment in interface org.activemq.store.jdbc.StatementProvider

---

getFindMessageAttributesForUpdateStatment

public java.lang.String getFindMessageAttributesForUpdateStatment()

Specified by:

getFindMessageAttributesForUpdateStatment in interface org.activemq.store.jdbc.StatementProvider

---

getFindAllMessagesStatment

public java.lang.String getFindAllMessagesStatment()

Specified by:

getFindAllMessagesStatment in interface org.activemq.store.jdbc.StatementProvider

---

getFindLastSequenceIdInMsgs

public java.lang.String getFindLastSequenceIdInMsgs()

Specified by:

getFindLastSequenceIdInMsgs in interface org.activemq.store.jdbc.StatementProvider

---

getFindLastSequenceIdInAcks

public java.lang.String getFindLastSequenceIdInAcks()

Specified by:

getFindLastSequenceIdInAcks in interface org.activemq.store.jdbc.StatementProvider

---

getAddXidStatment

public java.lang.String getAddXidStatment()

Specified by:

getAddXidStatment in interface org.activemq.store.jdbc.StatementProvider

---

getRemoveXidStatment

public java.lang.String getRemoveXidStatment()

Specified by:

getRemoveXidStatment in interface org.activemq.store.jdbc.StatementProvider

---

getFindAllXidStatment

public java.lang.String getFindAllXidStatment()

Specified by:

getFindAllXidStatment in interface org.activemq.store.jdbc.StatementProvider

---

getCreateDurableSubStatment

public java.lang.String getCreateDurableSubStatment()

Specified by:

getCreateDurableSubStatment in interface org.activemq.store.jdbc.StatementProvider

---

getUpdateDurableSubStatment

public java.lang.String getUpdateDurableSubStatment()

Specified by:

getUpdateDurableSubStatment in interface org.activemq.store.jdbc.StatementProvider

---

getFindDurableSubStatment

public java.lang.String getFindDurableSubStatment()

Specified by:

getFindDurableSubStatment in interface org.activemq.store.jdbc.StatementProvider

---

getUpdateLastAckOfDurableSub

public java.lang.String getUpdateLastAckOfDurableSub()

Specified by:

getUpdateLastAckOfDurableSub in interface org.activemq.store.jdbc.StatementProvider

---

getDeleteSubscriptionStatment

public java.lang.String getDeleteSubscriptionStatment()

Specified by:

getDeleteSubscriptionStatment in interface org.activemq.store.jdbc.StatementProvider

---

getFindAllDurableSubMessagesStatment

public java.lang.String getFindAllDurableSubMessagesStatment()

Specified by:

getFindAllDurableSubMessagesStatment in interface org.activemq.store.jdbc.StatementProvider

---

getRemoveAllMessagesStatment

public java.lang.String getRemoveAllMessagesStatment()

Specified by:

getRemoveAllMessagesStatment in interface org.activemq.store.jdbc.StatementProvider

---

getRemoveAllSubscriptionsStatment

public java.lang.String getRemoveAllSubscriptionsStatment()

Specified by:

getRemoveAllSubscriptionsStatment in interface org.activemq.store.jdbc.StatementProvider

---

getDeleteOldMessagesStatment

public java.lang.String getDeleteOldMessagesStatment()

Specified by:

getDeleteOldMessagesStatment in interface org.activemq.store.jdbc.StatementProvider

---

getFindExpiredMessagesStatment

public java.lang.String getFindExpiredMessagesStatment()

Specified by:

getFindExpiredMessagesStatment in interface org.activemq.store.jdbc.StatementProvider

---

getSetDeadLetterFlagStatement

public java.lang.String getSetDeadLetterFlagStatement()

Specified by:

getSetDeadLetterFlagStatement in interface org.activemq.store.jdbc.StatementProvider

---

getDeleteMessageStatement

public java.lang.String getDeleteMessageStatement()

Specified by:

getDeleteMessageStatement in interface org.activemq.store.jdbc.StatementProvider

---

getContainerNameDataType

public java.lang.String getContainerNameDataType()

---

setContainerNameDataType

public void setContainerNameDataType(java.lang.String containerNameDataType)

---

getBinaryDataType

public java.lang.String getBinaryDataType()

---

setBinaryDataType

public void setBinaryDataType(java.lang.String messageDataType)

---

getMessageTableName

public java.lang.String getMessageTableName()

---

setMessageTableName

public void setMessageTableName(java.lang.String messageTableName)

---

getMsgIdDataType

public java.lang.String getMsgIdDataType()

---

setMsgIdDataType

public void setMsgIdDataType(java.lang.String msgIdDataType)

---

getSequenceDataType

public java.lang.String getSequenceDataType()

---

setSequenceDataType

public void setSequenceDataType(java.lang.String sequenceDataType)

---

getTablePrefix

public java.lang.String getTablePrefix()

Specified by:

getTablePrefix in interface org.activemq.store.jdbc.StatementProvider

---

setTablePrefix

public void setTablePrefix(java.lang.String tablePrefix)

Specified by:

setTablePrefix in interface org.activemq.store.jdbc.StatementProvider

---

getTxTableName

public java.lang.String getTxTableName()

---

setTxTableName

public void setTxTableName(java.lang.String txTableName)

---

getXidDataType

public java.lang.String getXidDataType()

---

setXidDataType

public void setXidDataType(java.lang.String xidDataType)

---

getDurableSubAcksTableName

public java.lang.String getDurableSubAcksTableName()

---

setDurableSubAcksTableName

public void setDurableSubAcksTableName(java.lang.String durableSubAcksTableName)

---

getSubscriptionIdDataType

public java.lang.String getSubscriptionIdDataType()

---

setSubscriptionIdDataType

public void setSubscriptionIdDataType(java.lang.String subscriptionIdDataType)

---

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)

---

Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> store >> jdbc >> [ adapter overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---