Java 类com.hp.hpl.jena.query.ResultSet 实例源码

@Parameters(name="{index}: {0}")
public static Collection<Object[]> getAllTestLists() {
    Collection<Object[]> results = new ArrayList<Object[]>();
    for (File dir: new File(TEST_SUITE_DIR).listFiles()) {
        if (!dir.isDirectory() || !new File(dir.getAbsolutePath() + "/manifest.ttl").exists()) continue;
        String absolutePath = dir.getAbsolutePath();
        Model model = FileManager.get().loadModel(absolutePath + "/manifest.ttl");
        ResultSet resultSet = QueryExecutionFactory.create(QUERY, model).execSelect();
        while (resultSet.hasNext()) {
            QuerySolution solution = resultSet.nextSolution();
            if (Arrays.asList(D2RQTestUtil.SKIPPED_R2RML_TESTS).contains(solution.getResource("s").getLocalName())) continue;
            results.add(new Object[]{
                    PrettyPrinter.toString(solution.getResource("s")),
                    absolutePath + "/create.sql",
                    absolutePath + "/" + solution.getLiteral("rml").getLexicalForm(),
                    (solution.get("nquad") == null) ? 
                            null : 
                            absolutePath + "/" + solution.getLiteral("nquad").getLexicalForm()
            });
        }
    }
    return results;
}

private List<Statement> expandSubClasses(Model model){
    List<Statement> stmts = new ArrayList<Statement>();


    String sparql = "PREFIX rdfs: <" + RDFS.getURI() + ">"
            + "SELECT DISTINCT ?class ?synonym "
            + "WHERE { "
            + "?class rdfs:subClassOf+ ?subClass . "
            + "?subClass <" + synonym + "> ?synonym"
            + "}";

    Query query = QueryFactory.create(sparql, Syntax.syntaxARQ);
    QueryExecution queryExecution = QueryExecutionFactory.create(query, model);
    ResultSet resultSet = queryExecution.execSelect();
    resultSet.forEachRemaining(querySolution -> {
        stmts.add(new StatementImpl(querySolution.getResource("class"), synonym, querySolution.getLiteral("synonym")));
    });
    return stmts;
}

private List<Statement> expandSubProperties(Model model){
    List<Statement> stmts = new ArrayList<Statement>();

    String sparql = "PREFIX rdfs: <" + RDFS.getURI() + ">"
            + "SELECT DISTINCT ?property ?synonym "
            + "WHERE { "
            + "?property rdfs:subPropertyOf+ ?subProperty . "
            + "?subProperty <" + synonym + "> ?synonym"
            + "}";

    Query query = QueryFactory.create(sparql, Syntax.syntaxARQ);
    QueryExecution queryExecution = QueryExecutionFactory.create(query, model);
    ResultSet resultSet = queryExecution.execSelect();
    resultSet.forEachRemaining(querySolution -> {
        stmts.add(new StatementImpl(querySolution.getResource("property"), synonym, querySolution.getLiteral("synonym")));
    });
    return stmts;
}

public Resource getAgentUri(VirtGraph graphOrgs, String vatId) {

    Resource agentUri = null;

    String queryUri = "PREFIX gr: <http://purl.org/goodrelations/v1#> " +
                "SELECT ?org ?vatId " +
                "FROM <" + QueryConfiguration.queryGraphOrganizations + "> " +
                "WHERE { " +
                "?org gr:vatID ?vatId . " +
                "FILTER ( ?vatId = \"" + vatId + "\"^^<http://www.w3.org/2001/XMLSchema#string> ) " +
                "}";

    VirtuosoQueryExecution vqeUri = VirtuosoQueryExecutionFactory.create(queryUri, graphOrgs);      
    ResultSet resultsUri = vqeUri.execSelect();

    if (resultsUri.hasNext()) {
        QuerySolution result = resultsUri.nextSolution();
        agentUri = result.getResource("org");
    }

    vqeUri.close();

    return agentUri;
}

