Module graph

Package de.grogra.persistence

Class Transaction

java.lang.Object

java.io.OutputStream

de.grogra.util.OutputQueue

de.grogra.util.HierarchicalQueue

de.grogra.persistence.XAQueue

de.grogra.persistence.Transaction

All Implemented Interfaces:

PersistenceOutput, Closeable, DataOutput, Flushable, ObjectOutput, AutoCloseable

Direct Known Subclasses:

GraphTransaction

public abstract class Transaction
extends XAQueue

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	Transaction.Consumer
static final class	Transaction.Data
static interface	Transaction.ExtendedConsumer
static final class	Transaction.Key
class	Transaction.Reader

Nested classes/interfaces inherited from class de.grogra.util.HierarchicalQueue

HierarchicalQueue.Cursor

Field Summary

Fields

Modifier and Type	Field	Description
static final int	INSERT_BOOLEAN
static final int	INSERT_BYTE
static final int	INSERT_CHAR
static final int	INSERT_DOUBLE
static final int	INSERT_FLOAT
static final int	INSERT_INT
static final int	INSERT_LONG
static final int	INSERT_OBJECT
static final int	INSERT_SHORT
static final int	MAKE_PERSISTENT
static final int	MAKE_TRANSIENT
static final int	MIN_UNUSED_ITEM
static final int	READ_DATA
static final int	REDO_TRANSACTION
static final int	REMOVE_BOOLEAN
static final int	REMOVE_BYTE
static final int	REMOVE_CHAR
static final int	REMOVE_DOUBLE
static final int	REMOVE_FLOAT
static final int	REMOVE_INT
static final int	REMOVE_LONG
static final int	REMOVE_OBJECT
static final int	REMOVE_SHORT
static final int	SET_BOOLEAN
static final int	SET_BYTE
static final int	SET_CHAR
static final int	SET_DOUBLE
static final int	SET_FLOAT
static final int	SET_INT
static final int	SET_LONG
static final int	SET_OBJECT
static final int	SET_SHORT
static final int	UNDO_TRANSACTION

Fields inherited from class de.grogra.persistence.XAQueue

cache, manager

Fields inherited from class de.grogra.util.HierarchicalQueue

BEGIN_LEVEL, IS_FINISHED, ITEM_AND_BITS_MASK, ITEM_MASK, MAX_UNUSED_BIT, MIN_UNUSED_BIT, NEXT_EXISTS, out

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Transaction(PersistenceManager manager, Thread thread)

Method Summary

