org.deegree.observation.persistence.binary
Class BinarySQLDatastore

java.lang.Object
  extended by org.deegree.observation.persistence.SQLObservationDatastore
      extended by org.deegree.observation.persistence.simple.SimpleObservationDatastore
          extended by org.deegree.observation.persistence.binary.BinarySQLDatastore
All Implemented Interfaces:
ObservationDatastore

public class BinarySQLDatastore
extends SimpleObservationDatastore

This datastore is able to manage data with a high sampling rate. The data is read from DB records with SQL byte arrays. The current implementation allows each record to store measurements that occurred within one second. The number of measurements per seconds and the time interval between them can be configured with the ms_per_record and number_of_records options. (e.g. if you have 10ms sampling rate: number_of_records = 100, ms_per_record=10)

Version:
$Revision: 26739 $, $Date: 2010-09-14 16:30:04 +0200 (Tue, 14 Sep 2010) $
Author:
Oliver Tonnhofer, last edited by: $Author: aionita $

Field Summary
 
Fields inherited from class org.deegree.observation.persistence.simple.SimpleObservationDatastore
procColumn, timeColumn
 
Fields inherited from class org.deegree.observation.persistence.SQLObservationDatastore
columnMap, jdbcId, optionMap, properties, tableName
 
Constructor Summary
BinarySQLDatastore(String jdbcId, String tableName, Map<String,String> columnMap, Map<String,String> optionMap, List<Property> properties)
           
 
Method Summary
 Observation getObservation(FilterCollection filter, Offering offering)
          Get measurements from the datastore.
 SamplingTime getSamplingTime()
          Get the time span (sampling time) of all observations in this datastore.
protected  PreparedStatement getStatement(FilterCollection filter, Collection<String> collection, Connection conn, Offering offering)
          Create the sql statement.
 
Methods inherited from class org.deegree.observation.persistence.simple.SimpleObservationDatastore
getFilterConverter, getProcedure, getPropertyMap
 
Methods inherited from class org.deegree.observation.persistence.SQLObservationDatastore
getJdbcId, getProperties
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BinarySQLDatastore

public BinarySQLDatastore(String jdbcId,
                          String tableName,
                          Map<String,String> columnMap,
                          Map<String,String> optionMap,
                          List<Property> properties)
Parameters:
dsConfig -
Method Detail

getSamplingTime

public SamplingTime getSamplingTime()
Description copied from interface: ObservationDatastore
Get the time span (sampling time) of all observations in this datastore.

Specified by:
getSamplingTime in interface ObservationDatastore
Overrides:
getSamplingTime in class SimpleObservationDatastore
Returns:
the sampling time of the datastore

getObservation

public Observation getObservation(FilterCollection filter,
                                  Offering offering)
                           throws ObservationDatastoreException
Description copied from interface: ObservationDatastore
Get measurements from the datastore.

Specified by:
getObservation in interface ObservationDatastore
Overrides:
getObservation in class SimpleObservationDatastore
Returns:
the resulting measurements
Throws:
ObservationDatastoreException

getStatement

protected PreparedStatement getStatement(FilterCollection filter,
                                         Collection<String> collection,
                                         Connection conn,
                                         Offering offering)
                                  throws SQLException,
                                         FilterException
Description copied from class: SimpleObservationDatastore
Create the sql statement.

Overrides:
getStatement in class SimpleObservationDatastore
Returns:
the sql select statement with where clauses
Throws:
SQLException
FilterException


Copyright © 2011. All Rights Reserved.