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

javazx · 发表于 2016-6-20 14:48:56

1、源码
import 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;
import org.apache.lucene.index.DirectoryReader;
import org.apache.lucene.index.IndexReader;
import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.index.IndexWriterConfig;
import org.apache.lucene.index.Term;
import org.apache.lucene.store.Directory;
import org.apache.lucene.store.FSDirectory;
import org.junit.Before;
import org.junit.Test;

public class IndexingTest {

private String ids[]={"1","2","3"};
private String citys[]={"qingdao","nanjing","shanghai"};
private String descs[]={
         "Qingdao is a beautiful city.",
         "Nanjing is a city of culture.",
         "Shanghai is a bustling city."
};

private Directory dir;

@Before
public void setUp() throws Exception {
      dir=FSDirectory.open(Paths.get("D:\\lucene2"));
      IndexWriter writer=getWriter();
      for(int i=0;i<ids.length;i++){
         Document doc=new Document();
         doc.add(new StringField("id", ids, Field.Store.YES));# u! L+ H; w* T; ?. S  q' o
         doc.add(new StringField("city",citys,Field.Store.YES));- B0 f9 ~* y& J% ]. A. U6 C
         doc.add(new TextField("desc", descs, Field.Store.NO));
         writer.addDocument(doc); // 添加文档
5 A3 |9 j8 e  x# b) U9 D$ c1 ]       }
! ]# h6 V/ D. u' y7 z6 h       writer.close();& ~) g# C% U4 o2 U
}
. b5 b7 \. T1 q6 ?
, Y7 R' [0 a: r /**
9 t" Y0 J! L5 O% `6 i$ m" ~# x6 C. O    * 获取IndexWriter实例
4 B  |0 B: ^/ e- N' H$ \    * @return6 U% k, w/ k4 ?  d2 Y7 ?/ t( Z0 l4 e
   * @throws Exception# q+ B& ^8 r  r0 R4 H8 g
   */
0 ^1 l. L) |# ~3 j1 i8 @ private IndexWriter getWriter()throws Exception{
3 I, d4 r1 v$ Y7 G       Analyzer analyzer=new StandardAnalyzer(); // 标准分词器
. j1 U% i* }5 u4 L: M9 s! Q" I       IndexWriterConfig iwc=new IndexWriterConfig(analyzer);
+ b" U+ k4 k, `# c/ {       IndexWriter writer=new IndexWriter(dir, iwc);1 K; m7 K0 s) A3 q& _% d: g
      return writer;; `9 p) M2 B8 W
}
6 D6 f) W3 r" ?0 F$ H3 e( V+ c. T0 ~  r( Z
/**8 }# n$ g0 {) c# Y
   * 测试写了几个文档
2 }) z) c# k$ r2 ?    * @throws Exception
3 P8 G- B* b- _& c    */+ U. |& X8 T! k( l, F
@Test
, {) X: b& B+ B( N- s public void testIndexWriter()throws Exception{
2 J" b" z( n- Q       IndexWriter writer=getWriter();
8 b" I) Z% t" w! j       System.out.println("写入了"+writer.numDocs()+"个文档");
$ s" g, i' V1 H, |  P# W  @" S8 z       writer.close();2 t5 U4 j/ i; m! c9 D7 D$ f( Q
}
* d7 \; F, i5 n, [" Q" L1 v
7 v, \3 \. B  V6 N /**+ n4 V% P; F1 m8 O0 X
   * 测试读取文档9 x" D1 L* D, B' e1 R* v
   * @throws Exception
: B6 g2 U) r. F8 j9 D+ N    */- f$ B. w) X* j# z' }% H
@Test
7 I  _; ^0 K0 Z9 ?4 N: ` public void testIndexReader()throws Exception{2 P# {) }9 S* T  e
      IndexReader reader=DirectoryReader.open(dir);# b& p" t7 N0 m( V5 Y
      System.out.println("最大文档数："+reader.maxDoc());
6 O$ ~" l; r5 p0 m       System.out.println("实际文档数："+reader.numDocs());. t6 y/ X' D  o( ~
      reader.close();4 D0 {% c! |. Z4 b/ m* g& K; }
}/ C7 V' T$ v. B" ]* h  Q! Y

