1 21 22 package org.continuent.sequoia.controller.recoverylog.events; 23 24 import java.sql.SQLException ; 25 26 import org.continuent.sequoia.common.i18n.Translate; 27 import org.continuent.sequoia.controller.recoverylog.LoggerThread; 28 29 35 public class DeleteLogEntriesAndCheckpointBetweenEvent implements LogEvent 36 { 37 private long fromId; 38 private long toId; 39 40 47 public DeleteLogEntriesAndCheckpointBetweenEvent(long fromId, long toId) 48 { 49 this.fromId = fromId; 50 this.toId = toId; 51 } 52 53 56 public boolean belongToTransaction(long tid) 57 { 58 return false; 59 } 60 61 64 public void execute(LoggerThread loggerThread) 65 { 66 try 67 { 68 loggerThread.deleteLogEntriesAndCheckpointBetween(fromId, toId); 69 } 70 catch (SQLException e) 71 { 72 loggerThread.invalidateLogStatements(); 73 loggerThread.getLogger().error( 74 Translate.get("recovery.jdbc.loggerthread.shift.failed", e 75 .getMessage()), e); 76 loggerThread.putBackAtHeadOfQueue(this, e); 78 } 79 } 80 81 84 public String toString() 85 { 86 return "Delete log entries from " + fromId + " to " + toId; 87 } 88 89 } 90 | Popular Tags |