Lucene快速入门

public class IndexManager {
    @Test
    public void createIndex() throws Exception {
        // 采集数据, 这里是从数据库
        BookDao dao = new BookDaoImpl();
        List<Book> list = dao.queryBooks();
        // 封装到Document对象中
        List<Document> docList = new ArrayList<>();
        Document document = null;
       
　　 for (Book book : list) {
            document = new Document();
            // 创建field, filed类型详解见下
            // 不分词、索引、存储 
            Field id = new StringField("id", book.getId().toString(), Store.YES); // store:如果是yes，则说明存储到文档域中
            // 分词、索引、存储 
            Field name = new TextField("name", book.getName(), Store.YES);
            // 分词、索引、存储 
            Field price = new FloatField("price", book.getPrice(), Store.YES);
            // 不分词、不索引、存储
            Field pic = new StoredField("pic", book.getPic());
            // 分词、索引、不存储 
            Field description = new TextField("description", book.getDescription(), Store.NO);

            // 建立索引时设置boost值, 能改变查询结果优先级(default:1.0f)
            if (book.getId() == 4)
                description.setBoost(100f);
         
　　　　　   // 将field域设置到Document对象中
            document.add(id);
            document.add(name);
            document.add(price);
            document.add(pic);
            document.add(description);

            docList.add(document);
        }
    
        // 定义索引目录流, 指定索引库保存地址. FSDirectory:文件系统中存储; RAMDirectory:内存中存储
        File indexDir = new File("D:\\index\\");
        Directory directory = FSDirectory.open(indexDir);
        

　　　　// 创建分词器和基本配置. StandardAnalyzer标准分词器
        Analyzer analyzer = new StandardAnalyzer();
        IndexWriterConfig config = new IndexWriterConfig(Version.LUCENE_4_10_3, analyzer);
       
　　　　 // 创建IndexWriter, 需要目录流+设置
        IndexWriter writer = new IndexWriter(directory, config);
        // 通过IndexWriter将Document写入到索引库中
        for (Document doc : docList) {
            writer.addDocument(doc);
        }

        // 关闭writer
        writer.close();
    }
}

public class IndexSearch {

    @Test
    public void indexSearch() throws Exception {
        // 创建QueryParser
        // 第一参数:设置默认!搜索域的名称; 第二参数:分词器(搜索与索引的分词器需相同)
        QueryParser parser = new QueryParser("description", new StandardAnalyzer());

        // 创建query对象 (关键字AND一定要大写), 语句指定了查询的域
        Query query = parser.parse("description:java AND lucene");

        doSearch(query);
    }
    
    private void doSearch(Query query) {
        try {
            // 创建IndexReader, 需要目录流
            File indexDir = new File("D:\\index\\");
            Directory directory = FSDirectory.open(indexDir);
            IndexReader reader = DirectoryReader.open(directory);
            // 创建IndexSearcher
            IndexSearcher searcher = new IndexSearcher(reader);
            // 通过searcher来搜索索引库
            // 通过IndexSearcher搜索索引库. 第二参数：选出头N条记录
            TopDocs topDocs = searcher.search(query, 10);
            
            // 打分文档(和排序有关).   另, topDocs.totalHits能获得匹配查询条件的总记录数
            ScoreDoc[] scoreDocs = topDocs.scoreDocs;

            for (ScoreDoc scoreDoc : scoreDocs) {
                // 获取文档ID
                int docId = scoreDoc.doc;
                // 通过文档ID获取文档
                Document doc = searcher.doc(docId);
                
                System.out.println("商品ID：" + doc.get("id"));
                System.out.println("商品名称：" + doc.get("name"));
                System.out.println("商品价格：" + doc.get("price"));
                System.out.println("商品图片地址：" + doc.get("pic"));
            }
            // 关闭资源
            reader.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

public class IndexSearch {

    @Test
    public void termQuery() {
        // 创建TermQuery对象
        Query query = new TermQuery(new Term("description", "java"));
        doSearch(query);
    }

    @Test
    public void numericRangeQuery() {
        // 创建NumericRangeQuery对象
        // 参数：域的名称、最小值、最大值、是否包含最小值、是否包含最大值
        Query query = NumericRangeQuery.newFloatRange("price", 55f, 60f, true, false);
        doSearch(query);
    }

    @Test
    public void booleanQuery() {
        // 创建BooleanQuery
        BooleanQuery query = new BooleanQuery();
        // 创建TermQuery对象
        Query q1 = new TermQuery(new Term("description", "lucene"));
        // 创建NumericRangeQuery对象
        Query q2 = NumericRangeQuery.newFloatRange("price", 55f, 60f, true, false);

        // 组合关系代表的意思如下:
        // 1、MUST和MUST: 与, 交集
        // 2、SHOULD与SHOULD: 或, 并集
        // 3、MUST A和MUST_NOT B: 包含前者不包含后者 A-B
        // 4、SHOULD A与MUST B相当于MUST B, SHOULD失去作用
        // 5、SHOUlD与MUST_NOT相当于MUST与MUST_NOT
        // 6、MUST_NOT和MUST_NOT无意义
        query.add(q1, Occur.MUST_NOT);
        query.add(q2, Occur.MUST_NOT);

        doSearch(query);
    }



    @Test
    public void multiFieldQueryParser() throws Exception {
        // 创建MultiFieldQueryParser
        // 设置默认!搜索域(多个)
        String[] fields = {"name", "description"};
        Analyzer analyzer = new StandardAnalyzer();  //查询也可以有分词器, 例如查询"lucene java"
        //搜索时设置boost值, 改变查询结果优先级
        Map<String, Float> boosts = new HashMap<String, Float>();
        boosts.put("name", 200f);
        
        MultiFieldQueryParser parser = new MultiFieldQueryParser(fields, analyzer, boosts);

        Query query1 = parser.parse("name:lucene OR description:lucene");
        Query query2 = parser.parse("lucene");  // 设置了默认搜索域, 等效于query1 

        doSearch(query2);
    }
}

public class IndexManager {
    // 增或改
    @Test
    public void updateIndex() throws Exception {
        // 创建IndexWriter
        Directory directory = FSDirectory.open(new File("D:\\index\\"));
        Analyzer analyzer = new StandardAnalyzer();
        IndexWriterConfig config = new IndexWriterConfig(Version.LUCENE_4_10_3, analyzer);
        IndexWriter writer = new IndexWriter(directory, config);

        // 创建一个新的Document
        Document doc = new Document();
        doc.add(new TextField("name", "lisi", Store.YES));
        // 更新Document. 第一个参数：指定查询条件; 第二个参数：修改后的对象
        // 能查询出结果，则先删除，再添加Document对象; 没有查询出结果，则新增一个Document
        writer.updateDocument(new Term("name", "zhangsan"), doc);

        writer.close();
    }
    
    // 删
    @Test
    public void deleteIndex() throws Exception {
        // 创建IndexWriter
        Directory directory = FSDirectory.open(new File("D:\\index\\"));
        Analyzer analyzer = new StandardAnalyzer();
        IndexWriterConfig config = new IndexWriterConfig(Version.LUCENE_4_10_3, analyzer);
        IndexWriter writer = new IndexWriter(directory, config);
        
        // 先根据Term查询, 再删除
        // 删除索引文档记录, 建议用唯一键删, 否则可能会删除多条记录.  writer.deleteAll删除全部索引
        writer.deleteDocuments(new Term("id", "1"));

        writer.close();
    }    
}