public Resource getAgentUriNoVat(VirtGraph graphOrgs, String vatId) {

    Resource agentUri = null;

    String queryUri = "PREFIX gr: <http://purl.org/goodrelations/v1#> " +
                "SELECT DISTINCT ?org " +
                "FROM <" + QueryConfiguration.queryGraphOrganizations + "> " +
                "WHERE { " +
                "?org rdf:type foaf:Organization . " +
                "FILTER (STR(?org) = \"http://linkedeconomy.org/resource/Organization/" + vatId + "\") . " +
                "}";

    VirtuosoQueryExecution vqeUri = VirtuosoQueryExecutionFactory.create(queryUri, graphOrgs);      
    ResultSet resultsUri = vqeUri.execSelect();

    if (resultsUri.hasNext()) {
        QuerySolution result = resultsUri.nextSolution();
        agentUri = result.getResource("org");
    }

    vqeUri.close();

    return agentUri;
}

public Resource getAgentUri(VirtGraph graphOrgs, String vatId) {

    Resource agentUri = null;

    String queryUri = "PREFIX gr: <http://purl.org/goodrelations/v1#> " +
                "SELECT ?org ?vatId " +
                "FROM <" + QueryConfiguration.queryGraphOrganizations + "> " +
                "WHERE { " +
                "?org gr:vatID ?vatId . " +
                "FILTER ( ?vatId = \"" + vatId + "\"^^<http://www.w3.org/2001/XMLSchema#string> ) " +
                "}";

    VirtuosoQueryExecution vqeUri = VirtuosoQueryExecutionFactory.create(queryUri, graphOrgs);      
    ResultSet resultsUri = vqeUri.execSelect();

    if (resultsUri.hasNext()) {
        QuerySolution result = resultsUri.nextSolution();
        agentUri = result.getResource("org");
    }

    vqeUri.close();

    return agentUri;
}

public Resource getAgentUriNoVat(VirtGraph graphOrgs, String vatId) {

    Resource agentUri = null;

    String queryUri = "PREFIX gr: <http://purl.org/goodrelations/v1#> " +
                "SELECT DISTINCT ?org " +
                "FROM <" + QueryConfiguration.queryGraphOrganizations + "> " +
                "WHERE { " +
                "?org rdf:type foaf:Organization . " +
                "FILTER (STR(?org) = \"http://linkedeconomy.org/resource/Organization/" + vatId + "\") . " +
                "}";

    VirtuosoQueryExecution vqeUri = VirtuosoQueryExecutionFactory.create(queryUri, graphOrgs);      
    ResultSet resultsUri = vqeUri.execSelect();

    if (resultsUri.hasNext()) {
        QuerySolution result = resultsUri.nextSolution();
        agentUri = result.getResource("org");
    }

    vqeUri.close();

    return agentUri;
}

@Test
public void testBulkLoad() throws URISyntaxException, IOException, OperationNotSupportedException {
    URL[] files = new URL[1];
    URL url = TDBTest.class.getResource("/org/aksw/kbox/kibe/dbpedia_3.9.xml");
    files[0] = url;
    java.nio.file.Path f = Files.createTempDirectory("kb");
    String path = f.toFile().getPath();
    TDB.bulkload(f.toFile().getPath(), files);
    Date start = new Date();
    ResultSet rs = TDB.query("Select ?p where {<http://dbpedia.org/ontology/Place> ?p ?o}", path);
    int i = 0;
    Date end = new Date();
    System.out.println(end.getTime() - start.getTime());
    while (rs != null && rs.hasNext()) {
        rs.next();
        i++;
    }
    assertEquals(19, i);
}

@Test
public void testQueryInstalledKB() throws Exception {
    ResultSet rs = KBox.query("Select ?p where {<http://dbpedia.org/ontology/Place> ?p ?o}",
            new URL("http://dbpedia39"));
    int i = 0;
    while (rs != null && rs.hasNext()) {
        rs.next();
        i++;
    }
    assertEquals(19, i);

    rs = KBox.query( 
            "Select ?p where {<http://dbpedia.org/ontology/Place> ?p ?o}",
            new URL("http://dbpedia39"));
    i = 0;
    while (rs != null && rs.hasNext()) {
    rs.next();
    i++;
    }
    assertEquals(19, i);
}

public static void main(String[] args) {
    ModelD2RQ m = new ModelD2RQ("file:doc/example/mapping-iswc.ttl");
    String sparql = 
        "PREFIX dc: <http://purl.org/dc/elements/1.1/>" +
        "PREFIX foaf: <http://xmlns.com/foaf/0.1/>" +
        "SELECT ?paperTitle ?authorName WHERE {" +
        "    ?paper dc:title ?paperTitle . " +
        "    ?paper dc:creator ?author ." +
        "    ?author foaf:name ?authorName ." +
        "}";
    Query q = QueryFactory.create(sparql); 
    ResultSet rs = QueryExecutionFactory.create(q, m).execSelect();
    while (rs.hasNext()) {
        QuerySolution row = rs.nextSolution();
        System.out.println("Title: " + row.getLiteral("paperTitle").getString());
        System.out.println("Author: " + row.getLiteral("authorName").getString());
    }
    m.close();
}

