package journal.action; import journal.reader.DataJournalEntry; import journal.reader.JournalEntry; public class OpenAndHaveFilter extends BaseFilter { private boolean passThrough(JournalEntry entry) { DataJournalEntry dataEntry = (DataJournalEntry) entry; String tableName = dataEntry.getTableName(); if (tableName.equals("db.have") || tableName.equals("db.working") || tableName.equals("db.locks") || tableName.equals("db.resolve") || tableName.equals("db.resolved")) { return false; } return true; } @Override public void putValue(JournalEntry entry) throws Exception { if (passThrough(entry)) { nextAction.putValue(entry); } } @Override public void replaceValue(JournalEntry entry) throws Exception { if (passThrough(entry)) { nextAction.replaceValue(entry); } } @Override public void deleteValue(JournalEntry entry) throws Exception { if (passThrough(entry)) { nextAction.deleteValue(entry); } } }
# | Change | User | Description | Committed | |
---|---|---|---|---|---|
#2 | 7529 | Sven Erik Knop |
Deleted the whole JournalReader. It has actually moved to //guest/sven_erik_knop/java/JournalReader/. |
||
#1 | 7427 | Sven Erik Knop |
Major update of the JournalReader: - New help (usage) system, which explains all options - Config file that allows storing of parameters in a file. These are necessary for the SQLLoader and Updater, because classpath, classname and connection parameters need to be set. (see the example *.cfg files provided) - Now tested with MySQL, SQLite and Oracle 10 XE |