Implementation of SearchService.

git-svn-id: https://svn.apache.org/repos/asf/lucene/java/trunk@150768 13f79535-47bb-0310-9956-ffa450edef68

sandbox/contributions/fulcrum/LuceneSearchService.java

@@ -0,0 +1,188 @@
+import org.apache.fulcrum.InitializationException;
+import org.apache.fulcrum.ServiceException;
+import org.apache.log4j.Category;
+import org.apache.lucene.analysis.Analyzer;
+import org.apache.lucene.analysis.standard.StandardAnalyzer;
+import org.apache.lucene.search.*;
+
+import search.SearchIndexer;
+
+import java.io.IOException;
+
+/**
+ * Implementation of {@link SearchService}.
+ * <p>
+ * <b>Note that this implementation uses code from
+ * /projects/appex/search.</b>
+ * </p>
+ */
+public class LuceneSearchService
+        extends org.apache.fulcrum.BaseService implements SearchService
+{
+    /**
+     * Log4j category.
+     */
+    private static Category cat = Category.getInstance(LuceneSearchService.class);
+
+    /**
+     * The analyzer used for searching and indexing. Analyzers have no
+     * state so its ok to return the same analyzer to clients.
+     */
+    private Analyzer analyzer;
+
+    /**
+     * Is the index locked?
+     */
+    private boolean indexLocked = false;
+
+    /**
+     * Filesystem location of the index.
+     */
+    private String searchIndexLocation;
+
+    public void init() throws InitializationException
+    {
+        searchIndexLocation = getConfiguration().getString(
+                SearchService.INDEX_LOCATION_KEY);
+        setInit(true);
+    }
+
+    public SearchResults search(Query query) throws ServiceException
+    {
+        return search(query, null);
+    }
+
+    public SearchResults search(Query query, Filter filter) throws ServiceException
+    {
+        Searcher searcher = null;
+        SearchResults results = null;
+        try
+        {
+            searcher = new IndexSearcher(searchIndexLocation);
+            Hits hits = searcher.search(query, filter);
+            results = new SearchResults(hits);
+        }
+        catch (IOException ioe)
+        {
+            throw new ServiceException("Error encountered searching!", ioe);
+        }
+        finally
+        {
+            try
+            {
+                if (searcher != null)
+                    searcher.close();
+            }
+            catch (IOException ioe)
+            {
+                throw new ServiceException("Error encountered searching!", ioe);
+            }
+            return results;
+        }
+    }
+
+    public SearchResults search(Query query, Filter filter,
+                                int from, int to) throws ServiceException
+    {
+        Searcher searcher = null;
+        SearchResults results = null;
+        try
+        {
+            searcher = new IndexSearcher(searchIndexLocation);
+            Hits hits = searcher.search(query, filter);
+            results = new SearchResults(hits, from, to);
+        }
+        catch (IOException ioe)
+        {
+            throw new ServiceException("Error encountered searching!", ioe);
+        }
+        finally
+        {
+            try
+            {
+                if (searcher != null)
+                    searcher.close();
+            }
+            catch (IOException ioe)
+            {
+                throw new ServiceException("Error encountered searching!", ioe);
+            }
+            return results;
+        }
+    }
+
+    public void batchIndex() throws ServiceException
+    {
+        try
+        {
+            acquireIndexLock();
+            new IndexerThread(new SearchIndexer());
+        }
+        catch (IOException ioe)
+        {
+            throw new ServiceException("Error encountered indexing!", ioe);
+        }
+        catch (InterruptedException ie)
+        {
+            throw new ServiceException("Error encountered indexing!", ie);
+        }
+    }
+
+    public boolean isIndexing()
+    {
+        return IndexerThread.isIndexing || indexLocked;
+    }
+
+    public Analyzer getAnalyzer()
+    {
+        if (analyzer == null)
+        {
+            analyzer = new StandardAnalyzer();
+        }
+        return analyzer;
+    }
+
+    private void acquireIndexLock() throws InterruptedException
+    {
+        while (isIndexing())
+        {
+            wait(500);
+        }
+    }
+}
+
+class IndexerThread extends Thread
+{
+    protected static boolean isIndexing = false;
+    private static Category cat = Category.getInstance(IndexerThread.class);
+
+    private SearchIndexer indexer;
+
+    public IndexerThread()
+    {
+        super();
+    }
+
+    public IndexerThread(SearchIndexer indexer)
+    {
+        isIndexing = true;
+        this.indexer = indexer;
+        start();
+    }
+
+    public void run()
+    {
+        try
+        {
+            indexer.index();
+        }
+        catch (Exception e)
+        {
+            cat.error("Error indexing: " + e.getMessage(), e);
+        }
+        finally
+        {
+            isIndexing = false;
+        }
+    }
+}