public static Collection<Object[]> getTestListFromManifest(String manifestFileURL) {
        // We'd like to use FileManager.loadModel() but it doesn't work on jar: URLs
//      Model m = FileManager.get().loadModel(manifestFileURL);
        Model m = ModelFactory.createDefaultModel();
        m.read(manifestFileURL, "TURTLE");

        IRI baseIRI = D2RQTestUtil.createIRI(m.getNsPrefixURI("base"));
        ResultSet rs = QueryExecutionFactory.create(TEST_CASE_LIST, m).execSelect();
        List<Object[]> result = new ArrayList<Object[]>();
        while (rs.hasNext()) {
            QuerySolution qs = rs.next();
            Resource mapping = qs.getResource("mapping");
            Resource schema = qs.getResource("schema");
//          if (!mapping.getLocalName().equals("constant-object.ttl")) continue;
            QueryExecution qe = QueryExecutionFactory.create(TEST_CASE_TRIPLES, m);
            qe.setInitialBinding(qs);
            Model expectedTriples = qe.execConstruct();
            result.add(new Object[]{baseIRI.relativize(mapping.getURI()).toString(), mapping.getURI(), 
                    schema.getURI(), expectedTriples});
        }
        return result;
    }

@Parameters(name="{index}: {0}")
    public static Collection<Object[]> getTestLists() {
        Model m = D2RQTestUtil.loadTurtle(MANIFEST_FILE);
        IRI baseIRI = D2RQTestUtil.createIRI(m.getNsPrefixURI("base"));
        ResultSet rs = QueryExecutionFactory.create(TEST_CASE_LIST, m).execSelect();
        List<Object[]> result = new ArrayList<Object[]>();
        while (rs.hasNext()) {
            QuerySolution qs = rs.next();
            Resource testCase = qs.getResource("case");
//          if (!case.getLocalName().equals("expression")) continue;
            QueryExecution qe = QueryExecutionFactory.create(TEST_CASE_TRIPLES, m);
            qe.setInitialBinding(qs);
            Model expectedTriples = qe.execConstruct();
            result.add(new Object[]{
                    baseIRI.relativize(testCase.getURI()).toString(), 
                    qs.getLiteral("sql").getLexicalForm(), 
                    expectedTriples});
        }
        return result;
    }

public static void main(String[] args) {
    ModelD2RQ m = new ModelD2RQ("file:doc/example/mapping-iswc.ttl");
    String sparql = 
        "PREFIX dc: <http://purl.org/dc/elements/1.1/>" +
        "PREFIX foaf: <http://xmlns.com/foaf/0.1/>" +
        "SELECT ?paperTitle ?authorName WHERE {" +
        "    ?paper dc:title ?paperTitle . " +
        "    ?paper dc:creator ?author ." +
        "    ?author foaf:name ?authorName ." +
        "}";
    Query q = QueryFactory.create(sparql); 
    ResultSet rs = QueryExecutionFactory.create(q, m).execSelect();
    while (rs.hasNext()) {
        QuerySolution row = rs.nextSolution();
        System.out.println("Title: " + row.getLiteral("paperTitle").getString());
        System.out.println("Author: " + row.getLiteral("authorName").getString());
    }
    m.close();
}

/**
  * Gets and returns the geolocation of a POI
  * @param resource
  * @return
  */
 private static Literal getGeoLocation(String resource){

    Literal geoLocation;

    String sparqlquery= "PREFIX geo:<http://www.w3.org/2003/01/geo/wgs84_pos#> \n"          
                + "select distinct ?geolocation where {" 
                + "<"+resource+"> geo:geometry ?geolocation.}\n"
                + "LIMIT 1 ";
    Query query = QueryFactory.create(sparqlquery);
  QueryExecution qexec = QueryExecutionFactory.sparqlService("http://dbpedia.org/sparql", query);
  ResultSet results = qexec.execSelect();
  if (results.hasNext() ){              
QuerySolution soln = results.nextSolution();
geoLocation = soln.getLiteral("geolocation");
   qexec.close();
   return geoLocation;
  }
  else {
   qexec.close();
    return null;
  }
 }

