[DL-Learner SVN] SF.net SVN: dl-learner:[3630] trunk/components-core/src/main/java/org/ dllearner/kb/sparql/simple

[<dc...@us...>]

Revision: 3630
          http://dl-learner.svn.sourceforge.net/dl-learner/?rev=3630&view=rev
Author:   dcherix
Date:     2012-04-09 18:27:16 +0000 (Mon, 09 Apr 2012)
Log Message:
-----------


Modified Paths:
--------------
    trunk/components-core/src/main/java/org/dllearner/kb/sparql/simple/SchemaIndexer.java
    trunk/components-core/src/main/java/org/dllearner/kb/sparql/simple/SparqlSimpleExtractor.java

Modified: trunk/components-core/src/main/java/org/dllearner/kb/sparql/simple/SchemaIndexer.java
===================================================================
--- trunk/components-core/src/main/java/org/dllearner/kb/sparql/simple/SchemaIndexer.java	2012-04-09 18:26:42 UTC (rev 3629)
+++ trunk/components-core/src/main/java/org/dllearner/kb/sparql/simple/SchemaIndexer.java	2012-04-09 18:27:16 UTC (rev 3630)
@@ -1,6 +1,6 @@
 package org.dllearner.kb.sparql.simple;
 
-//import org.nlp2rdf.ontology.ClassIndexer;
+import org.nlp2rdf.ontology.ClassIndexer;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -9,24 +9,28 @@
 
 public class SchemaIndexer {
     private static Logger log = LoggerFactory.getLogger(SchemaIndexer.class);
-//    private ClassIndexer classIndexer=null;
+    private ClassIndexer classIndexer=null;
     
     public SchemaIndexer(){}
     
     public void init(){
-//        classIndexer=new ClassIndexer();
+        classIndexer=new ClassIndexer();
         OntModel model = ModelFactory.createOntologyModel();
-        model.read(SchemaIndexer.class.getResourceAsStream("dbpedia_3-3.6.owl"), null);
-//        classIndexer.index(model);
+        model.read(SchemaIndexer.class.getClassLoader().getResourceAsStream("dbpedia_3.6.owl"), null);
+        classIndexer.index(model);
     }
     
     public OntModel getHierarchyForURI(String classUri){
-//        if(classIndexer==null){
-//            this.init();
-//        }
-//        return classIndexer.getHierarchyForClassURI(classUri);
-    	return null;
+        if(classIndexer==null){
+            this.init();
+        }
+        return classIndexer.getHierarchyForClassURI(classUri);
     }
     
+    public static void main(String...args){
+    	SchemaIndexer i= new SchemaIndexer();
+    	System.out.println(i.getHierarchyForURI("http://dbpedia.org/ontology/Software"));
+    }
+   
     
 }
\ No newline at end of file

Modified: trunk/components-core/src/main/java/org/dllearner/kb/sparql/simple/SparqlSimpleExtractor.java
===================================================================
--- trunk/components-core/src/main/java/org/dllearner/kb/sparql/simple/SparqlSimpleExtractor.java	2012-04-09 18:26:42 UTC (rev 3629)
+++ trunk/components-core/src/main/java/org/dllearner/kb/sparql/simple/SparqlSimpleExtractor.java	2012-04-09 18:27:16 UTC (rev 3630)
@@ -1,7 +1,10 @@
 package org.dllearner.kb.sparql.simple;
 
+import java.io.File;
+import java.util.ArrayList;
 import java.util.LinkedList;
 import java.util.List;
+import java.util.Set;
 
 import org.dllearner.core.ComponentAnn;
 import org.dllearner.core.ComponentInitException;
@@ -11,151 +14,225 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import com.hp.hpl.jena.ontology.OntClass;
 import com.hp.hpl.jena.ontology.OntModel;
 import com.hp.hpl.jena.rdf.model.Model;
 import com.hp.hpl.jena.rdf.model.ModelFactory;
