Project

General

Profile

« Previous | Next » 

Revision 48735

Added by Alessia Bardi over 6 years ago

Transformed in springboot application because jena gets in with a dependency to jackson that conflicts with the one of exist

View differences:

modules/dnet-parthenos-publisher/trunk/dnet-parthenos-publisher.iml
22 22 
    <orderEntry type="inheritedJdk" />
23 23 
    <orderEntry type="sourceFolder" forTests="false" />
24 24 
    <orderEntry type="module" module-name="dnet-core-components" />
25 
    <orderEntry type="library" name="Maven: org.springframework:spring-webmvc:4.2.5.RELEASE" level="project" />
26 
    <orderEntry type="library" name="Maven: org.springframework:spring-expression:4.2.5.RELEASE" level="project" />
27 
    <orderEntry type="library" name="Maven: org.springframework:spring-web:4.2.5.RELEASE" level="project" />
25 
    <orderEntry type="library" name="Maven: org.springframework:spring-webmvc:4.3.7.RELEASE" level="project" />
26 
    <orderEntry type="library" name="Maven: org.springframework:spring-aop:4.3.7.RELEASE" level="project" />
27 
    <orderEntry type="library" name="Maven: org.springframework:spring-expression:4.3.7.RELEASE" level="project" />
28 
    <orderEntry type="library" name="Maven: org.springframework:spring-web:4.3.7.RELEASE" level="project" />
28 29 
    <orderEntry type="library" name="Maven: org.quartz-scheduler:quartz:2.2.2" level="project" />
29 30 
    <orderEntry type="library" name="Maven: c3p0:c3p0:0.9.1.1" level="project" />
30 
    <orderEntry type="library" name="Maven: org.springframework:spring-context:4.2.5.RELEASE" level="project" />
31 
    <orderEntry type="library" name="Maven: org.springframework:spring-aop:4.2.5.RELEASE" level="project" />
32 
    <orderEntry type="library" name="Maven: aopalliance:aopalliance:1.0" level="project" />
33 
    <orderEntry type="library" name="Maven: org.springframework:spring-beans:4.2.5.RELEASE" level="project" />
34 
    <orderEntry type="library" name="Maven: org.springframework:spring-context-support:4.2.5.RELEASE" level="project" />
31 
    <orderEntry type="library" name="Maven: org.springframework:spring-context:4.3.7.RELEASE" level="project" />
32 
    <orderEntry type="library" name="Maven: org.springframework:spring-beans:4.3.7.RELEASE" level="project" />
33 
    <orderEntry type="library" name="Maven: org.springframework:spring-context-support:4.3.7.RELEASE" level="project" />
35 34 
    <orderEntry type="library" name="Maven: com.google.guava:guava:18.0" level="project" />
36 35 
    <orderEntry type="library" name="Maven: net.sf.ehcache:ehcache-core:2.6.2" level="project" />
37 36 
    <orderEntry type="library" name="Maven: org.apache.lucene:lucene-queryparser:5.5.0" level="project" />
......
43 42 
    <orderEntry type="library" name="Maven: org.antlr:antlr:2.7.7" level="project" />
44 43 
    <orderEntry type="library" name="Maven: org.apache.commons:commons-lang3:3.4" level="project" />
45 44 
    <orderEntry type="library" name="Maven: commons-io:commons-io:2.4" level="project" />
46 
    <orderEntry type="library" name="Maven: com.google.code.gson:gson:2.6.2" level="project" />
47 
    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpclient:4.4.1" level="project" />
48 
    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpcore:4.4.1" level="project" />
45 
    <orderEntry type="library" name="Maven: com.google.code.gson:gson:2.8.0" level="project" />
46 
    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpclient:4.5.3" level="project" />
47 
    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpcore:4.4.6" level="project" />
49 48 
    <orderEntry type="library" name="Maven: org.apache.cxf:cxf-core:3.1.5" level="project" />
50 49 
    <orderEntry type="library" name="Maven: org.codehaus.woodstox:woodstox-core-asl:4.4.1" level="project" />
51 50 
    <orderEntry type="library" name="Maven: org.codehaus.woodstox:stax2-api:3.1.4" level="project" />
......
64 63 
    <orderEntry type="library" name="Maven: org.apache.cxf:cxf-rt-ws-addr:3.1.5" level="project" />
65 64 
    <orderEntry type="library" name="Maven: org.apache.cxf:cxf-rt-ws-policy:3.1.5" level="project" />
66 65 
    <orderEntry type="library" name="Maven: org.apache.neethi:neethi:3.0.3" level="project" />
67 
    <orderEntry type="library" name="Maven: commons-codec:commons-codec:1.8" level="project" />
66 
    <orderEntry type="library" name="Maven: commons-codec:commons-codec:1.10" level="project" />
