【第二节】Lucene5教程增、删、改、查

javazx

1、源码
0 ~9 U3 `( s5 I) n0 F; yimport java.nio.file.Paths;

! a% ~. I( ^5 Z7 {1 C, V7 [! Timport org.apache.lucene.analysis.Analyzer;
8 H1 p: K. U1 |7 cimport org.apache.lucene.analysis.standard.StandardAnalyzer;
- V6 t# u. J5 D5 ?2 z$ e6 aimport org.apache.lucene.document.Document;
! L4 m  f, H9 n6 e9 Qimport org.apache.lucene.document.Field;
import org.apache.lucene.document.StringField;
import org.apache.lucene.document.TextField;
import org.apache.lucene.index.DirectoryReader;
import org.apache.lucene.index.IndexReader;
) j9 O1 u/ N4 a! \7 q0 j; a/ Limport org.apache.lucene.index.IndexWriter;
import org.apache.lucene.index.IndexWriterConfig;
. W: L8 w& ?4 ~0 p) `8 eimport org.apache.lucene.index.Term;
8 o3 u1 n7 d* E' Z2 Vimport org.apache.lucene.store.Directory;
' f. H" @: f. @+ Q. Vimport org.apache.lucene.store.FSDirectory;
/ w" W! p6 l/ W, k, |9 Pimport org.junit.Before;
& H2 W8 O- O( c) W# T6 j  U2 nimport org.junit.Test;
; }, K/ C7 ^7 l7 D1 M, S; p
public class IndexingTest {
5 A: U/ c0 V  s
    private String ids[]={"1","2","3"};
    private String citys[]={"qingdao","nanjing","shanghai"};
    private String descs[]={
9 A' B; {7 V1 j            "Qingdao is a beautiful city.",
            "Nanjing is a city of culture.",
  `9 Q- a; E: ^* ]. u3 @            "Shanghai is a bustling city."
    };

    private Directory dir;

+ @) u. j: p/ L! K5 a    @Before
    public void setUp() throws Exception {
* S2 [/ j% y( d) ]3 y6 m: i6 G; r        dir=FSDirectory.open(Paths.get("D:\\lucene2"));
        IndexWriter writer=getWriter();
        for(int i=0;i<ids.length;i++){
% x* V% p5 E, C& d            Document doc=new Document();
            doc.add(new StringField("id", ids, Field.Store.YES));
6 p1 i/ t- B6 n7 [) ~            doc.add(new StringField("city",citys,Field.Store.YES));
8 N& q9 }/ c8 X& }! j            doc.add(new TextField("desc", descs, Field.Store.NO));
, b* x* A+ b9 x0 C& x, m            writer.addDocument(doc); // 添加文档
        }
        writer.close();
) ^* ~5 i9 `+ E5 b- m% f    }

( [& K0 S6 j5 s& L    /**
; J/ g. P! p" N+ h     * 获取IndexWriter实例
     * @return
4 |, i; J- n$ u) D     * @throws Exception
% m! I' d: b3 _7 i4 w     */
6 F( L. ^: ?; o" e4 S% p' k    private IndexWriter getWriter()throws Exception{
        Analyzer analyzer=new StandardAnalyzer(); // 标准分词器
4 v3 W; J# H; a        IndexWriterConfig iwc=new IndexWriterConfig(analyzer);
2 M2 c% i  K/ N3 v1 O$ e% U        IndexWriter writer=new IndexWriter(dir, iwc);
        return writer;
    }
) {$ t4 e2 |. e9 O
    /**
4 r( o3 x) i% `; t     * 测试写了几个文档
     * @throws Exception
- n- R" `" s2 V( A0 W" _3 a     */
    @Test
    public void testIndexWriter()throws Exception{
        IndexWriter writer=getWriter();
, `, a- f, i- w        System.out.println("写入了"+writer.numDocs()+"个文档");
        writer.close();
    }
! F0 m2 G3 O$ |7 @' I$ J& j
    /**
3 J1 g" J; b+ {+ g     * 测试读取文档
     * @throws Exception
) F# \! L1 b- h     */
    @Test
0 m- t* e; a# z- z& \    public void testIndexReader()throws Exception{
        IndexReader reader=DirectoryReader.open(dir);
! T/ c9 g' M9 D5 C        System.out.println("最大文档数："+reader.maxDoc());
        System.out.println("实际文档数："+reader.numDocs());
( X9 i5 T+ Y8 `& _" G8 o        reader.close();
/ V' C% [3 j; G, ]( M8 Y    }
% [& K( D# _- W
4 ~- s0 G( E1 i- T; b' f    /**
* o( D+ X" b7 H9 S) x$ R( g     * 测试删除 在合并前
     * @throws Exception
     */
    @Test
    public void testDeleteBeforeMerge()throws Exception{
) x8 m* x: Y4 \# h% j* y5 |        IndexWriter writer=getWriter();
        System.out.println("删除前："+writer.numDocs());
        writer.deleteDocuments(new Term("id","1"));
        writer.commit();
        System.out.println("writer.maxDoc()："+writer.maxDoc());
        System.out.println("writer.numDocs()："+writer.numDocs());
6 T( D! E, s. m- q- W  G        writer.close();
: x. O' S2 I2 @    }
& S& S: I' L+ x' `5 s8 N
    /**
     * 测试删除 在合并后
     * @throws Exception
     */
' U9 d% z6 W; f    @Test
    public void testDeleteAfterMerge()throws Exception{
$ ]- I4 J  P  p        IndexWriter writer=getWriter();
        System.out.println("删除前："+writer.numDocs());
        writer.deleteDocuments(new Term("id","1"));
        writer.forceMergeDeletes(); // 强制删除
        writer.commit();
        System.out.println("writer.maxDoc()："+writer.maxDoc());
        System.out.println("writer.numDocs()："+writer.numDocs());
$ H2 P$ q! M# i7 B4 \        writer.close();
    }
& [2 U. n! e/ W. ^
! G+ x- }) R, a' ?" t' }    /**
     * 测试更新
8 k% P. Y  z2 ]; U8 j     * @throws Exception
     */
( e5 H; r  G9 Y; i, E    @Test
    public void testUpdate()throws Exception{
1 R; e7 H* ?& h* \% X        IndexWriter writer=getWriter();
        Document doc=new Document();
( k: ?  d) M; U* g* ~) y* \) M( W5 K        doc.add(new StringField("id", "1", Field.Store.YES));
        doc.add(new StringField("city","qingdao",Field.Store.YES));
        doc.add(new TextField("desc", "dsss is a city.", Field.Store.NO));
& m' T1 I, ^. F8 w% O0 Q2 L        writer.updateDocument(new Term("id","1"), doc);
, K% r$ D  o8 k, K" a3 D        writer.close();
    }
}

$ y) |( Q: H. F2 P8 H( F
7 H* I+ C6 R4 b  }  u4 O( N3 V
9 O1 q6 ~5 l- f! s. F: H

学java来尚学堂

看了那么多 好感谢楼主。也希望有想学的跟我一起去尚学堂啊。那里教的特别好