引言

前面介绍了一些Lucene的基本知识，但是不用代码实现总是觉得不踏实，下面我们就完成Lucene的基本操作；

第一、导入所需jar包

上面jar包是本文中所用到的示例所需的jar包

第二、创建索引

  // 创建索引
  @Test
  public void testIndex() throws Exception {
    // 第一步：创建一个java工程，并导入jar包。
    // 第二步：创建一个indexwriter对象。
    Directory directory = FSDirectory.open(new File("D:\\temp\\index"));
    // 创建索引分析器
    Analyzer analyzer = new IKAnalyzer();// 官方推荐
    // 当项目中有多个lucene包的时候，需要在下面指定使用的版本
    IndexWriterConfig config = new IndexWriterConfig(Version.LATEST, analyzer);
    IndexWriter indexWriter = new IndexWriter(directory, config);
    // 1）指定索引库的存放位置Directory对象
    // 2）指定一个分析器，对文档内容进行分析。
    // 第三步：创建field对象，将field添加到document对象中。
    File f = new File("D:\\Lucene");
    // 获得路径下面的所有的文件
    File[] listFiles = f.listFiles();
    for (File file : listFiles) {
      // 第三步创建document对象
      Document document = new Document();
      String file_name = file.getName();
      // 创建域
      Field fileNameField = new TextField("fileName", file_name, Store.YES);
      long file_size = FileUtils.sizeOf(file);
      Field fileSizeField = new LongField("fileSize", file_size, Store.YES);
      // 文件路径
      String file_path = file.getPath();
      Field filePathField = new StoredField("filePath", file_path);
      // 文件内容
      String file_content = FileUtils.readFileToString(file);
      Field fileContentField = new TextField("fileContent", file_content, Store.NO);
      document.add(fileNameField);
      document.add(fileSizeField);
      document.add(filePathField);
      document.add(fileContentField);
      // 第四步 使用 indexwriter对象将docum对象写人索引库，此过程进行索引创建。并将索引和document对象写入索引库
      indexWriter.addDocument(document);
    }
    // 第五步： 关闭indexwriter对象
    indexWriter.close();
  }

注意：D:\\temp\\index这个路径是我们创建的索引存储的位置，如果此路径不存在，程序会自动创建D:\\Lucene 这个路径是我需要搜索的文件所在的位置

我们可以通过lukeall-4.10.3.jar查看，请读者自行下载！

第三、搜索索引

      // 搜索索引
  @Test
  public void testSearch() throws Exception {
    // 第一步：创建一个Directory对象，也就是索引库存放的位置。
    Directory directory = FSDirectory.open(new File("D:\\temp\\index"));
    // 第二步：创建一个indexReader对象，需要指定Directory对象。
    IndexReader indexReader = DirectoryReader.open(directory);
    // 第三步：创建一个indexsearcher对象，需要指定IndexReader对象
    IndexSearcher indexSearcher = new IndexSearcher(indexReader);
    // 第四步：创建一个TermQuery对象，指定查询的域和查询的关键词。
    Query query = new TermQuery(new Term("fileName", "quartz.txt"));
    // 第五步：执行查询。
    TopDocs topDocs = indexSearcher.search(query, 10);
    // 第六步：返回查询结果。遍历查询结果并输出。
    ScoreDoc[] scoreDocs = topDocs.scoreDocs;
    for (ScoreDoc scoreDoc : scoreDocs) {
      int doc = scoreDoc.doc;
      Document document = indexSearcher.doc(doc);
      // 文件名称
      String fileName = document.get("fileName");
      System.out.println(fileName);
      // 文件内容
      String fileContent = document.get("fileContent");
      System.out.println(fileContent);
      // 文件大小
      String fileSize = document.get("fileSize");
      System.out.println(fileSize);
      // 文件路径
      String filePath = document.get("filePath");
      System.out.println(filePath);
      System.out.println("------------");
    }
    indexReader.close();
  }

这里需要注意：创建索引和搜索时所用的分词器必须一致(才能匹配)

为了更好的展示我们的基本操作代码，我们讲创建indexSearcher对象的代码和查看查询结果的代码抽离

// 抽离创建indexSearcher对象的代码
  public IndexSearcher getIndexSearcher() throws Exception {
    Directory directory = FSDirectory.open(new File("D:\\temp\\index"));
    IndexReader indexReader = DirectoryReader.open(directory);
    return new IndexSearcher(indexReader);
  }
  // 抽离执行查询结果的代码
  public void printResult(IndexSearcher indexSearcher, Query query) throws Exception {
    // 第五步：执行查询。
    TopDocs topDocs = indexSearcher.search(query, 10);
    // 第六步：返回查询结果。遍历查询结果并输出。
    ScoreDoc[] scoreDocs = topDocs.scoreDocs;
    for (ScoreDoc scoreDoc : scoreDocs) {
      int doc = scoreDoc.doc;
      Document document = indexSearcher.doc(doc);
      // 文件名称
      String fileName = document.get("fileName");
      System.out.println(fileName);
      // 文件内容
      String fileContent = document.get("fileContent");
      System.out.println(fileContent);
      // 文件大小
      String fileSize = document.get("fileSize");
      System.out.println(fileSize);
      // 文件路径
      String filePath = document.get("filePath");
      System.out.println(filePath);
      System.out.println("------------");
    }
  }

