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

javazx

1、源码
& p5 p3 M. I" q3 F0 u2 ~) Simport 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;
6 {5 @) T7 C9 J2 u" _" U  {; ~! Kimport org.apache.lucene.document.StringField;
import org.apache.lucene.document.TextField;
import org.apache.lucene.index.DirectoryReader;
import org.apache.lucene.index.IndexReader;
# t5 d4 Y' d, a  _9 rimport org.apache.lucene.index.IndexWriter;
% w0 H' \! m! Bimport org.apache.lucene.index.IndexWriterConfig;
0 x9 P: p0 k  m# N- j' O3 W: cimport org.apache.lucene.index.Term;
& _% x' T7 h) iimport org.apache.lucene.store.Directory;
import org.apache.lucene.store.FSDirectory;
import org.junit.Before;
  E. Z, _8 _( S3 u# Z  U" K4 Zimport org.junit.Test;
9 C8 E# I. S5 q7 U: O4 Y" R
* m% a+ v. ~, g/ {1 L! J5 Q! gpublic class IndexingTest {

. x. O" i( @9 C* b    private String ids[]={"1","2","3"};
    private String citys[]={"qingdao","nanjing","shanghai"};
& w( o: |5 w& V; a+ W; s    private String descs[]={
            "Qingdao is a beautiful city.",
            "Nanjing is a city of culture.",
- N% p- L4 t  B            "Shanghai is a bustling city."
  i/ e" t  c4 y% T( E( X3 k    };

( G. V8 q, k! k" y% T9 W    private Directory dir;

    @Before
    public void setUp() throws Exception {
        dir=FSDirectory.open(Paths.get("D:\\lucene2"));
2 c2 W  u9 ?3 T" Q        IndexWriter writer=getWriter();
        for(int i=0;i<ids.length;i++){
            Document doc=new Document();
, Z! v! V# P7 H$ j+ G7 X6 O9 r            doc.add(new StringField("id", ids, Field.Store.YES));
            doc.add(new StringField("city",citys,Field.Store.YES));
% Y: o! \5 H: s* z3 O- S$ k. C            doc.add(new TextField("desc", descs, Field.Store.NO));
            writer.addDocument(doc); // 添加文档
& M& I: o( }" ^9 U0 E3 V( d        }
        writer.close();
    }

* K6 r+ l9 x! B    /**
6 ~6 ?9 m* x  F9 }" A$ |     * 获取IndexWriter实例
     * @return
) Z) `4 ]- @0 V     * @throws Exception
     */
    private IndexWriter getWriter()throws Exception{
! f4 E4 M" X' c$ ?: \" g+ C# O        Analyzer analyzer=new StandardAnalyzer(); // 标准分词器
- Z$ A5 I* j. `0 h! J4 o8 ]        IndexWriterConfig iwc=new IndexWriterConfig(analyzer);
: k' k# _' S. |* z& I        IndexWriter writer=new IndexWriter(dir, iwc);
$ W- K! e3 @! t3 `9 g        return writer;
  V; b; E1 F8 n) k4 [0 @  D7 Y5 g    }

  X1 W3 G7 \& k1 y0 {    /**
     * 测试写了几个文档
     * @throws Exception
- @/ t7 n' I( ]$ _( l! G     */
    @Test
    public void testIndexWriter()throws Exception{
6 g- C+ \$ Q3 P' I' k        IndexWriter writer=getWriter();
1 V0 w' x- V: h5 ^* H) v        System.out.println("写入了"+writer.numDocs()+"个文档");
        writer.close();
    }

3 ?+ x  b! ]. z    /**
     * 测试读取文档
     * @throws Exception
) D7 U5 y5 ?1 ]$ G, \) U: L     */
% f3 b1 u# d# \' `    @Test
    public void testIndexReader()throws Exception{
0 B) [9 L' s- A) q" |        IndexReader reader=DirectoryReader.open(dir);
        System.out.println("最大文档数："+reader.maxDoc());
0 O& P4 T8 s! Z  _8 W' B        System.out.println("实际文档数："+reader.numDocs());
        reader.close();
% V) R& h3 f" U% O# _0 Q7 p/ u& m    }
" a' I' m" a% q" n( ~  @
9 w8 N9 A, M5 B5 ~' [, j  z    /**
7 ~3 E  k. P: Y' s; A     * 测试删除 在合并前
     * @throws Exception
* M+ _, {$ [1 w% v, {; H- U     */
# b' I& A3 T. d$ a) \# c8 s    @Test
% F, ]' \( w% x* b: F7 d    public void testDeleteBeforeMerge()throws Exception{
6 z$ l2 R3 N6 s" E9 N- M& M; K        IndexWriter writer=getWriter();
        System.out.println("删除前："+writer.numDocs());
        writer.deleteDocuments(new Term("id","1"));
        writer.commit();
        System.out.println("writer.maxDoc()："+writer.maxDoc());
        System.out.println("writer.numDocs()："+writer.numDocs());
        writer.close();
8 u* m/ O2 X% j. N    }

    /**
     * 测试删除 在合并后
     * @throws Exception
     */
    @Test
    public void testDeleteAfterMerge()throws Exception{
- f, H8 |) ]2 J* b$ e: I1 x        IndexWriter writer=getWriter();
. Q% ?+ A8 w0 T0 O# H: v        System.out.println("删除前："+writer.numDocs());
& [1 G8 z& l3 d+ N1 [        writer.deleteDocuments(new Term("id","1"));
3 s7 ]5 S& T' I- g' U. ?        writer.forceMergeDeletes(); // 强制删除
        writer.commit();
' v2 J( B' a- f4 A; |$ J6 s) `  y        System.out.println("writer.maxDoc()："+writer.maxDoc());
        System.out.println("writer.numDocs()："+writer.numDocs());
8 m0 B+ w: s. W; m/ m        writer.close();
1 E( R) u% N( p5 p3 x    }
# `; y) Z. G" |& ?, A
  f7 {4 W% y- c9 I3 x6 ^    /**
3 O3 f3 x2 k! n  j6 r% [; D5 u3 J     * 测试更新
     * @throws Exception
     */
    @Test
    public void testUpdate()throws Exception{
        IndexWriter writer=getWriter();
6 E9 o, L% t4 T# U        Document doc=new Document();
1 O, p9 {8 U3 P        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));
        writer.updateDocument(new Term("id","1"), doc);
" r% J2 i7 k7 o  O; Z& S( X        writer.close();
    }
  p, g0 q  T& C$ b& K* L3 Z}

, M1 w7 @' B' L2 E# c) L

学java来尚学堂

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