org.eclipse.scada.ae.server.storage.postgres

Class JdbcDao

java.lang.Object

org.eclipse.scada.ae.server.storage.postgres.JdbcDao

public class JdbcDao
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JdbcDao.ReplicationDataFormat

Field Summary

Fields

Modifier and Type	Field and Description
JdbcDao.ReplicationDataFormat	dataFormat

Constructor Summary

Constructors

Constructor and Description
JdbcDao(CommonConnectionAccessor accessor, String schema, String instance, NodeIdProvider nodeIdProvider)

Method Summary

Modifier and Type	Method and Description
int	cleanUp(Date date)
Event	load(UUID id)
ResultSet	queryEvents(Filter filter)
void	store(ConnectionContext connectionContext, Event event)
void	storeReplication(ConnectionContext connectionContext, Event event)
void	update(ConnectionContext connectionContext, Event event)

Methods inherited from class java.lang.Object

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

Field Detail

dataFormat

public final JdbcDao.ReplicationDataFormat dataFormat

Constructor Detail

JdbcDao

public JdbcDao(CommonConnectionAccessor accessor,
               String schema,
               String instance,
               NodeIdProvider nodeIdProvider)

Method Detail

load

public Event load(UUID id)

store

public void store(ConnectionContext connectionContext,
                  Event event)
           throws SQLException

Throws:

SQLException

storeReplication

public void storeReplication(ConnectionContext connectionContext,
                             Event event)
                      throws SQLException,
                             IOException

Throws:

SQLException

IOException

update

public void update(ConnectionContext connectionContext,
                   Event event)
            throws SQLException

Throws:

SQLException

cleanUp

public int cleanUp(Date date)

queryEvents

public ResultSet queryEvents(Filter filter)
                      throws SQLException,
                             NotSupportedException

Throws:

SQLException

NotSupportedException