package com.geostar.poi.support.lucene;
 
 import java.io.File;
 import java.io.IOException;
 
 import org.apache.log4j.Logger;
 import org.apache.lucene.analysis.Analyzer;
 import org.apache.lucene.analysis.standard.StandardAnalyzer;
 import org.apache.lucene.index.CorruptIndexException;
 import org.apache.lucene.index.IndexReader;
 import org.apache.lucene.index.IndexWriter;
 import org.apache.lucene.index.IndexWriter.MaxFieldLength;
 import org.apache.lucene.store.FSDirectory;
 import org.apache.lucene.store.LockObtainFailedException;
 import org.apache.lucene.util.Version;
 
 import com.geostar.poi.support.POIConfig;
 
 public class POILuceneManager implements LuceneManager{
     private IndexWriter  indexWriter=null;
     private IndexReader  indexReader=null;
     //------lock 1
     private Object lock_w=new Object();
     //------lock 2
     private Object lock_r=new Object();
     
     private Logger logger=Logger.getLogger(POILuceneManager.class);
     @Override
     public IndexWriter getIndexWriter() throws CorruptIndexException, LockObtainFailedException, IOException {        
         synchronized(lock_w){
            if(indexWriter==null){
              System.out.println("创建对象");
              if(IndexWriter.isLocked(FSDirectory.open(new File(POIConfig.DEFULT_POI_LUCENNE_INDEX_PATH)))){
                  IndexWriter.unlock(FSDirectory.open(new File(POIConfig.DEFULT_POI_LUCENNE_INDEX_PATH)));
              };
              Analyzer any=new StandardAnalyzer(Version.LUCENE_CURRENT);
              indexWriter=new IndexWriter(FSDirectory.open(new File(POIConfig.DEFULT_POI_LUCENNE_INDEX_PATH)),any,MaxFieldLength.UNLIMITED );
            };
            
        }
         return indexWriter;
     }
 
     @Override
     public IndexReader getIndexReader() throws CorruptIndexException, IOException {
       synchronized (lock_r) {
             if(indexReader==null){
                 indexReader=IndexReader.open(FSDirectory.open(new File(POIConfig.DEFULT_POI_LUCENNE_INDEX_PATH)));
             };
         }
         return  indexReader;
     }
 
     @Override
     public void closeIndexWriter() throws IOException {
         // TODO Auto-generated method stub
 //synchronized (lock_w) {
             if(this.indexWriter!=null){
                 this.indexWriter.close();
             };
         //}
         
     }
 
     @Override
     public void closeIndexReader() throws IOException {
         // TODO Auto-generated method stub
 //synchronized (lock_r) {
             if(this.indexReader!=null){
                 this.indexReader.close();
             };
         //}
         
         
     }
 
     @Override
     public void closeAll() throws IOException {
         // TODO Auto-generated method stub
         this.closeIndexReader();
         this.closeIndexWriter();
         
     }
 
 }