68 67 
    <orderEntry type="library" name="Maven: net.sf.saxon:Saxon-HE:9.5.1-5" level="project" />
69 68 
    <orderEntry type="library" name="Maven: jaxen:jaxen:1.1.6" level="project" />
70 69 
    <orderEntry type="library" name="Maven: dom4j:dom4j:1.6.1" level="project" />
71 70 
    <orderEntry type="library" name="Maven: com.ximpleware:vtd-xml:2.13.2" level="project" />
72 71 
    <orderEntry type="library" name="Maven: com.mycila:xmltool:3.3" level="project" />
73 72 
    <orderEntry type="library" name="Maven: org.mongodb:mongo-java-driver:3.4.2" level="project" />
74 
    <orderEntry type="library" name="Maven: joda-time:joda-time:2.9.9" level="project" />
75 
    <orderEntry type="library" name="Maven: org.springframework:spring-test:4.2.5.RELEASE" level="project" />
76 
    <orderEntry type="module" module-name="dnet-msro-service" />
77 
    <orderEntry type="module" module-name="dnet-core-services" />
78 
    <orderEntry type="library" name="Maven: com.typesafe:config:1.3.0" level="project" />
79 
    <orderEntry type="library" name="Maven: javax.mail:mail:1.4.7" level="project" />
80 
    <orderEntry type="library" name="Maven: javax.activation:activation:1.1" level="project" />
81 
    <orderEntry type="library" name="Maven: org.codehaus.groovy:groovy-all:2.4.6" level="project" />
82 
    <orderEntry type="library" name="Maven: gr.forth.ics.isl:x3ml-engine:1.8.0-SNAPSHOT" level="project" />
83 
    <orderEntry type="library" name="Maven: com.thoughtworks.xstream:xstream:1.4.2" level="project" />
84 
    <orderEntry type="library" name="Maven: xmlpull:xmlpull:1.1.3.1" level="project" />
85 
    <orderEntry type="library" name="Maven: xpp3:xpp3_min:1.1.4c" level="project" />
86 
    <orderEntry type="library" name="Maven: com.damnhandy:handy-uri-templates:2.1.6" level="project" />
87 
    <orderEntry type="library" name="Maven: org.jooq:joox:1.2.0" level="project" />
88 
    <orderEntry type="library" name="Maven: gr.forth.ics.isl:X3ML_reverse_utils:1.5" level="project" />
89 
    <orderEntry type="library" name="Maven: org.jsoup:jsoup:1.7.3" level="project" />
73 
    <orderEntry type="library" name="Maven: joda-time:joda-time:2.9.7" level="project" />
74 
    <orderEntry type="library" name="Maven: org.springframework:spring-test:4.3.7.RELEASE" level="project" />
75 
    <orderEntry type="library" name="Maven: log4j:log4j:1.2.17" level="project" />
90 76 
    <orderEntry type="library" name="Maven: virtuoso:jena-driver:3.0" level="project" />
91 77 
    <orderEntry type="library" name="Maven: openlink:virtuoso-jdbc:4.0" level="project" />
92 
    <orderEntry type="library" name="Maven: org.apache.jena:jena-arq:3.3.0" level="project" />
93 
    <orderEntry type="library" name="Maven: org.apache.jena:jena-shaded-guava:3.3.0" level="project" />
94 
    <orderEntry type="library" name="Maven: com.github.jsonld-java:jsonld-java:0.9.0" level="project" />
95 
    <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-core:2.7.4" level="project" />
96 
    <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-databind:2.7.4" level="project" />
97 
    <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-annotations:2.7.0" level="project" />
98 
    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpclient-cache:4.5.2" level="project" />
78 
    <orderEntry type="library" name="Maven: org.apache.jena:jena-arq:3.4.0" level="project" />
79 
    <orderEntry type="library" name="Maven: org.apache.jena:jena-shaded-guava:3.4.0" level="project" />
80 
    <orderEntry type="library" name="Maven: com.github.jsonld-java:jsonld-java:0.10.0" level="project" />
81 
    <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-core:2.8.7" level="project" />
82 
    <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-databind:2.8.7" level="project" />
83 
    <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-annotations:2.8.0" level="project" />
84 
    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpclient-cache:4.5.3" level="project" />
99 85 
    <orderEntry type="library" name="Maven: org.apache.thrift:libthrift:0.9.3" level="project" />
100 
    <orderEntry type="library" name="Maven: org.slf4j:jcl-over-slf4j:1.7.21" level="project" />
101 
    <orderEntry type="library" name="Maven: org.apache.commons:commons-csv:1.3" level="project" />
102 
    <orderEntry type="library" name="Maven: org.apache.jena:jena-tdb:3.3.0" level="project" />
103 
    <orderEntry type="library" name="Maven: org.apache.jena:jena-rdfconnection:3.3.0" level="project" />
