org.eclipse.scada.ae.server.storage.jdbc

Class AbstractJdbcStorageDao

java.lang.Object

org.eclipse.scada.ae.server.storage.jdbc.BaseStorageDao

org.eclipse.scada.ae.server.storage.jdbc.AbstractJdbcStorageDao

All Implemented Interfaces:

StorageDao

Direct Known Subclasses:

JdbcStorageDao, JdbcStorageDao

public abstract class AbstractJdbcStorageDao
extends BaseStorageDao

Field Summary

Fields inherited from class org.eclipse.scada.ae.server.storage.jdbc.BaseStorageDao

accessor

Constructor Summary

Constructors

Constructor and Description
AbstractJdbcStorageDao(org.osgi.service.jdbc.DataSourceFactory dataSourceFactory, Properties properties, boolean usePool, Long loginTimeout, com.google.common.collect.Interner<String> stringInterner)

Method Summary

Modifier and Type	Method and Description
void	cleanupArchive()
protected int	cleanupArchive(int days) Cleanup the archive
protected String	getDeleteAttributesSql()
protected String	getInsertAttributesSql()
protected String	intern(String string)
Event	loadEvent(UUID id)
protected void	logSQLError(SQLException e)
protected void	performStoreEvent(Event event, ConnectionContext connectionContext)
ResultSet	queryEvents(Filter filter) Get an open result result for a filter
void	storeEvent(Event event)
protected void	storeReplicationEvent(Event event, Connection con)
boolean	toEventList(ResultSet rs, Collection<Event> events, boolean isBeforeFirst, long count)

Methods inherited from class org.eclipse.scada.ae.server.storage.jdbc.BaseStorageDao

clip, closeConnection, closeStatement, createConnection, dispose, getAccessor, getCleanupDays, getInstance, getMaxLength, getSchema, setInstance, setMaxLength, setSchema, updateComment

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractJdbcStorageDao

public AbstractJdbcStorageDao(org.osgi.service.jdbc.DataSourceFactory dataSourceFactory,
                              Properties properties,
                              boolean usePool,
                              Long loginTimeout,
                              com.google.common.collect.Interner<String> stringInterner)
                       throws SQLException

Throws:

SQLException

Method Detail

storeEvent

public void storeEvent(Event event)
                throws Exception

Throws:

Exception

storeReplicationEvent

protected void storeReplicationEvent(Event event,
                                     Connection con)
                              throws Exception

Throws:

Exception

logSQLError

protected void logSQLError(SQLException e)

loadEvent

public Event loadEvent(UUID id)
                throws SQLException

Throws:

SQLException

queryEvents

public ResultSet queryEvents(Filter filter)
                      throws SQLException,
                             NotSupportedException

Get an open result result for a filter

The caller has to close the result set and the connection

Throws:

SQLException

NotSupportedException

toEventList

public boolean toEventList(ResultSet rs,
                           Collection<Event> events,
                           boolean isBeforeFirst,
                           long count)
                    throws SQLException

Throws:

SQLException

intern

protected String intern(String string)

getDeleteAttributesSql

protected String getDeleteAttributesSql()

Specified by:

getDeleteAttributesSql in class BaseStorageDao

getInsertAttributesSql

protected String getInsertAttributesSql()

Specified by:

getInsertAttributesSql in class BaseStorageDao

cleanupArchive

public void cleanupArchive()

cleanupArchive

protected int cleanupArchive(int days)
                      throws Exception

Cleanup the archive

Parameters:

days - days in the past that should remain in the archive

Returns:

the number of entries deleted or -1 if the parameters days was negative or zero.

Throws:

Exception

performStoreEvent

protected void performStoreEvent(Event event,
                                 ConnectionContext connectionContext)
                          throws SQLException,
                                 Exception

Throws:

SQLException

Exception