D-Net

		long res = client.feedProvenance("ariadne_____::0002b8b77eb2d6c62f61c6e1a1ce6891", "2017-05-14T12:06:38.152+02:00" , "2017-05-14T12:11:55.573", "ARIADNE", "ariadne_api");

import org.apache.jena.util.iterator.ExtendedIterator;

	@Test

	public void testSearch(){

		VirtGraph graph = new VirtGraph(testGraph, connectionString, testUser, testPwd);

		assertNotNull(graph);

		graph.clear();

		Assert.assertTrue(graph.isEmpty());

		Triple t1 = new Triple(NodeFactory.createURI("http://test/1"), NodeFactory.createURI("http://test/is_friend_of"),

				NodeFactory.createURI("http://test/KevinBacon"));

		Triple t2 = new Triple(NodeFactory.createURI("http://test/1"), NodeFactory.createURI("http://test/is_friend_of"),

				NodeFactory.createURI("http://test/BonoVox"));

		Triple t3 = new Triple(NodeFactory.createURI("http://test/1"), NodeFactory.createURI("http://test/is_enemy_of"),

				NodeFactory.createURI("http://test/Spiderman"));

		graph.performAdd(t1);

		graph.performAdd(t2);

		graph.performAdd(t3);

		assertEquals(3, graph.getCount());

		final ExtendedIterator<Triple> friends = graph.find(null, NodeFactory.createURI("http://test/is_friend_of"), null);

		while(friends.hasNext()){

			System.out.println(friends.next());

		}

	}

      <configuration>

        <fileset id="fileset" name="Spring Application Context" removed="false">

          <file>file://$MODULE_DIR$/src/main/resources/eu/dnetlib/parthenos/applicationContext-msro-parthenos-nodes.xml</file>

        </fileset>

      </configuration>

    <orderEntry type="module" module-name="dnet-msro-service" />

    <orderEntry type="module" module-name="dnet-core-services" />

    <orderEntry type="library" name="Maven: com.typesafe:config:1.3.0" level="project" />

    <orderEntry type="library" name="Maven: javax.mail:mail:1.4.7" level="project" />

    <orderEntry type="library" name="Maven: javax.activation:activation:1.1" level="project" />

    <orderEntry type="library" name="Maven: org.codehaus.groovy:groovy-all:2.4.6" level="project" />

    <orderEntry type="library" name="Maven: gr.forth.ics.isl:x3ml-engine:1.8.0-SNAPSHOT" level="project" />

    <orderEntry type="library" name="Maven: com.thoughtworks.xstream:xstream:1.4.2" level="project" />

    <orderEntry type="library" name="Maven: xmlpull:xmlpull:1.1.3.1" level="project" />

    <orderEntry type="library" name="Maven: xpp3:xpp3_min:1.1.4c" level="project" />

    <orderEntry type="library" name="Maven: com.damnhandy:handy-uri-templates:2.1.6" level="project" />

    <orderEntry type="library" name="Maven: org.jooq:joox:1.2.0" level="project" />

    <orderEntry type="library" name="Maven: gr.forth.ics.isl:X3ML_reverse_utils:1.5" level="project" />

    <orderEntry type="library" name="Maven: org.jsoup:jsoup:1.7.3" level="project" />

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

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

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

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

import eu.dnetlib.parthenos.virtuoso.VirtuosoClient;

import eu.dnetlib.parthenos.virtuoso.VirtuosoClientFactory;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

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

public class DropFromVirtuosoJobNode extends SimpleJobNode {

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

	private String datasourceInterface;

	@Autowired

	private VirtuosoClientFactory virtuosoClientFactory;

	@Override

	protected String execute(final Env env) throws Exception {

		VirtuosoClient virtuosoClient = this.virtuosoClientFactory.getVirtuosoClient();

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

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

		env.setAttribute("triples", nTriples);

		return Arc.DEFAULT_ARC;

	}

	public VirtuosoClientFactory getVirtuosoClientFactory() {

		return virtuosoClientFactory;

	}

	public void setVirtuosoClientFactory(final VirtuosoClientFactory virtuosoClientFactory) {

		this.virtuosoClientFactory = virtuosoClientFactory;

	}

	public String getDatasourceInterface() {

		return datasourceInterface;

	}

	public void setDatasourceInterface(final String datasourceInterface) {

		this.datasourceInterface = datasourceInterface;

	}

}

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

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

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

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

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

import eu.dnetlib.parthenos.virtuoso.VirtuosoClient;

import eu.dnetlib.parthenos.virtuoso.VirtuosoClientFactory;

import eu.dnetlib.rmi.common.ResultSet;

import eu.dnetlib.rmi.manager.MSROException;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

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

public class StoreVirtuosoJobNode extends SimpleJobNode {

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

	private String inputEprParam;

	private String datasourceInterface;

	@Autowired

	private ResultSetClient resultSetClient;

	@Autowired

	private VirtuosoClientFactory virtuosoClientFactory;

	@Override

	protected String execute(final Env env) throws Exception {

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

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

		VirtuosoClient virtuosoClient = this.virtuosoClientFactory.getVirtuosoClient();

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

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

		env.setAttribute("triples", nTriples);

		return Arc.DEFAULT_ARC;

	}

	public String getInputEprParam() {

		return this.inputEprParam;

	}

	public void setInputEprParam(final String inputEprParam) {

		this.inputEprParam = inputEprParam;

	}