104 
    <orderEntry type="library" name="Maven: org.apache.jena:jena-cmds:3.3.0" level="project" />
105 
    <orderEntry type="library" name="Maven: org.slf4j:slf4j-log4j12:1.7.21" level="project" />
106 
    <orderEntry type="library" name="Maven: org.slf4j:slf4j-api:1.7.21" level="project" />
107 
    <orderEntry type="library" name="Maven: org.apache.jena:jena-core:3.3.0" level="project" />
108 
    <orderEntry type="library" name="Maven: org.apache.jena:jena-iri:3.3.0" level="project" />
86 
    <orderEntry type="library" name="Maven: org.slf4j:jcl-over-slf4j:1.7.24" level="project" />
87 
    <orderEntry type="library" name="Maven: org.apache.commons:commons-csv:1.4" level="project" />
88 
    <orderEntry type="library" name="Maven: org.apache.jena:jena-tdb:3.4.0" level="project" />
89 
    <orderEntry type="library" name="Maven: org.apache.jena:jena-rdfconnection:3.4.0" level="project" />
90 
    <orderEntry type="library" name="Maven: org.apache.jena:jena-cmds:3.4.0" level="project" />
91 
    <orderEntry type="library" name="Maven: org.slf4j:slf4j-log4j12:1.7.24" level="project" />
92 
    <orderEntry type="library" name="Maven: org.slf4j:slf4j-api:1.7.24" level="project" />
93 
    <orderEntry type="library" name="Maven: org.apache.jena:jena-core:3.4.0" level="project" />
94 
    <orderEntry type="library" name="Maven: org.apache.jena:jena-iri:3.4.0" level="project" />
109 95 
    <orderEntry type="library" name="Maven: xerces:xercesImpl:2.11.0" level="project" />
110 96 
    <orderEntry type="library" name="Maven: xml-apis:xml-apis:1.4.01" level="project" />
111 
    <orderEntry type="library" name="Maven: commons-cli:commons-cli:1.3" level="project" />
112 
    <orderEntry type="library" name="Maven: org.apache.jena:jena-base:3.3.0" level="project" />
113 
    <orderEntry type="library" name="Maven: com.github.andrewoma.dexx:collection:0.6" level="project" />
114 
    <orderEntry type="library" name="Maven: junit:junit:4.12" level="project" />
115 
    <orderEntry type="library" name="Maven: org.hamcrest:hamcrest-core:1.3" level="project" />
116 
    <orderEntry type="library" scope="TEST" name="Maven: org.springframework:spring-core:4.2.5.RELEASE" level="project" />
117 
    <orderEntry type="library" name="Maven: commons-logging:commons-logging:1.2" level="project" />
118 
    <orderEntry type="library" name="Maven: log4j:log4j:1.2.17" level="project" />
97 
    <orderEntry type="library" name="Maven: commons-cli:commons-cli:1.4" level="project" />
98 
    <orderEntry type="library" name="Maven: org.apache.jena:jena-base:3.4.0" level="project" />
99 
    <orderEntry type="library" name="Maven: com.github.andrewoma.dexx:collection:0.7" level="project" />
100 
    <orderEntry type="library" scope="TEST" name="Maven: org.springframework.boot:spring-boot-starter-test:1.5.2.RELEASE" level="project" />
101 
    <orderEntry type="library" scope="TEST" name="Maven: org.springframework.boot:spring-boot-test:1.5.2.RELEASE" level="project" />
102 
    <orderEntry type="library" scope="TEST" name="Maven: org.springframework.boot:spring-boot:1.5.2.RELEASE" level="project" />
103 
    <orderEntry type="library" scope="TEST" name="Maven: org.springframework.boot:spring-boot-test-autoconfigure:1.5.2.RELEASE" level="project" />
104 
    <orderEntry type="library" scope="TEST" name="Maven: org.springframework.boot:spring-boot-autoconfigure:1.5.2.RELEASE" level="project" />
105 
    <orderEntry type="library" scope="TEST" name="Maven: com.jayway.jsonpath:json-path:2.2.0" level="project" />
106 
    <orderEntry type="library" scope="TEST" name="Maven: net.minidev:json-smart:2.2.1" level="project" />
107 
    <orderEntry type="library" scope="TEST" name="Maven: net.minidev:accessors-smart:1.1" level="project" />
108 
    <orderEntry type="library" scope="TEST" name="Maven: junit:junit:4.12" level="project" />
109 
    <orderEntry type="library" scope="TEST" name="Maven: org.assertj:assertj-core:2.6.0" level="project" />
110 
    <orderEntry type="library" scope="TEST" name="Maven: org.mockito:mockito-core:1.10.19" level="project" />
111 
    <orderEntry type="library" scope="TEST" name="Maven: org.objenesis:objenesis:2.1" level="project" />
