public class GenericJDBCConfigurationStore extends AbstractJDBCConfigurationStore implements MessageStoreProvider
CONFIGURATION_STORE_TABLE_NAMES
Constructor and Description |
---|
GenericJDBCConfigurationStore(Class<? extends ConfiguredObject> rootClass) |
Modifier and Type | Method and Description |
---|---|
protected void |
checkConfigurationStoreOpen() |
void |
closeConfigurationStore() |
protected byte[] |
getBlobAsBytes(ResultSet rs,
int col) |
protected String |
getBlobAsString(ResultSet rs,
int col) |
protected Connection |
getConnection() |
protected org.slf4j.Logger |
getLogger() |
MessageStore |
getMessageStore() |
protected String |
getPlainTextPassword(JDBCSettings settings) |
String |
getSqlBigIntType() |
protected String |
getSqlBlobType() |
protected String |
getSqlVarBinaryType(int size) |
void |
openConfigurationStore(ConfiguredObject<?> parent,
boolean overwrite,
ConfiguredObjectRecord... initialRecords)
Initializes and opens the configuration store.
|
void |
upgradeStoreStructure()
Requests that the store performs any upgrade work on the store's structure.
|
create, createOrOpenConfigurationStoreDatabase, hasNoConfigurationEntries, newAutoCommitConnection, newConnection, onDelete, remove, tableExists, update, upgradeIfNecessary, visitConfiguredObjectRecords
public GenericJDBCConfigurationStore(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
public String getSqlBigIntType()
getSqlBigIntType
in class AbstractJDBCConfigurationStore
protected String getBlobAsString(ResultSet rs, int col) throws SQLException
getBlobAsString
in class AbstractJDBCConfigurationStore
SQLException
protected byte[] getBlobAsBytes(ResultSet rs, int col) throws SQLException
SQLException
protected void checkConfigurationStoreOpen()
checkConfigurationStoreOpen
in class AbstractJDBCConfigurationStore
protected org.slf4j.Logger getLogger()
getLogger
in class AbstractJDBCConfigurationStore
public MessageStore getMessageStore()
getMessageStore
in interface MessageStoreProvider
protected String getPlainTextPassword(JDBCSettings settings)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.