1 package de.dlr.shepard.context.semantic.daos;
2
3 import de.dlr.shepard.common.neo4j.daos.GenericDAO;
4 import de.dlr.shepard.common.util.CypherQueryHelper;
5 import de.dlr.shepard.common.util.QueryParamHelper;
6 import de.dlr.shepard.context.semantic.entities.SemanticRepository;
7 import jakarta.enterprise.context.RequestScoped;
8 import java.util.ArrayList;
9 import java.util.HashMap;
10 import java.util.List;
11 import java.util.Map;
12
13 @RequestScoped
14 public class SemanticRepositoryDAO extends GenericDAO<SemanticRepository> {
15
16 public List<SemanticRepository> findAllSemanticRepositories(QueryParamHelper params) {
17 Map<String, Object> paramsMap = new HashMap<>();
18 if (params.hasName()) paramsMap.put("name", params.getName());
19 var query =
20 "MATCH %s WITH r".formatted(CypherQueryHelper.getObjectPart("r", "SemanticRepository", params.hasName()));
21 if (params.hasOrderByAttribute()) {
22 query += " " + CypherQueryHelper.getOrderByPart("r", params.getOrderByAttribute(), params.getOrderDesc());
23 }
24 if (params.hasPagination()) {
25 paramsMap.put("offset", params.getPagination().getOffset());
26 paramsMap.put("size", params.getPagination().getSize());
27 query += " " + CypherQueryHelper.getPaginationPart();
28 }
29 query += " " + CypherQueryHelper.getReturnPart("r");
30 var result = new ArrayList<SemanticRepository>();
31 for (var rep : findByQuery(query, paramsMap)) {
32 if (matchName(rep, params.getName())) {
33 result.add(rep);
34 }
35 }
36
37 return result;
38 }
39
40 private boolean matchName(SemanticRepository rep, String name) {
41 return name == null || rep.getName().equalsIgnoreCase(name);
42 }
43
44 @Override
45 public Class<SemanticRepository> getEntityType() {
46 return SemanticRepository.class;
47 }
48 }