112 
    <orderEntry type="library" scope="TEST" name="Maven: org.hamcrest:hamcrest-core:1.3" level="project" />
113 
    <orderEntry type="library" scope="TEST" name="Maven: org.hamcrest:hamcrest-library:1.3" level="project" />
114 
    <orderEntry type="library" scope="TEST" name="Maven: org.skyscreamer:jsonassert:1.4.0" level="project" />
115 
    <orderEntry type="library" scope="TEST" name="Maven: com.vaadin.external.google:android-json:0.0.20131108.vaadin1" level="project" />
116 
    <orderEntry type="library" name="Maven: org.springframework:spring-core:4.3.7.RELEASE" level="project" />
119 117 
  </component>
120 118 
</module>
modules/dnet-parthenos-publisher/trunk/src/main/java/eu/dnetlib/msro/workflows/nodes/parthenos/virtuoso/DropFromVirtuosoJobNode.java
1 1 
package eu.dnetlib.msro.workflows.nodes.parthenos.virtuoso;
2 2 

  		




  3
  
  
    
import eu.dnetlib.msro.workflows.graph.Arc;


  		




  4
  
  
    
import eu.dnetlib.msro.workflows.nodes.SimpleJobNode;


  		




  5
  
  
    
import eu.dnetlib.msro.workflows.procs.Env;


  		




  6
  
  
    
import eu.dnetlib.parthenos.virtuoso.VirtuosoClient;


  		




  7
  
  
    
import eu.dnetlib.parthenos.virtuoso.VirtuosoClientFactory;


  		




  8
  
  
    
import org.apache.commons.logging.Log;


  		




  9
  
  
    
import org.apache.commons.logging.LogFactory;


  		




  10
  
  
    
import org.springframework.beans.factory.annotation.Autowired;


  		




  11
  
  
    

  		




  12
  
  
    
public class DropFromVirtuosoJobNode extends SimpleJobNode {


  		




  13
  
  
    

  		




  14
  
  
    
	private static final Log log = LogFactory.getLog(DropFromVirtuosoJobNode.class);


  		




  15
  
  
    

  		




  16
  
  
    
	private String datasourceInterface;


  		




  17
  
  
    

  		




  18
  
  
    
	@Autowired


  		




  19
  
  
    
	private VirtuosoClientFactory virtuosoClientFactory;


  		




  20
  
  
    

  		




  21
  
  
    
	@Override


  		




  22
  
  
    
	protected String execute(final Env env) throws Exception {


  		




  23
  
  
    

  		




  24
  
  
    
		VirtuosoClient virtuosoClient = this.virtuosoClientFactory.getVirtuosoClient();


  		




  25
  
  
    
		long nTriples = virtuosoClient.drop(getDatasourceInterface());


  		




  26
  
  
    
		log.info("Deleted " + nTriples + " triples in Virtuoso server");


  		




  27
  
  
    

  		




  28
  
  
    
		env.setAttribute("triples", nTriples);


  		




  29
  
  
    
		return Arc.DEFAULT_ARC;


  		




  30
  
  
    

  		




  31
  
  
    
	}


  		




  32
  
  
    

  		




  33
  
  
    
	public VirtuosoClientFactory getVirtuosoClientFactory() {


  		




  34
  
  
    
		return virtuosoClientFactory;


  		




  35
  
  
    
	}


  		




  36
  
  
    

  		




  37
  
  
    
	public void setVirtuosoClientFactory(final VirtuosoClientFactory virtuosoClientFactory) {


  		




  38
  
  
    
		this.virtuosoClientFactory = virtuosoClientFactory;


  		




  39
  
  
    
	}


  		




  40
  
  
    

  		




  41
  
  
    
	public String getDatasourceInterface() {


  		




  42
  
  
    
		return datasourceInterface;


  		




  43
  
  
    
	}


  		




  44
  
  
    

  		




  45
  
  
    
