D-Net

package eu.dnetlib.parthenos.virtuoso;

import java.io.IOException;

import eu.dnetlib.parthenos.publisher.ParthenosPublisherException;

import eu.dnetlib.parthenos.publisher.SaxonHelper;

import eu.dnetlib.parthenos.rdf.RecordParserHelper;

import net.sf.saxon.s9api.SaxonApiException;

import org.apache.commons.io.IOUtils;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.junit.Assert;

import org.junit.Before;

import org.junit.Ignore;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.junit.runners.JUnit4;

import org.springframework.core.io.ClassPathResource;

import virtuoso.jena.driver.VirtModel;

/**

 * Created by Alessia Bardi on 12/07/2017.

 *

 * @author Alessia Bardi

 */

@Ignore

@RunWith(JUnit4.class)

public class VirtuosoClientTest {

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

	private String testGraph = "virt:test";

	//private String connectionString = "jdbc:virtuoso://localhost:1111";

	private String connectionString = "jdbc:virtuoso://virtuoso.parthenos.d4science.org:1111";

	private String testUser = "dba";

	private String testPwd = "dba";

	private String defaultURIBaseURl = "http://test/";

	private String recordPath = "eu/dnetlib/parthenos/virtuoso/test_record_plain.xml";

	private VirtuosoClient client;

	private SaxonHelper saxonHelper = new SaxonHelper();

	@Before

	public void prepare() throws SaxonApiException {

		RecordParserHelper rph = new RecordParserHelper();

		rph.setSaxonHelper(saxonHelper);

		rph.init();

		client = new VirtuosoClient(connectionString, testUser, testPwd, rph, defaultURIBaseURl);

	}

	@Test

	public void testConnection(){

		VirtModel.openDatabaseModel("x", connectionString, testUser, testPwd);

	}

	@Test

	public void testFeedProvenance(){

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

		Assert.assertEquals(3, res);

	}

	@Test

	public void testRecord() throws ParthenosPublisherException {

		System.out.println(client.feed(getString(recordPath)));

	}

	@Test

	public void testRemoveFromProvenance(){

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

		Assert.assertEquals(3, res);

		long deleted = client.drop("ariadne_api");

		Assert.assertEquals(0, deleted);

	}

	private String getString(final String classpath) {

		try {

			final ClassPathResource resource = new ClassPathResource(classpath);

			return IOUtils.toString(resource.getInputStream(), "UTF-8");

		}catch(IOException e){

			return null;

		}

	}

}