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

javazx

1、源码
0 J4 p% n- y' C! j% d" M- ~$ limport java.nio.file.Paths;

import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.analysis.standard.StandardAnalyzer;
import org.apache.lucene.document.Document;
import org.apache.lucene.document.Field;
- u2 `. {5 t9 x3 }& H7 X5 Rimport org.apache.lucene.document.StringField;
' }" C- c, J4 {' C; A+ I2 S6 ~import org.apache.lucene.document.TextField;
import org.apache.lucene.index.DirectoryReader;
) E* b9 B, j5 ?" N4 Jimport org.apache.lucene.index.IndexReader;
import org.apache.lucene.index.IndexWriter;
1 K3 f( `1 |' x4 u4 e0 Uimport org.apache.lucene.index.IndexWriterConfig;
) k& h0 F6 T9 Z/ u0 R2 E* Oimport org.apache.lucene.index.Term;
import org.apache.lucene.store.Directory;
1 y& Q  U! d/ R" D# R* Y3 O: D  Iimport org.apache.lucene.store.FSDirectory;
2 E1 S+ J" W! t  V1 a0 f. ?import org.junit.Before;
import org.junit.Test;

" n/ M) q; T; @& |# bpublic class IndexingTest {

# }( H6 r6 }9 ^. @+ P0 p    private String ids[]={"1","2","3"};
    private String citys[]={"qingdao","nanjing","shanghai"};
- F& l$ l% |$ S. Z" o    private String descs[]={
            "Qingdao is a beautiful city.",
            "Nanjing is a city of culture.",
7 H5 N+ h# q% e0 K            "Shanghai is a bustling city."
    };
% i( A' `; e9 j  V% |( G
    private Directory dir;
; \  q' g/ ^1 a- |9 K
    @Before
    public void setUp() throws Exception {
; K$ l; V( A( Y5 {2 `& _        dir=FSDirectory.open(Paths.get("D:\\lucene2"));
        IndexWriter writer=getWriter();
        for(int i=0;i<ids.length;i++){
3 q; y1 J* f+ b5 z+ y            Document doc=new Document();
. M7 U/ k( Y0 `) M% ^            doc.add(new StringField("id", ids, Field.Store.YES));
            doc.add(new StringField("city",citys,Field.Store.YES));
            doc.add(new TextField("desc", descs, Field.Store.NO));
  S" M+ _  e. @8 ^' W3 k, t/ D2 _            writer.addDocument(doc); // 添加文档
        }
* p0 j" f% {" V7 v- n, z7 ]( U        writer.close();
    }
( _3 U. j5 C' o" d. X: q( a
    /**
( X, t# x) c% o  W     * 获取IndexWriter实例
     * @return
     * @throws Exception
     */
    private IndexWriter getWriter()throws Exception{
$ J# O& m$ [6 a% G+ d        Analyzer analyzer=new StandardAnalyzer(); // 标准分词器
        IndexWriterConfig iwc=new IndexWriterConfig(analyzer);
        IndexWriter writer=new IndexWriter(dir, iwc);
! C; U4 [6 T" Y/ @) r4 P4 F        return writer;
    }
0 o2 o9 Q" w* j$ G# E& |' w/ W
/ F. w* v/ `( U* |& l8 m6 ^    /**
+ ^9 ~& B$ u- l! m     * 测试写了几个文档
     * @throws Exception
     */
: i' w8 R6 r- z7 I    @Test
, m+ `5 K: |3 @9 F; ^4 z    public void testIndexWriter()throws Exception{
& T6 @6 B  W" R8 e" k# P        IndexWriter writer=getWriter();
1 F4 j4 a, r+ _  Z$ |* |3 x" S        System.out.println("写入了"+writer.numDocs()+"个文档");
' C$ |2 I. c' H& Y) y/ m( t. W        writer.close();
& m- p+ P/ E2 d- V# b) c) R' B& [' X    }

    /**
     * 测试读取文档
     * @throws Exception
     */
    @Test
0 X* W; b8 j5 V+ e+ B; p  }    public void testIndexReader()throws Exception{
/ n; p4 r- ]3 Y3 D! r4 ]9 V; `        IndexReader reader=DirectoryReader.open(dir);
+ m: H% K$ \0 {9 a4 I2 u9 w        System.out.println("最大文档数："+reader.maxDoc());
: d; ~, ~' [+ k! X+ S        System.out.println("实际文档数："+reader.numDocs());
9 A: M& h1 W4 @2 p% k+ c$ u+ B" B        reader.close();
) l& p, @. G" e; q1 r/ g    }
& M! X3 v5 A  _
* M9 s# G+ w' j9 q( k5 U3 @2 E    /**
     * 测试删除 在合并前
0 [4 R  P( v8 q2 u! t' A; a5 d     * @throws Exception
     */
+ @' K$ P" e. |8 o0 k2 @& g    @Test
    public void testDeleteBeforeMerge()throws Exception{
        IndexWriter writer=getWriter();
        System.out.println("删除前："+writer.numDocs());
        writer.deleteDocuments(new Term("id","1"));
        writer.commit();
2 I- ^3 @4 `6 A. y3 H% `        System.out.println("writer.maxDoc()："+writer.maxDoc());
        System.out.println("writer.numDocs()："+writer.numDocs());
' F) u% e# T3 ]5 `        writer.close();
) B6 E! y( {+ d    }
/ m; h4 h" n7 d/ w. a+ z
    /**
     * 测试删除 在合并后
( L- h6 o* F% b2 z9 ~' h, d     * @throws Exception
4 y  X" x; @* \$ i2 o     */
' z* w7 t. m1 J2 P- G    @Test
7 B7 `( S" l0 g+ B9 \    public void testDeleteAfterMerge()throws Exception{
        IndexWriter writer=getWriter();
+ f/ o& E* N# i: d1 A: X        System.out.println("删除前："+writer.numDocs());
6 g1 r( s! ~1 E6 a        writer.deleteDocuments(new Term("id","1"));
        writer.forceMergeDeletes(); // 强制删除
, X( }8 ?; C* \( R1 k        writer.commit();
" L' W" g( s1 h/ Y* l        System.out.println("writer.maxDoc()："+writer.maxDoc());
        System.out.println("writer.numDocs()："+writer.numDocs());
        writer.close();
    }

    /**
# J" q1 n, m- p4 o0 ]  M     * 测试更新
+ V% I! J* D, R) w" F9 O     * @throws Exception
2 x; ]$ O) d6 o) I0 |7 z+ \1 x& n     */
, k% r9 g; T7 Q- U; D    @Test
    public void testUpdate()throws Exception{
        IndexWriter writer=getWriter();
        Document doc=new Document();
        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));
1 e3 W& z0 ?  P6 |. X3 N1 a" k$ w        writer.updateDocument(new Term("id","1"), doc);
        writer.close();
    }
}
. K' e, ?3 o4 q0 ]
# `, K8 L3 L- {$ g( y9 k. I

7 Y; S2 D5 A" H# m. ]( R7 P

学java来尚学堂

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