	public void setDatasourceInterface(final String datasourceInterface) {


  		




  46
  
  
    
		this.datasourceInterface = datasourceInterface;


  		




  47
  
  
    
	}


  		




  
  3
  
    
public class DropFromVirtuosoJobNode {


  		




  
  4
  
    
//	extends


  		




  
  5
  
    
//} SimpleJobNode {


  		




  
  6
  
    
//


  		




  
  7
  
    
//	private static final Log log = LogFactory.getLog(DropFromVirtuosoJobNode.class);


  		




  
  8
  
    
//


  		




  
  9
  
    
//	private String datasourceInterface;


  		




  
  10
  
    
//


  		




  
  11
  
    
//	@Autowired


  		




  
  12
  
    
//	private VirtuosoClientFactory virtuosoClientFactory;


  		




  
  13
  
    
//


  		




  
  14
  
    
//	@Override


  		




  
  15
  
    
//	protected String execute(final Env env) throws Exception {


  		




  
  16
  
    
//


  		




  
  17
  
    
//		VirtuosoClient virtuosoClient = this.virtuosoClientFactory.getVirtuosoClient();


  		




  
  18
  
    
//		long nTriples = virtuosoClient.drop(getDatasourceInterface());


  		




  
  19
  
    
//		log.info("Deleted " + nTriples + " triples in Virtuoso server");


  		




  
  20
  
    
//


  		




  
  21
  
    
//		env.setAttribute("triples", nTriples);


  		




  
  22
  
    
//		return Arc.DEFAULT_ARC;


  		




  
  23
  
    
//


  		




  
  24
  
    
//	}


  		




  
  25
  
    
//


  		




  
  26
  
    
//	public VirtuosoClientFactory getVirtuosoClientFactory() {


  		




  
  27
  
    
//		return virtuosoClientFactory;


  		




  
  28
  
    
//	}


  		




  
  29
  
    
//


  		




  
  30
  
    
//	public void setVirtuosoClientFactory(final VirtuosoClientFactory virtuosoClientFactory) {


  		




  
  31
  
    
//		this.virtuosoClientFactory = virtuosoClientFactory;


  		




  
  32
  
    
//	}


  		




  
  33
  
    
//


  		




  
  34
  
    
//	public String getDatasourceInterface() {


  		




  
  35
  
    
//		return datasourceInterface;


  		




  
  36
  
    
//	}


  		




  
  37
  
    
//


  		




  
  38
  
    
//	public void setDatasourceInterface(final String datasourceInterface) {


  		




  
  39
  
    
//		this.datasourceInterface = datasourceInterface;


  		




  
  40
  
    
//	}


  		




  48
  41
  
    
}


  		












  

    
      modules/dnet-parthenos-publisher/trunk/src/main/java/eu/dnetlib/msro/workflows/nodes/parthenos/virtuoso/StoreVirtuosoJobNode.java
    
  





  1
  1
  
    
package eu.dnetlib.msro.workflows.nodes.parthenos.virtuoso;


  		




  2
  2
  
    

  		




  3
  
  
    
import eu.dnetlib.enabling.resultset.client.ResultSetClient;


  		




  4
  
  
    
import eu.dnetlib.msro.workflows.graph.Arc;


  		




  5
  
  
    
import eu.dnetlib.msro.workflows.nodes.SimpleJobNode;


  		




  6
  
  
    
import eu.dnetlib.msro.workflows.procs.Env;


  		




  7
  
  
    
import eu.dnetlib.parthenos.virtuoso.VirtuosoClient;


  		




  8
  
  
    
import eu.dnetlib.parthenos.virtuoso.VirtuosoClientFactory;


  		




  9
  
  
    
import eu.dnetlib.rmi.common.ResultSet;


  		




  10
  
  
    
import eu.dnetlib.rmi.manager.MSROException;


  		




  11
  
  
    
import org.apache.commons.logging.Log;


  		




  12
  
  
    
import org.apache.commons.logging.LogFactory;


  		




  13
  
  
    
import org.springframework.beans.factory.annotation.Autowired;


  		




  14
  
  
    

  		




  15
  
  
    
public class StoreVirtuosoJobNode extends SimpleJobNode {


  		




  16
  
  
    

  		




  17
  
  
    
	private static final Log log = LogFactory.getLog(StoreVirtuosoJobNode.class);


  		




  18
  
  
    

  		




  19
  
  
    
	private String inputEprParam;


  		




  20
  
  
    
	private String datasourceInterface;


  		




  21
  
  
    

  		




  22
  
  
    
	@Autowired


  		




  23
  
  
    
	private ResultSetClient resultSetClient;


  		




  24
  
  
    

  		




  25
  
  
    
	@Autowired


  		




  26
  
  
    
	private VirtuosoClientFactory virtuosoClientFactory;


  		




  27
  
  
    

  		




  28
  
  
    
	@Override


  		




  29
  
  
    
	protected String execute(final Env env) throws Exception {


  		




  30
  
  
    

  		




  31
  
  
    
		final ResultSet<?> rsIn = env.getAttribute(this.inputEprParam, ResultSet.class);


  		




  32
  
  
    
		if ((rsIn == null)) { throw new MSROException("InputEprParam (" + this.inputEprParam + ") not found in ENV"); }


  		




  33
  
  
    
		VirtuosoClient virtuosoClient = this.virtuosoClientFactory.getVirtuosoClient();


  		




  34
  
  
    
		long nTriples = virtuosoClient.feed(getResultSetClient().iter(rsIn, String.class), getDatasourceInterface());


  		




  35
  
  
    
		log.info("Stored " + nTriples + " triples in Virtuoso server");


  		




  36
  
  
    

  		




  37
  
  
    
		env.setAttribute("triples", nTriples);


  		




  38
  
  
    
		return Arc.DEFAULT_ARC;


  		




  39
  
  
    

  		




  40
  
  
    
	}


  		




