D-Net

package eu.dnetlib.data.mapreduce.hbase.lodImport.utils;

import java.io.InputStream;

import org.apache.log4j.Logger;

import com.hp.hpl.jena.query.QueryExecution;

import com.hp.hpl.jena.query.QueryExecutionFactory;

import com.hp.hpl.jena.query.QuerySolution;

import com.hp.hpl.jena.query.ResultSet;

import com.hp.hpl.jena.rdf.model.Model;

import com.hp.hpl.jena.rdf.model.ModelFactory;

/**

 * Method: getCoutryURI

 * 

 * @author Giorgos Alexiou

 *

 */

public class MapCountries {

/**

 * This Method takes ISO ISO_3166_1 codes for Countries as input and returns the respective URI from dbpedia.org as output.

 * For example iso639_3 for Germany is "DE" and the respective URI from dbpedia.org is <http://dbpedia.org/resource/Germany>

 * 

 * @param iso_3166_1_Code

 * @return country URI <String>

 */

	public MapCountries(){

	}

	private Logger log = Logger.getLogger(this.getClass());

	public  String getCountryURI(String iso_3166_1_Code){

		String countryURI="";

		try{

			iso_3166_1_Code = iso_3166_1_Code.trim();

			if(iso_3166_1_Code.equals("UK") || iso_3166_1_Code.equals("GB")) return "http://dbpedia.org/resource/United_Kingdom";

			Model dbpediaCountries =  ModelFactory.createDefaultModel();

	//		URL file =  MapCountries.class.getClassLoader().getResource("rdfData/dbpedia_Countries.rdf");

//			InputStream is = new FileInputStream(path);

		//	InputStream is = this.getClass().getResourceAsStream("lodImport/dbpedia_Countries.rdf");

            InputStream is =  ClassLoader.getSystemResourceAsStream("eu/dnetlib/data/mapreduce/hbase/lodImport/dbpedia_Countries.rdf");

			dbpediaCountries.read(is, "RDF/XML");

			String isoURI = "http://dbpedia.org/resource/ISO_3166-1:"+iso_3166_1_Code;

			String query = "PREFIX dbpedia-owl:<http://dbpedia.org/ontology/> select distinct ?s ?r where {<"+isoURI+"> dbpedia-owl:wikiPageRedirects ?s}";

	//		System.out.println(query);

			QueryExecution queryExecution = QueryExecutionFactory.create(query,dbpediaCountries);

			ResultSet resultSet = queryExecution.execSelect();

			while (resultSet.hasNext()) {

				 QuerySolution qs = resultSet.next();

				 String uriString = qs.getResource("s").toString().trim();

				 countryURI=uriString;

			}

		}catch(Exception e){

			log.error("MapCountries error"+e.toString(),e);

		}

		return countryURI;	

	}

}