org.apache.qpid.server.store.derby

Class DerbyConfigurationStore

java.lang.Object

org.apache.qpid.server.store.AbstractJDBCConfigurationStore

org.apache.qpid.server.store.derby.DerbyConfigurationStore

All Implemented Interfaces:

DurableConfigurationStore, MessageStoreProvider

public class DerbyConfigurationStore
extends AbstractJDBCConfigurationStore
implements MessageStoreProvider, DurableConfigurationStore

Implementation of a DurableConfigurationStore backed by Apache Derby that also provides a MessageStore.A

Field Summary

Fields inherited from class org.apache.qpid.server.store.AbstractJDBCConfigurationStore

CONFIGURATION_STORE_TABLE_NAMES

Constructor Summary

Constructors

Constructor and Description
DerbyConfigurationStore(Class<? extends ConfiguredObject> rootClass)

Method Summary

Modifier and Type	Method and Description
protected void	checkConfigurationStoreOpen()
void	closeConfigurationStore()
protected String	getBlobAsString(ResultSet rs, int col)
protected Connection	getConnection()
protected org.slf4j.Logger	getLogger()
MessageStore	getMessageStore()
protected String	getSqlBigIntType()
protected String	getSqlBlobType()
protected String	getSqlVarBinaryType(int size)
void	onDelete(ConfiguredObject<?> parent) Deletes the configuration store from its underlying storage.
void	openConfigurationStore(ConfiguredObject<?> parent, boolean overwrite, ConfiguredObjectRecord... initialRecords) Initializes and opens the configuration store.
protected boolean	tableExists(String tableName, Connection conn)
void	upgradeStoreStructure() Requests that the store performs any upgrade work on the store's structure.

Methods inherited from class org.apache.qpid.server.store.AbstractJDBCConfigurationStore

create, createOrOpenConfigurationStoreDatabase, hasNoConfigurationEntries, newAutoCommitConnection, newConnection, remove, update, upgradeIfNecessary, visitConfiguredObjectRecords

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.qpid.server.store.DurableConfigurationStore

create, remove, update, visitConfiguredObjectRecords

Constructor Detail

DerbyConfigurationStore

public DerbyConfigurationStore(Class<? extends ConfiguredObject> rootClass)

Method Detail

openConfigurationStore

public void openConfigurationStore(ConfiguredObject<?> parent,
                                   boolean overwrite,
                                   ConfiguredObjectRecord... initialRecords)
                            throws StoreException

Description copied from interface: DurableConfigurationStore

Initializes and opens the configuration store.

Specified by:

openConfigurationStore in interface DurableConfigurationStore

Throws:

StoreException

upgradeStoreStructure

public void upgradeStoreStructure()
                           throws StoreException

Description copied from interface: DurableConfigurationStore

Requests that the store performs any upgrade work on the store's structure. If there is no upgrade work to be done, this method should return without doing anything.

Specified by:

upgradeStoreStructure in interface DurableConfigurationStore

Throws:

StoreException - signals that a problem was encountered trying to upgrade the store. Implementations, on encountering a problem, should endeavour to leave the store in its original state.

getConnection

protected Connection getConnection()
                            throws SQLException

Specified by:

getConnection in class AbstractJDBCConfigurationStore

Throws:

SQLException

closeConfigurationStore

public void closeConfigurationStore()
                             throws StoreException

Specified by:

closeConfigurationStore in interface DurableConfigurationStore

Throws:

StoreException

getSqlBlobType

protected String getSqlBlobType()

Specified by:

getSqlBlobType in class AbstractJDBCConfigurationStore

getSqlVarBinaryType

protected String getSqlVarBinaryType(int size)

Specified by:

getSqlVarBinaryType in class AbstractJDBCConfigurationStore

getSqlBigIntType

protected String getSqlBigIntType()

Specified by:

getSqlBigIntType in class AbstractJDBCConfigurationStore

getBlobAsString

protected String getBlobAsString(ResultSet rs,
                                 int col)
                          throws SQLException

Specified by:

getBlobAsString in class AbstractJDBCConfigurationStore

Throws:

SQLException

onDelete

public void onDelete(ConfiguredObject<?> parent)

Description copied from interface: DurableConfigurationStore

Deletes the configuration store from its underlying storage. If the store has not be opened, then this call will be ignored. The store should be closed before making this call.

Specified by:

onDelete in interface DurableConfigurationStore

Overrides:

onDelete in class AbstractJDBCConfigurationStore

getMessageStore

public MessageStore getMessageStore()

Specified by:

getMessageStore in interface MessageStoreProvider

tableExists

protected boolean tableExists(String tableName,
                              Connection conn)
                       throws SQLException

Overrides:

tableExists in class AbstractJDBCConfigurationStore

Throws:

SQLException

checkConfigurationStoreOpen

protected void checkConfigurationStoreOpen()

Specified by:

checkConfigurationStoreOpen in class AbstractJDBCConfigurationStore

getLogger

protected org.slf4j.Logger getLogger()

Specified by:

getLogger in class AbstractJDBCConfigurationStore