  41
  
  
    

  		




  42
  
  
    
	public String getInputEprParam() {


  		




  43
  
  
    
		return this.inputEprParam;


  		




  44
  
  
    
	}


  		




  45
  
  
    

  		




  46
  
  
    
	public void setInputEprParam(final String inputEprParam) {


  		




  47
  
  
    
		this.inputEprParam = inputEprParam;


  		




  48
  
  
    
	}


  		




  49
  
  
    

  		




  50
  
  
    
	public VirtuosoClientFactory getVirtuosoClientFactory() {


  		




  51
  
  
    
		return virtuosoClientFactory;


  		




  52
  
  
    
	}


  		




  53
  
  
    

  		




  54
  
  
    
	public void setVirtuosoClientFactory(final VirtuosoClientFactory virtuosoClientFactory) {


  		




  55
  
  
    
		this.virtuosoClientFactory = virtuosoClientFactory;


  		




  56
  
  
    
	}


  		




  57
  
  
    

  		




  58
  
  
    
	public ResultSetClient getResultSetClient() {


  		




  59
  
  
    
		return resultSetClient;


  		




  60
  
  
    
	}


  		




  61
  
  
    

  		




  62
  
  
    
	public void setResultSetClient(final ResultSetClient resultSetClient) {


  		




  63
  
  
    
		this.resultSetClient = resultSetClient;


  		




  64
  
  
    
	}


  		




  65
  
  
    

  		




  66
  
  
    
	public String getDatasourceInterface() {


  		




  67
  
  
    
		return datasourceInterface;


  		




  68
  
  
    
	}


  		




  69
  
  
    

  		




  70
  
  
    
	public void setDatasourceInterface(final String datasourceInterface) {


  		




  71
  
  
    
		this.datasourceInterface = datasourceInterface;


  		




  72
  
  
    
	}


  		




  
  3
  
    
public class StoreVirtuosoJobNode {


  		




  
  4
  
    
//		extends SimpleJobNode {


  		




  
  5
  
    
//


  		




  
  6
  
    
//	private static final Log log = LogFactory.getLog(StoreVirtuosoJobNode.class);


  		




  
  7
  
    
//


  		




  
  8
  
    
//	private String inputEprParam;


  		




  
  9
  
    
//	private String datasourceInterface;


  		




  
  10
  
    
//


  		




  
  11
  
    
//	@Autowired


  		




  
  12
  
    
//	private ResultSetClient resultSetClient;


  		




  
  13
  
    
//


  		




  
  14
  
    
//	@Autowired


  		




  
  15
  
    
//	private VirtuosoClientFactory virtuosoClientFactory;


  		




  
  16
  
    
//


  		




  
  17
  
    
//	@Override


  		




  
  18
  
    
//	protected String execute(final Env env) throws Exception {


  		




  
  19
  
    
//


  		




  
  20
  
    
//		final ResultSet<?> rsIn = env.getAttribute(this.inputEprParam, ResultSet.class);


  		




  
  21
  
    
//		if ((rsIn == null)) { throw new MSROException("InputEprParam (" + this.inputEprParam + ") not found in ENV"); }


  		




  
  22
  
    
//		VirtuosoClient virtuosoClient = this.virtuosoClientFactory.getVirtuosoClient();


  		




  
  23
  
    
//		long nTriples = virtuosoClient.feed(getResultSetClient().iter(rsIn, String.class), getDatasourceInterface());


  		




  
  24
  
    
//		log.info("Stored " + nTriples + " triples in Virtuoso server");


  		




  
  25
  
    
//


  		




  
  26
  
    
//		env.setAttribute("triples", nTriples);


  		




  
  27
  
    
//		return Arc.DEFAULT_ARC;


  		




  
  28
  
    
//


  		




  
  29
  
    
//	}


  		




  
  30
  
    
//


  		




  
  31
  
    
//	public String getInputEprParam() {


  		




  
  32
  
    
//		return this.inputEprParam;


  		




  
  33
  
    
//	}


  		




  
  34
  
    
//


  		




  
  35
  
    
//	public void setInputEprParam(final String inputEprParam) {


  		




  
  36
  
    
//		this.inputEprParam = inputEprParam;


  		




  
  37
  
    
//	}


  		




  
  38
  
    
//


  		




  
  39
  
    
//	public VirtuosoClientFactory getVirtuosoClientFactory() {


  		




  
  40
  
    
//		return virtuosoClientFactory;


  		




  
  41
  
    
//	}


  		




  
  42
  
    
//


  		




  
  43
  
    
//	public void setVirtuosoClientFactory(final VirtuosoClientFactory virtuosoClientFactory) {


  		




  
  44
  
    
//		this.virtuosoClientFactory = virtuosoClientFactory;


  		




  
  45
  
    
//	}


  		




  
  46
  
    
//


  		




  
  47
  
    
//	public ResultSetClient getResultSetClient() {


  		




  
  48
  
    
//		return resultSetClient;


  		




  
  49
  
    
//	}


  		




  
  50
  
    
//


  		




  
  51
  
    
//	public void setResultSetClient(final ResultSetClient resultSetClient) {


  		




  
  52
  
    
//		this.resultSetClient = resultSetClient;


  		




  
  53
  
    
//	}


  		




  
  54
  
    
//


  		




  
  55
  
    
//	public String getDatasourceInterface() {


  		




  
  56
  
    
//		return datasourceInterface;


  		




  
  57
  
    
//	}


  		




  
  58
  
    
//


  		




  
  59
  
    
//	public void setDatasourceInterface(final String datasourceInterface) {


  		




  
  60
  
    
//		this.datasourceInterface = datasourceInterface;


  		




  
  61
  
    
//	}


  		