@Override
public Result call() throws Exception
{
    QueryEngine engine = pool.getPool().borrowObject();
    try
    {
        ResultSet rs = engine.execSelect(q);

        Result r = new Result();
        r.resultSet = Collections.singletonList(rs);
        r.cursorMap.putAll(engine.getContext().getCursorMap());
        r.metaData.putAll(engine.getContext().getMetadata());

        return r;
    }
    finally
    {
        if (engine != null)
        {
            pool.getPool().returnObject(engine);
        }
    }
}

/**
 * Queries for the supertypes of the given resource
 * @param resource
 * @return
 */
private static List<Resource> retrieveHierarchyTwo(String resource){

    String sparqlquery= "PREFIX dbpedia-owl:<http://dbpedia.org/ontology/> \n"
+ "PREFIX geo:<http://www.w3.org/2003/01/geo/wgs84_pos#> \n"
+ "PREFIX rdfs:<http://www.w3.org/2000/01/rdf-schema#> \n"
+ "PREFIX foaf:<http://xmlns.com/foaf/0.1/> \n"
+ "PREFIX xsd:<http://www.w3.org/2001/XMLSchema#> \n"
+ "select distinct ?super ?subclass where {" 
+ "<"+resource+"> a ?super.\n"
+ "<"+resource+">  a ?subclass.\n"
+ "?subclass rdfs:subClassOf ?super.\n"
+ "FILTER (?subclass!=?super)}";

    Query query = QueryFactory.create(sparqlquery);
 QueryExecution qexec = QueryExecutionFactory.sparqlService("http://dbpedia.org/sparql", query);
 ResultSet results = qexec.execSelect();

 // Parse the result to avoid transitivity and thus repetition of types
 List<Resource> hierarchy_two = parseResult(results);
 qexec.close();

 return hierarchy_two;

}

static void readOwlFile (String pathToOwlFile) {
        OntModel ontologyModel =
                ModelFactory.createOntologyModel(OntModelSpec.OWL_MEM, null);
        ontologyModel.read(pathToOwlFile, "RDF/XML-ABBREV");
       // OntClass myClass = ontologyModel.getOntClass("namespace+className");

        OntClass myClass = ontologyModel.getOntClass(ResourcesUri.nwr+"domain-ontology#Motion");
        System.out.println("myClass.toString() = " + myClass.toString());
        System.out.println("myClass.getSuperClass().toString() = " + myClass.getSuperClass().toString());

        //List list =
              //  namedHierarchyRoots(ontologyModel);


       Iterator i = ontologyModel.listHierarchyRootClasses()
                .filterDrop( new Filter() {
                    public boolean accept( Object o ) {
                        return ((Resource) o).isAnon();
                    }} ); ///get all top nodes and excludes anonymous classes

       // Iterator i = ontologyModel.listHierarchyRootClasses();
        while (i.hasNext()) {
            System.out.println(i.next().toString());
/*            OntClass ontClass = ontologyModel.getOntClass(i.next().toString());
            if (ontClass.hasSubClass()) {

            }*/
        }

        String q = createSparql("event", "<http://www.newsreader-project.eu/domain-ontology#Motion>");
        System.out.println("q = " + q);
        QueryExecution qe = QueryExecutionFactory.create(q,
                ontologyModel);
        for (ResultSet rs = qe.execSelect() ; rs.hasNext() ; ) {
            QuerySolution binding = rs.nextSolution();
            System.out.println("binding = " + binding.toString());
            System.out.println("Event: " + binding.get("event"));
        }

        ontologyModel.close();
    }

public static StringMatrix sparql(String endpoint, String queryString)
        throws Exception {
    StringMatrix table = null;

    // use Apache for doing the SPARQL query
    DefaultHttpClient httpclient = new DefaultHttpClient();
    List<NameValuePair> formparams = new ArrayList<NameValuePair>();
    formparams.add(new BasicNameValuePair("query", queryString));
    UrlEncodedFormEntity entity = new UrlEncodedFormEntity(formparams, "UTF-8");
    HttpPost httppost = new HttpPost(endpoint);
    httppost.setEntity(entity);
    HttpResponse response = httpclient.execute(httppost);
    HttpEntity responseEntity = response.getEntity();
    InputStream in = responseEntity.getContent();

    // now the Jena part
    ResultSet results = ResultSetFactory.fromXML(in);
    // also use Jena for getting the prefixes...
    // Query query = QueryFactory.create(queryString);
    // PrefixMapping prefixMap = query.getPrefixMapping();
    table = convertIntoTable(null, results);

    in.close();
    return table;
}

