/ - Diff - Metacat - Ecoinformatics Redmine

            InputStream emlInputStream = new FileInputStream(new File(EMLFILEPATH));
            solrIndex.insert(id, systemMetadata, emlInputStream);
            String result = doQuery(solrIndex.getSolrServer());
            List<String> ids = solrIndex.getSolrIds();
            assertTrue(ids.size() == 1);
            for(String identifiers :ids) {
                assertTrue(id.equals(identifiers));
+           }
            assertTrue(result.contains("version1"));
+        }

     import org.apache.commons.io.output.ByteArrayOutputStream;
     import org.apache.commons.logging.Log;
     import org.apache.commons.logging.LogFactory;
     import org.apache.solr.client.solrj.SolrQuery;
     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.client.solrj.response.UpdateResponse;
     import org.apache.solr.common.SolrDocument;
     import org.apache.solr.common.SolrDocumentList;
     import org.apache.solr.common.SolrInputDocument;
     import org.apache.solr.common.util.NamedList;
     import org.dataone.cn.indexer.XMLNamespaceConfig;
     import org.dataone.cn.indexer.parser.IDocumentSubprocessor;
     import org.dataone.cn.indexer.parser.SolrField;
-...
     import org.dataone.service.util.TypeMarshaller;
     import org.jibx.runtime.JiBXException;
     import org.w3c.dom.Document;
     import org.w3c.dom.NameList;
     import org.xml.sax.SAXException;
     /**
-...
      */
     public class SolrIndex {
         public static final String ID = "id";
         private static final String IDQUERY = ID+":*";
         private List<IDocumentSubprocessor> subprocessors = null;
         private SolrServer solrServer = null;
         private XMLNamespaceConfig xmlNamespaceConfig = null;
-...
          * Get the solrServer
          * @return
          */
         SolrServer getSolrServer() {
         public SolrServer getSolrServer() {
             return solrServer;
+        }
         /**
          * Set the solrServer. This method is only for setting a test solr server in the junit test.
          * Set the solrServer.
          * @param solrServer
          */
         void setSolrServer(SolrServer solrServer) {
         public void setSolrServer(SolrServer solrServer) {
             this.solrServer = solrServer;
+        }
         /**
          * Get all indexed ids in the solr server.
          * @return
          * @throws SolrServerException
          */
         public List<String> getSolrIds() throws SolrServerException {
             List<String> list = new ArrayList<String>();
             SolrQuery query = new SolrQuery(IDQUERY);
             query.setRows(Integer.MAX_VALUE);
             query.setFields(ID);
             QueryResponse response = solrServer.query(query);
             SolrDocumentList docs = response.getResults();
             if(docs != null) {
                 for(SolrDocument doc :docs) {
                     String identifier = (String)doc.getFieldValue(ID);
                     //System.out.println("======================== "+identifier);
                     list.add(identifier);
+                }
+            }
             return list;
+        }
+    }

+            }
             return obsoletes;
+        }
         /**
          * Get an InputStream as the data object for the specific pid.
          * @param pid
          * @return
          * @throws FileNotFoundException
          */
         public InputStream getDataObject(String pid) throws FileNotFoundException {
             String objectPath = objectPathMap.get(pid);
             InputStream data = null;
             data = new FileInputStream(objectPath);
             return data;
+        }
     	public void entryAdded(EntryEvent<Identifier, SystemMetadata> entryEvent) {
     		// use the same implementation for insert/update for now
     		this.entryUpdated(entryEvent);

Project

General

Profile

Metacat

Revision 7604

Added by Jing Tao over 11 years ago