Modifier and Type	Method	Description
void	begin(boolean readOnly)
void	beginApply()
void	close()
void	commit()
final void	commitAll()
protected Transaction.Data	createData()
abstract Transaction.Reader	createReader()
void	endApply()
void	finishSet()
void	finishSet(XAQueue.Reader reader)
void	fireSharedObjectModified(Shareable object)
int	getActiveCount()
final long	getId()
final Transaction.Key	getKey()
final long	getUserId()
boolean	hasModified()
boolean	isActive()
static boolean	isApplying(Transaction t)
protected boolean	isLoggingSuppressed()
boolean	isModified(Object object, PersistenceField field, int[] indices)
static boolean	isNotApplying(Transaction t)
void	logInsertBoolean(PersistenceCapable o, PersistenceField field, int[] indices, boolean newValue)
void	logInsertByte(PersistenceCapable o, PersistenceField field, int[] indices, byte newValue)
void	logInsertChar(PersistenceCapable o, PersistenceField field, int[] indices, char newValue)
void	logInsertDouble(PersistenceCapable o, PersistenceField field, int[] indices, double newValue)
void	logInsertFloat(PersistenceCapable o, PersistenceField field, int[] indices, float newValue)
void	logInsertInt(PersistenceCapable o, PersistenceField field, int[] indices, int newValue)
void	logInsertLong(PersistenceCapable o, PersistenceField field, int[] indices, long newValue)
void	logInsertObject(PersistenceCapable o, PersistenceField field, int[] indices, Object newValue)
void	logInsertShort(PersistenceCapable o, PersistenceField field, int[] indices, short newValue)
void	logMakePersistent(PersistenceCapable o)
void	logMakeTransient(PersistenceCapable o)
void	logReadData(PersistenceCapable o, boolean onRollback)
void	logRedo(Transaction.Key k)
void	logRemoveBoolean(PersistenceCapable o, PersistenceField field, int[] indices, boolean oldValue)
void	logRemoveByte(PersistenceCapable o, PersistenceField field, int[] indices, byte oldValue)
void	logRemoveChar(PersistenceCapable o, PersistenceField field, int[] indices, char oldValue)
void	logRemoveDouble(PersistenceCapable o, PersistenceField field, int[] indices, double oldValue)
void	logRemoveFloat(PersistenceCapable o, PersistenceField field, int[] indices, float oldValue)
void	logRemoveInt(PersistenceCapable o, PersistenceField field, int[] indices, int oldValue)
void	logRemoveLong(PersistenceCapable o, PersistenceField field, int[] indices, long oldValue)
void	logRemoveObject(PersistenceCapable o, PersistenceField field, int[] indices, Object oldValue)
void	logRemoveShort(PersistenceCapable o, PersistenceField field, int[] indices, short oldValue)
void	logSetBoolean(PersistenceCapable o, PersistenceField field, int[] indices, boolean oldValue, boolean newValue)
void	logSetByte(PersistenceCapable o, PersistenceField field, int[] indices, byte oldValue, byte newValue)
void	logSetChar(PersistenceCapable o, PersistenceField field, int[] indices, char oldValue, char newValue)
void	logSetDouble(PersistenceCapable o, PersistenceField field, int[] indices, double oldValue, double newValue)
void	logSetFloat(PersistenceCapable o, PersistenceField field, int[] indices, float oldValue, float newValue)
void	logSetInt(PersistenceCapable o, PersistenceField field, int[] indices, int oldValue, int newValue)
void	logSetLong(PersistenceCapable o, PersistenceField field, int[] indices, long oldValue, long newValue)
void	logSetObject(PersistenceCapable o, PersistenceField field, int[] indices, Object oldValue, Object newValue)
void	logSetShort(PersistenceCapable o, PersistenceField field, int[] indices, short oldValue, short newValue)
void	logUndo(Transaction.Key k)
Transaction	makeActive()
void	markModified(Object object, PersistenceField field, int[] indices)
void	prepareLogSetBoolean(PersistenceCapable o, PersistenceField field, int[] indices, boolean oldValue)
void	prepareLogSetByte(PersistenceCapable o, PersistenceField field, int[] indices, byte oldValue)
void	prepareLogSetChar(PersistenceCapable o, PersistenceField field, int[] indices, char oldValue)
void	prepareLogSetDouble(PersistenceCapable o, PersistenceField field, int[] indices, double oldValue)
void	prepareLogSetFloat(PersistenceCapable o, PersistenceField field, int[] indices, float oldValue)
void	prepareLogSetInt(PersistenceCapable o, PersistenceField field, int[] indices, int oldValue)
void	prepareLogSetLong(PersistenceCapable o, PersistenceField field, int[] indices, long oldValue)
void	prepareLogSetObject(PersistenceCapable o, PersistenceField field, int[] indices, Object oldValue)
void	prepareLogSetShort(PersistenceCapable o, PersistenceField field, int[] indices, short oldValue)
void	prepareSetBoolean(PersistenceCapable pc, PersistenceField field, int[] indices)
void	prepareSetByte(PersistenceCapable pc, PersistenceField field, int[] indices)
void	prepareSetChar(PersistenceCapable pc, PersistenceField field, int[] indices)
void	prepareSetDouble(PersistenceCapable pc, PersistenceField field, int[] indices)
void	prepareSetFloat(PersistenceCapable pc, PersistenceField field, int[] indices)
void	prepareSetInt(PersistenceCapable pc, PersistenceField field, int[] indices)
void	prepareSetLong(PersistenceCapable pc, PersistenceField field, int[] indices)
void	prepareSetObject(PersistenceCapable pc, PersistenceField field, int[] indices)
void	prepareSetShort(PersistenceCapable pc, PersistenceField field, int[] indices)
final void	redo(Transaction.Data d)
void	restore(HierarchicalQueue.Data data)
void	rollback()
final void	rollbackAll()
protected void	setModified()
final void	setReadOnly()
final void	setUserId(long userId)
final void	undo(Transaction.Data d)
void	unmarkModified()

Methods inherited from class de.grogra.persistence.XAQueue

beginArray, beginField, beginFields, beginManaged, clear, endArray, endField, endFields, endManaged, getPersistenceManager, setNested, writeComponentSeparator, writeLibraryObjectReference, writeName, writeNullObject, writeObject, writePersistentObjectReference, writeSharedObjectReference, writeString, writeStringObject

Methods inherited from class de.grogra.util.HierarchicalQueue

beginLevel, beginSkipBlock, cloneData, discardLevel, endLevel, endSkipBlock, getCursor, getData, hasItems, hasItemsInCurrentLevel, moveTo, setItemSize, writeItem, writeObject, writeObjectInStream

Methods inherited from class de.grogra.util.OutputQueue

dump, flush, write, write, write, writeBoolean, writeByte, writeBytes, writeChar, writeChars, writeDouble, writeFloat, writeInt, writeLong, writeObjectInQueue, writeShort, writeUTF

Methods inherited from class java.io.OutputStream

nullOutputStream

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.io.DataOutput