  73
  62
  
    
}


  		












  

    
      modules/dnet-parthenos-publisher/trunk/pom.xml
    
  





  2
  2
  
    
<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://maven.apache.org/POM/4.0.0"


  		




  3
  3
  
    
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">


  		




  4
  4
  
    
	<parent>


  		




  5
  
  
    
		<groupId>eu.dnetlib</groupId>


  		




  6
  
  
    
		<artifactId>dnet-parent</artifactId>


  		




  7
  
  
    
		<version>2.0.0-SNAPSHOT</version>


  		




  8
  
  
    
		<relativePath/>


  		




  
  5
  
    
		<groupId>org.springframework.boot</groupId>


  		




  
  6
  
    
		<artifactId>spring-boot-starter-parent</artifactId>


  		




  
  7
  
    
		<version>1.5.2.RELEASE</version>


  		




  
  8
  
    
		<relativePath></relativePath>


  		




  9
  9
  
    
	</parent>


  		




  
  10
  
    

  		




  10
  11
  
    
	<modelVersion>4.0.0</modelVersion>


  		




  11
  12
  
    
	<groupId>eu.dnetlib</groupId>


  		




  12
  13
  
    
	<artifactId>dnet-parthenos-publisher</artifactId>


  		




  13
  14
  
    
	<packaging>jar</packaging>


  		




  14
  
  
    
	<version>1.0.0-SNAPSHOT</version>


  		




  
  15
  
    
	<version>2.0.0-SNAPSHOT</version>


  		




  15
  16
  
    
	<scm>


  		




  16
  17
  
    
		<developerConnection>scm:svn:https://svn.driver.research-infrastructures.eu/driver/dnet50/modules/dnet-parthenos-publisher/trunk</developerConnection>


  		




  17
  18
  
    
	</scm>


  		




  
  19
  
    
	<ciManagement>


  		




  
  20
  
    
		<system>jenkins</system>


  		




  
  21
  
    
		<url>https://jenkins-dnet.d4science.org/view/DNet50/job/DSL50_dnet-parthenos-publisher/</url>


  		




  
  22
  
    
	</ciManagement>


  		




  
  23
  
    
	<distributionManagement>


  		




  
  24
  
    
		<repository>


  		




  
  25
  
    
			<id>dnet5-releases</id>


  		




  
  26
  
    
			<name>D-Net 5 Releases</name>


  		




  
  27
  
    
			<url>http://maven.research-infrastructures.eu/nexus/content/repositories/dnet5-releases</url>


  		




  
  28
  
    
			<layout>default</layout>


  		




  
  29
  
    
		</repository>


  		




  
  30
  
    
	</distributionManagement>


  		




  
  31
  
    

  		




  
  32
  
    
	<!-- Inherit defaults from Spring Boot -->


  		




  
  33
  
    

  		




  
  34
  
    
	<repositories>


  		




  
  35
  
    
		<repository>


  		




  
  36
  
    
			<id>dnet-deps</id>


  		




  
  37
  
    
			<name>dnet-dependencies</name>


  		




  
  38
  
    
			<url>http://maven.research-infrastructures.eu/nexus/content/repositories/dnet-deps</url>


  		




  
  39
  
    
			<layout>default</layout>


  		




  
  40
  
    
		</repository>


  		




  
  41
  
    
		<repository>


  		




  
  42
  
    
			<id>dnet5-releases</id>


  		




  
  43
  
    
			<name>D-Net 5 Releases</name>


  		




  
  44
  
    
			<url>http://maven.research-infrastructures.eu/nexus/content/repositories/dnet5-releases</url>


  		




  
  45
  
    
			<layout>default</layout>


  		




  
  46
  
    
			<snapshots>


  		




  
  47
  
    
				<enabled>false</enabled>


  		




  
  48
  
    
			</snapshots>


  		




  
  49
  
    
		</repository>


  		




  
  50
  
    
		<repository>


  		




  
  51
  
    
			<id>dnet5-snapshots</id>


  		




  
  52
  
    
			<name>D-Net 5 Snapshots</name>


  		




  
  53
  
    
			<url>http://maven.research-infrastructures.eu/nexus/content/repositories/dnet5-snapshots</url>


  		




  
  54
  
    
			<layout>default</layout>


  		




  
  55
  
    
			<snapshots>


  		




  
  56
  
    
				<enabled>true</enabled>


  		




  
  57
  
    
			</snapshots>


  		




  
  58
  
    
		</repository>


  		




  
  59
  
    
	</repositories>


  		




  
  60
  
    

  		