	public VirtuosoClientFactory getVirtuosoClientFactory() {

		return virtuosoClientFactory;

	}

	public void setVirtuosoClientFactory(final VirtuosoClientFactory virtuosoClientFactory) {

		this.virtuosoClientFactory = virtuosoClientFactory;

	}

	public ResultSetClient getResultSetClient() {

		return resultSetClient;

	}

	public void setResultSetClient(final ResultSetClient resultSetClient) {

		this.resultSetClient = resultSetClient;

	}

	public String getDatasourceInterface() {

		return datasourceInterface;

	}

	public void setDatasourceInterface(final String datasourceInterface) {

		this.datasourceInterface = datasourceInterface;

	}

}

import net.sf.saxon.s9api.Serializer;

import org.apache.jena.datatypes.xsd.XSDDatatype;

import org.apache.jena.rdf.model.*;

	private static final String PROVENANCE_GRAPH = "provenance";

	public static Property IS_API_OF = ResourceFactory.createProperty("dnet", "isApiOf");

	public static Property COLL_FROM = ResourceFactory.createProperty("dnet", "collectedFrom");

	public static Property COLL_IN_DATE = ResourceFactory.createProperty("dnet", "collectedInDate");

	public static Property TRANS_IN_DATE = ResourceFactory.createProperty("dnet", "transformedInDate");

	public long feed(final String record, final String dsInterface) {

		String namedGraph= getRecordDefaultURI(objIdentifier, dsInterface);

		Model md = VirtModel.openDatabaseModel(namedGraph, getConnectionString(), getUsername(), getPassword());

		log.debug("Opened virtuoso model for graph " + namedGraph);

		log.debug("Removed all triples from graph " + namedGraph);

		log.info("Graph " + namedGraph + " now has " + size + " triples");

		long ntriples = feedProvenance(namedGraph, collectionDate, transformationDate, datasource, dsInterface);

		log.debug("provenance graph for "+namedGraph+" updated with " + ntriples + " triples");

	long feedProvenance(final String namedGraphURI, final String collectionDate, final String transformationDate, final String datasource, final String api) {

		Model md = VirtModel.openDatabaseModel(PROVENANCE_GRAPH, getConnectionString(), getUsername(), getPassword());

		Resource rApi = ResourceFactory.createResource(defaultBaseURI + api);

		Resource r = ResourceFactory.createResource(namedGraphURI);

		Statement stmApi =

				ResourceFactory.createStatement(rApi, IS_API_OF, ResourceFactory.createPlainLiteral(datasource));

				ResourceFactory.createStatement(r, COLL_FROM, rApi);

				.createStatement(r, COLL_IN_DATE, ResourceFactory.createTypedLiteral(collectionDate, XSDDatatype.XSDdateTime));

				.createStatement(r, TRANS_IN_DATE, ResourceFactory.createTypedLiteral(transformationDate, XSDDatatype.XSDdateTime));

		md.add(stmApi).add(stmCollFrom).add(stmCollDate).add(stmTransDate);

	public long feed(final Iterable<String> records, final String api) {

		for (String r : records) count += this.feed(r, api);

	/**

	 * Delete all triples in named graphs collected from the given api

	 * @param api the id of the API

	 * @return the number of triples deleted from the named graphs associated to the given api

	 */

	public long drop(final String api){

		Model prov = VirtModel.openDatabaseModel(PROVENANCE_GRAPH, getConnectionString(), getUsername(), getPassword());

		//look for all named graphs associated to the api

		Resource rApi = ResourceFactory.createResource(defaultBaseURI + api);

		long deletedTriples = 0;

		final ResIterator resIterator = prov.listSubjectsWithProperty(COLL_FROM, rApi);

		while (resIterator.hasNext()) {

			Resource namedGraphURI = resIterator.nextResource();

			//delete all triples belonging to the r named graph

			deletedTriples += dropNamedGraph(namedGraphURI.getURI());

			//delete the named graph from the provenance graph

			prov.remove(namedGraphURI, null, null);

		}

		//delete the api from the provenance graph

		prov.remove(null, null, rApi);

		prov.remove(rApi, null, null);

		return deletedTriples;

	private long dropNamedGraph(String namedGraphURI){

		Model namedGraph = VirtModel.openDatabaseModel(namedGraphURI, getConnectionString(), getUsername(), getPassword());

		long deletedTriples = namedGraph.size();

		namedGraph.removeAll();

		return deletedTriples;

	}

	private String getRecordDefaultURI(final String objIdentifier, final String datasourceApi) {

		return defaultBaseURI + datasourceApi + "/" + objIdentifier;

	}

			return this.saxonHelper.help().setSerializerProperty(Serializer.Property.OMIT_XML_DECLARATION, "yes").evaluateSingleAsString(record, xPathSelector);

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

       xmlns:p="http://www.springframework.org/schema/p"

       xmlns="http://www.springframework.org/schema/beans"

       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

	<bean id="wfNodeStoreVirtuoso"

	      class="eu.dnetlib.msro.workflows.nodes.parthenos.virtuoso.StoreVirtuosoJobNode"

	      scope="prototype"/>

	<bean id="wfNodeDropFromVirtuoso"

	      class="eu.dnetlib.msro.workflows.nodes.parthenos.virtuoso.DropFromVirtuosoJobNode"

	      scope="prototype"/>

</beans>

			<groupId>eu.dnetlib</groupId>

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

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

		</dependency>

		<dependency>