writeBoolean, writeByte, writeBytes, writeChar, writeChars, writeDouble, writeFloat, writeInt, writeLong, writeShort, writeUTF

Methods inherited from interface java.io.ObjectOutput

flush, write, write, write

Methods inherited from interface de.grogra.persistence.PersistenceOutput

writeBoolean, writeByte, writeChar, writeDouble, writeFloat, writeInt, writeLong, writeShort, writeStatic

Field Details

SET_BOOLEAN

public static final int SET_BOOLEAN

See Also:

• Constant Field Values

INSERT_BOOLEAN

public static final int INSERT_BOOLEAN

See Also:

• Constant Field Values

REMOVE_BOOLEAN

public static final int REMOVE_BOOLEAN

See Also:

• Constant Field Values

SET_BYTE

public static final int SET_BYTE

See Also:

• Constant Field Values

INSERT_BYTE

public static final int INSERT_BYTE

See Also:

• Constant Field Values

REMOVE_BYTE

public static final int REMOVE_BYTE

See Also:

• Constant Field Values

SET_SHORT

public static final int SET_SHORT

See Also:

• Constant Field Values

INSERT_SHORT

public static final int INSERT_SHORT

See Also:

• Constant Field Values

REMOVE_SHORT

public static final int REMOVE_SHORT

See Also:

• Constant Field Values

SET_CHAR

public static final int SET_CHAR

See Also:

• Constant Field Values

INSERT_CHAR

public static final int INSERT_CHAR

See Also:

• Constant Field Values

REMOVE_CHAR

public static final int REMOVE_CHAR

See Also:

• Constant Field Values

SET_INT

public static final int SET_INT

See Also:

• Constant Field Values

INSERT_INT

public static final int INSERT_INT

See Also:

• Constant Field Values

REMOVE_INT

public static final int REMOVE_INT

See Also:

• Constant Field Values

SET_LONG

public static final int SET_LONG

See Also:

• Constant Field Values

INSERT_LONG

public static final int INSERT_LONG

See Also:

• Constant Field Values

REMOVE_LONG

public static final int REMOVE_LONG

See Also:

• Constant Field Values

SET_FLOAT

public static final int SET_FLOAT

See Also:

• Constant Field Values

INSERT_FLOAT

public static final int INSERT_FLOAT

See Also:

• Constant Field Values

REMOVE_FLOAT

public static final int REMOVE_FLOAT

See Also:

• Constant Field Values

SET_DOUBLE

public static final int SET_DOUBLE

See Also:

• Constant Field Values

INSERT_DOUBLE

public static final int INSERT_DOUBLE

See Also:

• Constant Field Values

REMOVE_DOUBLE

public static final int REMOVE_DOUBLE

See Also:

• Constant Field Values

SET_OBJECT

public static final int SET_OBJECT

See Also:

• Constant Field Values

INSERT_OBJECT

public static final int INSERT_OBJECT

See Also:

• Constant Field Values

REMOVE_OBJECT

public static final int REMOVE_OBJECT

See Also:

• Constant Field Values

UNDO_TRANSACTION

public static final int UNDO_TRANSACTION

See Also:

• Constant Field Values

REDO_TRANSACTION

public static final int REDO_TRANSACTION

See Also:

• Constant Field Values

MAKE_PERSISTENT

public static final int MAKE_PERSISTENT

See Also:

• Constant Field Values

MAKE_TRANSIENT

public static final int MAKE_TRANSIENT

See Also:

• Constant Field Values

READ_DATA

public static final int READ_DATA

See Also:

• Constant Field Values

MIN_UNUSED_ITEM

public static final int MIN_UNUSED_ITEM

See Also:

• Constant Field Values

Constructor Details

Transaction

protected Transaction(PersistenceManager manager,
 Thread thread)

Method Details

createData

protected Transaction.Data createData()

Overrides:

createData in class XAQueue

isLoggingSuppressed

protected boolean isLoggingSuppressed()

logSetBoolean

public void logSetBoolean(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 boolean oldValue,
 boolean newValue)

prepareLogSetBoolean

public void prepareLogSetBoolean(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 boolean oldValue)

logInsertBoolean

public void logInsertBoolean(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 boolean newValue)

logRemoveBoolean

public void logRemoveBoolean(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 boolean oldValue)

logSetByte

public void logSetByte(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 byte oldValue,
 byte newValue)

prepareLogSetByte

public void prepareLogSetByte(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 byte oldValue)

logInsertByte

public void logInsertByte(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 byte newValue)

logRemoveByte

public void logRemoveByte(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 byte oldValue)

logSetShort

public void logSetShort(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 short oldValue,
 short newValue)

prepareLogSetShort

public void prepareLogSetShort(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 short oldValue)

logInsertShort

public void logInsertShort(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 short newValue)

logRemoveShort

public void logRemoveShort(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 short oldValue)

