读书人

Lucene小练3索引删除恢复更新

发布时间: 2012-09-22 21:54:54 作者: rapoo

Lucene小练三——索引删除,恢复,更新

package org.se.lucene;//主类import java.io.File;import java.io.IOException;import org.apache.lucene.analysis.standard.StandardAnalyzer;import org.apache.lucene.document.Document;import org.apache.lucene.document.Field;import org.apache.lucene.index.CorruptIndexException;import org.apache.lucene.index.IndexReader;import org.apache.lucene.index.IndexWriter;import org.apache.lucene.index.IndexWriterConfig;import org.apache.lucene.index.Term;import org.apache.lucene.store.Directory;import org.apache.lucene.store.FSDirectory;import org.apache.lucene.store.LockObtainFailedException;import org.apache.lucene.util.Version;public class lucene_index {private String[] ids={"1","2","3","4","5","6"};private String[] emails={"aa@aa.org","cc@cc.org","dd@@dd.org","bb@bb.org","ee@ee.org","ff@ff.org"};private String[] contents={"welcometotyu","hellowboy","higirl","howareyou","googluck","badgosh"};private int[] attachs={1,2,3,4,5,6};private String[] names={"liwu","zhangsan","xiaoqinag","laona","dabao","lisi"};private Directory directory=null;public lucene_index(){try {directory=FSDirectory.open(new File("f:/lucene/index02"));} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}}public void quary(){try {IndexReader reader=IndexReader.open(directory);System.out.println("numdocs"+reader.numDocs());System.out.println("maxDocs"+reader.maxDoc());System.out.println("detelemaxDocs"+reader.numDeletedDocs());reader.close();} catch (CorruptIndexException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (IOException e) {// TODO Auto-generated catch block e.printStackTrace();}}@SuppressWarnings("deprecation")public void undelete(){try {//回复时必须把reader的只读设为falseIndexReader reader=IndexReader.open(directory,false);reader.undeleteAll();reader.close();} catch (CorruptIndexException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}}//清空回收站,强制优化public void forceDelete(){IndexWriter writer=null;try {writer=new IndexWriter(directory, new IndexWriterConfig(Version.LUCENE_36,new StandardAnalyzer(Version.LUCENE_36)));//参数十一个选项,可以是一个query,也可以是一个term  term就是一个精确查找的值//此时删除的文档并未完全删除,而是存储在回收站中,可以恢复的writer.forceMergeDeletes();} catch (CorruptIndexException e) {e.printStackTrace();} catch (LockObtainFailedException e) {e.printStackTrace();} catch (IOException e) {    e.printStackTrace();}finally{if (writer!=null) {try {writer.close();} catch (CorruptIndexException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}}public void merge(){IndexWriter writer=null;try {writer=new IndexWriter(directory, new IndexWriterConfig(Version.LUCENE_36,new StandardAnalyzer(Version.LUCENE_36)));writer.forceMerge(2);} catch (CorruptIndexException e) {e.printStackTrace();} catch (LockObtainFailedException e) {e.printStackTrace();} catch (IOException e) {    e.printStackTrace();}finally{if (writer!=null) {try {writer.close();} catch (CorruptIndexException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}}public void delete(){IndexWriter writer=null;try {writer=new IndexWriter(directory, new IndexWriterConfig(Version.LUCENE_36,new StandardAnalyzer(Version.LUCENE_36)));//参数十一个选项,可以是一个query,也可以是一个term  term就是一个精确查找的值//此时删除的文档并未完全删除,而是存储在回收站中,可以恢复的writer.deleteDocuments(new Term("id","1"));} catch (CorruptIndexException e) {e.printStackTrace();} catch (LockObtainFailedException e) {e.printStackTrace();} catch (IOException e) {    e.printStackTrace();}finally{if (writer!=null) {try {writer.close();} catch (CorruptIndexException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}}public void index(){   IndexWriter writer=null;   Document doc=null;   try {writer =new IndexWriter(directory,new IndexWriterConfig(Version.LUCENE_36,    new StandardAnalyzer(Version.LUCENE_36)));//writer.deleteAll();for(int i=0;i<ids.length;i++){doc=new Document();    doc.add(new Field("id",ids[i],Field.Store.YES,Field.Index.NOT_ANALYZED_NO_NORMS));    doc.add(new Field("emails",emails[i],Field.Store.YES,Field.Index.NOT_ANALYZED));    doc.add(new Field("contents",contents[i],Field.Store.YES,Field.Index.ANALYZED));    doc.add(new Field("name",names[i],Field.Store.YES,Field.Index.NOT_ANALYZED_NO_NORMS));    writer.addDocument(doc); }} catch (CorruptIndexException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (LockObtainFailedException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}   finally{   if(writer!=null)   {  try {writer.close();} catch (CorruptIndexException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}      }   }}       //更新索引public void update(){/*lucene本身不支持更新 *  * 通过删除索引然后再建立索引来更新 */  IndexWriter writer=null;   Document doc=null;   try {writer =new IndexWriter(directory,new IndexWriterConfig(Version.LUCENE_36,    new StandardAnalyzer(Version.LUCENE_36)));writer.deleteAll();for(int i=0;i<ids.length;i++){doc=new Document();    doc.add(new Field("id",ids[i],Field.Store.YES,Field.Index.NOT_ANALYZED_NO_NORMS));    doc.add(new Field("emails",emails[i],Field.Store.YES,Field.Index.NOT_ANALYZED));    doc.add(new Field("contents",contents[i],Field.Store.YES,Field.Index.ANALYZED));    doc.add(new Field("name",names[i],Field.Store.YES,Field.Index.NOT_ANALYZED_NO_NORMS));    writer.updateDocument(new Term("id","1"), doc); }} catch (CorruptIndexException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (LockObtainFailedException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}   finally{   if(writer!=null)   {  try {writer.close();} catch (CorruptIndexException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}      }   }}}//测试类package org.se.lucene;import org.junit.Test;public class test {@Testpublic void testIndex(){lucene_index l_index=new lucene_index();l_index.index();    }@Testpublic void testquary(){lucene_index l_index=new lucene_index();l_index.quary();}@Testpublic void testDelete(){lucene_index l_index=new lucene_index();l_index.delete();}@Testpublic void testunDelete(){lucene_index l_index=new lucene_index();l_index.undelete();}@Testpublic void testForceDelete(){lucene_index l_index=new lucene_index();l_index.forceDelete();}@Testpublic void testmerge(){lucene_index l_index=new lucene_index();l_index.merge();}@Testpublic void upDate(){lucene_index l_index=new lucene_index();l_index.update();}}


读书人网 >编程

热点推荐