Project

General

Profile

« Previous | Next » 

Revision 7807

Added by Jing Tao over 11 years ago

Add code to implment set and get the last processed date.

View differences:

metacat-index/src/main/java/edu/ucsb/nceas/metacat/index/event/IndexEventFileLog.java
26 26 
import java.io.FileOutputStream;
27 27 
import java.io.IOException;
28 28 
import java.text.DateFormat;
29 
import java.text.ParseException;
29 30 
import java.text.SimpleDateFormat;
30 31 
import java.util.Date;
31 32 
import java.util.List;
......
45 46 
public class IndexEventFileLog implements IndexEventLog {
46 47 
    private static final String FIELDSEPERATOR = " ";
47 48 
    private static final String LOGFILENAME = "solr-index.log";
49 
    private static final String LASTPROCESSEDDATEFILENAME = "solr-last-proccessed-date";
48 50 
    private File logFile = null;
51 
    private File lastProcessedDateFile = null;
49 52 
    private long index=1;
53 
    private SimpleDateFormat format = new SimpleDateFormat();
50 54
51 55 
    /**
52 56 
     * Constructor. Initialize the log file. The log file locates solr.homeDir.
......
66 70 
        if(!logFile.exists()) {
67 71 
            logFile.createNewFile();
68 72 
        }
73 
        lastProcessedDateFile = new File(pathDir, LASTPROCESSEDDATEFILENAME);
74 
        if(!lastProcessedDateFile.exists()) {
75 
            lastProcessedDateFile.createNewFile();
76 
        }
69 77 
    }
70 78 
    /**
71 79 
     * Write an IndexEvent into a file
......
145 153 
     * @throws IndexEventLogException
146 154 
     */
147 155 
    public Date getLastProcessDate() throws IndexEventLogException {
148 
        return null;
156 
        Date date = null;
157 
        try {
158 
            String dateStr = FileUtils.readFileToString(lastProcessedDateFile, "UTF-8");
159 
            if(dateStr != null && !dateStr.trim().equals("")) {
160 
                date = format.parse(dateStr);
161 
            }
162 
        } catch (IOException e) {
163 
            throw new IndexEventLogException("IndexEventFileLog.getLastProcessedDate - couldn't read the last processed date :", e);
164 
        } catch (ParseException e) {
165 
            // TODO Auto-generated catch block
166 
            throw new IndexEventLogException("IndexEventFileLog.getLastProcessedDate - couldn't read the last processed date since the content of file is not date :", e);
167 
        }
168 
        return date;
149 169 
    }
150 170
151 171
......
155 175 
     * @throws IndexEventLogException
156 176 
     */
157 177 
    public void setLastProcessDate(Date date) throws IndexEventLogException {
158
178 
        String dateStr = format.format(date);
179 
        try {
180 
            FileUtils.writeStringToFile(lastProcessedDateFile, dateStr, "UTF-8");
181 
        } catch (IOException e) {
182 
            // TODO Auto-generated catch block
183 
           throw new IndexEventLogException("IndexEventFileLog.setLastProcessedDate - couldn't set the last processed date :", e);
184 
        }
159 185 
    }
160 186 
}

Also available in: Unified diff