@Test
public void testMetric_TotalBuilds() {
    Query query =
        QueryFactory.
            create(
                loadResource("/metrics/total_builds.sparql"));
    QueryExecution queryExecution = null;
    try {
        queryExecution = QueryExecutionFactory.create(query, buildsDataSet());
        ResultSet results = queryExecution.execSelect();
        for(; results.hasNext();) {
            QuerySolution solution = results.nextSolution();
            long buildId = solution.getLiteral("total_builds").getLong();
            System.out.printf("Total builds: %d%n",buildId);
        }
    } finally {
        if (queryExecution != null) {
            queryExecution.close();
        }
    }
}

@Test
public void testMetric_TotalExecutions_PerBuild() {
    Query query =
        QueryFactory.
            create(
                loadResource("/metrics/total_executions_per_build.sparql"));
    QueryExecution queryExecution = null;
    try {
        queryExecution = QueryExecutionFactory.create(query, executionsDataSet());
        ResultSet results = queryExecution.execSelect();
        for(; results.hasNext();) {
            QuerySolution solution = results.nextSolution();
            long total_executions = solution.getLiteral("total_executions").getLong();
            String buildId = shorten(solution.getResource("build").getURI());
            System.out.printf("Total executions of build %s: %d%n",buildId,total_executions);
        }
    } finally {
        if (queryExecution != null) {
            queryExecution.close();
        }
    }
}

@Test
public void testMetric_TotalSuccesfulExecutions_Global_Period() {
    Query query =
        QueryFactory.
            create(
                loadResource("/metrics/total_succesful_executions_global_period.sparql"));
    QueryExecution queryExecution = null;
    try {
        queryExecution = QueryExecutionFactory.create(query, executionsDataSet());
        ResultSet results = queryExecution.execSelect();
        for(; results.hasNext();) {
            QuerySolution solution = results.nextSolution();
            long total_executions = solution.getLiteral("total_executions").getLong();
            String day = solution.getLiteral("day").getString();
            System.out.printf("Total succesful executions [%s]: %d%n",day,total_executions);
        }
    } finally {
        if (queryExecution != null) {
            queryExecution.close();
        }
    }
}

@Test
public void testMetric_TotalSuccesfulExecutions_PerBuild() {
    Query query =
        QueryFactory.
            create(
                loadResource("/metrics/total_succesful_executions_per_build.sparql"));
    QueryExecution queryExecution = null;
    try {
        queryExecution = QueryExecutionFactory.create(query, executionsDataSet());
        ResultSet results = queryExecution.execSelect();
        for(; results.hasNext();) {
            QuerySolution solution = results.nextSolution();
            long total_executions = solution.getLiteral("total_executions").getLong();
            String buildId = shorten(solution.getResource("build").getURI());
            System.out.printf("Total succesful executions of build %s: %d%n",buildId,total_executions);
        }
    } finally {
        if (queryExecution != null) {
            queryExecution.close();
        }
    }
}

@Test
public void testMetric_TotalBrokenExecutions_Global() {
    Query query =
        QueryFactory.
            create(
                loadResource("/metrics/total_broken_executions_global.sparql"));
    QueryExecution queryExecution = null;
    try {
        queryExecution = QueryExecutionFactory.create(query, executionsDataSet());
        ResultSet results = queryExecution.execSelect();
        for(; results.hasNext();) {
            QuerySolution solution = results.nextSolution();
            long total_executions = solution.getLiteral("total_executions").getLong();
            System.out.printf("Total broken executions: %d%n",total_executions);
        }
    } finally {
        if (queryExecution != null) {
            queryExecution.close();
        }
    }
}

