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

javazx

1、源码
import java.nio.file.Paths;

import org.apache.lucene.analysis.Analyzer;
+ q' g& n/ q/ b. Uimport org.apache.lucene.analysis.standard.StandardAnalyzer;
import org.apache.lucene.document.Document;
* m8 l% n! v1 A1 m% L6 [$ wimport org.apache.lucene.document.Field;
import org.apache.lucene.document.StringField;
import org.apache.lucene.document.TextField;
import org.apache.lucene.index.DirectoryReader;
; `8 a6 {! a- Q4 V' ^import org.apache.lucene.index.IndexReader;
import org.apache.lucene.index.IndexWriter;
9 X; G3 e7 A9 K& @; Z4 @import org.apache.lucene.index.IndexWriterConfig;
import org.apache.lucene.index.Term;
import org.apache.lucene.store.Directory;
$ W" |5 W& y' `% d; B- j& ?import org.apache.lucene.store.FSDirectory;
import org.junit.Before;
% }  o. f0 N) y8 r7 Kimport org.junit.Test;
  o; p' N  F5 ~$ I3 d" ~1 g
% G$ V* z" b) {& f/ H. Ppublic class IndexingTest {
8 @) a8 F. t0 H& B! j# j, D4 K6 m
& _3 s+ @6 O( H9 o; B    private String ids[]={"1","2","3"};
    private String citys[]={"qingdao","nanjing","shanghai"};
    private String descs[]={
5 C; v# f& F1 y: [! J, q            "Qingdao is a beautiful city.",
& U+ u' y. N# O4 H            "Nanjing is a city of culture.",
) Y* ]3 z8 k: L! v$ b# m            "Shanghai is a bustling city."
    };

' e# J& I' O( {9 _    private Directory dir;

    @Before
    public void setUp() throws Exception {
        dir=FSDirectory.open(Paths.get("D:\\lucene2"));
* ^* C' l: P' U        IndexWriter writer=getWriter();
1 r; D4 }/ K1 i/ t7 n1 P5 t( L$ F; B5 u        for(int i=0;i<ids.length;i++){
            Document doc=new Document();
  \$ ^, |' E) @$ S% U, u% U8 \            doc.add(new StringField("id", ids, Field.Store.YES));
0 F- B0 Y( d; D1 J4 \            doc.add(new StringField("city",citys,Field.Store.YES));
            doc.add(new TextField("desc", descs, Field.Store.NO));
3 d; R" Z* U5 q            writer.addDocument(doc); // 添加文档
        }
* p, l* _2 c3 C# g. Y        writer.close();
6 A$ n, A6 J+ ]" r    }

    /**
: I  ?1 K. |* J5 V0 o     * 获取IndexWriter实例
. P' U$ H4 n6 R( e; f2 D; j& Z     * @return
     * @throws Exception
6 n% _) x* {9 f6 y     */
  Y4 X3 S) v  f' [    private IndexWriter getWriter()throws Exception{
( |) g9 `( {  A; F" n7 _        Analyzer analyzer=new StandardAnalyzer(); // 标准分词器
        IndexWriterConfig iwc=new IndexWriterConfig(analyzer);
1 e7 P8 G& [( y* v* L& ?        IndexWriter writer=new IndexWriter(dir, iwc);
        return writer;
    }

    /**
) ?% z  X. X6 W. N% n& r1 M: |     * 测试写了几个文档
8 s0 M; W3 L  ?$ F4 y3 o0 }, `     * @throws Exception
     */
8 Q1 p! p8 [' d* J0 O' x) _* G4 V    @Test
    public void testIndexWriter()throws Exception{
        IndexWriter writer=getWriter();
        System.out.println("写入了"+writer.numDocs()+"个文档");
* _2 ?8 X% v4 D* g1 H+ Y+ @        writer.close();
/ T/ q1 Z; ^- P( ^    }

    /**
     * 测试读取文档
; f( A6 \0 t( Z. Y' H     * @throws Exception
" P7 t/ }7 ]& L3 v- a. j0 @7 A( O     */
    @Test
    public void testIndexReader()throws Exception{
        IndexReader reader=DirectoryReader.open(dir);
        System.out.println("最大文档数："+reader.maxDoc());
/ c$ ]5 r/ a8 A5 P        System.out.println("实际文档数："+reader.numDocs());
* ^7 a" z! o" p& F# |% a8 b; d        reader.close();
& _: U: E' f! o( K! ?    }

    /**
     * 测试删除 在合并前
     * @throws Exception
/ X4 \% t& b4 W3 z3 E! D* K" U     */
    @Test
    public void testDeleteBeforeMerge()throws Exception{
; ?5 W' M- h. @9 A; w        IndexWriter writer=getWriter();
        System.out.println("删除前："+writer.numDocs());
: l- M. N* g3 d4 |        writer.deleteDocuments(new Term("id","1"));
        writer.commit();
        System.out.println("writer.maxDoc()："+writer.maxDoc());
) k! k$ s) d6 d        System.out.println("writer.numDocs()："+writer.numDocs());
        writer.close();
0 x, M, d" r: O3 u/ D1 d! Z    }

    /**
. a& u1 T% Y* Q" c+ N7 n4 W+ R     * 测试删除 在合并后
     * @throws Exception
; E! X8 p7 T( C2 g/ b, H; j     */
    @Test
    public void testDeleteAfterMerge()throws Exception{
7 f# q, P) X8 j0 ^) s/ N0 l        IndexWriter writer=getWriter();
        System.out.println("删除前："+writer.numDocs());
        writer.deleteDocuments(new Term("id","1"));
. L2 ^$ v- D0 ^: M$ q6 B4 R7 e        writer.forceMergeDeletes(); // 强制删除
4 D7 k3 G; ]* K        writer.commit();
        System.out.println("writer.maxDoc()："+writer.maxDoc());
        System.out.println("writer.numDocs()："+writer.numDocs());
        writer.close();
    }
! J7 n9 a) S2 O
    /**
% |  o0 V( ]& ]3 e. c) m/ U     * 测试更新
     * @throws Exception
' h( O" E% I8 ]/ a, O     */
    @Test
: s1 _! e- R7 S& ^/ k5 w    public void testUpdate()throws Exception{
        IndexWriter writer=getWriter();
        Document doc=new Document();
        doc.add(new StringField("id", "1", Field.Store.YES));
4 S1 Q/ s, B+ ^0 M6 B0 n, f        doc.add(new StringField("city","qingdao",Field.Store.YES));
        doc.add(new TextField("desc", "dsss is a city.", Field.Store.NO));
        writer.updateDocument(new Term("id","1"), doc);
! g3 s4 A/ y; D4 Y' i0 l        writer.close();
- ]+ q" k  b, X1 m% B0 y7 Z: @: q- W$ C    }
9 }- C. h6 \( r! M4 W' W- u$ E4 @}


6 U4 `+ r7 S: O( N: u8 |/ e* }# C

学java来尚学堂

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