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

javazx

1、源码
import java.nio.file.Paths;
7 ~( {$ r. ~" @5 d
import org.apache.lucene.analysis.Analyzer;
: U9 i! K. ^1 U# [( M) u; Ximport org.apache.lucene.analysis.standard.StandardAnalyzer;
  T$ [3 m- g5 c) _3 d% X% d3 M2 }: ?+ \import org.apache.lucene.document.Document;
" I$ J' Z- w$ v3 {4 _import org.apache.lucene.document.Field;
import org.apache.lucene.document.StringField;
* t" T9 ^4 q, c: H2 h9 t1 oimport org.apache.lucene.document.TextField;
% Y3 d. Q7 e6 yimport org.apache.lucene.index.DirectoryReader;
8 J, `' w' [* x( _! m1 X% zimport org.apache.lucene.index.IndexReader;
import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.index.IndexWriterConfig;
1 `, y+ [, `! R% M  Mimport org.apache.lucene.index.Term;
import org.apache.lucene.store.Directory;
import org.apache.lucene.store.FSDirectory;
$ x/ c6 ~9 m( F0 P% O' oimport org.junit.Before;
8 r. o3 O9 _0 ?import org.junit.Test;
, a2 a0 m; d) ^, B6 ~
' g- ^# q! K% M" }# g/ npublic class IndexingTest {

  Y6 R3 a5 T$ S    private String ids[]={"1","2","3"};
    private String citys[]={"qingdao","nanjing","shanghai"};
    private String descs[]={
/ U# g: U3 B- }7 o) \            "Qingdao is a beautiful city.",
- {- D- r, ^  l: x% [7 l/ i            "Nanjing is a city of culture.",
            "Shanghai is a bustling city."
1 O- N1 [) [: ]0 a    };
, h0 L/ Z6 A3 V4 }. Z$ ]
    private Directory dir;
# _7 @0 {. Z; x4 |. g4 a
    @Before
    public void setUp() throws Exception {
        dir=FSDirectory.open(Paths.get("D:\\lucene2"));
8 C; A) Z7 f$ Y        IndexWriter writer=getWriter();
& f$ @9 v/ `5 Z$ B        for(int i=0;i<ids.length;i++){
4 l) L" e# F  ]; n( Z            Document doc=new Document();
" s6 \$ F* [3 P- X8 T  {$ o" ~+ R            doc.add(new StringField("id", ids, Field.Store.YES));
            doc.add(new StringField("city",citys,Field.Store.YES));
7 f$ ?9 @- ]: h% a0 T            doc.add(new TextField("desc", descs, Field.Store.NO));
3 B+ J* X) c; u5 `+ q6 [            writer.addDocument(doc); // 添加文档
        }
        writer.close();
    }
  K+ e; G3 z6 O0 g5 D
    /**
( \, r+ V& t( d$ A% F( }! Q     * 获取IndexWriter实例
1 @9 |& M3 x: p6 y! u  {8 ^     * @return
     * @throws Exception
5 ]. H. i1 g! `! R) c7 w$ m. t& k! Q9 ^) L     */
+ ]1 `) A- G+ e  ^$ l8 @* R    private IndexWriter getWriter()throws Exception{
        Analyzer analyzer=new StandardAnalyzer(); // 标准分词器
4 a9 ^8 T8 ^$ r; I$ [. P3 V6 z1 y        IndexWriterConfig iwc=new IndexWriterConfig(analyzer);
        IndexWriter writer=new IndexWriter(dir, iwc);
8 q" f3 G, w6 P. a/ H% r! S8 m7 R' ?        return writer;
    }

5 ^8 ^7 u: \- \0 I6 D    /**
     * 测试写了几个文档
9 F! a: \% a/ l/ l# Z2 `7 V$ @     * @throws Exception
     */
    @Test
    public void testIndexWriter()throws Exception{
1 S/ l: A* g! f  w; i: C$ s        IndexWriter writer=getWriter();
3 H9 B4 t$ j8 ]8 Y        System.out.println("写入了"+writer.numDocs()+"个文档");
        writer.close();
    }

7 W6 O9 K/ e4 {5 p. x    /**
     * 测试读取文档
' I# G' L. F) m- y     * @throws Exception
. G$ e/ ~6 u% L7 `9 I; a     */
& J" n7 O+ c4 w$ }    @Test
    public void testIndexReader()throws Exception{
6 e) p2 l' F/ b        IndexReader reader=DirectoryReader.open(dir);
        System.out.println("最大文档数："+reader.maxDoc());
) ^/ F; J) v  S, M        System.out.println("实际文档数："+reader.numDocs());
8 z8 {4 P# E( W! ?6 Z, I4 T        reader.close();
    }

) s* K* a8 p& t+ ^7 n& H    /**
* i" ~! q+ E7 u' C: X, u3 _     * 测试删除 在合并前
     * @throws Exception
/ `5 E) j2 m: F     */
    @Test
$ _. N! @0 t3 N1 s    public void testDeleteBeforeMerge()throws Exception{
        IndexWriter writer=getWriter();
        System.out.println("删除前："+writer.numDocs());
1 r# o5 @0 w+ g( m        writer.deleteDocuments(new Term("id","1"));
. g7 t) {: P8 x7 d! T  P  L4 f        writer.commit();
& M0 ?" l8 q. {2 U6 n        System.out.println("writer.maxDoc()："+writer.maxDoc());
        System.out.println("writer.numDocs()："+writer.numDocs());
        writer.close();
    }
0 O4 R6 V: [$ V
7 H( d* \& R9 J( ]+ l2 a- R1 i    /**
     * 测试删除 在合并后
     * @throws Exception
+ ?# y4 ]3 N# f4 f     */
    @Test
0 f* ^8 f% E- _" ?6 G    public void testDeleteAfterMerge()throws Exception{
2 B* O% W& ~. j+ k; l9 R        IndexWriter writer=getWriter();
        System.out.println("删除前："+writer.numDocs());
        writer.deleteDocuments(new Term("id","1"));
1 [0 D1 Y/ D) y, T        writer.forceMergeDeletes(); // 强制删除
        writer.commit();
        System.out.println("writer.maxDoc()："+writer.maxDoc());
        System.out.println("writer.numDocs()："+writer.numDocs());
2 H/ d! W( L- @+ T# ^        writer.close();
. B: }( C9 R5 k; t    }
; T# ]' c3 F7 m- ~  z
! c$ b& u& Q8 a6 O    /**
     * 测试更新
     * @throws Exception
     */
: U0 E9 q7 }$ Q! C  j1 I( M* w    @Test
    public void testUpdate()throws Exception{
        IndexWriter writer=getWriter();
        Document doc=new Document();
/ g5 s: q9 ~9 N7 k$ I        doc.add(new StringField("id", "1", Field.Store.YES));
        doc.add(new StringField("city","qingdao",Field.Store.YES));
4 R3 A8 P& M+ t# o8 ~7 f        doc.add(new TextField("desc", "dsss is a city.", Field.Store.NO));
        writer.updateDocument(new Term("id","1"), doc);
, r0 n( X* U; p$ N        writer.close();
    }
}
5 l6 N% d1 q/ p4 v: V0 k
2 Q" O/ j+ |$ s5 h% c+ k2 f
: B6 f  B! d! G( h

学java来尚学堂

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