Metacat

import java.io.InputStream;

import java.io.StringWriter;

import java.io.Writer;

import java.util.ArrayList;

import java.util.Collections;

import java.util.Date;

import org.dataone.cn.indexer.resourcemap.ResourceMap;

import org.dataone.cn.indexer.solrhttp.SolrDoc;

import org.dataone.cn.indexer.solrhttp.SolrElementField;

import org.w3c.dom.Document;

import org.w3c.dom.Element;

import org.w3c.dom.NodeList;

import edu.ucsb.nceas.metacat.common.query.SolrQueryResponseTransformer;

import edu.ucsb.nceas.metacat.common.query.SolrQueryResponseWriterFactory;

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

import edu.ucsb.nceas.metacat.index.SolrIndex;

    @Override

    public Map<String, SolrDoc> processDocument(String identifier, Map<String, SolrDoc> docs,

    Document doc) throws IOException, EncoderException, SAXException,

        SolrDoc resourceMapDoc = docs.get(identifier);

        List<SolrDoc> processedDocs = processResourceMap(resourceMapDoc, doc);

        Map<String, SolrDoc> processedDocsMap = new HashMap<String, SolrDoc>();

    }

    private List<SolrDoc> processResourceMap(SolrDoc indexDocument, Document resourceMapDocument)

        ResourceMap resourceMap = new ResourceMap(resourceMapDocument);

        List<String> documentIds = resourceMap.getAllDocumentIDs();

        //List<SolrDoc> updateDocuments = getHttpService().getDocuments(getSolrQueryUri(), documentIds);

    /*

     * Get the SolrDoc list for the list of the ids.

     */

        List<SolrDoc> list = new ArrayList<SolrDoc>();

        if(ids != null) {

            for(String id : ids) {

    /*

     * Get the SolrDoc for the specified id 

     */

        SolrDoc solrDoc = null;

        if(solrServer != null) {

           String query = QUERY+"\""+id+"\"";

           SolrParams solrParams = SolrRequestParsers.parseQueryString(query);

           solrDoc = transformQueryResponseToSolrDoc(solrParams, response);

           /*if(solrDoc != null) {

     * @param reponse

     * @return

     */

        SolrDoc solrDoc = null;

        if(response != null) {

            DocumentBuilderFactory dbFactory = DocumentBuilderFactory.newInstance();

            DocumentBuilder dBuilder = dbFactory.newDocumentBuilder();

            solrDoc = parseResults(doc);

        }

        return solrDoc;

    /*

     * Parse the query result document. This method only choose the first one from a list.

     */

        SolrDoc solrDoc = null;

        NodeList nodeList = (NodeList) XPathFactory.newInstance().newXPath()

                .evaluate("/response/result/doc", document, XPathConstants.NODESET);

    /*

     * Parse an element

     */

        SolrDoc doc = new SolrDoc();

        doc.LoadFromElement(docElement, validSolrFieldNames);

        return doc;

     * Get the valid schema fields from the solr server.

     * @return

     */

        List<String> validSolrFieldNames = new ArrayList<String>();

        IndexSchema schema = solrCore.getSchema();

        Map<String, SchemaField> fieldMap = schema.getFields();

        }

        //System.out.println("the valid file name is\n"+validSolrFieldNames);

        return validSolrFieldNames;

}

import org.dataone.cn.indexer.parser.SolrField;

import org.dataone.cn.indexer.solrhttp.SolrDoc;

import org.dataone.cn.indexer.solrhttp.SolrElementField;

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

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

import org.dataone.service.util.TypeMarshaller;

     * @throws JiBXException 

     * @throws SolrServerException 

     * @throws EncoderException

     */

    private Map<String, SolrDoc> process(String id, SystemMetadata systemMetadata, InputStream dataStream)

                    throws IOException, SAXException, ParserConfigurationException,

        // Load the System Metadata document

        ByteArrayOutputStream systemMetadataOutputStream = new ByteArrayOutputStream();

     * @throws SAXException 

     * @throws ParserConfigurationException 

     * @throws SolrServerException 

     */

    // TODO:combine merge function with resourcemap merge function

    private SolrDoc mergeWithIndexedDocument(SolrDoc indexDocument) throws IOException,

        List<String> ids = new ArrayList<String>();

        ids.add(indexDocument.getIdentifier());

        List<SolrDoc> indexedDocuments = ResourceMapSubprocessor.getSolrDocs(ids);

     * @throws SolrServerException 

     * @throws JiBXException 

     * @throws EncoderException 

     */

    private synchronized void insert(String pid, SystemMetadata systemMetadata, InputStream data) 

                    throws IOException, SAXException, ParserConfigurationException,

        checkParams(pid, systemMetadata, data);

        Map<String, SolrDoc> docs = process(pid, systemMetadata, data);

     * @throws SolrServerException 

     * @throws JiBXException 

     * @throws EncoderException 

     */

    public void update(String pid, List<String> obsoleteIds, SystemMetadata systemMetadata, InputStream data) 

                    throws IOException, SAXException, ParserConfigurationException,

        checkParams(pid, systemMetadata, data);

        boolean isArchive = systemMetadata.getArchived();

        if(isArchive) {