  18
  61
  
    
	<dependencies>


  		




  19
  62
  
    
		<dependency>


  		




  20
  63
  
    
			<groupId>eu.dnetlib</groupId>


  		




  21
  64
  
    
			<artifactId>dnet-core-components</artifactId>


  		




  22
  
  
    
			<version>[2.0.0-SAXONHE-SNAPSHOT]</version>


  		




  
  65
  
    
			<version>2.0.0-SAXONHE-SNAPSHOT</version>


  		




  23
  66
  
    
		</dependency>


  		




  24
  
  
    

  		




  25
  67
  
    
		<dependency>


  		




  26
  
  
    
			<groupId>eu.dnetlib</groupId>


  		




  27
  
  
    
			<artifactId>dnet-msro-service</artifactId>


  		




  28
  
  
    
			<version>[6.0.0-SAXONHE-SNAPSHOT]</version>


  		




  29
  
  
    
		</dependency>


  		




  30
  
  
    
		<dependency>


  		




  31
  68
  
    
			<groupId>virtuoso</groupId>


  		




  32
  69
  
    
			<artifactId>jena-driver</artifactId>


  		




  33
  70
  
    
			<version>3.0</version>


  		




  ......




  48
  85
  
    
			<artifactId>jena-core</artifactId>


  		




  49
  86
  
    
			<version>[3.3.0,4.0.0)</version>


  		




  50
  87
  
    
		</dependency>


  		




  
  88
  
    

  		




  51
  89
  
    
		<dependency>


  		




  52
  
  
    
			<groupId>junit</groupId>


  		




  53
  
  
    
			<artifactId>junit</artifactId>


  		




  54
  
  
    
			<version>${junit.version}</version>


  		




  55
  
  
    
		</dependency>


  		




  56
  
  
    
		<dependency>


  		




  57
  
  
    
			<groupId>org.springframework</groupId>


  		




  58
  
  
    
			<artifactId>spring-core</artifactId>


  		




  59
  
  
    
			<version>${spring.version}</version>


  		




  
  90
  
    
			<groupId>org.springframework.boot</groupId>


  		




  
  91
  
    
			<artifactId>spring-boot-starter-test</artifactId>


  		




  60
  92
  
    
			<scope>test</scope>


  		




  61
  93
  
    
		</dependency>


  		




  62
  94
  
    
	</dependencies>


  		




  63
  95
  
    

  		




  
  96
  
    
	<build>


  		




  
  97
  
    
		<plugins>


  		




  
  98
  
    
			<plugin>


  		




  
  99
  
    
				<groupId>org.springframework.boot</groupId>


  		




  
  100
  
    
				<artifactId>spring-boot-maven-plugin</artifactId>


  		




  
  101
  
    
				<configuration>


  		




  
  102
  
    
					<executable>true</executable>


  		




  
  103
  
    
				</configuration>


  		




  
  104
  
    
			</plugin>


  		




  
  105
  
    
		</plugins>


  		




  
  106
  
    
	</build>


  		




  
  107
  
    

  		




  64
  108
  
    
	<properties>


  		




  65
  
  
    
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>


  		




  
  109
  
    
		<java.version>1.8</java.version>


  		




  
  110
  
    
		<maven.javadoc.failOnError>false</maven.javadoc.failOnError>


  		




  66
  111
  
    
	</properties>


  		




  67
  112
  
    

  		




  
  113
  
    
	<profiles>


  		




  
  114
  
    
		<profile>


  		




  
  115
  
    
			<id>java8-doclint-disabled</id>


  		




  
  116
  
    
			<activation>


  		




  
  117
  
    
				<jdk>[1.8,)</jdk>


  		




  
  118
  
    
			</activation>


  		




  
  119
  
    
			<properties>


  		




  
  120
  
    
				<javadoc.opts>-Xdoclint:none</javadoc.opts>


  		




  
  121
  
    
			</properties>


  		




  
  122
  
    
		</profile>


  		




  
  123
  
    
	</profiles>


  		




  68
  124
  
    
</project>


  		












Also available in:  Unified diff