博爱老头的草屋

1、CreateDataBase.java  
/** *@description 创建库文件 *@package com.mysearch *@author  李国庆 *@company  LEEMENZ *@version  1.0.0 *@discription * */ package com.mysearch; import java.io.File; import org.apache.lucene.analysis.standard.StandardAnalyzer; import org.apache.lucene.index.IndexWriter; /** * @author Administrator * */ public class CreateDataBase { public CreateDataBase() { } /**  *  * @param file  * @return  */ public int createDataBase(File file) {  int returnValue = 0;  if (!file.isDirectory()) {   file.mkdirs();  }  try {   IndexWriter indexWriter = new IndexWriter(file,     new StandardAnalyzer(), true);   indexWriter.close();   returnValue = 1;  } catch (Exception ex) {   ex.printStackTrace();  }  return returnValue; } /**  *传入检索库路径,初始化库  * @paramfile  * @return  */ public int createDataBase(String file) {  return this.createDataBase(new File(file)); } /*  *  *  */ public static void main(String[] args) {  CreateDataBase temp = new CreateDataBase();  if (temp.createDataBase("d:\\lucene\\holendb") == 1) {   System.out.println("db init succ");  } } } <a name="entrymore"></a> 2、InsertRecords 添加索引 /** *@description 添加索引 *@package com.mysearch *@author  李国庆 *@company  LEEMENZ *@version  1.0.0 *@discription * */ package com.mysearch; import java.io.File; import java.io.FileReader; import java.io.Reader; import org.apache.lucene.analysis.standard.StandardAnalyzer; import org.apache.lucene.document.Document; import org.apache.lucene.document.Field; import org.apache.lucene.index.IndexWriter; /** * @author Administrator * */ public class InsertRecords { public InsertRecords() { } /**  *  * @param dbpath 数据文件（INDEX）所在的路径  * @param file   文件名  * @return  */ public int insertRecords(String dbpath, File file) {  int returnValue = 0;  try {   IndexWriter indexWriter = new IndexWriter(dbpath,     new StandardAnalyzer(), false);   this.addFiles(indexWriter, file);   returnValue = 1;  } catch (Exception ex) {   ex.printStackTrace();  }  return returnValue; } /**  * 传入需加载的文件名  *  * @paramfile  dbpath   需加载的文件路径  * @return   file   需加载的文件名  */ public int insertRecords(String dbpath, String file) {  return this.insertRecords(dbpath, new File(file)); } /**  * 建立索引  * @param indexWriter  lucene内部对象，负责建立索引  * @param file         文件名  */ public void addFiles(IndexWriter indexWriter, File file) {  Document doc = new Document();  try {   doc.add(Field.Keyword("filename", file.getName()));   // 以下两句只能取一句,前者是索引不存储,后者是索引且存储   // doc.add(Field.Text("content",new FileReader(file)));   doc.add(Field.Text("content", this.chgFileToString(file)));   indexWriter.addDocument(doc);   indexWriter.close();  } catch (Exception ex) {   ex.printStackTrace();  } } /**  * 从文本文件中读取内容  *  * @param file  * @return string  */ public String chgFileToString(File file) {  String returnValue = null;  StringBuffer sb = new StringBuffer();  char[] c = new char[4096];  try {   Reader reader = new FileReader(file);   //以reader的形式读取文件   int n = 0;   while (true) {    n = reader.read(c);    if (n > 0) {     sb.append(c, 0, n);    } else {     break;    }   }   reader.close();    //关闭流  } catch (Exception ex) {   ex.printStackTrace();  }  returnValue = sb.toString();  return returnValue; } /**  *  执行插入数据操作  * @param args  */ public static void main(String[] args) {  InsertRecords temp = new InsertRecords();  String dbpath = "d:\\lucene\\holendb";  // holen1.txt中包含关键字"nationally"和"ggbm"  if (temp.insertRecords(dbpath, "d:\\lucene\\nationally1.txt") == 1) {   System.out.println("add file1 succ");  }  // holen2.txt中包含关键字"nationally"和"<a href="http://www.icnote.com" target="_blank" title="http://www.icnote.com" class="mykeyword">leo</a><img src="http://www.icnote.com/images/logo.gif" alt="leo" />"  if (temp.insertRecords(dbpath, "d:\\lucene\\nationally2.txt") == 1) {   System.out.println("add file2 succ");  }  // holenalsdjflasdlfj.txt 中不包括关键字"nationally"  if (temp.insertRecords(dbpath,    "d:\\lucene\\nationallynalsdjflasdlfj.txt") == 1) {   System.out.println("add file3 succ");  } } } 3、QueryRecords  测试查询 /** *@description 测试查询 *@package com.mysearch *@author  李国庆 *@company  LEEMENZ *@version  1.0.0 *@discription * */ package com.mysearch; import java.util.ArrayList; import org.apache.lucene.analysis.standard.StandardAnalyzer; import org.apache.lucene.document.Document; 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 org.apache.lucene.search.Searcher; /** * @author Administrator * */ public class QueryRecords { public QueryRecords(){    }        /**     *检索查询,将结果集返回     * @param searchkey     * @param dbpath     * @param searchfield     * @return ArrayList     */    public ArrayList queryRecords(String searchkey,String dbpath,String searchfield){       ArrayList list= null;       try{           Searcher searcher= new IndexSearcher(dbpath);           Query query = QueryParser.parse(searchkey,searchfield,new StandardAnalyzer());           Hits hits = searcher.search(query);           if(hits!= null){              list= new ArrayList();              int temp_hitslength=hits.length();              Document doc= null;              for(int i=0;i<temp_hitslength;i++){                  doc=hits.doc(i);                  list.add(doc.get("filename"));              }           }       }catch(Exception ex){           ex.printStackTrace();       }       return list;    }    /**     *     * @param args     */    public static void main(String[]args) {       QueryRecords temp= new QueryRecords();             ArrayList list= null;       list=temp.queryRecords("nationally","d:\\lucene\\holendb","content");       for(int i=0;i<list.size();i++){           System.out.println((String)list.get(i));       }    } }
然后在d:\lucene下建立3个文本文件，我的是holenalsdjflasdlfj.txt、holen1.txt、holen2.txt，在里面输入一些内容，有一个包含有"nationally"就可以了，这个就是我们要测试查询的字符串。
首先执行CreateDataBase.java（初始化库），然后InsertRecords.java（添加索引），最后QueryRecords.java（测试文件）
然后就可以看到正确的输出了。

：），就到这里，欢迎指正！！！！！！

作者：博爱老头@博爱老头的草屋
地址：http://www.icnote.com/post/14/
版权所有。转载时必须以链接形式注明作者和原始出处及本声明！