import java.io.File;
import java.io.IOException;
 
import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.document.Document;
import org.apache.lucene.document.Field.Store;
import org.apache.lucene.document.IntField;
import org.apache.lucene.document.TextField;
import org.apache.lucene.index.DirectoryReader;
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.IndexSearcher;
import org.apache.lucene.search.Query;
import org.apache.lucene.search.ScoreDoc;
import org.apache.lucene.store.Directory;
import org.apache.lucene.store.FSDirectory;
import org.apache.lucene.util.Version;
import org.wltea.analyzer.lucene.IKAnalyzer;

class LuceneBasicTest  
{        
    private static String path = "d:/index";

     
    public static void main(String[] args){
    	System.out.println("addIndex");
    	//addIndex(5,"1","55");
    	//addIndex(5,"1","66");
    	//addIndex(5,"1","77");
    	//addIndex(5,"1","88");
     	//updateIndex();
    	System.out.println("search");
        search("55"); 
        search("66"); 
        search("77"); 
        search("88"); 
    }
     
    public static void addIndex(Integer id,String docId,String content){
        try {
        	Analyzer analyzer = new IKAnalyzer();
        	Directory directory = FSDirectory.open(new File(path));

            IndexWriterConfig config = new IndexWriterConfig(Version.LUCENE_CURRENT, analyzer);
        	
            IndexWriter write =  new IndexWriter(directory, config);
            
            Document doc = new Document();
            doc.add(new IntField("id", id, Store.YES));
            doc.add(new TextField("docId", docId, Store.YES));
            doc.add(new TextField("content", content, Store.YES));
            write.addDocument(doc);
            
            write.close(); 
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
     
     
    public static void updateIndex(){
        try {
        	Analyzer analyzer = new IKAnalyzer();
        	Directory directory = FSDirectory.open(new File(path)); 
            IndexWriterConfig config = new IndexWriterConfig(Version.LUCENE_CURRENT, analyzer);
        	IndexWriter write =  new IndexWriter(directory, config);
            
            Document docNew = new Document();
            docNew.add(new TextField("id","123456",Store.YES));
            docNew.add(new TextField("content","第一",Store.YES));
            Term term = new Term("id","123456");
            /**
              调用updateDocument的方法，传给它一个新的doc来更新数据，
              Term term = new Term("id","1234567");
              先去索引文件里查找id为1234567的Doc,如果有就更新它(如果有多条，最后更新后只有一条)。如果没有就新增.
             
              数据库更新的时候，我们可以只针对某个列来更新，而lucene只能针对一行数据更新。
             */
            write.updateDocument(term, docNew);
             
            write.close();
             
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
     
    public static void search(String str){
        try {
            Directory directory = FSDirectory.open(new File(path));
            DirectoryReader ireader = DirectoryReader.open(directory);
            IndexSearcher isearcher = new IndexSearcher(ireader);
            
            Analyzer analyzer = new IKAnalyzer();
            QueryParser parser = new QueryParser(Version.LUCENE_CURRENT, "content",analyzer);
            Query query =  parser.parse(str);
            
            ScoreDoc[] hits = isearcher.search(query, null, 1000).scoreDocs;
            
            for (int i = 0; i < hits.length; i++) {
	            	Document hitDoc = isearcher.doc(hits[i].doc);
	                System.out.println("own id = " + hitDoc.get("id"));
	                System.out.println("docId = "+ hitDoc.get("docId"));
	                System.out.println("content = "+ hitDoc.get("content"));
	                System.out.println("");
            	}
                 
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
}