D-Net

package eu.dnetlib.parthenos.workflows.nodes;

import eu.dnetlib.enabling.resultset.factory.ResultSetFactory;

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

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

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

import eu.dnetlib.rmi.common.ResultSet;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

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

/**

 * Created by Alessia Bardi on 26/01/2018.

 *

 * @author Alessia Bardi

 */

public class ReadVirtuosoJobNode extends AsyncJobNode {

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

	private String datasourceName;

	private String datasourceInterface;

	private String virtuosoReaderAPIUrl;

	@Autowired

	private ResultSetFactory rsFactory;

	@Override

	protected String execute(final Env env){

		log.info("Using virtuoso reader at : " + getVirtuosoReaderAPIUrl());

		VirtuosoParthenosIterator iterator = new VirtuosoParthenosIterator().datasourceInterface(getDatasourceInterface()).virtuosoReaderAPIUrl(getVirtuosoReaderAPIUrl()).datasourceName(getDatasourceName());

		ResultSet<String> rs = rsFactory.createResultSet(new VirtuosoParthenosIterable(iterator));

		env.setAttribute("virtuoso_rs", rs);

		return Arc.DEFAULT_ARC;

	}

	public String getDatasourceName() {

		return datasourceName;

	}

	public void setDatasourceName(final String datasourceName) {

		this.datasourceName = datasourceName;

	}

	public String getDatasourceInterface() {

		return datasourceInterface;

	}

	public void setDatasourceInterface(final String datasourceInterface) {

		this.datasourceInterface = datasourceInterface;

	}

	public String getVirtuosoReaderAPIUrl() {

		return virtuosoReaderAPIUrl;

	}

	public void setVirtuosoReaderAPIUrl(final String virtuosoReaderAPIUrl) {

		this.virtuosoReaderAPIUrl = virtuosoReaderAPIUrl;

	}

}