package com.cmy.lucene.lucene;

import java.io.File;

import java.io.FileReader;

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.TextField;

import org.apache.lucene.index.IndexWriter;

import org.apache.lucene.index.IndexWriterConfig;

import org.apache.lucene.store.Directory;

import org.apache.lucene.store.FSDirectory;

public class Indexer {

    private IndexWriter writer;

    /**

     * 构造方法,实例化indexwriter

     * @param indexDir

     * @throws Exception

     */

    public Indexer(String indexDir) throws Exception{

        Directory directory  = FSDirectory.open(Paths.get(indexDir));

        Analyzer analyzer = new StandardAnalyzer();//标准分词器

        IndexWriterConfig indexWriterConfig = new IndexWriterConfig(analyzer);

        writer = new IndexWriter(directory, indexWriterConfig);

    }

    /**

     *

     * @throws Exception

     */

    public void close() throws Exception{

        writer.close();

    }

    /**

     *

     * @param dataDir

     * @throws Exception

     */

    public int index(String dataDir) throws Exception{

        File []files = new File(dataDir).listFiles();

        for(File file:files){

            IndexFile(file);

        }

        return writer.numDocs();//返回索引文件的数量

    }

    /**

     * 索引指定文件

     * @param file

     * @throws Exception

     */

    private void IndexFile(File file) throws Exception {

        System.out.println("索引文件:"+file.getCanonicalPath());//返回规范化的绝对路径

        Document document = getDocument(file);

        writer.addDocument(document);;

    }

    /**

     * 获取文档,文档里再设置每个字段

     * @param file

     * @return

     */

    private Document getDocument(File file) throws Exception{

        Document document = new Document();//定义文档对象

        document.add(new TextField("contents",new FileReader(file)));//在文档中引入字段(key,value)形式

        document.add(new TextField("fileName",file.getName(),Field.Store.YES));

        document.add(new TextField("fullPath",file.getCanonicalPath(),Field.Store.YES));

        return document;

    }

    public static void main(String[] args) {

        String indexDir = "D:\\lucene";

        String dataDir = "E:\\JavaEE\\luceneData";

        Indexer indexer = null;

        int numIndexed = 0;

        long start = System.currentTimeMillis();

        try {

            indexer = new Indexer(indexDir);

            numIndexed = indexer.index(dataDir);

        } catch (Exception e) {

            e.printStackTrace();

            e.printStackTrace();

        }finally {

            try {

                indexer.close();

            } catch (Exception e2) {

                e2.printStackTrace();

            }

        }

        long end = System.currentTimeMillis();

        System.out.println("索引: "+numIndexed+" 个文件,话费了"+(end-start)+" s");

    }

}

package com.cmy.lucene.lucene;

import java.nio.channels.ScatteringByteChannel;

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.index.DirectoryReader;

import org.apache.lucene.index.IndexReader;

import org.apache.lucene.queryparser.classic.QueryParser;

import org.apache.lucene.search.IndexSearcher;

import org.apache.lucene.search.Query;

import org.apache.lucene.search.ScoreDoc;

import org.apache.lucene.search.TopDocs;

import org.apache.lucene.store.Directory;

import org.apache.lucene.store.FSDirectory;

public class Searcher {

    public static void search(String indexDir,String qString) throws Exception{

        Directory directory = FSDirectory.open(Paths.get(indexDir));

        IndexReader reader = DirectoryReader.open(directory);//读取完整路径下的reader

        IndexSearcher iSearcher = new IndexSearcher(reader);//索引查询器，参数是Indexreader

        Analyzer analyzer = new StandardAnalyzer();//标准分词器

        QueryParser parser = new QueryParser("contents", analyzer);//解析制定内容，使用制定分词器

        Query query = parser.parse(qString);

        long start = System.currentTimeMillis();

        TopDocs hits = iSearcher.search(query, 10);//传入query对象，返回的数据数量，此处返回前十条，哎，那总该有个顺序吧，怎么搞

        long end = System.currentTimeMillis();

        System.out.println("匹配"+qString+",总共花费"+(end-start)+" 毫秒");

        //遍历结果集，获取文档

        for(ScoreDoc scoreDoc:hits.scoreDocs){

            Document document = iSearcher.doc(scoreDoc.doc);//获取结果集中的doc主键（id）并据此查询获取文档对象

            System.out.println("fullPath: "+document.get("fullPath"));//获取完整的fullPath，

        }

        reader.close();

    }

    public static void main(String[] args) {

        String indexDir = "D:\\lucene";

        String dataDir = "Zygmunt Saloni";

        try {

            search(indexDir,dataDir);

        } catch (Exception e) {

            e.printStackTrace();

        }

    }

}