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.JSONObject;

import org.json.simple.parser.JSONParser;

import org.json.simple.parser.ParseException;

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();

    @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("/", "\\/"))));

                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);

    }

    public void testrecods() {

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

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

        // System.out.println(recordId);

        for (String s : split) {

            System.out.println(s);

        }

    }

    public void testType()

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

    }

    public void writeToRedis() throws Exception {

        RedisClusterClient clusterClient = RedisClusterClient.create(redisUri);

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