public class DerbyConfigurationStore extends AbstractJDBCConfigurationStore implements MessageStoreProvider, DurableConfigurationStore
CONFIGURATION_STORE_TABLE_NAMES
Constructor and Description |
---|
DerbyConfigurationStore(Class<? extends ConfiguredObject> rootClass) |
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.
|
create, createOrOpenConfigurationStoreDatabase, hasNoConfigurationEntries, newAutoCommitConnection, newConnection, remove, update, upgradeIfNecessary, visitConfiguredObjectRecords
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
create, remove, update, visitConfiguredObjectRecords
public DerbyConfigurationStore(Class<? extends ConfiguredObject> rootClass)
public void openConfigurationStore(ConfiguredObject<?> parent, boolean overwrite, ConfiguredObjectRecord... initialRecords) throws StoreException
DurableConfigurationStore
openConfigurationStore
in interface DurableConfigurationStore
StoreException
public void upgradeStoreStructure() throws StoreException
DurableConfigurationStore
upgradeStoreStructure
in interface DurableConfigurationStore
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.protected Connection getConnection() throws SQLException
getConnection
in class AbstractJDBCConfigurationStore
SQLException
public void closeConfigurationStore() throws StoreException
closeConfigurationStore
in interface DurableConfigurationStore
StoreException
protected String getSqlBlobType()
getSqlBlobType
in class AbstractJDBCConfigurationStore
protected String getSqlVarBinaryType(int size)
getSqlVarBinaryType
in class AbstractJDBCConfigurationStore
protected String getSqlBigIntType()
getSqlBigIntType
in class AbstractJDBCConfigurationStore
protected String getBlobAsString(ResultSet rs, int col) throws SQLException
getBlobAsString
in class AbstractJDBCConfigurationStore
SQLException
public void onDelete(ConfiguredObject<?> parent)
DurableConfigurationStore
onDelete
in interface DurableConfigurationStore
onDelete
in class AbstractJDBCConfigurationStore
public MessageStore getMessageStore()
getMessageStore
in interface MessageStoreProvider
protected boolean tableExists(String tableName, Connection conn) throws SQLException
tableExists
in class AbstractJDBCConfigurationStore
SQLException
protected void checkConfigurationStoreOpen()
checkConfigurationStoreOpen
in class AbstractJDBCConfigurationStore
protected org.slf4j.Logger getLogger()
getLogger
in class AbstractJDBCConfigurationStore
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.