@Test
public void testMetric_TotalBrokenExecutions_PerBuild() {
    Query query =
        QueryFactory.
            create(
                loadResource("/metrics/total_broken_executions_per_build.sparql"));
    QueryExecution queryExecution = null;
    try {
        queryExecution = QueryExecutionFactory.create(query, executionsDataSet());
        ResultSet results = queryExecution.execSelect();
        for(; results.hasNext();) {
            QuerySolution solution = results.nextSolution();
            long total_executions = solution.getLiteral("total_executions").getLong();
            String buildId = shorten(solution.getResource("build").getURI());
            System.out.printf("Total broken executions of build %s: %d%n",buildId,total_executions);
        }
    } finally {
        if (queryExecution != null) {
            queryExecution.close();
        }
    }
}

private ArrayList<QuerySolution> fetch(String pageQueryString) {
    ArrayList<QuerySolution> result = new ArrayList<QuerySolution>();
    Query q = QueryFactory.create(pageQueryString);
    QueryExecution qexec =QueryExecutionFactory.sparqlService(endPoint, q);
    ResultSet results;
    try {
        results = qexec.execSelect();       
        for (; results.hasNext();) {
            QuerySolution soln = results.nextSolution();
            result.add(soln);               
        }
    }
    catch(Exception e){
        e.printStackTrace();
        return null;
    }       
    finally {
        qexec.close();
    }       
    return result;
}

private String checkAvailability(String resource) {
    try {
        Query query = QueryFactory
                .create("SELECT ?label WHERE{ <"
                        + resource
                        + "> <http://www.w3.org/2000/01/rdf-schema#label> ?label. }");
        QueryExecution qe = QueryExecutionFactory.create(query, this.m_l);
        ResultSet results = qe.execSelect();
        if (results.hasNext()) {
            return resource;
        }
    } catch (Exception e) {
        return "";
    }
    return "";
}

private String checkAvailability(String resource) {
    try {
        Query query = QueryFactory
                .create("SELECT ?label WHERE{ <"
                        + resource
                        + "> <http://www.w3.org/2000/01/rdf-schema#label> ?label. }");
        QueryExecution qe = QueryExecutionFactory.create(query, this.m_l);
        ResultSet results = qe.execSelect();
        if (results.hasNext()) {
            return resource;
        }
    } catch (Exception e) {
        return "";
    }
    return "";
}

private String checkRedirects(String resource) {
    String result = resource;
    try {

        Query query = QueryFactory
                .create("SELECT ?redirect WHERE{ <"
                        + resource
                        + "> <http://dbpedia.org/ontology/wikiPageRedirects> ?redirect. }");
        QueryExecution qe = QueryExecutionFactory.create(query, this.m);
        ResultSet results = qe.execSelect();
        while (results.hasNext()) {
            QuerySolution sol = results.nextSolution();
            result = sol.getResource("redirect").getURI();
        }
    } catch (Exception e) {
        return resource;
    }
    return result;
}

private Set<String> queryEntitiesFromCategory(final String catUri) {
    Set<String> set = new HashSet<String>();
    final String query = "SELECT ?entities WHERE{ ?entities <http://purl.org/dc/terms/subject> <"
            + catUri + ">. }";
    try {
        final com.hp.hpl.jena.query.Query cquery = QueryFactory
                .create(query);
        final QueryExecution qexec = QueryExecutionFactory
                .create(cquery, m);
        final ResultSet results = qexec.execSelect();
        while (results.hasNext()) {
            final QuerySolution sol = results.nextSolution();
            set.add(sol.getResource("entities").getURI()
                    .replaceAll("http://dbpedia.org/resource/", ""));
        }

    } catch (final QueryException e) {
        Logger.getRootLogger().error(e.getStackTrace());
    }
    return set;
}

private String queryEntitiesFromCategory(final String catUri) {
    String res = null;

    final String query = "SELECT ?entities WHERE{ ?entities <http://purl.org/dc/terms/subject> <"
            + catUri + ">. }";
    try {
        final com.hp.hpl.jena.query.Query cquery = QueryFactory
                .create(query);
        final QueryExecution qexec = QueryExecutionFactory
                .create(cquery, m);
        final ResultSet results = qexec.execSelect();
        List<String> entities = new LinkedList<String>();
        while (results.hasNext()) {
            final QuerySolution sol = results.nextSolution();
            entities.add(sol.getResource("entities").getURI());
        }
        if (entities.size() != 0) {
            int randomNr = this.random.nextInt(entities.size());
            return entities.get(randomNr);
        }

    } catch (final QueryException e) {
        Logger.getRootLogger().error(e.getStackTrace());
    }
    return res;
}

