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

javazx

1、源码
% O5 d$ r; c& [import java.nio.file.Paths;

: R7 A. q* V& f. h0 l1 X2 t  Vimport org.apache.lucene.analysis.Analyzer;
' U3 j" f- H) i3 W" }& }# t# Mimport org.apache.lucene.analysis.standard.StandardAnalyzer;
1 S8 i9 k5 o6 Eimport org.apache.lucene.document.Document;
import org.apache.lucene.document.Field;
. x9 Y7 ?- k' V7 Y& Ximport org.apache.lucene.document.StringField;
import org.apache.lucene.document.TextField;
import org.apache.lucene.index.DirectoryReader;
import org.apache.lucene.index.IndexReader;
import org.apache.lucene.index.IndexWriter;
. W9 y6 `- H( f3 a& wimport 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.junit.Before;
import org.junit.Test;
; L4 \" K" k# U5 O( U' A, C
public class IndexingTest {

5 a1 A( U- o( `5 `2 J0 `0 i    private String ids[]={"1","2","3"};
    private String citys[]={"qingdao","nanjing","shanghai"};
    private String descs[]={
9 N3 ?: d: c( H# [7 w9 d            "Qingdao is a beautiful city.",
            "Nanjing is a city of culture.",
            "Shanghai is a bustling city."
    };

    private Directory dir;

    @Before
0 R0 u1 |7 U& p) h' H! L9 W    public void setUp() throws Exception {
$ h. g. P- |7 H8 n% J        dir=FSDirectory.open(Paths.get("D:\\lucene2"));
        IndexWriter writer=getWriter();
        for(int i=0;i<ids.length;i++){
            Document doc=new Document();
" R8 ]* h, J* Z            doc.add(new StringField("id", ids, Field.Store.YES));
* _7 ]7 t& h2 Z8 x, b, r/ y( x            doc.add(new StringField("city",citys,Field.Store.YES));
# b% r0 w* b2 O- V  V3 W            doc.add(new TextField("desc", descs, Field.Store.NO));
            writer.addDocument(doc); // 添加文档
, v/ E5 o8 C# z$ `" ^8 {6 D# H        }
        writer.close();
    }
6 k& u4 h9 [( Q- W
    /**
6 D! w4 ]1 i: D9 |2 S$ m     * 获取IndexWriter实例
     * @return
     * @throws Exception
0 B7 _! b) M+ b# O+ [- h     */
, @0 E; Q& I4 B0 r! D' @0 D' A& z    private IndexWriter getWriter()throws Exception{
5 o7 M: C% R1 V        Analyzer analyzer=new StandardAnalyzer(); // 标准分词器
        IndexWriterConfig iwc=new IndexWriterConfig(analyzer);
* r. I( ^1 t0 p" Q        IndexWriter writer=new IndexWriter(dir, iwc);
        return writer;
    }
( b) r/ x/ Z$ ]2 R5 K
    /**
     * 测试写了几个文档
. Q( r- j/ m  T6 O- F. H     * @throws Exception
     */
    @Test
    public void testIndexWriter()throws Exception{
+ e' _% R6 k; H' x; a        IndexWriter writer=getWriter();
; c: Q  z; n, T        System.out.println("写入了"+writer.numDocs()+"个文档");
* X; P6 c/ b! z! }9 O2 ^        writer.close();
% {9 Q* U/ Z; T8 s    }

3 P& s4 Q4 f" G- Z    /**
     * 测试读取文档
7 t" g: ]2 l$ l. [     * @throws Exception
% A- ~, c) ?3 w% T     */
  ~0 H& z1 ~; j4 `) q& k6 m    @Test
    public void testIndexReader()throws Exception{
& M4 Z9 t# o  T6 @5 n        IndexReader reader=DirectoryReader.open(dir);
9 [3 e3 D" O( g, Y+ _        System.out.println("最大文档数："+reader.maxDoc());
        System.out.println("实际文档数："+reader.numDocs());
        reader.close();
& j& x0 o9 k: b5 }    }

    /**
     * 测试删除 在合并前
$ x0 S  t6 I- h0 P' G: l4 u& n/ d. a     * @throws Exception
     */
* y  e/ K: {, q! \1 `+ G: ]    @Test
* t6 N- t" E" {1 l" g    public void testDeleteBeforeMerge()throws Exception{
        IndexWriter writer=getWriter();
        System.out.println("删除前："+writer.numDocs());
        writer.deleteDocuments(new Term("id","1"));
        writer.commit();
4 \: T& i9 h2 ^$ a3 m        System.out.println("writer.maxDoc()："+writer.maxDoc());
        System.out.println("writer.numDocs()："+writer.numDocs());
- }1 C8 P' g. Y        writer.close();
3 ?8 D5 z% s3 S8 ~* {! b: O2 h0 B    }
  l: C- o! J% T+ u9 ~- s0 a# n4 H
3 c* X+ M( q( k: X! l    /**
     * 测试删除 在合并后
: a: E/ r- N8 C     * @throws Exception
4 Z8 z1 B5 _/ u( Z& F     */
    @Test
    public void testDeleteAfterMerge()throws Exception{
        IndexWriter writer=getWriter();
        System.out.println("删除前："+writer.numDocs());
        writer.deleteDocuments(new Term("id","1"));
- q/ u' F3 P) k; J0 ?+ K1 R        writer.forceMergeDeletes(); // 强制删除
        writer.commit();
        System.out.println("writer.maxDoc()："+writer.maxDoc());
        System.out.println("writer.numDocs()："+writer.numDocs());
        writer.close();
    }
, ~9 A* p3 t: U
    /**
. C* w2 p6 d" Y4 _" U' w2 C6 m% o     * 测试更新
     * @throws Exception
. d$ [/ Y! I3 j     */
3 A! W% }! K3 g8 E# K9 B) J    @Test
0 r7 Y+ Q! Q6 [* F    public void testUpdate()throws Exception{
/ M/ n2 y0 j* o  V; e) G2 W9 e        IndexWriter writer=getWriter();
$ k0 i" P- f6 `/ B7 H7 E3 z- F        Document doc=new Document();
" j! ]4 t$ T4 z1 U        doc.add(new StringField("id", "1", Field.Store.YES));
: V- ~1 Z5 L& j/ r" d        doc.add(new StringField("city","qingdao",Field.Store.YES));
& g7 {" v" Z. b* o" w- J$ \1 R9 D1 f        doc.add(new TextField("desc", "dsss is a city.", Field.Store.NO));
% F5 i6 y: s! S& h) D8 ?+ ~        writer.updateDocument(new Term("id","1"), doc);
1 B5 c  `& A( i) ~        writer.close();
    }
9 U/ G0 |# u& J) S}


! y3 m( O7 q( R" V/ r3 k3 ^
& D, u. x2 J  f

学java来尚学堂

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