! i0 \/ q& ~4 v: Q" O /**
! Y! c; w% G, F0 C! D/ `4 z3 t2 G    * 测试删除在合并前, n5 K2 n7 w1 U0 X/ V; t- l
   * @throws Exception
7 {) K% g- w. q, [) ~$ N7 B    */$ F2 _) a! R$ K: `
@Test% `- d7 u2 P2 ]( G4 G/ M4 C$ f1 H
public void testDeleteBeforeMerge()throws Exception{4 R) u) U8 M8 ^; }& g7 S
      IndexWriter writer=getWriter();
4 U! _+ M+ p1 m       System.out.println("删除前："+writer.numDocs());
' ?4 j! d1 o5 |$ W7 a       writer.deleteDocuments(new Term("id","1"));" G( [5 D1 _/ s8 i: ?
      writer.commit();5 ]7 |  f5 I+ d
      System.out.println("writer.maxDoc()："+writer.maxDoc());
1 w+ e- t) c' m1 m" `+ r       System.out.println("writer.numDocs()："+writer.numDocs());, s8 w+ u0 d. r. |3 x
      writer.close();
7 i$ v( \! @" l# `' S$ ] }
" P0 `# s4 i: I7 L# N3 p3 e1 j
( G* W: ^3 V. b4 a% u* x2 M1 o /**6 d: a5 _2 A: O- @
   * 测试删除在合并后+ h6 Y* O: A2 M7 t4 h7 d
   * @throws Exception, Z$ ~# w% P+ K( `' _
   */
8 N) s* b# ~# c" p! [. ]8 F @Test' A! F- R- D5 |6 C/ c# ~* G4 X9 d: p
public void testDeleteAfterMerge()throws Exception{$ x! Y- D' C" ~: R/ b. E
      IndexWriter writer=getWriter();
- Q) Q  o* V9 ]" r( k- o       System.out.println("删除前："+writer.numDocs());
9 f* E* P1 S6 }/ B       writer.deleteDocuments(new Term("id","1"));
. v  d% q6 z% O4 I       writer.forceMergeDeletes(); // 强制删除
! P3 H& H% }+ P& |: O8 B& e- W! K, |       writer.commit();
' N4 b1 K+ T4 h* D       System.out.println("writer.maxDoc()："+writer.maxDoc());
8 H1 b, D5 g8 }; W# i& T3 B       System.out.println("writer.numDocs()："+writer.numDocs());
% J/ K" |3 g# A       writer.close();- N  s. j, j: m0 V3 Z
}
- e8 E" ~0 C3 C/ W4 t
; W! i9 h0 w$ C, `& ` /**8 F. A4 t# j- A6 f0 Z, G, Q" a' i4 W+ j
   * 测试更新0 \! L5 f- P) \6 F7 o8 R- x
   * @throws Exception
" M+ T7 ]3 |+ s% a. l    */
4 {3 B+ D/ h# I* o- Z' R @Test
1 n" ~& f0 d& b: z+ z public void testUpdate()throws Exception{( j" b' ?5 h% N) ~% x5 B
      IndexWriter writer=getWriter();
2 d8 q; @7 |" m" v1 r       Document doc=new Document();
' r1 b" }3 t7 a$ a+ {* A" y+ ~3 Y9 ^       doc.add(new StringField("id", "1", Field.Store.YES));
+ y# q" g, [' Q       doc.add(new StringField("city","qingdao",Field.Store.YES));, }" V# J$ z  j0 D( z1 w& M. o
      doc.add(new TextField("desc", "dsss is a city.", Field.Store.NO));
" v' [: W3 }0 |$ L! ]3 j       writer.updateDocument(new Term("id","1"), doc);& `1 h. z4 X# R7 w1 K
      writer.close();2 X2 A) t# ?) f" T" A# b- [
}9 }; E/ {( O  T/ L4 U
}
5 ]( l" u; Z9 ?9 t
& _' x2 U( ~1 e" G8 ?/ G# ^$ t  o) C: y( `9 o# W

9 M" _: o. n/ y

学java来尚学堂 · 发表于 2016-10-29 14:17:08

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

		自动登录	找回密码
密码			立即注册

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

相关帖子

宣传达人

突出贡献

优秀版主

荣誉管理

论坛元老