Skip to content

Commit 67c28f6

Browse files
author
Evgenii Grigorev
committed
Rename has-pipeline-name to has-script
1 parent 274b5f7 commit 67c28f6

File tree

6 files changed

+19
-12
lines changed

6 files changed

+19
-12
lines changed

src/main/java/og_spipes/model/spipes/TransformationDTO.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212
public class TransformationDTO extends Transformation {
1313

1414
// //TODO ask why this attribute is not possible to map??? Also I lose properties field
15-
// @OWLDataProperty(iri = "http://onto.fel.cvut.cz/ontologies/s-pipes/has-pipeline-name")
15+
// @OWLDataProperty(iri = "http://onto.fel.cvut.cz/ontologies/s-pipes/has-script")
1616
// private String pipelineName;
1717
//
1818
// @OWLDataProperty(iri = "http://onto.fel.cvut.cz/ontologies/s-pipes/has-pipeline-execution-duration")

src/main/java/og_spipes/persistence/dao/TransformationDAO.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ public String getPipelineName(String executionId) {
4141
String execUri = "http://onto.fel.cvut.cz/ontologies/dataset-descriptor/pipeline-execution/" + executionId;
4242
String sparql = "SELECT DISTINCT ?pipelineName WHERE { " +
4343
"<" + execUri + "> <http://onto.fel.cvut.cz/ontologies/dataset-descriptor/has-part> ?moduleExec . " +
44-
"?moduleExec <http://onto.fel.cvut.cz/ontologies/s-pipes/has-pipeline-name> ?pipelineName . " +
44+
"?moduleExec <http://onto.fel.cvut.cz/ontologies/s-pipes/has-script> ?pipelineName . " +
4545
"}";
4646
Query query = em.createNativeQuery(sparql);
4747
return query.getSingleResult().toString();

src/main/java/og_spipes/service/FormService.java

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -448,10 +448,17 @@ public Question functionToForm(Model script, Resource function) {
448448

449449
subQuestions.add(functionQ);
450450

451-
for(Statement st : script.listStatements(null, new PropertyImpl("http://spinrdf.org/sp#varName"), (String) null).toList()){
451+
Property parameterProp = function.getModel().createProperty("http://www.w3.org/ns/shacl#parameter");
452+
Property pathProp = function.getModel().createProperty("http://www.w3.org/ns/shacl#path");
453+
454+
StmtIterator parameters = function.listProperties(parameterProp);
455+
while (parameters.hasNext()) {
456+
Resource constraint = parameters.nextStatement().getResource();
457+
Statement st = constraint.getProperty(pathProp);
458+
452459
Question q = new Question();
453460
initializeQuestionUri(q);
454-
q.setLabel(st.getObject().toString());
461+
q.setLabel(st.getResource().getLocalName());
455462
q.setProperties(extractQuestionMetadata(st));
456463
q.setPrecedingQuestions(Collections.singleton(functionQ));
457464
subQuestions.add(q);

src/main/java/og_spipes/service/SPipesExecutionService.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -127,10 +127,10 @@ public String moduleExecution(String moduleScript, String moduleInput, String mo
127127
*/
128128
public List<ExecutionDTO> getAllExecution() {
129129
return transformationDAO.getAllExecutionTransformation().stream()
130-
.filter(x -> x.getProperties().containsKey("http://onto.fel.cvut.cz/ontologies/s-pipes/has-pipeline-name"))
130+
.filter(x -> x.getProperties().containsKey("http://onto.fel.cvut.cz/ontologies/s-pipes/has-script"))
131131
.map(x -> {
132132
Map<String, Set<Object>> properties = x.getProperties();
133-
String pipelineURI = properties.get("http://onto.fel.cvut.cz/ontologies/s-pipes/has-pipeline-name").stream().findFirst().orElse("").toString();
133+
String pipelineURI = properties.get("http://onto.fel.cvut.cz/ontologies/s-pipes/has-script").stream().findFirst().orElse("").toString();
134134
String name = pipelineURI.substring(pipelineURI.lastIndexOf("/")+1);
135135
String duration = properties.get("http://onto.fel.cvut.cz/ontologies/s-pipes/has-pipeline-execution-duration").stream().findFirst().orElse("").toString();
136136
Date startDate = x.getStart_date();

src/test/java/og_spipes/service/SPipesExecutionServiceTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ public void moduleExecution() throws IOException, SPipesEngineException {
7575
@Test
7676
public void getAllExecution() throws IOException {
7777
Map<String, Set<Object>> properties = new HashMap<>();
78-
properties.put("http://onto.fel.cvut.cz/ontologies/s-pipes/has-pipeline-name", Collections.singleton("http://onto.fel.cvut.cz/ontologies/s-pipes/hello-world-example-0.2"));
78+
properties.put("http://onto.fel.cvut.cz/ontologies/s-pipes/has-script", Collections.singleton("http://onto.fel.cvut.cz/ontologies/s-pipes/hello-world-example-0.2"));
7979
properties.put("http://onto.fel.cvut.cz/ontologies/dataset-descriptor/has-part", Collections.singleton("http://onto.fel.cvut.cz/ontologies/dataset-descriptor/transformation/1618874296751000"));
8080
properties.put("http://onto.fel.cvut.cz/ontologies/s-pipes/has-pipeline-execution-start-date", Collections.singleton(new Date(1619039405731L)));
8181
properties.put("http://onto.fel.cvut.cz/ontologies/s-pipes/has-pipeline-execution-finish-date", Collections.singleton(new Date(1619039432986L)));

src/test/resources/rdf4j_source/repositories/rdf4j_export

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-pipeline-execution-finish-date-unix>
1515
"1619043855186"^^<http://www.w3.org/2001/XMLSchema#long>;
1616
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-pipeline-execution-duration> "281"^^<http://www.w3.org/2001/XMLSchema#long>;
17-
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-pipeline-name> <http://onto.fel.cvut.cz/ontologies/s-pipes/hello-world-example-0.2> .
17+
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-script> <http://onto.fel.cvut.cz/ontologies/s-pipes/hello-world-example-0.2> .
1818

1919
<http://onto.fel.cvut.cz/ontologies/s-pipes/query_solution_1619043854967> a <http://onto.fel.cvut.cz/ontologies/s-pipes/query_solution>;
2020
<http://onto.fel.cvut.cz/ontologies/s-pipes/has_binding> <http://onto.fel.cvut.cz/ontologies/s-pipes/query_solution_1619043854967/repositoryName>,
@@ -58,7 +58,7 @@
5858
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-input-model-triple-count> "0"^^<http://www.w3.org/2001/XMLSchema#long>;
5959
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-module-type> <http://topbraid.org/sparqlmotionlib#BindWithConstant>;
6060
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-module-execution-duration> "4"^^<http://www.w3.org/2001/XMLSchema#long>;
61-
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-pipeline-name> <http://onto.fel.cvut.cz/ontologies/s-pipes/hello-world-example-0.2> .
61+
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-script> <http://onto.fel.cvut.cz/ontologies/s-pipes/hello-world-example-0.2> .
6262

6363
<http://onto.fel.cvut.cz/ontologies/dataset-descriptor/transformation/1619043854875003-1312806988-399429203>
6464
a <http://www.w3.org/2002/07/owl#Thing>, <http://onto.fel.cvut.cz/ontologies/dataset-descriptor/transformation>;
@@ -77,7 +77,7 @@
7777
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-input-model-triple-count> "0"^^<http://www.w3.org/2001/XMLSchema#long>;
7878
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-module-type> <http://topbraid.org/sparqlmotionlib#BindWithConstant>;
7979
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-module-execution-duration> "3"^^<http://www.w3.org/2001/XMLSchema#long>;
80-
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-pipeline-name> <http://onto.fel.cvut.cz/ontologies/s-pipes/hello-world-example-0.2> .
80+
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-script> <http://onto.fel.cvut.cz/ontologies/s-pipes/hello-world-example-0.2> .
8181

8282
<file:/home/jordan/apache-tomcat-9.0.45/temp/2021-04-21T22_23_58.900Z-s-pipes-log-5181096301762785817/pipeline-execution-1619043854875003/2021-04-21T22_24_14.926Z-module-1619043854875003-845999858-399429203-input.ttl>
8383
a <http://onto.fel.cvut.cz/ontologies/dataset-descriptor/source-dataset-snapshot> .
@@ -132,7 +132,7 @@
132132
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-input-model-triple-count> "0"^^<http://www.w3.org/2001/XMLSchema#long>;
133133
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-module-type> <http://topbraid.org/sparqlmotionlib#ApplyConstruct>;
134134
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-module-execution-duration> "4"^^<http://www.w3.org/2001/XMLSchema#long>;
135-
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-pipeline-name> <http://onto.fel.cvut.cz/ontologies/s-pipes/hello-world-example-0.2> .
135+
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-script> <http://onto.fel.cvut.cz/ontologies/s-pipes/hello-world-example-0.2> .
136136

137137
<file:/home/jordan/apache-tomcat-9.0.45/temp/2021-04-21T22_23_58.900Z-s-pipes-log-5181096301762785817/pipeline-execution-1619043854875003/2021-04-21T22_24_14.994Z-module-1619043854875003-1312806988-399429203-input.ttl>
138138
a <http://onto.fel.cvut.cz/ontologies/dataset-descriptor/source-dataset-snapshot> .
@@ -191,7 +191,7 @@
191191
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-input-model-triple-count> "1"^^<http://www.w3.org/2001/XMLSchema#long>;
192192
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-module-type> <http://topbraid.org/sparqlmotionlib#ReturnRDF>;
193193
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-module-execution-duration> "2"^^<http://www.w3.org/2001/XMLSchema#long>;
194-
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-pipeline-name> <http://onto.fel.cvut.cz/ontologies/s-pipes/hello-world-example-0.2> .
194+
<http://onto.fel.cvut.cz/ontologies/s-pipes/has-script> <http://onto.fel.cvut.cz/ontologies/s-pipes/hello-world-example-0.2> .
195195

196196
<file:/home/jordan/apache-tomcat-9.0.45/temp/2021-04-21T22_23_58.900Z-s-pipes-log-5181096301762785817/pipeline-execution-1619043854875003/2021-04-21T22_24_15.059Z-module-1619043854875003-1304810422-399429203-input.ttl>
197197
a <http://onto.fel.cvut.cz/ontologies/dataset-descriptor/source-dataset-snapshot> .

0 commit comments

Comments
 (0)