Lucene的基本使用

 1 //创建索引 2 @Test 3 public void testIndex() throws IOException { 4 ????//1. ?采集数据：(jdbc采集数据通过BookDao调用方法得到结果集) 5 ????BookDaoImpl dao = new BookDaoImpl(); 6 ????List<Book> bookList = dao.queryBookList(); 7 ?8 ????//2. ?遍历book结果集，组装Document数据列表 9 ????for (Book book : bookList) {10 ?????????Document doc = new Document();11 ?????????//3. ?构建Field域，说白了就是将要存储的数据字段需要用到new TextField对象三个参数的构造方法，book中有多个字段，所以创建多个Field对象。12 ?????????//参数一:域的名称,可随意起;参数二:域对应的值;参数三:是否存储13 ?????????/*Field id = new TextField("id", book.getId().toString(), Field.Store.YES);14 ?????????Field name = new TextField("name",book.getName(), Field.Store.YES);15 ?????????Field price = new TextField("price",book.getPrice().toString(), Field.Store.YES);16 ?????????Field pic = new TextField("pic",book.getPic(), Field.Store.YES);17 ?????????Field description = new TextField("description",book.getDescription(), Field.Store.YES);*/18 19 ?????????//id不分词 要索引 要存储20 ?????????Field id = new StringField("id", book.getId().toString(), Field.Store.YES);21 ?????????// name 要分词 要索引 要存储22 ?????????Field name = new TextField("name", book.getName(), Field.Store.YES);23 ?????????// price 要分词 要索引 要存储,数字比较特殊24 ?????????Field price = new FloatField("price", book.getPrice(), Field.Store.YES);25 ?????????// pic 不分词 不索引 要存储26 ?????????Field pic = new StoredField("pic", book.getPic());27 ?????????// description 要分词 要索引 不存储28 ?????????Field description = new TextField("description", book.getDescription(), Field.Store.NO);29 30 ?????????//4. ?将Field域所有对象，添加到文档对象中。调用Document.add31 ?????????doc.add(id);32 ?????????doc.add(name);33 ?????????doc.add(price);34 ?????????doc.add(pic);35 ?????????doc.add(description);36 37 ?????????//5. ?创建一个标准分词器(Analyzer与StandardAnalyzer)，对文档中的Field域进行分词38 ?????????StandardAnalyzer analyzer = new StandardAnalyzer();39 ?????????//6. ?指定索引储存目录，使用FSDirectory.open()方法。40 ?????????FSDirectory directory = FSDirectory.open(new File("/Users/Shared/index"));41 ?????????//7. ?创建IndexWriterConfig对象，直接new，用于接下来创建IndexWriter对象42 ?????????IndexWriterConfig config = new IndexWriterConfig(Version.LATEST, analyzer);43 ?????????//8. ?创建IndexWriter对象，直接new44 ?????????IndexWriter writer = new IndexWriter(directory, config);45 ?????????//9. ?添加文档对象到索引库输出对象中，使用IndexWriter.addDocuments方法46 ?????????writer.addDocument(doc);47 ?????????//10. ?释放资源IndexWriter.close();48 ?????????writer.close();49 ?????}50 }

 1 //搜索 2 @Test 3 public void testQuery() throws IOException { 4 ?????// 1. ?创建一个Directory对象，FSDirectory.open指定索引库存放的位置 5 ?????FSDirectory directory = FSDirectory.open(new File("/Users/Shared/index")); 6 ?????// 2. ?创建一个IndexReader对象，DirectoryReader.open需要指定Directory对象 7 ?????IndexReader indexReader = DirectoryReader.open(directory); 8 ?????// 3. ?创建一个Indexsearcher对象，直接new，需要指定IndexReader对象 9 ?????IndexSearcher indexSearcher = new IndexSearcher(indexReader);10 ?????// 4. ?创建一个TermQuery对象，直接new，指定查询的域和查询的关键词new Term(域名称，关键词)11 ?????TermQuery query = new TermQuery(new Term("name", "java"));12 ?????// 5. ?执行查询，IndexSearcher.search，需要指定TermQuery对象与查询排名靠多少名前的记录数，得到结果TopDocs13 ?????TopDocs docs = indexSearcher.search(query, 10);14 ?????// 6. ?遍历查询结果并输出，TopDocs.totalHits总记录数，topDocs.scoreDocs数据列表，通过scoreDoc.doc得到唯一id,再通过IndexSearcher.doc(id)，得到文档对象Document再Document.get(域名称)得到结果15 ?????System.out.println("查询总记录数为:"+docs.totalHits);16 ?????for (ScoreDoc scoreDoc : docs.scoreDocs) {17 ?????????//得到文档18 ?????????int id = scoreDoc.doc;19 ?????????Document doc = indexSearcher.doc(id);20 ?????????System.out.println("id:"+doc.get("id"));21 ?????????System.out.println("name:"+doc.get("name"));22 ?????????System.out.println("price:"+doc.get("price"));23 ?????????System.out.println("pic:"+doc.get("pic"));24 ?????????System.out.println("description:"+doc.get("description"));25 ??????}26 ?????// 7. ?关闭IndexReader对象27 ?????indexReader.close();28 }

1 @Test2 public void testFindall() throws Exception{3 ????//matachalldocsquery4 ????Query query = new MatchAllDocsQuery();5 ????//创建一个indexSearcher 对象6 ????//通过indexSearcher 调用search方法查询7 ????doSearcherBy(query);8 }

1 @Test2 public void testTermQuery() throws IOException {3 　　TermQuery termQuery = new TermQuery(new Term("name", "apache"));4 　　doSearchBy(termQuery);5 }

 1 @Test 2 public void testNumbericRange() throws IOException{ 3 　　//第一个参数：域的名称 4 　　//第二个参数：最小值 5 　　//第三个参数：最大值 6 　　//第四个参数：是否包含最小值 ?7 　　//第五个参数：是否包含最大值 ?8 　　NumericRangeQuery query = NumericRangeQuery.newFloatRange("price", 55f, 60f, false, false); 9 　　doSearcherBy(query);10 }

 1 @Test 2 publicvoid booleanQuery() throws Exception { 3 　　BooleanQuery query = new BooleanQuery(); 4 　　Query query1 = new TermQuery(new Term("id", "3")); 5 　　Query query2 = NumericRangeQuery.newFloatRange("price", 10f, 200f,true, true); 6 　　//MUST：查询条件必须满足，相当于AND 7 　　//SHOULD:查询条件可选，相当于OR 8 　　//MUST_NOT：查询条件不能满足，相当于NOT非 9 　　query.add(query1, Occur.MUST);10 　　query.add(query2, Occur.SHOULD);11 　　System.out.println(query);12 　　doSearcherBy(query);13 }

 1 @Test 2 publicvoidtestMultiFieldQueryParser() throws Exception { 3 　　// 可以指定默认搜索的域是多个 4 　　String[] fields = { "name", "description" }; 5 　　// 创建一个MulitFiledQueryParser对象 6 　　QueryParser parser = new MultiFieldQueryParser(fields, new IKAnalyzer()); 7 　　// 指定查询语法，如果不指定域，就搜索默认的域 8 　　Query query = parser.parse("lucene"); 9 　　// 2、执行搜索10 　　doSearcherBy(query);11 }