svn commit: r1452378 - in /camel/trunk/components/camel-solr/src/test/java/org/apache/camel/component/solr: SolrComponentTestSupport.java SolrDeleteTest.java

[boday]

Author: boday
Date: Mon Mar  4 16:39:08 2013
New Revision: 1452378

URL: http://svn.apache.org/r1452378
Log:
added a camel-solr unit tests to show how a List/split() can be used…

Modified:
    
camel/trunk/components/camel-solr/src/test/java/org/apache/camel/component/solr/SolrComponentTestSupport.java
    
camel/trunk/components/camel-solr/src/test/java/org/apache/camel/component/solr/SolrDeleteTest.java

Modified: 
camel/trunk/components/camel-solr/src/test/java/org/apache/camel/component/solr/SolrComponentTestSupport.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-solr/src/test/java/org/apache/camel/component/solr/SolrComponentTestSupport.java?rev=1452378&r1=1452377&r2=1452378&view=diff
==============================================================================
--- 
camel/trunk/components/camel-solr/src/test/java/org/apache/camel/component/solr/SolrComponentTestSupport.java
 (original)
+++ 
camel/trunk/components/camel-solr/src/test/java/org/apache/camel/component/solr/SolrComponentTestSupport.java
 Mon Mar  4 16:39:08 2013
@@ -35,14 +35,19 @@ public class SolrComponentTestSupport ex
     public static final int PORT = AvailablePortFinder.getNextAvailable(8899);
     public static final String SOLR_ROUTE_URI = "solr://localhost:" + PORT + 
"/solr";
 
-    protected static final String TEST_ID = "1234";
+    protected static final String TEST_ID = "test1";
+    protected static final String TEST_ID2 = "test2";
     protected static JettySolrRunner solrRunner;
     protected static HttpSolrServer solrServer;
 
     protected void solrInsertTestEntry() {
+        solrInsertTestEntry(TEST_ID);
+    }
+
+    protected void solrInsertTestEntry(String id) {
         Map<String, Object> headers = new HashMap<String, Object>();
         headers.put(SolrConstants.OPERATION, SolrConstants.OPERATION_INSERT);
-        headers.put("SolrField.id", TEST_ID);
+        headers.put("SolrField.id", id);
         template.sendBodyAndHeaders("direct:start", null, headers);
     }
 
@@ -83,6 +88,12 @@ public class SolrComponentTestSupport ex
             @Override
             public void configure() throws Exception {
                 from("direct:start").to(SOLR_ROUTE_URI);
+                from("direct:splitThenCommit")
+                    .split(body())
+                        .to(SOLR_ROUTE_URI)
+                    .end()
+                    .setHeader(SolrConstants.OPERATION, 
constant(SolrConstants.OPERATION_COMMIT))
+                    .to(SOLR_ROUTE_URI);
             }
         };
     }

Modified: 
camel/trunk/components/camel-solr/src/test/java/org/apache/camel/component/solr/SolrDeleteTest.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-solr/src/test/java/org/apache/camel/component/solr/SolrDeleteTest.java?rev=1452378&r1=1452377&r2=1452378&view=diff
==============================================================================
--- 
camel/trunk/components/camel-solr/src/test/java/org/apache/camel/component/solr/SolrDeleteTest.java
 (original)
+++ 
camel/trunk/components/camel-solr/src/test/java/org/apache/camel/component/solr/SolrDeleteTest.java
 Mon Mar  4 16:39:08 2013
@@ -16,6 +16,7 @@
  */
 package org.apache.camel.component.solr;
 
+import java.util.*;
 import org.junit.Test;
 
 public class SolrDeleteTest extends SolrComponentTestSupport {
@@ -37,18 +38,35 @@ public class SolrDeleteTest extends Solr
     }
 
     @Test
+    public void testDeleteListOfIDs() throws Exception {
+
+        //insert, commit and verify
+        solrInsertTestEntry(TEST_ID);
+        solrInsertTestEntry(TEST_ID2);
+        solrCommit();
+        assertEquals("wrong number of entries found", 2, 
executeSolrQuery("id:test*").getResults().getNumFound());
+
+        //delete
+        template.sendBodyAndHeader("direct:splitThenCommit", 
Arrays.asList(TEST_ID, TEST_ID2), SolrConstants.OPERATION, 
SolrConstants.OPERATION_DELETE_BY_ID);
+
+        //verify
+        assertEquals("wrong number of entries found", 0, 
executeSolrQuery("id:test*").getResults().getNumFound());
+    }
+
+    @Test
     public void testDeleteByQuery() throws Exception {
 
         //insert, commit and verify
-        solrInsertTestEntry();
+        solrInsertTestEntry(TEST_ID);
+        solrInsertTestEntry(TEST_ID2);
         solrCommit();
-        assertEquals("wrong number of entries found", 1, 
executeSolrQuery("id:" + TEST_ID).getResults().getNumFound());
+        assertEquals("wrong number of entries found", 2, 
executeSolrQuery("id:test*").getResults().getNumFound());
 
         //delete
-        template.sendBodyAndHeader("direct:start", "id:" + TEST_ID, 
SolrConstants.OPERATION, SolrConstants.OPERATION_DELETE_BY_QUERY);
+        template.sendBodyAndHeader("direct:start", "id:test*", 
SolrConstants.OPERATION, SolrConstants.OPERATION_DELETE_BY_QUERY);
         solrCommit();
 
         //verify
-        assertEquals("wrong number of entries found", 0, 
executeSolrQuery("id:" + TEST_ID).getResults().getNumFound());
+        assertEquals("wrong number of entries found", 0, 
executeSolrQuery("id:test*").getResults().getNumFound());
     }
 }