+import com.jamonapi.Monitor;
+import com.jamonapi.MonitorFactory;
 
 @ComponentAnn(name = "efficient SPARQL fragment extractor", shortName = "sparqls", version = 0.1)
 public class SparqlSimpleExtractor implements KnowledgeSource {
-    
-    @ConfigOption(name = "endpointURL", description = "URL of the SPARQL endpoint", required = true)
-    private String endpointURL = null;
-    private OntModel model = null;
-    @ConfigOption(name = "instances", description = "List of the instances to use", required = true)
-    private List<String> instances = null;
-    @ConfigOption(name = "filters", description = "List of the filters to use", required = true)
-    private List<String> filters = null;
-    @ConfigOption(name = "recursionDepth", description = "recursion depth", required = true)
-    private int recursionDepth = 0;
-    
+
+	@ConfigOption(name = "endpointURL", description = "URL of the SPARQL endpoint", required = true)
+	private String endpointURL = null;
+	private OntModel model = null;
+	@ConfigOption(name = "instances", description = "List of the instances to use", required = true)
+	private List<String> instances = null;
+	@ConfigOption(name = "filters", description = "List of the filters to use", required = true)
+	private List<String> filters = null;
+	@ConfigOption(name = "recursionDepth", description = "recursion depth", required = true)
+	private int recursionDepth = 0;
+
 	@ConfigOption(name = "defaultGraphURI", description = "default graph URI", required = true)
-    private String defaultGraphURI=null;
-    private OWLOntology owlOntology;
-    
-    private static Logger log = LoggerFactory.getLogger(SparqlSimpleExtractor.class);
-    
-    public SparqlSimpleExtractor() {
-        model = ModelFactory.createOntologyModel();
-    }
-    
-    /**
-     * @param args
-     * @throws ComponentInitException
-     */
-    public static void main(String[] args) throws ComponentInitException {
-        SparqlSimpleExtractor extractor = new SparqlSimpleExtractor();
-        // extractor.init();
-        List<String> individuals = new LinkedList<String>();
-        individuals.add("People");
-        individuals.add("Animals");
-        extractor.setInstances(individuals);
-        // System.out.println(extractor.createQuery());
-    }
-    
-    @Override
-    public void init() throws ComponentInitException {
-        if (endpointURL == null) {
-            throw new ComponentInitException("Parameter endpoint URL is required");
-        }
-        if (instances == null) {
-            throw new ComponentInitException("Parameter instances is required");
-        }
-        if (recursionDepth == 0) {
-            throw new ComponentInitException(
-                    "A value bigger than 0 is required for parameter recursionDepth");
-        }
-        ABoxQueryGenerator aGenerator = new ABoxQueryGenerator();
-        QueryExecutor executor = new QueryExecutor();
-        String queryString;
-        for (int i = 0; i < recursionDepth - 1; i++) {
-            queryString=aGenerator.createQuery(instances, model, filters);
-            log.info("SPARQL: {}", queryString);
-            executor.executeQuery(queryString, endpointURL, model,defaultGraphURI);   
-        }
-        queryString = aGenerator.createLastQuery(instances, model, filters);
-        log.info("SPARQL: {}", queryString);
-        
-        executor.executeQuery(queryString, endpointURL, model, defaultGraphURI);
-        TBoxQueryGenerator tGenerator = new TBoxQueryGenerator();
-        queryString = tGenerator.createQuery(model, filters, instances);
-        executor.executeQuery(queryString, endpointURL, model,defaultGraphURI);
-        JenaToOwlapiConverter converter = new JenaToOwlapiConverter();
-        owlOntology=converter.convert(this.model);
-    }
-    
-    public String getEndpointURL() {
-        return endpointURL;
-    }
-    
-    public void setEndpointURL(String endpointURL) {
-        this.endpointURL = endpointURL;
-    }
-    
-    public String getDefaultGraphURI() {
+	private String defaultGraphURI = null;
+	@ConfigOption(name = "sparqlQuery", description = "Sparql Query", required = false)
+	private String sparqlQuery = null;
+	@ConfigOption(name = "ontologyFile", description = "Ontology Schema File", required = true)
+	private File ontologyFile = null;
+	private OWLOntology owlOntology;
+	private SchemaIndexer indexer;
+
+	private static Logger log = LoggerFactory
+			.getLogger(SparqlSimpleExtractor.class);
+
+	public SparqlSimpleExtractor() {
+		model = ModelFactory.createOntologyModel();
+	}
+
+	/**
+	 * @param args
+	 * @throws ComponentInitException
+	 */
+	public static void main(String[] args) throws ComponentInitException {
+		SparqlSimpleExtractor extractor = new SparqlSimpleExtractor();
+		extractor.setEndpointURL("http://live.dbpedia.org/sparql");
+		extractor.setRecursionDepth(1);
+		extractor.setDefaultGraphURI("http://dbpedia.org");
+		List<String> instances = new ArrayList<String>(7);
+		instances.add("http://dbpedia.org/resource/Democritus");
+		instances.add("http://dbpedia.org/resource/Zeno_of_Elea");
+		instances.add("http://dbpedia.org/resource/Plato");
+		instances.add("http://dbpedia.org/resource/Socrates");
+		instances.add("http://dbpedia.org/resource/Archytas");
+		instances.add("http://dbpedia.org/resource/Pythagoras");
+		instances.add("http://dbpedia.org/resource/Philolaus");
+
+		extractor.setInstances(instances);
+		extractor.init();
+		List<String> individuals = new LinkedList<String>();
+		individuals.add("People");
+		individuals.add("Animals");
+		extractor.setInstances(individuals);
+		// System.out.println(extractor.createQuery());
+	}
+
+	@Override
+	public void init() throws ComponentInitException {
+		if (endpointURL == null) {
+			throw new ComponentInitException(
+					"Parameter endpoint URL is required");
+		}
+		if (instances == null) {
+			throw new ComponentInitException("Parameter instances is required");
+		}
+		if (recursionDepth == 0) {
+			throw new ComponentInitException(
+					"A value bigger than 0 is required for parameter recursionDepth");
+		}
+		if (ontologyFile == null) {
+			throw new ComponentInitException(
+					"An ontology schema description file (ontologyFile) in RDF ist required");
+		}
+		Monitor monComp = MonitorFactory.start("Simple SPARQL Component")
+				.start();
+		Monitor monIndexer = MonitorFactory.start("Schema Indexer").start();
+		indexer = new SchemaIndexer();
+		indexer.init();
+		monIndexer.stop();
+
+		Monitor monAquery;
+		Monitor monQuerying;
+		QueryExecutor executor = new QueryExecutor();
+		String queryString;
+		if (sparqlQuery == null) {
+			ABoxQueryGenerator aGenerator = new ABoxQueryGenerator();
+			for (int i = 0; i < recursionDepth - 1; i++) {
+				monAquery = MonitorFactory.getTimeMonitor("A query generator")
+						.start();
+				queryString = aGenerator.createQuery(instances, model, filters);
+				monAquery.stop();
+				log.debug("SPARQL: {}", queryString);
+				monQuerying = MonitorFactory.start("Querying");
+				executor.executeQuery(queryString, endpointURL, model,
+						defaultGraphURI);
+				monQuerying.stop();
+			}
+			monAquery = MonitorFactory.getTimeMonitor("A query generator")
+					.start();
+			queryString = aGenerator.createLastQuery(instances, model, filters);
+			monAquery.stop();
+			log.debug("SPARQL: {}", queryString);
+			monQuerying = MonitorFactory.start("Querying");
+			executor.executeQuery(queryString, endpointURL, model, defaultGraphURI);
+			monQuerying.stop();
+		} else {
+			monQuerying=MonitorFactory.getTimeMonitor("Querying").start();
+			executor.executeQuery(sparqlQuery, endpointURL, model);
+			monQuerying.stop();
+		}
+		
+
+		TBoxQueryGenerator tGenerator = new TBoxQueryGenerator();
+		Monitor monTquery = MonitorFactory.getTimeMonitor("T query generator")
+				.start();
+		queryString = tGenerator.createQuery(model, filters, instances);
+		monTquery.stop();
+		monQuerying = MonitorFactory.start("Querying");
+		executor.executeQuery(queryString, endpointURL, model, defaultGraphURI);
+		monQuerying.stop();
+		Set<OntClass> classes = model.listClasses().toSet();
+		for (OntClass ontClass : classes) {
+			OntModel hierarchy = indexer.getHierarchyForURI(ontClass.getURI());
+			if (hierarchy != null) {
+				model.add(hierarchy);
+				log.debug("{}", model);
+			}
+		}
+		JenaToOwlapiConverter converter = new JenaToOwlapiConverter();
+		owlOntology = converter.convert(this.model);
+		monComp.stop();
+		log.info("*******Simple SPARQL Extractor********");
+		for (Monitor monitor : MonitorFactory.getRootMonitor().getMonitors()) {
+			log.info("* {} *", monitor);
+		}
+		log.info("**************************************");
+	}
+
+	public String getEndpointURL() {
+		return endpointURL;
+	}
+
+	public void setEndpointURL(String endpointURL) {
+		this.endpointURL = endpointURL;
+	}
+
+	public String getDefaultGraphURI() {
 		return defaultGraphURI;
 	}
 
 	public void setDefaultGraphURI(String defaultGraphURI) {
 		this.defaultGraphURI = defaultGraphURI;
-	}    
-    
-    public Model getModel() {
-        return model;
-    }
-    
-    public void setModel(OntModel model) {
-        this.model = model;
-    }
-    
-    /**
-     * @return the filters
-     */
-    public List<String> getFilters() {
-        return filters;
-    }
-    
-    /**
-     * @param filters
-     *            the filters to set
-     */
-    public void setFilters(List<String> filters) {
-        this.filters = filters;
-    }
+	}
 
-    /**
-     * @return the instances
-     */
-    public List<String> getInstances() {
-        return instances;
-    }
+	public Model getModel() {
+		return model;
+	}
 
-    /**
-     * @param instances the instances to set
-     */
-    public void setInstances(List<String> instances) {
-        this.instances = instances;
-    }
+	public void setModel(OntModel model) {
+		this.model = model;
+	}
 
-    /**
-     * @return the recursionDepth
-     */
-    public int getRecursionDepth() {
-        return recursionDepth;
-    }
+	/**
+	 * @return the filters
+	 */
+	public List<String> getFilters() {
+		return filters;
+	}
 
-    /**
-     * @param recursionDepth the recursionDepth to set
-     */
-    public void setRecursionDepth(int recursionDepth) {
-        this.recursionDepth = recursionDepth;
-    }
+	/**
+	 * @param filters
+	 *            the filters to set
+	 */
+	public void setFilters(List<String> filters) {
+		this.filters = filters;
+	}
 
+	/**
+	 * @return the instances
+	 */
+	public List<String> getInstances() {
+		return instances;
+	}
 
-    /**
-     * @return
-     */
-    public OWLOntology getOWLOntology() {
-       return owlOntology;
-    }
-    
+	/**
+	 * @param instances
+	 *            the instances to set
+	 */
+	public void setInstances(List<String> instances) {
+		this.instances = instances;
+	}
+
+	/**
+	 * @return the recursionDepth
+	 */
+	public int getRecursionDepth() {
+		return recursionDepth;
+	}
+
+	/**
+	 * @param recursionDepth
+	 *            the recursionDepth to set
+	 */
+	public void setRecursionDepth(int recursionDepth) {
+		this.recursionDepth = recursionDepth;
+	}
+
+	/**
+	 * @return
+	 */
+	public OWLOntology getOWLOntology() {
+		return owlOntology;
+	}
+
 }

This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.