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

javazx

1、源码
import java.nio.file.Paths;
) i, G& z1 q/ t/ W& L4 L0 ^; q  Q
) }! }1 f* b' B; Zimport org.apache.lucene.analysis.Analyzer;
3 o1 M6 k& f# ~0 ~! Uimport org.apache.lucene.analysis.standard.StandardAnalyzer;
1 I% J' l  \+ ?' @! j9 uimport org.apache.lucene.document.Document;
import org.apache.lucene.document.Field;
: \3 n! s& T0 x8 i1 b/ q3 fimport org.apache.lucene.document.StringField;
import org.apache.lucene.document.TextField;
' `; L( F& p2 s( C2 Y$ z- L* Eimport org.apache.lucene.index.DirectoryReader;
6 j, \# f) R% {9 g5 Y* gimport org.apache.lucene.index.IndexReader;
$ X, K+ Q. C; J' j5 Kimport org.apache.lucene.index.IndexWriter;
import org.apache.lucene.index.IndexWriterConfig;
import org.apache.lucene.index.Term;
7 K! l! Y9 Y" h- S4 f: l! [import org.apache.lucene.store.Directory;
import org.apache.lucene.store.FSDirectory;
& [; K2 v1 \: l) Vimport org.junit.Before;
# b/ H# B8 Y8 ^  u# b( jimport org.junit.Test;

  U3 j9 a* O9 k  |& ^: R4 Fpublic class IndexingTest {

! {) ?4 P0 m1 K  q    private String ids[]={"1","2","3"};
1 [0 ^# V. ~2 h( N2 ~0 k    private String citys[]={"qingdao","nanjing","shanghai"};
    private String descs[]={
            "Qingdao is a beautiful city.",
( m/ o) C' ~+ S            "Nanjing is a city of culture.",
            "Shanghai is a bustling city."
    };

    private Directory dir;
4 a! e6 R: X' o! g; Z  M% Z4 F
; Z- s% q" E/ c! t0 Y; C4 b$ n& W    @Before
7 V& q5 j  j# m8 H8 r" M    public void setUp() throws Exception {
" O# g8 B6 Y2 a) |1 H& R        dir=FSDirectory.open(Paths.get("D:\\lucene2"));
        IndexWriter writer=getWriter();
' w' |* N8 L( T) a' \( M        for(int i=0;i<ids.length;i++){
1 u3 c/ @2 n: Q) x, [5 y+ I1 q) d            Document doc=new Document();
            doc.add(new StringField("id", ids, Field.Store.YES));
1 m( j+ \* z, _) M4 J6 V# f            doc.add(new StringField("city",citys,Field.Store.YES));
0 w+ ]- h1 b# Y. x2 J$ o6 ~6 `            doc.add(new TextField("desc", descs, Field.Store.NO));
. T1 K6 ?: b# P; O1 Q- ^0 G            writer.addDocument(doc); // 添加文档
        }
        writer.close();
    }

& R; o* ]3 P3 d; X) o4 T7 X    /**
     * 获取IndexWriter实例
     * @return
     * @throws Exception
     */
3 E/ U4 ~, o2 N    private IndexWriter getWriter()throws Exception{
$ g) W# W3 |$ J1 B- b) ^' S5 t        Analyzer analyzer=new StandardAnalyzer(); // 标准分词器
        IndexWriterConfig iwc=new IndexWriterConfig(analyzer);
        IndexWriter writer=new IndexWriter(dir, iwc);
        return writer;
    }
4 d% M6 H" x0 g6 b7 t5 {  T
    /**
& N: q0 H0 k$ A     * 测试写了几个文档
7 C0 J8 N0 v$ A- j) k! Q2 j     * @throws Exception
  Y2 V% b9 [4 \, O  q     */
    @Test
    public void testIndexWriter()throws Exception{
        IndexWriter writer=getWriter();
        System.out.println("写入了"+writer.numDocs()+"个文档");
        writer.close();
$ V$ \3 ?, b% V. A! K1 J; f    }

    /**
     * 测试读取文档
     * @throws Exception
     */
$ Q# y3 d$ D6 U    @Test
    public void testIndexReader()throws Exception{
        IndexReader reader=DirectoryReader.open(dir);
        System.out.println("最大文档数："+reader.maxDoc());
        System.out.println("实际文档数："+reader.numDocs());
# L( R: j5 c( v8 Y8 W; `: \" b5 S        reader.close();
3 Y3 A5 D7 {% }* F0 v    }
/ t7 s' p4 h* T! l( P" j6 p3 ^
: M7 W8 k# E0 _4 l! }    /**
$ q/ ]& d1 f$ f  A' @* B8 e# P9 B     * 测试删除 在合并前
     * @throws Exception
     */
    @Test
9 E9 X# X) U  v    public void testDeleteBeforeMerge()throws Exception{
        IndexWriter writer=getWriter();
8 z8 C$ A% N0 V6 W6 e        System.out.println("删除前："+writer.numDocs());
* D3 w9 x" _9 m9 S2 e7 R        writer.deleteDocuments(new Term("id","1"));
# _8 ]/ v5 t7 Z8 Y* m8 R0 k& _        writer.commit();
        System.out.println("writer.maxDoc()："+writer.maxDoc());
5 b4 b: J9 j  z) [" R) O% ]        System.out.println("writer.numDocs()："+writer.numDocs());
$ R. l0 E5 m7 A% n/ v$ r        writer.close();
; J# n' W) J5 W    }

    /**
     * 测试删除 在合并后
% Z# d$ ~: ~8 ]6 t* ~     * @throws Exception
     */
    @Test
    public void testDeleteAfterMerge()throws Exception{
        IndexWriter writer=getWriter();
' ]/ L! w. c: h  |6 m* F2 b        System.out.println("删除前："+writer.numDocs());
& V4 F- G8 i* v! i+ H        writer.deleteDocuments(new Term("id","1"));
        writer.forceMergeDeletes(); // 强制删除
. f# {. {5 t' @1 C, I        writer.commit();
        System.out.println("writer.maxDoc()："+writer.maxDoc());
        System.out.println("writer.numDocs()："+writer.numDocs());
        writer.close();
    }
! H( i% R8 R2 D7 H; v
    /**
     * 测试更新
4 x; H: C" A& S0 g1 }     * @throws Exception
  A2 g0 r* _! u+ X     */
    @Test
    public void testUpdate()throws Exception{
; ~8 W% W. k, C# t3 Z" f: ^, T; G) t        IndexWriter writer=getWriter();
        Document doc=new Document();
" M. ]+ n1 k9 ?* C  \0 e( ~* U        doc.add(new StringField("id", "1", Field.Store.YES));
        doc.add(new StringField("city","qingdao",Field.Store.YES));
0 Y5 S9 @/ o1 l- B) |. |! L        doc.add(new TextField("desc", "dsss is a city.", Field.Store.NO));
        writer.updateDocument(new Term("id","1"), doc);
        writer.close();
    }
) f- O: R# w1 z3 a; S: _, O. f}
( a4 Q6 ~( d) G  U: G3 \8 D) B
; I# V8 H+ y% Q  s" X, U+ q& A
  x$ j5 d# e. b' [  ^9 D

学java来尚学堂

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