org.eclipse.scada.ca.jdbc.internal

Class JdbcStorageDAOImpl

java.lang.Object

org.eclipse.scada.ca.jdbc.internal.JdbcStorageDAOImpl

All Implemented Interfaces:

JdbcStorageDAO

public class JdbcStorageDAOImpl
extends Object
implements JdbcStorageDAO

Constructor Summary

Constructors

Constructor and Description
JdbcStorageDAOImpl(org.osgi.service.jdbc.DataSourceFactory dataSourceFactory, Properties dataSourceProperties, boolean usePool)

Method Summary

Modifier and Type	Method and Description
protected List<Entry>	chunk(List<Entry> data)
protected List<Entry>	deChunk(List<Entry> data)
void	deleteConfiguration(String factoryId, String configurationId)
void	dispose()
protected List<Entry>	fixNulls(List<Entry> data)
protected void	internalDeleteConfiguration(ConnectionContext connectionContext, String factoryId, String configurationId)
protected List<Entry>	internalLoad(ConnectionContext connectionContext, String sql, Object... parameters)
protected Map<String,String>	internalStoreConfiguration(ConnectionContext connectionContext, String factoryId, String configurationId, Map<String,String> properties, boolean fullSet)
List<String>	listFactories()
protected List<Entry>	load(String sql, Object... parameters)
List<Entry>	loadAll()
List<Entry>	loadFactory(String factoryId)
List<Entry>	purgeFactory(String factoryId)
Map<String,String>	storeConfiguration(String factoryId, String configurationId, Map<String,String> properties, boolean fullSet)

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcStorageDAOImpl

public JdbcStorageDAOImpl(org.osgi.service.jdbc.DataSourceFactory dataSourceFactory,
                          Properties dataSourceProperties,
                          boolean usePool)
                   throws SQLException

Throws:

SQLException

Method Detail

dispose

public void dispose()

internalLoad

protected List<Entry> internalLoad(ConnectionContext connectionContext,
                                   String sql,
                                   Object... parameters)
                            throws SQLException

Throws:

SQLException

load

protected List<Entry> load(String sql,
                           Object... parameters)

loadAll

public List<Entry> loadAll()

Specified by:

loadAll in interface JdbcStorageDAO

loadFactory

public List<Entry> loadFactory(String factoryId)

Specified by:

loadFactory in interface JdbcStorageDAO

listFactories

public List<String> listFactories()

Specified by:

listFactories in interface JdbcStorageDAO

storeConfiguration

public Map<String,String> storeConfiguration(String factoryId,
                                             String configurationId,
                                             Map<String,String> properties,
                                             boolean fullSet)

Specified by:

storeConfiguration in interface JdbcStorageDAO

internalStoreConfiguration

protected Map<String,String> internalStoreConfiguration(ConnectionContext connectionContext,
                                                        String factoryId,
                                                        String configurationId,
                                                        Map<String,String> properties,
                                                        boolean fullSet)
                                                 throws SQLException

Throws:

SQLException

purgeFactory

public List<Entry> purgeFactory(String factoryId)

Specified by:

purgeFactory in interface JdbcStorageDAO

deleteConfiguration

public void deleteConfiguration(String factoryId,
                                String configurationId)

Specified by:

deleteConfiguration in interface JdbcStorageDAO

internalDeleteConfiguration

protected void internalDeleteConfiguration(ConnectionContext connectionContext,
                                           String factoryId,
                                           String configurationId)
                                    throws SQLException

Throws:

SQLException

fixNulls

protected List<Entry> fixNulls(List<Entry> data)

chunk

protected List<Entry> chunk(List<Entry> data)

deChunk

protected List<Entry> deChunk(List<Entry> data)