D-Net

import com.lambdaworks.redis.RedisURI;

import com.lambdaworks.redis.cluster.ClusterClientOptions;

import com.lambdaworks.redis.cluster.RedisAdvancedClusterConnection;

import com.lambdaworks.redis.cluster.RedisClusterClient;

import eu.dnetlib.data.mapreduce.hbase.lodExport.utils.LodConfiguration;

import org.json.simple.JSONArray;

import org.json.simple.JSONObject;

import org.json.simple.parser.JSONParser;

import org.json.simple.parser.ParseException;

import java.io.FileInputStream;

import java.io.IOException;

import java.io.InputStream;

import java.util.Properties;

/**

 * Created by eri_k on 5/28/2016.

 */

public class Test {

    @org.junit.Test

    public void testJson() throws IOException, ParseException {

        InputStream in = new FileInputStream("C:\\Users\\eri_k\\workspace\\lodinterlinking\\trunk\\src\\main\\resources\\eu\\dnetlib\\data\\mapreduce\\hbase\\lodExport\\mappings.properties");

        Properties properties = new Properties();

        properties.load(in);

        in.close();

        JSONParser parser = new JSONParser();

        JSONObject object = (JSONObject) parser.parse(properties.getProperty("lod_sourceMappings"));

        System.out.println(object.get("result"));

        if (((JSONArray) object.get("result")).toString().contains("http://dbpedia.org/ontology/type"))

            System.out.println("lal");

    }

    @org.junit.Test

    public void testSplit() throws Exception {

        String line = "<http://lod.openaire.eu/data/person/doajarticles::dc4862cbad761cd43925c558f89e7d17>	<http://www.w3.org/1999/02/22-rdf-syntax-ns#type>	<http://xmlns.com/foaf/0.1/Person>";

        InputStream in = new FileInputStream("C:\\Users\\eri_k\\workspace\\lodinterlinking\\trunk\\src\\main\\resources\\eu\\dnetlib\\data\\mapreduce\\hbase\\lodExport\\mappings.properties");

        Properties properties = new Properties();

        properties.load(in);

        in.close();

        line = line.replace("<", "").replace(">", "");

        LodConfiguration lodConfiguration = new LodConfiguration();

        lodConfiguration.load(properties.getProperty("lod_sourceMappings"));

        String[] Fields = line.toString().split("\t");

        int i = 1;

        String[] tmp = Fields[0].split("/");

        String entity = tmp[4];

        String id = Fields[0];

        System.out.println(entity);

        System.out.println(id);

        StringBuilder value = new StringBuilder();

        if (lodConfiguration.entityExists(entity)) {

            System.out.println("yeaah");

            System.out.println("field is " + Fields[i].replace("/", "\\/"));

            System.out.println((((org.json.simple.JSONArray) lodConfiguration.getConfig().get(entity))));

            System.out.println((((org.json.simple.JSONArray) lodConfiguration.getConfig().get(entity)).toString().contains(Fields[i].replace("/", "\\/"))));

            while (i < Fields.length - 1) {

                if (lodConfiguration.isValidField(entity, Fields[i].replace("/", "\\/"))) {

                    //  value.append(Fields[i] + "\t" + Fields[i+1]);

                    value.append(Fields[i] + "\t" + Fields[i + 1]);

                }

                i += 2;

            }

        }

        System.out.println("value is " + value);

    }

    @org.junit.Test

    public void testrecods() {

        String recordId = " id\thttp://lod.openaire.eu/data/result/doajarticles::1ba2cc76a1da1b039aeafb6da70543b9 http://lod.openaire.eu/vocab/resultSubject \"Social Sciences\" .,";

        recordId = "<http://lod.openaire.eu/data/result/od_______162::3147f9e84fde4d4599a45b10e6b7dffb> <http://purl.org/dc/terms/publisher> \"EDP Sciences\" ";

        String regex = "\\s+(?=((\\\\[\\\\\"]|[^\\\\\"])*\"(\\\\[\\\\\"]|[^\\\\\"])*\")*(\\\\[\\\\\"]|[^\\\\\"])*$)";

        //System.out.println(recordId.replaceAll(regex, "\t"));

        //recordId=recordId.replaceAll(regex, "\t");

        recordId = recordId.replaceAll(" +([?:]) +", "\t");

        // System.out.println(recordId);

        String[] split = recordId.split("\t");

        for (String s : split) {

            System.out.println("each");

            System.out.println(s);

        }

    }

    @org.junit.Test

    public void testType()

    {

        String id = "<http://dblp.l3s.de/d2r/resource/publications/journals/ijdsn/DanZYY13>";

        String[] s = id.split("/");

        System.out.println(s[5]);

    }

    @org.junit.Test

    public void writeToRedis() throws Exception {

        RedisURI redisUri = RedisURI.Builder.redis("83.212.110.197").withPort(6379).build();

        RedisClusterClient clusterClient = RedisClusterClient.create(redisUri);

        RedisAdvancedClusterConnection<String, String> connection = clusterClient.connectCluster();

        connection.set("a", "b");

    }

}