searcherimpl.java

Jaoso新闻文章发布系统 0.9.1final 程序架构: Struts+Spring+Hibernate 主要功能： ·新闻采用在线编辑器,可以象使用word一样编辑新闻,可简繁

package jaoso.framework.core.search.lucene;

import jaoso.framework.core.search.SearchUtil;
import jaoso.framework.core.search.Searcher;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.document.Document;
import org.apache.lucene.queryParser.MultiFieldQueryParser;
import org.apache.lucene.queryParser.ParseException;
import org.apache.lucene.queryParser.QueryParser;
import org.apache.lucene.search.Hits;
import org.apache.lucene.search.IndexSearcher;
import org.apache.lucene.search.Query;

import java.io.IOException;

import java.util.ArrayList;
import java.util.Collection;
import java.util.List;

/**
 * @author Quake Wang
 * @since 2004-5-21
 * @version $Revision: 1.5 $
 *  
 */
public class SearcherImpl implements Searcher {
	/** DOCUMENT ME! */
	private static final Log log = LogFactory.getLog(SearcherImpl.class);

	/** DOCUMENT ME! */
	private Analyzer analyzer;

	/** DOCUMENT ME! */
	private IndexStore indexStore;

	/** DOCUMENT ME! */
	private String[] defaultFields;

    public void setIndexStore(IndexStore indexStore) {
        this.indexStore = indexStore;
    }
	/**
	 * DOCUMENT ME!
	 * 
	 * @param analyzer
	 *            DOCUMENT ME!
	 */
	public void setAnalyzer(Analyzer analyzer) {
		this.analyzer = analyzer;
	}

	/**
	 * DOCUMENT ME!
	 * 
	 * @param strings
	 *            DOCUMENT ME!
	 */
	public void setDefaultFields(String[] strings) {
		defaultFields = strings;
	}

	/**
	 * DOCUMENT ME!
	 * 
	 * @param query
	 *            DOCUMENT ME!
	 * 
	 * @return DOCUMENT ME!
	 */
	public Collection search(String query) {
		return search(defaultFields, query);
	}

	/**
	 * DOCUMENT ME!
	 * 
	 * @param searchFields
	 *            DOCUMENT ME!
	 * @param query
	 *            DOCUMENT ME!
	 * 
	 * @return DOCUMENT ME!
	 */
	public Collection search(String[] searchFields, String query) {
		List result = new ArrayList();

		if ((query == null) || (query.trim().length() < 1)) {
			return result;
		}

		IndexSearcher searcher = null;

		try {
			searcher = indexStore.createSearcher();

			Query luceneQuery = null;

			if (searchFields.length == 1) {
				QueryParser qp = new QueryParser(searchFields[0], analyzer);
				luceneQuery = qp.parse(query);
			} else {
				luceneQuery = MultiFieldQueryParser.parse(query, searchFields,
						analyzer);
			}

			Hits hits = searcher.search(luceneQuery);

			for (int i = 0; i < hits.length(); i++) {
				Document doc = hits.doc(i);
				result.add(doc.get(SearchUtil.IDENTIFIER));
			}
		} catch (IOException ioe) {
			log.error(ioe);
		} catch (ParseException pe) {
			log.error(pe);
		} finally {
			if (searcher != null) {
				try {
					searcher.close();
				} catch (IOException ioe) {
					log.warn(ioe);
				}
			}
		}

		return result;
	}
}