private boolean hasSubCategory(String uri) {
    final String query = "SELECT ?entities WHERE{ ?types <http://www.w3.org/2004/02/skos/core#broader> <"
            + uri + ">. }";
    boolean hasSubtype = false;
    try {
        final com.hp.hpl.jena.query.Query cquery = QueryFactory
                .create(query);
        final QueryExecution qexec = QueryExecutionFactory
                .create(cquery, skosModel);
        final ResultSet results = qexec.execSelect();
        while (results.hasNext()) {
            hasSubtype = true;
            break;
        }

    } catch (final QueryException e) {
        Logger.getRootLogger().error(e.getStackTrace());
    }
    return hasSubtype;
}

private Set<String> queryEntitiesFromCategory(final String catUri) {
    Set<String> set = new HashSet<String>();
    final String query = "SELECT ?entities WHERE{ ?entities <http://purl.org/dc/terms/subject> <"
            + catUri + ">. }";
    try {
        final com.hp.hpl.jena.query.Query cquery = QueryFactory
                .create(query);
        final QueryExecution qexec = QueryExecutionFactory
                .create(cquery, m);
        final ResultSet results = qexec.execSelect();
        while (results.hasNext()) {
            final QuerySolution sol = results.nextSolution();
            set.add(sol.getResource("entities").getURI()
                    .replaceAll("http://dbpedia.org/resource/", ""));
        }

    } catch (final QueryException e) {
        Logger.getRootLogger().error(e.getStackTrace());
    }
    return set;
}

private String queryEntitiesFromCategory(final String catUri) {
    String res = null;

    final String query = "SELECT ?entities WHERE{ ?entities <http://purl.org/dc/terms/subject> <"
            + catUri + ">. }";
    try {
        final com.hp.hpl.jena.query.Query cquery = QueryFactory
                .create(query);
        final QueryExecution qexec = QueryExecutionFactory
                .create(cquery, m);
        final ResultSet results = qexec.execSelect();
        List<String> entities = new LinkedList<String>();
        while (results.hasNext()) {
            final QuerySolution sol = results.nextSolution();
            entities.add(sol.getResource("entities").getURI());
        }
        if (entities.size() != 0) {
            int randomNr = this.random.nextInt(entities.size());
            return entities.get(randomNr);
        }

    } catch (final QueryException e) {
        Logger.getRootLogger().error(e.getStackTrace());
    }
    return res;
}

private String getRedirect(String uri) {
    final Model model = DisambiguationMainService.getInstance().getDBpediaRedirects();
    final String query = "SELECT ?label WHERE{ <" + uri
            + "> <http://dbpedia.org/ontology/wikiPageRedirects> ?label. }";
    ResultSet results = null;
    QueryExecution qexec = null;
    String redirect = null;
    try {
        final com.hp.hpl.jena.query.Query cquery = QueryFactory.create(query);
        qexec = QueryExecutionFactory.create(cquery, model);
        results = qexec.execSelect();
    } catch (final QueryException e) {
        Logger.getRootLogger().error(e.getStackTrace());
    } finally {
        if (results.hasNext()) {
            final QuerySolution sol = results.nextSolution();
            redirect = sol.getResource("label").getURI();
        }
    }
    return redirect;
}

public static Set<Type> getRDFTypesFromEntity(final String entityUri) {
    Set<Type> set = new HashSet<Type>();
    final Model model = DisambiguationMainService.getInstance().getDBPediaInstanceTypes();
    final String query = "SELECT ?types WHERE{ <" + entityUri
            + "> <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> ?types. }";
    ResultSet results = null;
    QueryExecution qexec = null;
    try {
        final com.hp.hpl.jena.query.Query cquery = QueryFactory
                .create(query);
        qexec = QueryExecutionFactory.create(cquery, model);
        results = qexec.execSelect();
    } catch (final QueryException e) {
        Logger.getRootLogger().error(e.getStackTrace());
    } finally {
        if (results != null) {
            while (results.hasNext()) {
                final QuerySolution sol = results.nextSolution();
                final String type = sol.getResource("types").toString();
                set.add(new Type("", type, true, 0));
            }
        }
    }
    return set;
}