logSetChar

public void logSetChar(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 char oldValue,
 char newValue)

prepareLogSetChar

public void prepareLogSetChar(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 char oldValue)

logInsertChar

public void logInsertChar(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 char newValue)

logRemoveChar

public void logRemoveChar(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 char oldValue)

logSetInt

public void logSetInt(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 int oldValue,
 int newValue)

prepareLogSetInt

public void prepareLogSetInt(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 int oldValue)

logInsertInt

public void logInsertInt(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 int newValue)

logRemoveInt

public void logRemoveInt(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 int oldValue)

logSetLong

public void logSetLong(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 long oldValue,
 long newValue)

prepareLogSetLong

public void prepareLogSetLong(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 long oldValue)

logInsertLong

public void logInsertLong(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 long newValue)

logRemoveLong

public void logRemoveLong(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 long oldValue)

logSetFloat

public void logSetFloat(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 float oldValue,
 float newValue)

prepareLogSetFloat

public void prepareLogSetFloat(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 float oldValue)

logInsertFloat

public void logInsertFloat(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 float newValue)

logRemoveFloat

public void logRemoveFloat(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 float oldValue)

logSetDouble

public void logSetDouble(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 double oldValue,
 double newValue)

prepareLogSetDouble

public void prepareLogSetDouble(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 double oldValue)

logInsertDouble

public void logInsertDouble(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 double newValue)

logRemoveDouble

public void logRemoveDouble(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 double oldValue)

logSetObject

public void logSetObject(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 Object oldValue,
 Object newValue)

prepareLogSetObject

public void prepareLogSetObject(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 Object oldValue)

logInsertObject

public void logInsertObject(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 Object newValue)

logRemoveObject

public void logRemoveObject(PersistenceCapable o,
 PersistenceField field,
 int[] indices,
 Object oldValue)

logUndo

public void logUndo(Transaction.Key k)

logRedo

public void logRedo(Transaction.Key k)

logMakePersistent

public void logMakePersistent(PersistenceCapable o)

logMakeTransient

public void logMakeTransient(PersistenceCapable o)

logReadData

public void logReadData(PersistenceCapable o,
 boolean onRollback)

setReadOnly

public final void setReadOnly()

getUserId

public final long getUserId()

setUserId

public final void setUserId(long userId)

createReader

public abstract Transaction.Reader createReader()

setModified

protected void setModified()

hasModified

public boolean hasModified()

begin

public void begin(boolean readOnly)

commit

public void commit()

rollback

public void rollback()

commitAll

public final void commitAll()

rollbackAll

public final void rollbackAll()

undo

public final void undo(Transaction.Data d)
                throws IOException

Throws:

IOException

redo

public final void redo(Transaction.Data d)
                throws IOException

Throws:

IOException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface ObjectOutput

Overrides:

close in class OutputQueue

isActive

public boolean isActive()

getActiveCount

public int getActiveCount()

getId

public final long getId()

getKey

public final Transaction.Key getKey()

isApplying

public static boolean isApplying(Transaction t)

isNotApplying

public static boolean isNotApplying(Transaction t)

beginApply

public void beginApply()

endApply

public void endApply()

restore

public void restore(HierarchicalQueue.Data data)

Overrides:

restore in class HierarchicalQueue

prepareSetBoolean

public void prepareSetBoolean(PersistenceCapable pc,
 PersistenceField field,
 int[] indices)

prepareSetByte

public void prepareSetByte(PersistenceCapable pc,
 PersistenceField field,
 int[] indices)

prepareSetShort

public void prepareSetShort(PersistenceCapable pc,
 PersistenceField field,
 int[] indices)

prepareSetChar

public void prepareSetChar(PersistenceCapable pc,
 PersistenceField field,
 int[] indices)

prepareSetInt

public void prepareSetInt(PersistenceCapable pc,
 PersistenceField field,
 int[] indices)

prepareSetLong

public void prepareSetLong(PersistenceCapable pc,
 PersistenceField field,
 int[] indices)

prepareSetFloat

public void prepareSetFloat(PersistenceCapable pc,
 PersistenceField field,
 int[] indices)

prepareSetDouble

public void prepareSetDouble(PersistenceCapable pc,
 PersistenceField field,
 int[] indices)

prepareSetObject

public void prepareSetObject(PersistenceCapable pc,
 PersistenceField field,
 int[] indices)

finishSet

public void finishSet()

finishSet

public void finishSet(XAQueue.Reader reader)

makeActive

public Transaction makeActive()

fireSharedObjectModified

public void fireSharedObjectModified(Shareable object)

markModified

public void markModified(Object object,
 PersistenceField field,
 int[] indices)

unmarkModified

public void unmarkModified()

isModified

public boolean isModified(Object object,
 PersistenceField field,
 int[] indices)