org.n52.sos.ds.hibernate.cache.base

Class OfferingCacheUpdateTask

java.lang.Object

org.n52.sos.util.RunnableAction

org.n52.sos.util.ThreadableAction

org.n52.sos.ds.DatasourceCacheUpdate

org.n52.sos.ds.hibernate.cache.AbstractDatasourceCacheUpdate

org.n52.sos.ds.hibernate.cache.AbstractThreadableDatasourceCacheUpdate

org.n52.sos.ds.hibernate.cache.base.OfferingCacheUpdateTask

All Implemented Interfaces:

Runnable, Action

public class OfferingCacheUpdateTask
extends AbstractThreadableDatasourceCacheUpdate

Since:

4.0.0

Author:

Christian Autermann

Field Summary

Fields

Modifier and Type	Field and Description
private FeatureOfInterestDAO	featureDAO
private boolean	hasSamplingGeometry
private static org.slf4j.Logger	LOGGER
private boolean	obsConstSupported
private Collection<ObservationConstellationInfo>	observationConstellationInfos
private Offering	offering
private String	offeringId

Constructor Summary

Constructors

Constructor and Description
OfferingCacheUpdateTask(Offering offering, Collection<ObservationConstellationInfo> observationConstellationInfos, boolean hasSamplingGeometry) Constructor.

Method Summary

Modifier and Type	Method and Description
private void	addHumanReadableIdentifier(String offeringId, Offering offering, MultilingualString name)
protected void	addOfferingNamesAndDescriptionsToCache(String offeringId, org.hibernate.Session session)
protected void	addSpatialFilteringProfileEnvelopeForOffering(String prefixedOfferingId, String offeringID, org.hibernate.Session session) Get SpatialFilteringProfile envelope if exist and supported
void	execute()
protected SosEnvelope	getEnvelopeForOffering(Collection<String> featureOfInterestIdentifiers, org.hibernate.Session session)
protected Set<String>	getFeatureOfInterestTypes(List<String> featureOfInterestIdentifiers, org.hibernate.Session session)
protected Set<String>	getObservablePropertyIdentifier(org.hibernate.Session session)
protected Set<String>	getObservationTypes(org.hibernate.Session session)
private Set<String>	getObservationTypesFromObservations(org.hibernate.Session session)
protected void	getOfferingInformationFromDbAndAddItToCacheMaps(org.hibernate.Session session)
protected Map<ProcedureFlag,Set<String>>	getProcedureIdentifier(org.hibernate.Session session)
protected Collection<String>	getValidFeaturesOfInterestFrom(Collection<String> featureOfInterestIdentifiers)

Methods inherited from class org.n52.sos.ds.hibernate.cache.AbstractThreadableDatasourceCacheUpdate

getSession, getSessionFactory, setSessionFactory

Methods inherited from class org.n52.sos.ds.hibernate.cache.AbstractDatasourceCacheUpdate

setSession

Methods inherited from class org.n52.sos.ds.DatasourceCacheUpdate

getCache, getErrors, getFeatureQueryHandler, setCache, setErrors, toString

Methods inherited from class org.n52.sos.util.ThreadableAction

run, setParentCountDownLatch

Methods inherited from class org.n52.sos.util.RunnableAction

getStopwatchResult, startStopwatch

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

featureDAO

private final FeatureOfInterestDAO featureDAO

offeringId

private final String offeringId

observationConstellationInfos

private final Collection<ObservationConstellationInfo> observationConstellationInfos

offering

private final Offering offering

obsConstSupported

private boolean obsConstSupported

hasSamplingGeometry

private boolean hasSamplingGeometry

Constructor Detail

OfferingCacheUpdateTask

public OfferingCacheUpdateTask(Offering offering,
                               Collection<ObservationConstellationInfo> observationConstellationInfos,
                               boolean hasSamplingGeometry)

Constructor. Note: never pass in Hibernate objects that have been loaded by a session in a different thread

Parameters:

offering - Offering identifier

observationConstellationInfos - Observation Constellation info collection, passed in from parent update if supported

hasSamplingGeometry - Indicator to execute or not the extent query for the Spatial Filtering Profile

Method Detail

getOfferingInformationFromDbAndAddItToCacheMaps

protected void getOfferingInformationFromDbAndAddItToCacheMaps(org.hibernate.Session session)
                                                        throws OwsExceptionReport

Throws:

OwsExceptionReport

addOfferingNamesAndDescriptionsToCache

protected void addOfferingNamesAndDescriptionsToCache(String offeringId,
                                                      org.hibernate.Session session)
                                               throws OwsExceptionReport

Throws:

OwsExceptionReport

addHumanReadableIdentifier

private void addHumanReadableIdentifier(String offeringId,
                                        Offering offering,
                                        MultilingualString name)

getProcedureIdentifier

protected Map<ProcedureFlag,Set<String>> getProcedureIdentifier(org.hibernate.Session session)
                                                         throws OwsExceptionReport

Throws:

OwsExceptionReport

getValidFeaturesOfInterestFrom

protected Collection<String> getValidFeaturesOfInterestFrom(Collection<String> featureOfInterestIdentifiers)

getObservablePropertyIdentifier

protected Set<String> getObservablePropertyIdentifier(org.hibernate.Session session)
                                               throws OwsExceptionReport

Throws:

OwsExceptionReport

getObservationTypes

protected Set<String> getObservationTypes(org.hibernate.Session session)
                                   throws OwsExceptionReport

Throws:

OwsExceptionReport

getObservationTypesFromObservations

private Set<String> getObservationTypesFromObservations(org.hibernate.Session session)
                                                 throws OwsExceptionReport

Throws:

OwsExceptionReport

getFeatureOfInterestTypes

protected Set<String> getFeatureOfInterestTypes(List<String> featureOfInterestIdentifiers,
                                                org.hibernate.Session session)

getEnvelopeForOffering

protected SosEnvelope getEnvelopeForOffering(Collection<String> featureOfInterestIdentifiers,
                                             org.hibernate.Session session)
                                      throws OwsExceptionReport

Throws:

OwsExceptionReport

addSpatialFilteringProfileEnvelopeForOffering

protected void addSpatialFilteringProfileEnvelopeForOffering(String prefixedOfferingId,
                                                             String offeringID,
                                                             org.hibernate.Session session)
                                                      throws OwsExceptionReport

Get SpatialFilteringProfile envelope if exist and supported

Parameters:

prefixedOfferingId - Offering identifier used in requests and responses

offeringID - Database Offering identifier to get envelope for

session - Hibernate session

Throws:

OwsExceptionReport - If an error occurs

execute

public void execute()