public class ObservationDAO extends AbstractObservationDAO
AbstractObservationDAO.ObservationIdentifiers
TimeCreator.MinMax
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOGGER |
static String |
SQL_QUERY_GET_FIRST_OBSERVATION_TIME |
static String |
SQL_QUERY_GET_LATEST_OBSERVATION_TIME |
Constructor and Description |
---|
ObservationDAO() |
Modifier and Type | Method and Description |
---|---|
private void |
addAliasAndNotRestrictionFor(org.hibernate.Criteria c,
Set<Long> procedureIds,
Set<Long> observablePropertyIds,
Set<Long> featureIds) |
void |
addFeatureOfInterestRestrictionToObservationCriteria(org.hibernate.Criteria criteria,
String featureOfInterest)
Add featureOfInterest restriction to Hibernate Criteria for Observation
|
void |
addObservablePropertyRestrictionToObservationCriteria(org.hibernate.Criteria criteria,
String observableProperty)
Add observableProperty restriction to Hibernate Criteria for Observation
|
protected void |
addObservationIdentifiersToObservation(AbstractObservationDAO.ObservationIdentifiers observationIdentifiers,
AbstractObservation observation,
org.hibernate.Session session)
Add observation identifier (procedure, observableProperty,
featureOfInterest) to observation
|
void |
addProcedureRestrictionToObservationCriteria(org.hibernate.Criteria criteria,
String procedure)
Add procedure restriction to Hibernate Criteria for Observation
|
boolean |
checkBlobObservationsFor(String offeringIdentifier,
org.hibernate.Session session)
Check if there are blob observations for the offering
|
boolean |
checkBooleanObservationsFor(String offeringIdentifier,
org.hibernate.Session session)
Check if there are boolean observations for the offering
|
boolean |
checkCategoryObservationsFor(String offeringIdentifier,
org.hibernate.Session session)
Check if there are category observations for the offering
|
boolean |
checkCountObservationsFor(String offeringIdentifier,
org.hibernate.Session session)
Check if there are count observations for the offering
|
boolean |
checkGeometryObservationsFor(String offeringIdentifier,
org.hibernate.Session session)
Check if there are geometry observations for the offering
|
boolean |
checkNumericObservationsFor(String offeringIdentifier,
org.hibernate.Session session)
Check if there are numeric observations for the offering
|
boolean |
checkSweDataArrayObservationsFor(String offeringIdentifier,
org.hibernate.Session session)
Check if there are geometry observations for the offering
|
boolean |
checkTextObservationsFor(String offeringIdentifier,
org.hibernate.Session session)
Check if there are text observations for the offering
|
AbstractObservation |
createObservationFromValue(Value<?> value,
org.hibernate.Session session)
Create an observation object from SOS value
|
org.hibernate.Criteria |
getDefaultObservationCriteria(org.hibernate.Session session)
Get default Hibernate Criteria to query observations, default flag ==
false |
org.hibernate.Criteria |
getDefaultObservationInfoCriteria(org.hibernate.Session session)
Get default Hibernate Criteria to query observation info, default flag ==
false |
TimePeriod |
getGlobalTemporalBoundingBox(org.hibernate.Session session)
Get global temporal bounding box
|
org.joda.time.DateTime |
getMaxPhenomenonTime(org.hibernate.Session session)
Get max phenomenon time from observations
|
org.joda.time.DateTime |
getMaxResultTime(org.hibernate.Session session)
Get max phenomenon time from observations
|
org.joda.time.DateTime |
getMinPhenomenonTime(org.hibernate.Session session)
Get min phenomenon time from observations
|
org.joda.time.DateTime |
getMinResultTime(org.hibernate.Session session)
Get min result time from observations
|
org.hibernate.ScrollableResults |
getNotMatchingSeries(Set<Long> procedureIds,
Set<Long> observablePropertyIds,
Set<Long> featureIds,
GetObservationRequest request,
Set<String> features,
org.hibernate.criterion.Criterion temporalFilterCriterion,
org.hibernate.Session session) |
org.hibernate.ScrollableResults |
getNotMatchingSeries(Set<Long> procedureIds,
Set<Long> observablePropertyIds,
Set<Long> featureIds,
GetObservationRequest request,
Set<String> features,
org.hibernate.Session session) |
AbstractObservation |
getObservationByIdentifier(String identifier,
org.hibernate.Session session)
Query observation by identifier
|
org.hibernate.Criteria |
getObservationClassCriteriaForResultModel(String resultModel,
org.hibernate.Session session)
Get Hibernate Criteria for result model
|
protected org.hibernate.Criteria |
getObservationCriteriaFor(GetObservationRequest request,
Collection<String> features,
org.hibernate.criterion.Criterion filterCriterion,
SosConstants.SosIndeterminateTime sosIndeterminateTime,
org.hibernate.Session session) |
org.hibernate.Criteria |
getObservationCriteriaFor(String procedure,
String observableProperty,
org.hibernate.Session session)
Get Hibernate Criteria for observation with restrictions procedure and
observableProperty
|
org.hibernate.Criteria |
getObservationCriteriaFor(String procedure,
String observableProperty,
String featureOfInterest,
org.hibernate.Session session)
Get Hibernate Criteria for observation with restrictions procedure,
observableProperty and featureOfInterest
|
org.hibernate.Criteria |
getObservationCriteriaForFeatureOfInterest(String featureOfInterest,
org.hibernate.Session session)
Get Hibernate Criteria for observation with restriction featureOfInterest
|
org.hibernate.Criteria |
getObservationCriteriaForObservableProperty(String observableProperty,
org.hibernate.Session session)
Get Hibernate Criteria for observation with restriction
observableProperty
|
org.hibernate.Criteria |
getObservationCriteriaForProcedure(String procedure,
org.hibernate.Session session)
Get Hibernate Criteria for observation with restriction procedure
|
List<String> |
getObservationIdentifiers(org.hibernate.Session session)
Get all observation identifiers
|
Collection<String> |
getObservationIdentifiers(String procedureIdentifier,
org.hibernate.Session session)
Get all observation identifiers for a procedure.
|
org.hibernate.Criteria |
getObservationInfoCriteriaForFeatureOfInterestAndOffering(String feature,
String offering,
org.hibernate.Session session)
Get Hibernate Criteria for querying observations with parameters
featureOfInterst and offering
|
org.hibernate.Criteria |
getObservationInfoCriteriaForFeatureOfInterestAndProcedure(String feature,
String procedure,
org.hibernate.Session session)
Get Hibernate Criteria for querying observations with parameters
featureOfInterst and procedure
|
private List<AbstractObservation> |
getObservationsFor(GetObservationRequest request,
Collection<String> features,
org.hibernate.criterion.Criterion filterCriterion,
SosConstants.SosIndeterminateTime sosIndeterminateTime,
org.hibernate.Session session) |
Collection<AbstractObservation> |
getObservationsFor(GetObservationRequest request,
Set<String> features,
org.hibernate.criterion.Criterion filterCriterion,
org.hibernate.Session session) |
Collection<AbstractObservation> |
getObservationsFor(GetObservationRequest request,
Set<String> features,
org.hibernate.Session session) |
Collection<AbstractObservation> |
getObservationsFor(GetObservationRequest request,
Set<String> features,
SosConstants.SosIndeterminateTime sosIndeterminateTime,
org.hibernate.Session session) |
Collection<? extends AbstractObservation> |
getObservationsFor(ObservationConstellation oc,
HashSet<String> features,
GetObservationRequest request,
SosConstants.SosIndeterminateTime sosIndeterminateTime,
org.hibernate.Session session) |
List<com.vividsolutions.jts.geom.Geometry> |
getSamplingGeometries(String feature,
org.hibernate.Session session) |
SosEnvelope |
getSpatialFilteringProfileEnvelopeForOfferingId(String offeringID,
org.hibernate.Session session) |
org.hibernate.ScrollableResults |
getStreamingObservationsFor(GetObservationRequest request,
Set<String> features,
org.hibernate.criterion.Criterion temporalFilterCriterion,
org.hibernate.Session session) |
org.hibernate.ScrollableResults |
getStreamingObservationsFor(GetObservationRequest request,
Set<String> features,
org.hibernate.Session session) |
void |
updateObservationSetAsDeletedForProcedure(String procedure,
boolean deleteFlag,
org.hibernate.Session session)
Update observation by setting deleted flag
|
addIndeterminateTimeRestriction, addObservationIdentifierToCriteria, addPhenomenonTimeToObservation, addPhenomeonTimeAndResultTimeToObservation, addResultTimeToObservation, addValidTimeToObservation, checkAndAddSpatialFilteringProfileCriterion, checkObservationFor, createCriteriaForObservationClass, finalizeObservationInsertion, getCodespace, getDefaultObservationCriteria, getGlobalTemporalBoundingBox, getIndeterminateTimeExtremaProjection, getIndeterminateTimeFilterProperty, getMaxPhenomenonTime, getMaxResultTime, getMinPhenomenonTime, getMinResultTime, getOrder, getSpatialFilteringProfileEnvelopeForOfferingId, getUnit, insertObservationMultiValue, insertObservationSingleValue, insertObservationSingleValue, insertParameter, updateObservation
addMinMaxProjection, createTimePeriod
private static final org.slf4j.Logger LOGGER
public static final String SQL_QUERY_GET_LATEST_OBSERVATION_TIME
public static final String SQL_QUERY_GET_FIRST_OBSERVATION_TIME
public List<String> getObservationIdentifiers(org.hibernate.Session session)
AbstractObservationDAO
getObservationIdentifiers
in class AbstractObservationDAO
session
- Hibernate sessionpublic boolean checkNumericObservationsFor(String offeringIdentifier, org.hibernate.Session session)
AbstractObservationDAO
checkNumericObservationsFor
in class AbstractObservationDAO
offeringIdentifier
- Offering identifiersession
- Hibernate sessionpublic boolean checkBooleanObservationsFor(String offeringIdentifier, org.hibernate.Session session)
AbstractObservationDAO
checkBooleanObservationsFor
in class AbstractObservationDAO
offeringIdentifier
- Offering identifiersession
- Hibernate sessionpublic boolean checkCountObservationsFor(String offeringIdentifier, org.hibernate.Session session)
AbstractObservationDAO
checkCountObservationsFor
in class AbstractObservationDAO
offeringIdentifier
- Offering identifiersession
- Hibernate sessionpublic boolean checkCategoryObservationsFor(String offeringIdentifier, org.hibernate.Session session)
AbstractObservationDAO
checkCategoryObservationsFor
in class AbstractObservationDAO
offeringIdentifier
- Offering identifiersession
- Hibernate sessionpublic boolean checkTextObservationsFor(String offeringIdentifier, org.hibernate.Session session)
AbstractObservationDAO
checkTextObservationsFor
in class AbstractObservationDAO
offeringIdentifier
- Offering identifiersession
- Hibernate sessionpublic boolean checkBlobObservationsFor(String offeringIdentifier, org.hibernate.Session session)
AbstractObservationDAO
checkBlobObservationsFor
in class AbstractObservationDAO
offeringIdentifier
- Offering identifiersession
- Hibernate sessionpublic boolean checkGeometryObservationsFor(String offeringIdentifier, org.hibernate.Session session)
AbstractObservationDAO
checkGeometryObservationsFor
in class AbstractObservationDAO
offeringIdentifier
- Offering identifiersession
- Hibernate sessionpublic boolean checkSweDataArrayObservationsFor(String offeringIdentifier, org.hibernate.Session session)
AbstractObservationDAO
checkSweDataArrayObservationsFor
in class AbstractObservationDAO
offeringIdentifier
- Offering identifiersession
- Hibernate sessionpublic org.joda.time.DateTime getMinPhenomenonTime(org.hibernate.Session session)
AbstractObservationDAO
getMinPhenomenonTime
in class AbstractObservationDAO
session
- Hibernate session Hibernate sessionpublic org.joda.time.DateTime getMaxPhenomenonTime(org.hibernate.Session session)
AbstractObservationDAO
getMaxPhenomenonTime
in class AbstractObservationDAO
session
- Hibernate session Hibernate sessionpublic org.joda.time.DateTime getMinResultTime(org.hibernate.Session session)
AbstractObservationDAO
getMinResultTime
in class AbstractObservationDAO
session
- Hibernate session Hibernate sessionpublic org.joda.time.DateTime getMaxResultTime(org.hibernate.Session session)
AbstractObservationDAO
getMaxResultTime
in class AbstractObservationDAO
session
- Hibernate session Hibernate sessionpublic TimePeriod getGlobalTemporalBoundingBox(org.hibernate.Session session)
AbstractObservationDAO
getGlobalTemporalBoundingBox
in class AbstractObservationDAO
session
- Hibernate session the sessionpublic AbstractObservation createObservationFromValue(Value<?> value, org.hibernate.Session session)
AbstractObservationDAO
createObservationFromValue
in class AbstractObservationDAO
value
- SOS valuesession
- Hibernate sessionprotected void addObservationIdentifiersToObservation(AbstractObservationDAO.ObservationIdentifiers observationIdentifiers, AbstractObservation observation, org.hibernate.Session session)
AbstractObservationDAO
addObservationIdentifiersToObservation
in class AbstractObservationDAO
observationIdentifiers
- Observation identifiersobservation
- Observation to add identifierssession
- Hibernate sessionpublic org.hibernate.Criteria getObservationClassCriteriaForResultModel(String resultModel, org.hibernate.Session session)
AbstractObservationDAO
getObservationClassCriteriaForResultModel
in class AbstractObservationDAO
resultModel
- Result modelsession
- Hibernate sessionpublic org.hibernate.Criteria getDefaultObservationCriteria(org.hibernate.Session session)
AbstractObservationDAO
false
getDefaultObservationCriteria
in class AbstractObservationDAO
session
- Hiberante sessionpublic org.hibernate.Criteria getDefaultObservationInfoCriteria(org.hibernate.Session session)
AbstractObservationDAO
false
getDefaultObservationInfoCriteria
in class AbstractObservationDAO
session
- Hiberante sessionpublic AbstractObservation getObservationByIdentifier(String identifier, org.hibernate.Session session)
AbstractObservationDAO
getObservationByIdentifier
in class AbstractObservationDAO
identifier
- Observation identifier (gml:identifier)session
- Hiberante sessionpublic org.hibernate.Criteria getObservationInfoCriteriaForFeatureOfInterestAndProcedure(String feature, String procedure, org.hibernate.Session session)
AbstractObservationDAO
getObservationInfoCriteriaForFeatureOfInterestAndProcedure
in class AbstractObservationDAO
feature
- FeatureOfInterest to query forprocedure
- Procedure to query forsession
- Hiberante Sessionpublic org.hibernate.Criteria getObservationInfoCriteriaForFeatureOfInterestAndOffering(String feature, String offering, org.hibernate.Session session)
AbstractObservationDAO
getObservationInfoCriteriaForFeatureOfInterestAndOffering
in class AbstractObservationDAO
feature
- FeatureOfInterest to query foroffering
- Offering to query forsession
- Hiberante Sessionpublic void updateObservationSetAsDeletedForProcedure(String procedure, boolean deleteFlag, org.hibernate.Session session)
procedure
- Procedure for which the observations should be updateddeleteFlag
- New deleted flag valuesession
- Hibernate Sessionpublic void addObservablePropertyRestrictionToObservationCriteria(org.hibernate.Criteria criteria, String observableProperty)
criteria
- Hibernate Criteria for ObservationobservableProperty
- ObservableProperty identifier to addpublic void addProcedureRestrictionToObservationCriteria(org.hibernate.Criteria criteria, String procedure)
criteria
- Hibernate Criteria for Observationprocedure
- Procedure identifier to addpublic void addFeatureOfInterestRestrictionToObservationCriteria(org.hibernate.Criteria criteria, String featureOfInterest)
criteria
- Hibernate Criteria for ObservationfeatureOfInterest
- FeatureOfInterest identifier to addpublic org.hibernate.Criteria getObservationCriteriaForProcedure(String procedure, org.hibernate.Session session)
AbstractObservationDAO
getObservationCriteriaForProcedure
in class AbstractObservationDAO
procedure
- Procedure parametersession
- Hibernate sessionpublic org.hibernate.Criteria getObservationCriteriaForObservableProperty(String observableProperty, org.hibernate.Session session)
AbstractObservationDAO
getObservationCriteriaForObservableProperty
in class AbstractObservationDAO
session
- Hibernate sessionpublic org.hibernate.Criteria getObservationCriteriaForFeatureOfInterest(String featureOfInterest, org.hibernate.Session session)
AbstractObservationDAO
getObservationCriteriaForFeatureOfInterest
in class AbstractObservationDAO
session
- Hibernate sessionpublic org.hibernate.Criteria getObservationCriteriaFor(String procedure, String observableProperty, org.hibernate.Session session)
AbstractObservationDAO
getObservationCriteriaFor
in class AbstractObservationDAO
session
- Hibernate sessionpublic org.hibernate.Criteria getObservationCriteriaFor(String procedure, String observableProperty, String featureOfInterest, org.hibernate.Session session)
AbstractObservationDAO
getObservationCriteriaFor
in class AbstractObservationDAO
session
- Hibernate sessionpublic Collection<String> getObservationIdentifiers(String procedureIdentifier, org.hibernate.Session session)
AbstractObservationDAO
getObservationIdentifiers
in class AbstractObservationDAO
private List<AbstractObservation> getObservationsFor(GetObservationRequest request, Collection<String> features, org.hibernate.criterion.Criterion filterCriterion, SosConstants.SosIndeterminateTime sosIndeterminateTime, org.hibernate.Session session) throws OwsExceptionReport
OwsExceptionReport
protected org.hibernate.Criteria getObservationCriteriaFor(GetObservationRequest request, Collection<String> features, org.hibernate.criterion.Criterion filterCriterion, SosConstants.SosIndeterminateTime sosIndeterminateTime, org.hibernate.Session session) throws OwsExceptionReport
OwsExceptionReport
public Collection<AbstractObservation> getObservationsFor(GetObservationRequest request, Set<String> features, org.hibernate.criterion.Criterion filterCriterion, org.hibernate.Session session) throws OwsExceptionReport
OwsExceptionReport
public Collection<AbstractObservation> getObservationsFor(GetObservationRequest request, Set<String> features, SosConstants.SosIndeterminateTime sosIndeterminateTime, org.hibernate.Session session) throws OwsExceptionReport
OwsExceptionReport
public Collection<AbstractObservation> getObservationsFor(GetObservationRequest request, Set<String> features, org.hibernate.Session session) throws OwsExceptionReport
OwsExceptionReport
public Collection<? extends AbstractObservation> getObservationsFor(ObservationConstellation oc, HashSet<String> features, GetObservationRequest request, SosConstants.SosIndeterminateTime sosIndeterminateTime, org.hibernate.Session session) throws OwsExceptionReport
OwsExceptionReport
public org.hibernate.ScrollableResults getStreamingObservationsFor(GetObservationRequest request, Set<String> features, org.hibernate.criterion.Criterion temporalFilterCriterion, org.hibernate.Session session) throws org.hibernate.HibernateException, OwsExceptionReport
org.hibernate.HibernateException
OwsExceptionReport
public org.hibernate.ScrollableResults getStreamingObservationsFor(GetObservationRequest request, Set<String> features, org.hibernate.Session session) throws org.hibernate.HibernateException, OwsExceptionReport
org.hibernate.HibernateException
OwsExceptionReport
public org.hibernate.ScrollableResults getNotMatchingSeries(Set<Long> procedureIds, Set<Long> observablePropertyIds, Set<Long> featureIds, GetObservationRequest request, Set<String> features, org.hibernate.criterion.Criterion temporalFilterCriterion, org.hibernate.Session session) throws OwsExceptionReport
OwsExceptionReport
public org.hibernate.ScrollableResults getNotMatchingSeries(Set<Long> procedureIds, Set<Long> observablePropertyIds, Set<Long> featureIds, GetObservationRequest request, Set<String> features, org.hibernate.Session session) throws OwsExceptionReport
OwsExceptionReport
private void addAliasAndNotRestrictionFor(org.hibernate.Criteria c, Set<Long> procedureIds, Set<Long> observablePropertyIds, Set<Long> featureIds)
public SosEnvelope getSpatialFilteringProfileEnvelopeForOfferingId(String offeringID, org.hibernate.Session session) throws OwsExceptionReport
getSpatialFilteringProfileEnvelopeForOfferingId
in class AbstractObservationDAO
OwsExceptionReport
public List<com.vividsolutions.jts.geom.Geometry> getSamplingGeometries(String feature, org.hibernate.Session session)
getSamplingGeometries
in class AbstractObservationDAO
Copyright © 2012-2014 52north.org. All Rights Reserved.