Metacat

package edu.ucsb.nceas.metacat.index;

import static org.junit.Assert.assertEquals;

import static org.junit.Assert.assertTrue;

import java.io.File;

import java.io.FileInputStream;

import java.io.InputStream;

import java.util.List;

import org.apache.solr.client.solrj.SolrServer;

import org.apache.solr.client.solrj.SolrServerException;

import org.apache.solr.client.solrj.response.QueryResponse;

import org.apache.solr.common.SolrDocument;

import org.apache.solr.common.SolrDocumentList;

import org.apache.solr.common.params.SolrParams;

import org.apache.solr.servlet.SolrRequestParsers;

import org.dataone.configuration.Settings;

import org.dataone.service.types.v1.SystemMetadata;

import org.dataone.service.util.TypeMarshaller;

import org.junit.Test;

public class SolrIndexTest {

    private static final String SYSTEMMETAFILEPATH = "src/test/resources/eml-system-meta-example.xml";

    private static final String EMLFILEPATH = "src/test/resources/eml-example.xml";

    private static final String id = "urn:uuid:606a19dd-b531-4bf4-b5a5-6d06c3d39098";

    /**

     * Test building index for an insert.

     */

    @Test

    public void testInsert() throws Exception {

       SolrIndex solrIndex = generateSolrIndex();

       //InputStream systemInputStream = new FileInputStream(new File(SYSTEMMETAFILEPATH));

       SystemMetadata systemMetadata = TypeMarshaller.unmarshalTypeFromFile(SystemMetadata.class, SYSTEMMETAFILEPATH);

       InputStream emlInputStream = new FileInputStream(new File(EMLFILEPATH));    

       solrIndex.insert(id, systemMetadata, emlInputStream);

       doQuery(solrIndex.getSolrServer());

    }

    /**

     * Test building index for an insert.

     */

    @Test

    public void testDelete() throws Exception {

       //SolrIndex solrIndex = generateSolrIndex();

       //solrIndex.remove(id);

    }

    private SolrIndex generateSolrIndex() throws Exception {

        Settings.getConfiguration().setProperty("dataone.hazelcast.configFilePath", ApplicationControllerTest.pathToHazelcastFile);

        ApplicationController controller = new ApplicationController();

        List<SolrIndex> list = controller.getSolrIndexes();

        SolrIndex[] solrIndexesarray = list.toArray(new SolrIndex[list.size()]);

        SolrIndex index = solrIndexesarray[0];

        return index;

    }

    /*

     * Do query

     */

    private void doQuery(SolrServer server)

                    throws SolrServerException {

                StringBuffer request = new StringBuffer();

                request.append("q=" + "*:*");

                SolrParams solrParams = SolrRequestParsers.parseQueryString(request

                        .toString());

                QueryResponse reponse = server.query(solrParams);

                System.out.println(reponse.toString());

    }

    /*

     * Print out the QueryResponse

     */

    private void print(QueryResponse response) {

        SolrDocumentList docs = response.getResults();

        if (docs != null) {

            System.out.println(docs.getNumFound() + " documents found, "

                    + docs.size() + " returned : ");

            for (int i = 0; i < docs.size(); i++) {

                SolrDocument doc = docs.get(i);

                System.out.println("\t" + doc.toString());

            }

        }

    }

}