public abstract class BaseStorageDao extends Object implements StorageDao
Modifier and Type | Field and Description |
---|---|
protected CommonConnectionAccessor |
accessor |
Constructor and Description |
---|
BaseStorageDao(org.osgi.service.jdbc.DataSourceFactory dataSourceFactory,
Properties paramProperties,
boolean usePool) |
Modifier and Type | Method and Description |
---|---|
protected String |
clip(int i,
String string) |
void |
closeConnection(Connection connection) |
void |
closeStatement(Statement statement) |
Connection |
createConnection() |
void |
dispose() |
protected CommonConnectionAccessor |
getAccessor() |
protected int |
getCleanupDays() |
protected abstract String |
getDeleteAttributesSql() |
protected abstract String |
getInsertAttributesSql() |
String |
getInstance() |
int |
getMaxLength() |
String |
getSchema() |
void |
setInstance(String instance) |
void |
setMaxLength(int maxLength) |
void |
setSchema(String schema) |
void |
updateComment(UUID id,
String comment) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
cleanupArchive, loadEvent, queryEvents, storeEvent, toEventList
protected final CommonConnectionAccessor accessor
public BaseStorageDao(org.osgi.service.jdbc.DataSourceFactory dataSourceFactory, Properties paramProperties, boolean usePool) throws SQLException
SQLException
public void dispose()
dispose
in interface StorageDao
public void setSchema(String schema)
public String getSchema()
public void setMaxLength(int maxLength)
public int getMaxLength()
public void setInstance(String instance)
public String getInstance()
public Connection createConnection() throws SQLException
SQLException
protected CommonConnectionAccessor getAccessor()
public void closeStatement(Statement statement)
public void closeConnection(Connection connection)
public void updateComment(UUID id, String comment) throws Exception
updateComment
in interface StorageDao
Exception
protected int getCleanupDays()
protected abstract String getDeleteAttributesSql()
protected abstract String getInsertAttributesSql()