org.eclipse.scada.ae.slave.inject

Class JdbcStorageDao

java.lang.Object

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

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

org.eclipse.scada.ae.slave.inject.JdbcStorageDao

All Implemented Interfaces:

StorageDao

public class JdbcStorageDao
extends AbstractJdbcStorageDao

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	JdbcStorageDao.RowHandler

Field Summary

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

accessor

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
protected int	processOnce(ConnectionContext connectionContext)
protected void	processRow(ConnectionContext connectionContext, ResultSet resultSet)
protected int	runOnce()

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

cleanupArchive, cleanupArchive, getDeleteAttributesSql, getInsertAttributesSql, intern, loadEvent, logSQLError, performStoreEvent, queryEvents, storeEvent, storeReplicationEvent, toEventList

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

JdbcStorageDao

public JdbcStorageDao(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

runOnce

protected int runOnce()

processOnce

protected int processOnce(ConnectionContext connectionContext)
                   throws SQLException

Throws:

SQLException

processRow

protected void processRow(ConnectionContext connectionContext,
              ResultSet resultSet)
                   throws SQLException

Throws:

SQLException