Metacat

import static org.junit.Assert.assertTrue;

import edu.ucsb.nceas.metacat.common.SolrServerFactory;

import java.io.StringWriter;

import java.io.Writer;

import java.util.ArrayList;

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

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

       //List<String> chain = null;

       Identifier pid = new Identifier();

       pid.setValue(id);

       String result = doQuery(solrIndex.getSolrServer());

       List<String> ids = solrIndex.getSolrIds();

       //assertTrue(ids.size() == 1);

    public void testUpdate() throws Exception {

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

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

       /*obsoletes.add(id);

       obsoletes.add("tao");*/

       Identifier pid = new Identifier();

       pid.setValue(newId);

       String result = doQuery(solrIndex.getSolrServer());

       assertTrue(result.contains("version1"));

       assertTrue(result.contains("version2"));

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

       assertTrue(obsoletedSystemMetadata.getIdentifier().getValue().equals(obsoletedPid.getValue()));

       obsoletedSystemMetadata.setObsoletedBy(pid);

       // old version should be marked as obsoleted and not returned

       result = doQuery(solrIndex.getSolrServer(), "&fq=-obsoletedBy:*");

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

       //System metadata's archive is true.

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

       /*ArrayList<String> obsoletes = new ArrayList<String>();

       obsoletes.add(id);

       obsoletes.add("tao");*/

       Identifier pid = new Identifier();

       pid.setValue(newId);

       String result = doQuery(solrIndex.getSolrServer());

       assertTrue(result.contains("version1"));

       assertTrue(!result.contains("version2"));

    public void testDynamicFields() throws Exception {

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

       Identifier pid = new Identifier();

       pid.setValue(id);

       String result = doQuery(solrIndex.getSolrServer());

       List<String> ids = solrIndex.getSolrIds();

       boolean foundId = false;

    public void testOpenAnnotation() throws Exception {

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

       Identifier pid = new Identifier();

       pid.setValue(id);

       String result = doQuery(solrIndex.getSolrServer());

       List<String> ids = solrIndex.getSolrIds();

       boolean foundId = false;

       // augment with the dynamic field

       SystemMetadata annotationSystemMetadata = TypeMarshaller.unmarshalTypeFromFile(SystemMetadata.class, ANNOTATION_SYSTEM_META_FILE_PATH);

       Identifier annotationPid = new Identifier();

       annotationPid.setValue(annotation_id);

       String annotationResult = doQuery(solrIndex.getSolrServer(), "&fq=standard_sm:\"http://ecoinformatics.org/oboe/oboe.1.0/oboe-standards.owl#Gram\"");

       assertTrue(annotationResult.contains(pid.getValue()));

       assertTrue(annotationResult.contains("http://ecoinformatics.org/oboe/oboe.1.0/oboe-standards.owl#Gram"));

import java.io.FileNotFoundException;

import java.io.IOException;

import java.io.InputStream;

import java.util.ArrayList;

import java.util.Calendar;

import java.util.Date;

     * @throws NotFound 

     * @throws NotImplemented 

     */

                    throws IOException, SAXException, ParserConfigurationException,

                    XPathExpressionException, JiBXException, EncoderException, SolrServerException, NotImplemented, NotFound, UnsupportedType{

                                // metadata document.

                                // note that resource map processing touches all objects

                                // referenced by the resource map.

                                Document docObject = generateXmlDocument(dataStream);

                                if (docObject == null) {

                                    throw new Exception("Could not load OBJECT for ID " + id );

     * @param data

     * @throws SolrServerException

     */

        if(pid == null || pid.getValue() == null || pid.getValue().trim().equals("")) {

            throw new SolrServerException("The identifier of the indexed document should not be null or blank.");

        }

        if(systemMetadata == null) {

            throw new SolrServerException("The system metadata of the indexed document "+pid.getValue()+ " should not be null.");

        }

            throw new SolrServerException("The indexed document itself for pid "+pid.getValue()+" should not be null.");

        }

    }

     * Insert the indexes for a document.

     * @param pid  the id of this document

     * @param systemMetadata  the system metadata associated with the data object

     * @throws SolrServerException 

     * @throws JiBXException 

     * @throws EncoderException 

     * @throws NotFound 

     * @throws NotImplemented 

     */

                    throws IOException, SAXException, ParserConfigurationException,

                    XPathExpressionException, SolrServerException, JiBXException, EncoderException, NotImplemented, NotFound, UnsupportedType {

        //transform the Map to the SolrInputDocument which can be used by the solr server

        if(docs != null) {

     */

    public void update(Identifier pid, SystemMetadata systemMetadata) {

        String objectPath = null;

        try {

            objectPath = DistributedMapsFactory.getObjectPathMap().get(pid);

            EventlogFactory.createIndexEventLog().remove(pid);

        } catch (Exception e) {

            String error = "SolrIndex.update - could not update the solr index since " + e.getMessage();

     * @throws JiBXException

     * @throws EncoderException

     */

                                ServiceFailure, XPathExpressionException, NotImplemented, NotFound, UnsupportedType, 

                                IOException, SAXException, ParserConfigurationException, OREParserException, JiBXException, EncoderException {

        boolean isArchive = systemMetadata.getArchived() != null && systemMetadata.getArchived();

        if(isArchive ) {

            //delete the index for the archived objects

            log.info("SolrIndex.update============================= archive the idex for the identifier "+pid);

        } else {

            //generate index for either add or update.

            log.info("SolrIndex.update============================= insert index for the identifier "+pid);

        }

    }