1 package de.dlr.shepard.context.references.spatialdata.daos;
2
3 import de.dlr.shepard.common.util.CypherQueryHelper;
4 import de.dlr.shepard.context.references.spatialdata.entities.SpatialDataReference;
5 import de.dlr.shepard.context.version.daos.VersionableEntityDAO;
6 import jakarta.enterprise.context.RequestScoped;
7 import java.util.Collections;
8 import java.util.List;
9 import java.util.stream.StreamSupport;
10
11 @RequestScoped
12 public class SpatialDataReferenceDAO extends VersionableEntityDAO<SpatialDataReference> {
13
14 public List<SpatialDataReference> findByDataObjectShepardId(long dataObjectShepardId) {
15 String query =
16 "MATCH (d:DataObject {shepardId: %d})-[hr:has_reference]->%s".formatted(
17 dataObjectShepardId,
18 CypherQueryHelper.getObjectPart("r", "SpatialDataReference", false)
19 ) +
20 CypherQueryHelper.getReturnPart("r");
21 var queryResult = findByQuery(query, Collections.emptyMap());
22
23 List<SpatialDataReference> result = StreamSupport.stream(queryResult.spliterator(), false)
24 .filter(r -> r.getDataObject() != null && r.getDataObject().getShepardId().equals(dataObjectShepardId))
25 .toList();
26
27 return result;
28 }
29
30 @Override
31 public Class<SpatialDataReference> getEntityType() {
32 return SpatialDataReference.class;
33 }
34 }