org.apache.derby.impl.store.raw.data

Class InsertOperation

java.lang.Object

org.apache.derby.impl.store.raw.data.InsertOperation

All Implemented Interfaces:

java.io.Externalizable, java.io.Serializable, Formatable, TypedFormat, Loggable, LogicalUndoable, RePreparable, Undoable

public final class InsertOperation
extends java.lang.Object

Represents an insert of a record onto a page.

See Also:

Page.insertAtSlot(int, java.lang.Object[], org.apache.derby.iapi.services.io.FormatableBitSet, org.apache.derby.iapi.store.access.conglomerate.LogicalUndo, byte, int), 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
InsertOperation()

Method Summary

Modifier and Type	Method and Description
void	doMe(Transaction xact, LogInstant instant, LimitObjectInput in) Apply the change indicated by this operation and optional data.
org.apache.derby.impl.store.raw.data.BasePage	findpage(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.
Compensation	generateUndo(Transaction xact, LimitObjectInput in) Generate a Compensation (PageUndoOperation) that will rollback the changes of this page operation.
ContainerHandle	getContainer() Return the container handle where the log operated on
int	getNextStartColumn()
Page	getPage()
long	getPageVersion()
ByteArray	getPreparedLog() the default for optional data is set to null.
RecordHandle	getRecordHandle() Return the record handle that correspond to the record that was changed during roll forward.
int	getTypeFormatId() Return my format identifier.
int	group() A page operation is a RAWSTORE log record
boolean	needsRedo(Transaction xact) Returns true if this op should be redone during recovery redo, if so, get and latched the page.
void	readExternal(java.io.ObjectInput in) Read this in
void	reclaimPrepareLocks(Transaction t, LockingPolicy locking_policy) reclaim locks associated with the changes in this log record.
void	releaseResource(Transaction xact) Release latched page and any other resources acquired during a previous findpage, safe to call multiple times.
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
void	restoreLoggedRow(java.lang.Object[] row, LimitObjectInput in) Restore the row stored in the optional data of the log record.
void	restoreMe(Transaction xact, org.apache.derby.impl.store.raw.data.BasePage undoPage, LogInstant CLRinstant, LimitObjectInput in) restore the before image of the page
java.lang.String	toString() DEBUG: Print self.
void	undoMe(Transaction xact, org.apache.derby.impl.store.raw.data.BasePage undoPage, int undoRecordId, LogInstant CLRInstant, LimitObjectInput in) Undo the insert by simply marking the just inserted record as deleted.
void	writeExternal(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

Constructor Detail

InsertOperation

public InsertOperation()

Method Detail

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Write this out.

Specified by:

writeExternal in interface java.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.ClassNotFoundException

Read this in

Specified by:

readExternal in interface java.io.Externalizable

Throws:

java.io.IOException - error reading from log stream

java.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

Description copied from interface: Loggable

Apply the change indicated by this operation and optional data. If this method fail, the system will be shut down because the log record has already been written to disk. Moreover, the log record will be replayed during recovery and this doMe method will be called on the same page again, so if it fails again, recovery will fail and the database cannot be started. So it is very important to make sure that every resource you need, such as disk space, has been acquired before the logAndDo method is called!
This method cannot acquire any resource (like latching of a page) since it is called underneath the logging system, ie., the log record has already been written to the log stream.

The available() method of in indicates how much data can be read, i.e. how much was originally written.

Parameters:

xact - the Transaction

instant - the log instant of this operation

in - 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

Undo the insert by simply marking the just inserted record as deleted. All logical undo logic has already been taken care of by generateUndo.

Parameters:

xact - the Transaction doing the rollback

undoPage - the page to rollback changes on

undoRecordId - the recordId to rollback changes on

CLRInstant - the log instant of this (PageUndo) operation

in - optional data for the rollback operation

Throws:

java.io.IOException - Can be thrown by any of the methods of ObjectInput.

StandardException - Standard Derby policy.

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.IOException

Restore 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 stream

StandardException - 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 rollback

undoPage - the page to rollback changes on

CLRinstant - the log instant of this (PageUndo) operation

in - optional data for the rollback operation

Throws:

StandardException - Standard Derby Error Policy

java.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:

getPreparedLog in interface Loggable

getNextStartColumn

public int getNextStartColumn()

toString

public java.lang.String toString()

DEBUG: Print self.

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:

generateUndo in interface Undoable

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:

getContainer in interface LogicalUndoable

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:

resetRecordHandle in interface LogicalUndoable

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:

getRecordHandle in interface LogicalUndoable

reclaimPrepareLocks

public void reclaimPrepareLocks(Transaction t,
                                LockingPolicy locking_policy)
                         throws StandardException

reclaim locks associated with the changes in this log record.

Specified by:

reclaimPrepareLocks in interface RePreparable

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:

needsRedo in interface Loggable

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:

releaseResource in interface Loggable

group

public int group()

A page operation is a RAWSTORE log record

Specified by:

group in interface Loggable

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()