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

javazx

1、源码
, z4 _9 D3 b5 N2 Nimport 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;
import org.apache.lucene.document.StringField;
import org.apache.lucene.document.TextField;
% ~: ]8 k- P+ i8 H/ o+ r5 D5 \; b* Y3 Gimport org.apache.lucene.index.DirectoryReader;
8 S; k% G  P0 aimport org.apache.lucene.index.IndexReader;
import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.index.IndexWriterConfig;
  b5 O. y+ d# [( kimport org.apache.lucene.index.Term;
import org.apache.lucene.store.Directory;
, K) p& p3 W3 `+ c' simport org.apache.lucene.store.FSDirectory;
9 ^$ k5 U4 k5 Yimport org.junit.Before;
5 g0 c2 \+ K7 simport org.junit.Test;
* t  f7 q" i2 F
% F  a$ }1 O! A; p2 }public class IndexingTest {
8 N. E* G! u5 }" ?7 P
$ j) e* |3 G; s! u    private String ids[]={"1","2","3"};
9 W0 W% y$ ]$ q. u    private String citys[]={"qingdao","nanjing","shanghai"};
3 D( v7 X" k- ~" V4 o    private String descs[]={
            "Qingdao is a beautiful city.",
5 G4 E/ i3 {- s7 t1 b- F% l            "Nanjing is a city of culture.",
            "Shanghai is a bustling city."
    };
: C0 ?$ Q( W; @9 m' t
    private Directory dir;

    @Before
    public void setUp() throws Exception {
/ H8 y7 i) H7 _* j+ y        dir=FSDirectory.open(Paths.get("D:\\lucene2"));
' Q. ?# [; i9 d6 y& |4 K5 M        IndexWriter writer=getWriter();
        for(int i=0;i<ids.length;i++){
            Document doc=new Document();
6 t! T  P" B. D1 L0 U2 _( u7 v            doc.add(new StringField("id", ids, Field.Store.YES));
# X3 b1 O) u& \0 R/ v0 j$ x            doc.add(new StringField("city",citys,Field.Store.YES));
            doc.add(new TextField("desc", descs, Field.Store.NO));
            writer.addDocument(doc); // 添加文档
        }
1 b0 U* E( W9 t, N% H9 m+ f1 n        writer.close();
8 z! ~6 v, {* z' {# e    }

) [; B8 x, {; r    /**
6 _2 P/ h/ r1 X+ w! i; R     * 获取IndexWriter实例
     * @return
     * @throws Exception
) _8 G& L, j4 o     */
    private IndexWriter getWriter()throws Exception{
& W: d7 }2 e* M. k4 X* |        Analyzer analyzer=new StandardAnalyzer(); // 标准分词器
        IndexWriterConfig iwc=new IndexWriterConfig(analyzer);
3 K* i" ~9 D, i/ X& ~2 V: [        IndexWriter writer=new IndexWriter(dir, iwc);
' a; J( a  ?' N: [2 @0 ^; \, X4 X        return writer;
    }
' ^7 x7 }" J; v* W; n: z
    /**
1 e7 K# S4 c+ z9 W! ]) L  U4 c9 v) J     * 测试写了几个文档
     * @throws Exception
     */
* D  ^. x$ b# `* |/ w: a    @Test
$ k8 ^( \) J% v* E( V    public void testIndexWriter()throws Exception{
        IndexWriter writer=getWriter();
- S- s9 i3 m' l. s: Z5 F+ W        System.out.println("写入了"+writer.numDocs()+"个文档");
        writer.close();
% O' @6 I" m" h% ]# d. m9 }    }
; v% O+ O5 V2 x4 J+ {
( R& \$ k$ `! s' N  }3 H    /**
     * 测试读取文档
     * @throws Exception
     */
    @Test
    public void testIndexReader()throws Exception{
" r* I% I# s/ Z) p/ m        IndexReader reader=DirectoryReader.open(dir);
        System.out.println("最大文档数："+reader.maxDoc());
        System.out.println("实际文档数："+reader.numDocs());
4 U( ]+ U6 s5 J9 K& @8 b/ M  \, X        reader.close();
    }

    /**
% s" H6 \! J& b& p' Z     * 测试删除 在合并前
     * @throws Exception
5 c7 y7 F, ]6 z     */
    @Test
    public void testDeleteBeforeMerge()throws Exception{
8 z: Q# H' U& k+ X% ^3 U7 b% V        IndexWriter writer=getWriter();
  O6 X& i0 p- ^1 J$ M        System.out.println("删除前："+writer.numDocs());
2 `( {6 U# v# ?  |3 G8 j        writer.deleteDocuments(new Term("id","1"));
6 y9 M/ K- N3 v+ N, a) b        writer.commit();
' l$ K, ~0 j" G5 l$ _0 w& T9 _        System.out.println("writer.maxDoc()："+writer.maxDoc());
        System.out.println("writer.numDocs()："+writer.numDocs());
        writer.close();
    }

* p: |) }, y0 Z    /**
     * 测试删除 在合并后
     * @throws Exception
/ _: \* ]. {: h1 M) ^. G1 M     */
    @Test
    public void testDeleteAfterMerge()throws Exception{
+ Q1 P5 T3 A' i        IndexWriter writer=getWriter();
: `; x4 \; u; d% C" f& v. G        System.out.println("删除前："+writer.numDocs());
  Z# D5 r7 b; h        writer.deleteDocuments(new Term("id","1"));
6 B4 G3 U; v0 p/ O# k        writer.forceMergeDeletes(); // 强制删除
5 x- D7 l6 M* g        writer.commit();
% g* S, c. z) ?- c& A2 w, q        System.out.println("writer.maxDoc()："+writer.maxDoc());
& R. `2 b# C+ H" i$ F3 y/ q        System.out.println("writer.numDocs()："+writer.numDocs());
1 L, J& O$ k. W        writer.close();
    }
" k% j7 N$ V5 A" z+ G2 f* C) j2 n
    /**
3 Q. S7 A( l; b0 k1 O+ B     * 测试更新
6 z; K9 V% G9 c0 C, u! I     * @throws Exception
     */
0 J/ O& c" Y, Q+ y1 P; S( K    @Test
    public void testUpdate()throws Exception{
2 n+ |; J  ?6 X3 f2 b! k        IndexWriter writer=getWriter();
        Document doc=new Document();
        doc.add(new StringField("id", "1", Field.Store.YES));
5 O/ T0 |' y& n, e  G( X+ |6 [: u        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);
+ v+ N  l/ W0 O, g3 i- _" x8 F% J        writer.close();
    }
  b+ m+ d* o- `2 @}
; A5 o' \8 Z$ x
/ Z9 H3 t! a# S& ]; w

学java来尚学堂

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