package com.itheima.luncence;

 import java.io.File;

 import java.io.IOException;

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

 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.queryparser.classic.QueryParser;

 import org.apache.lucene.search.BooleanClause.Occur;

 import org.apache.lucene.search.BooleanQuery;

 import org.apache.lucene.search.IndexSearcher;

 import org.apache.lucene.search.MatchAllDocsQuery;

 import org.apache.lucene.search.NumericRangeQuery;

 import org.apache.lucene.search.Query;

 import org.apache.lucene.search.ScoreDoc;

 import org.apache.lucene.search.TermQuery;

 import org.apache.lucene.search.TopDocs;

 import org.apache.lucene.store.Directory;

 import org.apache.lucene.store.FSDirectory;

 import org.apache.lucene.util.Version;

 import org.junit.Test;

 import org.wltea.analyzer.lucene.IKAnalyzer;

 /**

  *

  * @author jack cheng

  *

  */

 public class LuceneManager {

     //公共部分保存到索引库

     public IndexWriter getIndexWriter() throws Exception{

         // 1、创建Directory

         // JDK 1.7以后 open只能接收Path

         Directory directory = FSDirectory.open(new File("D:\\BaiduYunDownload\\index"));

         // 2、创建IndexWriter

         Analyzer analyzer = new StandardAnalyzer();

         IndexWriterConfig config = new IndexWriterConfig(Version.LATEST, analyzer);

         IndexWriter indexWriter = new IndexWriter(directory, config);//************

         //indexWriter.deleteAll();// 清除以前的index

         return indexWriter;

     }

     //全删除

     @Test

     public void deleteAll() throws Exception{

         IndexWriter writer = getIndexWriter();

         writer.deleteAll();

         writer.close();

         System.out.println("删除成功");

     }

     //根据条件删除

     @Test

     public void deleteBy() throws Exception{

         IndexWriter writer = getIndexWriter();

         Query query = new TermQuery(new Term("filename", "apache"));

         writer.deleteDocuments(query);;

         writer.close();

         System.out.println("删除成功2");

     }

     //修该

     @Test

     public void update() throws Exception{

         IndexWriter writer = getIndexWriter();

         Document doc = new Document();

         doc.add(new TextField("fileN", "测试文件名",Store.YES));

         doc.add(new TextField("fileC", "测试文件内容",Store.YES));

         writer.updateDocument(new Term("filename", "lucene"), doc, new IKAnalyzer());//删除第一个，加入第二个

         writer.close();

         System.out.println("修该成功");

     }

     //***************************************************************************

     //公共部分读取索引库方法

     public IndexSearcher getIndexSearcher() throws Exception{

         //创建索引库

         Directory directory = FSDirectory.open(new File("D:\\BaiduYunDownload\\index"));

         //创建indexreader

         IndexReader indexReader = DirectoryReader.open(directory);

         //创建Searcher

         IndexSearcher indexSearcher = new IndexSearcher(indexReader);

         return indexSearcher;

     }

     //结果显示(公共部分)

     public void printResult(IndexSearcher indexSearcher,Query query) throws Exception{

         TopDocs topDocs = indexSearcher.search(query, 20);

         int totalHits = topDocs.totalHits;

         System.out.println("记录数" + totalHits);

         // 6、根据TopDocs获取ScoreDoc对象

         ScoreDoc[] scoreDocs = topDocs.scoreDocs;

         for (ScoreDoc scoreDoc : scoreDocs) {

             // 7、根据searcher和ScoreDoc对象获取具体的Document对象

             Document document = indexSearcher.doc(scoreDoc.doc);

             // 8、根据Document对象获取需要的值

             System.out.println("文件名：" + document.get("filename")

             + " " + "文件路径：" + document.get("filepath")

             + "文件大小："+ document.get("filesize")

             + "文件内容：" + document.get("content"));

             System.out.println("-----------------------------------------");

         }

     }

     //查询所有

     @Test

     public void testAll() throws Exception{

         IndexSearcher indexSearcher =getIndexSearcher();

         Query query = new MatchAllDocsQuery();

         printResult(indexSearcher, query);

         //关闭流

         indexSearcher.getIndexReader().close();

     } 

     //更具数据范围查询

     @Test

     public void testnumber() throws Exception{

         IndexSearcher indexSearcher =getIndexSearcher();

         Query query = NumericRangeQuery.newLongRange("filesize", 400l, 1000000l, true, true);

         printResult(indexSearcher, query);

         //关闭流

         indexSearcher.getIndexReader().close();

     }

     //组合查询

         @Test

         public void Booleanquery() throws Exception{

             IndexSearcher indexSearcher =getIndexSearcher();

             BooleanQuery booleanquery = new BooleanQuery();

             TermQuery query2 = new TermQuery(new Term("filename","changes"));

             TermQuery query1 = new TermQuery(new Term("content","changes"));

             booleanquery.add(query2,Occur.MUST);

             booleanquery.add(query1,Occur.MUST);

             printResult(indexSearcher, booleanquery);

             //关闭流

             indexSearcher.getIndexReader().close();

         }

         //解析查询（多看文档）

         @Test

         public void testqueryparser() throws Exception{

             IndexSearcher indexSearcher =getIndexSearcher();

             QueryParser queryParser = new QueryParser("filename",new IKAnalyzer());

             //Query query =queryParser.parse("*:*");//查询条件(查询所有)

             Query query =queryParser.parse("changes");

             printResult(indexSearcher, query);

             //关闭流

             indexSearcher.getIndexReader().close();

         }

 }