D-Net

package eu.dnetlib.resolver.mdstore.plugin;

import com.mongodb.MongoClient;

import com.mongodb.client.MongoCollection;

import eu.dnetlib.dli.collector.plugin.ScholixFromFSCollectorPlugin;

import eu.dnetlib.resolver.ConfigurationTestConfig;

import eu.dnetlib.resolver.DLIAbstractTest;

import eu.dnetlib.rmi.data.CollectorServiceException;

import eu.dnetlib.rmi.data.InterfaceDescriptor;

import org.bson.Document;

import org.junit.Ignore;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.test.context.ContextConfiguration;

import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import java.util.Iterator;

@Ignore

@RunWith(SpringJUnit4ClassRunner.class)

@ContextConfiguration(classes = { ConfigurationTestConfig.class })

public class DLIMergeRecordTest extends DLIAbstractTest {

    @Autowired

    private ScholixFromFSCollectorPlugin plugin = new ScholixFromFSCollectorPlugin();

    @Test

    public void testMergingRecord() throws CollectorServiceException {

        final InterfaceDescriptor interfaceDescriptor = new InterfaceDescriptor();

        interfaceDescriptor.setBaseUrl("/var/lib/dli/elsevier");

        int len =0;

        int cnt =0 ;

        Iterator<String> iterator = plugin.collect(interfaceDescriptor, null, null).iterator();

        System.out.println(iterator.next());

        while (iterator.hasNext())

        {

            cnt ++;

            iterator.next();

        }

//        String next = iterator.next();

//        System.out.println(next);

//        for (String item : plugin.collect(interfaceDescriptor,null,null)) {

//            len = item.length();

//            if (cnt++ % 100 == 0) {

////                System.out.println(item);

//                System.out.println("Parsed "+cnt);

//            }

//        }

        System.out.println("total "+cnt);

    }

}