D-Net

    }

    private boolean validateByType(OpenaireEntity entity,String type , String claimId ){

        //TODO add more types (e.g. patends) when they are available

            return validateResult((Result)entity,claimId);

        } else if(type.equals(ClaimUtils.CONTEXT)){

            return validateContext((Context)entity,claimId);

import eu.dnetlib.data.claims.migration.entity.*;

import eu.dnetlib.data.claims.migration.handler.*;

import eu.dnetlib.data.claimsDemo.ClaimUtils;

import eu.dnetlib.data.claimsDemo.SQLStoreException;

import org.apache.log4j.BasicConfigurator;

import org.springframework.context.ApplicationContext;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import org.springframework.context.support.PropertySourcesPlaceholderConfigurer;

import java.io.*;

import java.math.BigInteger;

import java.security.MessageDigest;

                        contexts++;

                    }

                }

            }catch (Exception e){

                e.printStackTrace();

                }else if(claim.getSourceType().equals(ClaimUtils.CONTEXT)){

                    contexts++;

                }

            }

                    System.out.println("Error fetching result from Openaire");

                }

            }

            if (result != null) {

                try {

                    PrintWriter out = new PrintWriter(new BufferedWriter(new FileWriter(claimValidation.getPathToSaveReport()+"dedup_results_found.txt", true)));

//            migration.createAndSaveRelationsClaims(true);

//            migration.createAndSaveContextRelationClaims(true);

            migration.createAndSaveRelationsClaims(true);

            migration.createAndSaveContextRelationClaims(true);

        }

        return relations;

    }

        List<ContextRelation> relations = null;

        relations = new ArrayList<ContextRelation>();

        while(rs.next()) {

        rs.close();

        return id;

    }

    /**

     * Gets the main information for a claim relation - builds a claim object

     * exports metadata

            }

            return project;

            ExternalRecordHandler externalRecordHandler = new ExternalRecordHandler();

            if(collectedFrom == null){

                return null;

                    result = indexResultHandler.fetchDatasetById(id,useProductionIndex);

                }else if(type.equals(ClaimUtils.SOFTWARE)){

                    result = indexResultHandler.fetchSoftwareById(id,useProductionIndex);

                }

                if(result == null){

                    logger.error("Record with id:"+id + " and type " + type + " couldn't be fetched from openaire.");

    private String fetchSoftwareResult(String id, boolean production) throws Exception {

        return  searchUtils.fetchSoftwareXmlFromIndex(id, production);

    }

    private String fetchDatasetResult(String id, boolean production) throws Exception {

        return searchUtils.fetchDatasetXmlFromIndex(id, production);

        }

        return OafParser.oaf2Result(oaf);

    }

//    public Result fetchDedupResultById(String id) throws Exception {

//

//        String oaf = fetchDedupPublicationResult(id);

        OpenaireEntity openaireEntity = null;

        if(type == null){

            openaireEntity = null;

            openaireEntity= buildResult(rs, index);

        }else if(type.equals(ClaimUtils.PROJECT)){

            openaireEntity = buildProject(rs,index);

    public static final String  PUBLICATION = "publication";

    public static final String  DATASET = "dataset";

    public static final String  SOFTWARE = "software";

    public static final String  PROJECT = "project";

    public static final String  CONTEXT = "context";

         return xml;

    }

    /**

     *Look up in API, if there is no result,

     * consider that id is a dedup id and search for the objIdentifier id.

        return ((production)?apiUrlForResultsProduction:apiUrlForResults)+"/publications?openairePublicationID="+id;

    }

    public static String  getSoftwareApiUrl(String id, boolean production)  {

        return ((production)?apiUrlForResultsProduction:apiUrlForResults)+"/software?openaireSoftwareID="+id;

    }

//    public static String getDedupPublicationApiUrl(String id)  {

//

//        return apiUrlForDedupResults+"/publications?openairePublicationID="+id;

import eu.dnetlib.data.claims.migration.entity.*;

import java.lang.reflect.Array;

import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.Date;

    /**

  ** Insert Queries **

  **/

    private String generateInsertResultQuery(String openaire_id, String result_type, String title, String collected_from , String external_url, String doi, String orcidworkid, String access_rights , String embargo_end_date, String best_license, String record_path, String record_format, ArrayList<Object> params) {

        if(title!=null&&title.contains("'")){

            title=title.replace("'","''");

        if(type==null){

            return null;

        }

            Result result=(Result)openaireEntity;

            query=generateInsertResultQuery(result.getOpenaireId(),result.getResultType(),result.getTitle(),result.getCollectedFrom(),result.getExternalUrl(),result.getDoi(), result.getOrcidworkid(), result.getAccessRights(),result.getEmbargoEndDate(),result.getBestLicense(),result.getRecordPath(), result.getRecordFormat(), params);

        }else if(type.equals(ClaimUtils.PROJECT)){

//            semantics="resultResult_supplement_isSupplementTo";

//        }

        //add above more specific semantics for pub,data and software

            semantics="resultResult_relationship_isRelatedTo";

        }

            semantics= "resultProject_outcome_produces";  //"resultProject_outcome_isProducedBy";

        }

            semantics= "isRelevantTo";

        }

                "drop table if exists project;\n" +

                "drop table if exists result;\n" +

                "drop table if exists context;\n" +

                "\n ";

    }

                "CREATE TABLE has_target_result(\n" +

                "\tclaim_id int references claim(id) NOT NULL,\n" +

                "\topenaire_id varchar(60) references result(openaire_id) NOT NULL\n" +

                ");\n"

                ;

        logger.debug(types);

        if(types == null || types.isEmpty() || (types.size() == 1 && types.get(0).isEmpty())){

            return null;

            //it's all types - no need to filter

            return null;

        }

        ArrayList<Object> clauseParams = new ArrayList<>();

        clauseParams.add(claimId);

        String orderbyLimitClause= null;

            return generateSelectclaimQuery(sourceType,targetType,null,null,null,false, clause,clauseParams,keyword, params);

        }else if(sourceType.equals(ClaimUtils.PROJECT)){

            return generateSelectclaimQuery(sourceType,targetType,null,null,null,false, clause,clauseParams,keyword, params);

        String fields= null;

        if (type != null) {

                fields = getResultFields(tableAlias);

            } else if (type.equals(ClaimUtils.PROJECT)) {

            return "";

        }

        keyword=keyword.toLowerCase();

            params.add("%" + keyword + "%");

            params.add("%" + keyword + "%");

            return "  (lower("+tableAlias+".title) like ? or lower("+tableAlias+".doi) like ?"+")";

                " ( " +generateSelectclaimQuery(ClaimUtils.PUBLICATION,ClaimUtils.PUBLICATION,null,null,null,false, specificWhereClause,whereParams,keyword, params)+" ) \nunion "+

                " ( " +generateSelectclaimQuery(ClaimUtils.DATASET,ClaimUtils.DATASET,null,null,null,false, specificWhereClause, whereParams,keyword, params)+" ) \nunion "+

                " ( " +generateSelectclaimQuery(ClaimUtils.SOFTWARE,ClaimUtils.SOFTWARE,null,null,null,false, specificWhereClause, whereParams,keyword, params)+" ) \nunion "+

                " ( " +generateSelectclaimQuery(ClaimUtils.PROJECT,ClaimUtils.PUBLICATION, null,null,null,false, specificWhereClause, whereParams,keyword, params)+" ) \nunion "+

                " ( " +generateSelectclaimQuery(ClaimUtils.CONTEXT,ClaimUtils.PUBLICATION,null,null,null,false, specificWhereClause, whereParams, keyword, params)+" )" +

        if(type == null){

            return null;

        }

            return "result";

        }else{

            return type;

            return null;

        }

        String query = null;

            query = generateDeleteResultQuery(resultid,claimId, params);

        }else if(type.equals(ClaimUtils.PROJECT)){

            query = generateDeleteProjectQuery(resultid,claimId, params);

        <!--<property name="locations" value="classpath:eu/dnetlib/data/claims/migration/springContext-claimsDemo.properties"/>-->

    <!--</bean>-->

    <bean id="directIndexHandler" class="eu.dnetlib.data.claims.migration.handler.DirectIndexHandler">

    </bean>

    <bean id="fetchClaimHandler" class="eu.dnetlib.data.claims.migration.handler.FetchClaimHandler">

        <property name="sqlDAO" ref="sqlDao"/>

services.claimsDemo.db.driverClassName = org.postgresql.Driver

services.claimsDemo.db.username = postgres

services.claimsDemo.db.password = snowflakes

services.claimsDemo.directClaim.APIURL = http://beta.services.openaire.eu:8280/is/mvc/api/publications

services.claims.mail.angularUrl = http://duffy.di.uoa.gr:3000/claims-project-manager?token=

services.claims.mail.specialRecipients = invalid_recipient@email.com