下面展示几种基本查询：

// 查询所有的资源
  @Test
  public void testMatchAllDocsQuery() throws Exception {
    IndexSearcher indexSearcher = getIndexSearcher();
    Query query = new MatchAllDocsQuery();
    System.out.println(query);
    printResult(indexSearcher, query);
    indexSearcher.getIndexReader().close();
  }
  // 根据数值范围查询
  @Test
  public void testNumericRangeQuery() throws Exception {
    IndexSearcher indexSearcher = getIndexSearcher();
    Query query = NumericRangeQuery.newLongRange("fileSize", 47L, 200L, false, true);
    System.out.println(query);
    printResult(indexSearcher, query);
    // 关闭资源
    indexSearcher.getIndexReader().close();
  }
  // 组合条件查询
  @Test
  public void testBooleanQuery() throws Exception {
    IndexSearcher indexSearcher = getIndexSearcher();
    BooleanQuery booleanQuery = new BooleanQuery();
    Query query1 = new TermQuery(new Term("fileName", "apache"));
    Query query2 = new TermQuery(new Term("fileName", "lucene"));
    booleanQuery.add(query1, Occur.MUST);
    booleanQuery.add(query2, Occur.SHOULD);
    printResult(indexSearcher, booleanQuery);
    // 关闭资源
    indexSearcher.getIndexReader().close();
  }
  // 条件查询
  @Test
  public void testQueryParser() throws Exception {
    IndexSearcher indexSearcher = getIndexSearcher();
    // 参数1：默认查询域
    // 参数2 采用分析器
    QueryParser queryParser = new QueryParser("fileName", new IKAnalyzer());
    // *:* 域：值
    Query query = queryParser.parse("fileName:paache AND fileName:lucene");
    printResult(indexSearcher, query);
    // 关闭资源
    indexSearcher.getIndexReader().close();
  }
  // 条件解析的对象查询 多个默认域
  @Test
  public void testMultiFieldQueryParser() throws Exception {
    IndexSearcher indexSearcher = getIndexSearcher();
    String[] fields = { "fileName", "fileContent" };
    // 参数1： 默认查询的域
    // 参数2：采用的分析器
    MultiFieldQueryParser queryParser = new MultiFieldQueryParser(fields, new IKAnalyzer());
    // *:* 域：值
    Query query = queryParser.parse("lucene is apache");
    printResult(indexSearcher, query);
    // 关闭资源
    indexSearcher.getIndexReader().close();
  }

第四、删除和修改

抽离创建IndexWriter对象的代码

public IndexWriter getIndexWriter() throws Exception {
    // 第一步：创建一个java工程，并导入jar包。
    // 第二步：创建一个indexwriter对象。
    Directory directory = FSDirectory.open(new File("D:\\temp\\index"));
    Analyzer analyzer = new StandardAnalyzer();// 官方推荐
    IndexWriterConfig config = new IndexWriterConfig(Version.LATEST, analyzer);
    return new IndexWriter(directory, config);
  }

// 根据条件删除
  @Test
  public void testDelete() throws Exception {
    IndexWriter indexWriter = getIndexWriter();
    Query query = new TermQuery(new Term("fileName", "lucene.txt"));
    indexWriter.deleteDocuments(query);
    indexWriter.close();
  }
  // 修改
  @Test
  public void testUpdate() throws Exception {
    IndexWriter indexWriter = getIndexWriter();
    Document doc = new Document();
    doc.add(new TextField("fileN", "测试文件名", Store.YES));
    doc.add(new TextField("fileC", "测试文件内容", Store.YES));
    indexWriter.updateDocument(new Term("fileName", "quartz.txt"), doc, new IKAnalyzer());
    indexWriter.close();
  }

修改的本质就是增加，如果document存在则是修改的操作结果，若果document不存在则是增加的操作结果

小结

上面是基于Lucene的对应document的操作，我们可看出来这个的过程非常的麻烦，所以说如果我们在实际项中采用这个方案，会非常的影响开发效率，就好像我们采用原生servlet来开发java项目一样，所以这就需要一个框架来简化这个开发过程，于是solr就出现了。你说是“时势造英雄”呢？还是“英雄造时势”呢？下篇博客讲解solr的基本知识！

Lucene的基本操作

小结

热门文章

最新文章

相关电子书