/modules/dnet-parthenos-publisher/trunk/test/main/java/eu/dnetlib/parthenos/virtuoso/VirtuosoTest.java - Diff - D-Net - D-Net project tracking tool

« Previous | Next »

Revision 51265

Added by Alessia Bardi about 6 years ago

Can't use jena Query because does not support inference rule, can't use jena HttpEngine because it does not support long queryif we do not use Query: hence let's query with handmade post request to the sparql endpoint.

     import java.io.IOException;
     import java.io.InputStream;
     import java.util.List;
     import org.apache.commons.io.IOUtils;
     import org.apache.http.HttpEntity;
     import org.apache.http.NameValuePair;
     import org.apache.http.client.entity.UrlEncodedFormEntity;
     import org.apache.http.client.methods.CloseableHttpResponse;
     import org.apache.http.client.methods.HttpPost;
     import org.apache.http.impl.client.CloseableHttpClient;
     import org.apache.http.impl.client.HttpClients;
     import org.apache.http.message.BasicNameValuePair;
     import org.apache.http.util.EntityUtils;
     import org.apache.jena.graph.NodeFactory;
     import org.apache.jena.graph.Triple;
     import org.apache.jena.query.*;
-...
     import org.apache.jena.riot.RDFDataMgr;
     import org.apache.jena.riot.RDFFormat;
     import org.apache.jena.sparql.engine.http.QueryEngineHTTP;
     import org.apache.jena.sparql.engine.http.QueryExceptionHTTP;
     import org.apache.jena.util.iterator.ExtendedIterator;
     import org.assertj.core.util.Lists;
     import org.junit.Assert;
     import org.junit.Before;
     import org.junit.Ignore;