public static String getDbPediaDescription(final String uri)
        throws QueryException {
    String res = null;
    final Model model = DisambiguationMainService.getInstance()
            .getDBPediaDescription();
    final String query = "SELECT ?description WHERE{ <" + uri
            + "> <http://dbpedia.org/ontology/abstract> ?description. }";
    ResultSet results = null; // NOPMD by quh on 14.02.14 10:04
    QueryExecution qexec = null;
    try {
        final com.hp.hpl.jena.query.Query cquery = QueryFactory
                .create(query);
        qexec = QueryExecutionFactory.create(cquery, model);
        results = qexec.execSelect();
    } finally {
        if ((results != null) && results.hasNext()) {
            res = results.nextSolution().getLiteral("description")
                    .getString();
        }
        if (qexec != null) {
            qexec.close();
        }
    }
    return res;
}

public static List<String> getDbPediaLabel(final String uri)
        throws QueryException {
    final List<String> labellist = new LinkedList<String>();

    final Model model = DisambiguationMainService.getInstance()
            .getDBPediaLabels();
    final String query = "SELECT ?label WHERE{ <" + uri
            + "> <http://www.w3.org/2000/01/rdf-schema#label> ?label. }";
    ResultSet results = null; // NOPMD by quh on 14.02.14 10:04
    QueryExecution qexec = null;

    final com.hp.hpl.jena.query.Query cquery = QueryFactory.create(query);
    qexec = QueryExecutionFactory.create(cquery, model);
    results = qexec.execSelect();

    if (results != null) {
        while (results.hasNext()) {
            final QuerySolution sol = results.nextSolution();
            final String label = sol.getLiteral("label").getLexicalForm();
            labellist.add(label);
        }
        qexec.close();
    }
    return labellist;
}

public static List<String> getDbPediaLabel_GER(final String uri)
        throws QueryException {
    final List<String> labellist = new LinkedList<String>();

    final Model model = DisambiguationMainService.getInstance()
            .getDBPediaLabels_GER();
    final String query = "SELECT ?label WHERE{ <" + uri
            + "> <http://www.w3.org/2000/01/rdf-schema#label> ?label. }";
    ResultSet results = null; // NOPMD by quh on 14.02.14 10:04
    QueryExecution qexec = null;

    final com.hp.hpl.jena.query.Query cquery = QueryFactory.create(query);
    qexec = QueryExecutionFactory.create(cquery, model);
    results = qexec.execSelect();

    if (results != null) {
        while (results.hasNext()) {
            final QuerySolution sol = results.nextSolution();
            final String label = sol.getLiteral("label").getLexicalForm();
            labellist.add(label);
        }
        qexec.close();
    }
    return labellist;
}

/**
 * Queries DBPedia dataset for info based on the name of the city of the current location
 * @param location
 * @return
 */
public static DBPediaInfoObject poseInfoQuery(Location location) { 
    String sQuery = "";
    try {
        java.net.URL url = Play.class.getResource("/dbpedia_sparql.txt");
        java.nio.file.Path resPath = java.nio.file.Paths.get(url.toURI());
        sQuery= new String(java.nio.file.Files.readAllBytes(resPath), "UTF8");

           sQuery = sQuery.replace("SIMPLE_NAME", location.getSimpleName());

           Query query = QueryFactory.create(sQuery);
           QueryExecution qexec = QueryExecutionFactory.sparqlService("http://dbpedia.org/sparql", query);
           ResultSet results = qexec.execSelect();
           // Put result into a DBPediaInfoObject
           DBPediaInfoObject info = parseResult(results);
           qexec.close();

           return info;
    } catch (Exception e) {
        e.printStackTrace();
    }

       return null;
}

public static List<Type> queryYagoCategories(final String uri) {
    final Model model = DisambiguationMainService.getInstance()
            .getYagoTransitiveTypes();

    final List<Type> types = new LinkedList<Type>();
    final String query = "SELECT ?type WHERE{ <"
            + uri
            + "> <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> ?type. }";
    try {
        final com.hp.hpl.jena.query.Query que = QueryFactory.create(query);
        final QueryExecution qexec = QueryExecutionFactory.create(que,
                model);
        final ResultSet results = qexec.execSelect(); // NOPMD by quh on
                                                        // 18.02.14 15:05
        while (results.hasNext()) {
            final QuerySolution sol = results.nextSolution();
            final String name = sol.getResource("type").toString();
            types.add(new Type("", name, true, 0));
        }
    } catch (final QueryException e) {
        Logger.getRootLogger().error(e.getStackTrace());
    }
    return types;
}