org.apache.derby.impl.store.raw.data
Class DeleteOperation
- java.lang.Object
-
- org.apache.derby.impl.store.raw.data.DeleteOperation
-
- All Implemented Interfaces:
- java.io.Externalizable, java.io.Serializable, Formatable, TypedFormat, Loggable, LogicalUndoable, RePreparable, Undoable
public final class DeleteOperation extends java.lang.ObjectRepresents a delete (or undelete) of a record in a page.- See Also:
- Serialized Form
-
-
Field Summary
-
Fields inherited from interface org.apache.derby.iapi.store.raw.Loggable
ABORT, BI_LOG, CHECKSUM, COMMIT, COMPENSATION, FILE_RESOURCE, FIRST, LAST, PREPARE, RAWSTORE, XA_NEEDLOCK
-
-
Constructor Summary
Constructors Constructor and Description DeleteOperation()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method and Description voiddoMe(Transaction xact, LogInstant instant, LimitObjectInput in)Mark the record as deleted on the page.org.apache.derby.impl.store.raw.data.BasePagefindpage(Transaction xact)Find the page the operation applies to and latch it, this only uses the segmentId, containerId, and pageId stored in this log record to find the page.CompensationgenerateUndo(Transaction xact, LimitObjectInput in)Generate a Compensation (PageUndoOperation) that will rollback the changes of this page operation.ContainerHandlegetContainer()Return the container handle where the log operated onPagegetPage()longgetPageVersion()ByteArraygetPreparedLog()the default for optional data is set to null.RecordHandlegetRecordHandle()Return the record handle that correspond to the record that was changed during roll forward.intgetTypeFormatId()Return my format identifier.intgroup()A page operation is a RAWSTORE log recordbooleanneedsRedo(Transaction xact)Returns true if this op should be redone during recovery redo, if so, get and latched the page.voidreadExternal(java.io.ObjectInput in)Read this invoidreclaimPrepareLocks(Transaction t, LockingPolicy locking_policy)reclaim locks associated with the changes in this log record.voidreleaseResource(Transaction xact)Release latched page and any other resources acquired during a previous findpage, safe to call multiple times.voidresetRecordHandle(RecordHandle rh)After the logical undo logic figures out where the real record that needs roll back is, reset this log operation to refer to that recordvoidrestoreLoggedRow(java.lang.Object[] row, LimitObjectInput in)Restore the row stored in the optional data of the log record.voidrestoreMe(Transaction xact, org.apache.derby.impl.store.raw.data.BasePage undoPage, LogInstant CLRinstant, LimitObjectInput in)restore the before image of the pagejava.lang.StringtoString()voidundoMe(Transaction xact, org.apache.derby.impl.store.raw.data.BasePage undoPage, int undoRecordId, LogInstant CLRInstant, LimitObjectInput in)Mark the record as not deleted, and then fix up the in-memory copy of the page.voidwriteExternal(java.io.ObjectOutput out)Write this out.-
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.derby.iapi.store.raw.Loggable
group, needsRedo, releaseResource
-
-
-
-
Method Detail
-
writeExternal
public void writeExternal(java.io.ObjectOutput out) throws java.io.IOExceptionWrite this out.- Specified by:
writeExternalin interfacejava.io.Externalizable- Throws:
java.io.IOException- error writing to log stream
-
readExternal
public void readExternal(java.io.ObjectInput in) throws java.io.IOException, java.lang.ClassNotFoundExceptionRead this in- Specified by:
readExternalin interfacejava.io.Externalizable- Throws:
java.io.IOException- error reading from log streamjava.lang.ClassNotFoundException- log stream corrupted
-
getTypeFormatId
public int getTypeFormatId()
Return my format identifier.- Returns:
- The identifier. (A UUID stuffed in an array of 16 bytes).
-
doMe
public void doMe(Transaction xact, LogInstant instant, LimitObjectInput in) throws StandardException, java.io.IOException
Mark the record as deleted on the page.- Parameters:
xact- the Transactioninstant- the log instant of this operationin- optional data- Throws:
java.io.IOException- Can be thrown by any of the methods of ObjectInput.StandardException- Standard Derby policy.- See Also:
Loggable.doMe(org.apache.derby.iapi.store.raw.Transaction, org.apache.derby.iapi.store.raw.log.LogInstant, org.apache.derby.iapi.services.io.LimitObjectInput)
-
undoMe
public void undoMe(Transaction xact, org.apache.derby.impl.store.raw.data.BasePage undoPage, int undoRecordId, LogInstant CLRInstant, LimitObjectInput in) throws StandardException, java.io.IOException
Mark the record as not deleted, and then fix up the in-memory copy of the page. All logical undo logic has already been taken care of by generateUndo.- Parameters:
xact- the Transaction doing the rollbackundoPage- the page to rollback changes onundoRecordId- the recordId to rollback changes onCLRInstant- the log instant of this (PageUndo) operationin- optional data for the rollback operation- Throws:
StandardException- Thrown by methods I calljava.io.IOException- Thrown by methods I call- See Also:
LogicalPageOperation.undoMe(org.apache.derby.iapi.store.raw.Transaction, org.apache.derby.impl.store.raw.data.BasePage, int, org.apache.derby.iapi.store.raw.log.LogInstant, org.apache.derby.iapi.services.io.LimitObjectInput)
-
restoreLoggedRow
public void restoreLoggedRow(java.lang.Object[] row, LimitObjectInput in) throws StandardException, java.io.IOExceptionRestore the row stored in the optional data of the log record.- Parameters:
row- an IN/OUT parameter, caller passed in the row with the correct column number and type, the log operation will restore the row with the optional data stored in the log record.- Throws:
java.io.IOException- error reading from log streamStandardException- Standard Derby error policy- See Also:
LogicalUndo
-
restoreMe
public void restoreMe(Transaction xact, org.apache.derby.impl.store.raw.data.BasePage undoPage, LogInstant CLRinstant, LimitObjectInput in) throws StandardException, java.io.IOException
restore the before image of the page- Parameters:
xact- the Transaction doing the rollbackundoPage- the page to rollback changes onCLRinstant- the log instant of this (PageUndo) operationin- optional data for the rollback operation- Throws:
StandardException- Standard Derby Error Policyjava.io.IOException- problem reading the complete log record from the input stream
-
getPreparedLog
public ByteArray getPreparedLog()
the default for optional data is set to null. If an operation has optional data, the operation need to prepare the optional data for this method. WARNING: If a log operation extends this class, and the operation has optional data, it MUST overwrite this method to return a ByteArray that contains the optional data.- Specified by:
getPreparedLogin interfaceLoggable
-
toString
public java.lang.String toString()
-
generateUndo
public Compensation generateUndo(Transaction xact, LimitObjectInput in) throws StandardException, java.io.IOException
Generate a Compensation (PageUndoOperation) that will rollback the changes of this page operation. If this Page operation cannot or need not be rolled back (redo only), overwrite this function to return null.- Specified by:
generateUndoin interfaceUndoable- Parameters:
xact- the transaction doing the rollback- Returns:
- the compensation operation that will rollback this change, or null if nothing to undo.
- Throws:
StandardException- Standard Derby policy.java.io.IOException- Method may read from ObjectInput- See Also:
LogicalUndo
-
getContainer
public ContainerHandle getContainer()
Return the container handle where the log operated on- Specified by:
getContainerin interfaceLogicalUndoable
-
resetRecordHandle
public void resetRecordHandle(RecordHandle rh)
After the logical undo logic figures out where the real record that needs roll back is, reset this log operation to refer to that record- Specified by:
resetRecordHandlein interfaceLogicalUndoable- Parameters:
rh- the RecordHandle that represents the row's new location
-
getRecordHandle
public RecordHandle getRecordHandle()
Return the record handle that correspond to the record that was changed during roll forward. This is used as a hint by logical undo as a good place to look for the record to apply the roll back.- Specified by:
getRecordHandlein interfaceLogicalUndoable
-
reclaimPrepareLocks
public void reclaimPrepareLocks(Transaction t, LockingPolicy locking_policy) throws StandardException
reclaim locks associated with the changes in this log record.- Specified by:
reclaimPrepareLocksin interfaceRePreparable- Parameters:
locking_policy- The locking policy to use to claim the locks.- Throws:
StandardException- Standard exception policy.
-
needsRedo
public final boolean needsRedo(Transaction xact) throws StandardException
Returns true if this op should be redone during recovery redo, if so, get and latched the page.- Specified by:
needsRedoin interfaceLoggable- Parameters:
xact- The transaction trying to redo this operation- Returns:
- true if operation needs redoing, false if not.
- Throws:
StandardException- Standard Derby policy.- See Also:
Loggable.releaseResource(org.apache.derby.iapi.store.raw.Transaction)
-
releaseResource
public void releaseResource(Transaction xact)
Release latched page and any other resources acquired during a previous findpage, safe to call multiple times. In this RawStore implementataion, resource is acquired by a log operation in one of two places- during runtime or recovery undo in PageOperation.generateUndo()
- during recovery redo in PageBasicOperation.needsRedo()
- Specified by:
releaseResourcein interfaceLoggable
-
group
public int group()
A page operation is a RAWSTORE log record
-
findpage
public final org.apache.derby.impl.store.raw.data.BasePage findpage(Transaction xact) throws StandardException
Find the page the operation applies to and latch it, this only uses the segmentId, containerId, and pageId stored in this log record to find the page.- Returns:
- null if container is dropped and committed (possibly stubbified), else return the latched page
- Throws:
StandardException- Standard Derby policy.
-
getPage
public final Page getPage()
-
getPageVersion
public final long getPageVersion()
-
-
DataMelt 3.0 © DataMelt by jWork.ORG