-...
     	 * See also: https://stackoverflow.com/questions/24576190/enable-reasoning-for-sparql-request-via-jena
     	 */
     	@Test
     	public void testInference1(){
     	public void testInference1() {
     		String q = "DEFINE input:inference 'parthenos_rules' CONSTRUCT {<%s> ?p ?o . } WHERE { <%s> ?p ?o .}";
     		String subjectURL = "http://clarin.eu/clarin-eric-datatables/centres";
     		String query = String.format(q, subjectURL, subjectURL, subjectURL, subjectURL);
     		System.out.println(query);
     		final QueryEngineHTTP request = new QueryEngineHTTP (sparqlEndpoint, query);
     		final QueryEngineHTTP request = new QueryEngineHTTP(sparqlEndpoint, query);
     		Model res = request.execConstruct();
     		RDFDataMgr.write(System.out, res, RDFFormat.RDFXML_PLAIN);
     		res.close();
     		request.close();
+    	}
     	@Test
     	public void testLongQuery() throws IOException {
     		String q = IOUtils.toString(getResourceAsStream("/eu/dnetlib/parthenos/sparql/longQuery.sparql"));
     		try (CloseableHttpClient httpclient = HttpClients.createDefault()) {
     			HttpPost httpPost = new HttpPost(sparqlEndpoint);
     			List<NameValuePair> nvps = Lists.newArrayList();
     			nvps.add(new BasicNameValuePair("query", q));
     			httpPost.setEntity(new UrlEncodedFormEntity(nvps));
     			try (CloseableHttpResponse response2 = httpclient.execute(httpPost)) {
     				System.out.println(response2.getStatusLine());
     				HttpEntity entity2 = response2.getEntity();
     				String s = IOUtils.toString(entity2.getContent());
     				System.out.println("OUT: " + s);
     				// do something useful with the response body
     				// and ensure it is fully consumed
     				EntityUtils.consume(entity2);
+    			}
+    		}
+    	}
     	@Test(expected = QueryExceptionHTTP.class)
     	public void testLongQueryFails() throws IOException {
     		String q = IOUtils.toString(getResourceAsStream("/eu/dnetlib/parthenos/sparql/longQuery.sparql"));
     		final QueryEngineHTTP request = new QueryEngineHTTP(sparqlEndpoint, q);
     		Model res = request.execConstruct();
     		RDFDataMgr.write(System.out, res, RDFFormat.RDFXML_PLAIN);
     		res.close();
     		request.close();
+    	}
     	@Test
     	public void testRemote(){
     	public void testRemote() {
     		String q = "DEFINE input:inference 'parthenos_rules' CONSTRUCT {<%s> ?p ?o . } WHERE { <%s> ?p ?o .}";
     		//String q = "CONSTRUCT {<%s> ?p ?o . } WHERE { <%s> ?p ?o .}";
     		String subjectURL = "http://clarin.eu/clarin-eric-datatables/centres";
-...
     	@Ignore
     	@Test
     	public void testDescribe(){
     	public void testDescribe() {
     		//put something in the graph
     		Model md = VirtModel.openDatabaseModel(testGraph, connectionString, testUser, testPwd);
     		md.read(getResourceAsStream("eu/dnetlib/parthenos/virtuoso/test.rdf"), defaultURIBaseURl);
     		String resURI = "http://www.parthenos-project.eu/ARIADNE/ARIADNECatalog/Dataset/http%3A%2F%2Fregistry.ariadne-infrastructure.eu%2Fdataset%2F25058478";
     		//now query for the resource URI
     		String describeQuery = "DESCRIBE <"+resURI+">";
     		Query query = QueryFactory.create(describeQuery) ;
     		String describeQuery = "DESCRIBE <" + resURI + ">";
     		Query query = QueryFactory.create(describeQuery);
     		String sparqlUrl = "http://localhost:8890/sparql";
     		final QueryEngineHTTP serviceRequest = QueryExecutionFactory.createServiceRequest(sparqlUrl, query);
     		Model resultModel = serviceRequest.execDescribe();
-...
     		graph.clear();
+    	}
     	@Ignore
     	@Test
     	public void testDescribeRemote(){
     	public void testDescribeRemote() {
     		String resURI = "http://hdl.handle.net/11858/00-203C-0000-0029-F5E8-C";
     		//now query for the resource URI
     		String describeQuery = "DESCRIBE <"+resURI+">";
     		Query query = QueryFactory.create(describeQuery) ;
     		String describeQuery = "DESCRIBE <" + resURI + ">";
     		Query query = QueryFactory.create(describeQuery);
     		String sparqlUrl = "https://virtuoso.parthenos.d4science.org/sparql";
     		final QueryEngineHTTP serviceRequest = QueryExecutionFactory.createServiceRequest(sparqlUrl, query);
     		Model resultModel = serviceRequest.execDescribe();
-...
     		while (graphs.hasNext()) {
     			countGraphs++;
     			Resource g = graphs.next().getResource("g");
     			System.out.println("*****GRAPH: "+g.getURI());
     			System.out.println("*****GRAPH: " + g.getURI());
     			final QueryEngineHTTP serviceRequest2 =
     					QueryExecutionFactory.createServiceRequest(sparqlUrl, QueryFactory.create(String.format(queryForSubjectsTemplate, g.getURI())));
     			ResultSet subjects = serviceRequest2.execSelect();
-...
     				resultModel.write(System.out);
+    			}
     			serviceRequest2.close();
     			System.out.println("Got "+countSubjects+" subjects");
     			System.out.println("Got " + countSubjects + " subjects");
+    		}
     		serviceRequest.close();
     		assertEquals("unexpected number of graphs", 4, countGraphs);
-...
     		Model md2 = VirtModel.openDatabaseModel("obj1", connectionString, testUser, testPwd);
     		final ResIterator resIterator = md2.listSubjects();
     		while(resIterator.hasNext()){
     		while (resIterator.hasNext()) {
     			Resource r = resIterator.nextResource();
     			System.out.println(r.getURI()+"*************");
     			System.out.println(r.getURI() + "*************");
     			Dataset d = RDFDataMgr.loadDataset(r.getURI());
     			RDFDataMgr.write(System.out, d, RDFFormat.RDFXML_PLAIN);
     			System.out.println("**********************");
-...
+    	}
     	@Test
     	public void testRemoveAllWildcards() {
     		VirtGraph graph = new VirtGraph(testGraph, connectionString, testUser, testPwd);
-...
+    	}
     	@Test
     	public void testSearch(){
     	public void testSearch() {
     		VirtGraph graph = new VirtGraph(testGraph, connectionString, testUser, testPwd);
     		assertNotNull(graph);
     		graph.clear();
-...
     		assertEquals(3, graph.getCount());
     		final ExtendedIterator<Triple> friends = graph.find(null, NodeFactory.createURI("http://test/is_friend_of"), null);
     		while(friends.hasNext()){
     		while (friends.hasNext()) {
     			System.out.println(friends.next());
+    		}
+    	}
     	private InputStream getResourceAsStream(final String classpath) {
     		try {
     			final ClassPathResource resource = new ClassPathResource(classpath);

Also available in: Unified diff

Project

General

Profile

D-Net

Revision 51265

Added by Alessia Bardi about 6 years ago