com.orientechnologies.orient.core.metadata.sequence

Class OSequence

java.lang.Object

com.orientechnologies.orient.core.metadata.sequence.OSequence

Direct Known Subclasses:

OSequenceCached, OSequenceOrdered

public abstract class OSequence
extends Object

Since:

3/2/2015

Author:

Matan Shukry ([email protected])

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OSequence.CreateParams
static class	OSequence.SEQUENCE_TYPE

Field Summary

Fields

Modifier and Type	Field and Description
static String	CLASS_NAME
protected static int	DEF_MAX_RETRY
static int	DEFAULT_CACHE
static int	DEFAULT_INCREMENT
static Long	DEFAULT_LIMIT_VALUE
static SequenceOrderType	DEFAULT_ORDER_TYPE
static boolean	DEFAULT_RECYCLABLE_VALUE
static long	DEFAULT_START
protected static int	replicationProtocolVersion
protected ThreadLocal<ODocument>	tlDocument

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	OSequence()
protected	OSequence(ODocument iDocument)
protected	OSequence(ODocument iDocument, OSequence.CreateParams params)

Method Summary

Modifier and Type	Method and Description
protected <T> T	callRetry(boolean reloadSequence, Callable<T> callable, String method)
long	current()
protected abstract long	currentWork()
protected boolean	getCrucialValueChanged()
protected ODatabaseDocumentInternal	getDatabase()
ODocument	getDocument()
protected int	getIncrement()
protected Long	getLimitValue()
int	getMaxRetry()
String	getName()
protected SequenceOrderType	getOrderType()
boolean	getRecyclable()
static String	getSequenceName(ODocument iDocument)
abstract OSequence.SEQUENCE_TYPE	getSequenceType()
static OSequence.SEQUENCE_TYPE	getSequenceType(ODocument document)
protected long	getStart()
protected long	getValue()
protected static Long	getValue(ODocument doc)
static void	initClass(OClassImpl sequenceClass)
protected void	initSequence(OSequence.CreateParams params)
protected boolean	isOnDistributted()
long	next()
abstract long	nextWork()
void	onUpdate(ODocument iDocument)
protected void	reloadSequence()
long	reset()
abstract long	resetWork()
void	save()
void	save(ODatabaseDocument database)
protected void	setCrucialValueChanged(boolean val)
protected void	setIncrement(int value)
protected void	setLimitValue(Long limitValue)
void	setMaxRetry(int maxRetry)
OSequence	setName(String name)
protected void	setOrderType(SequenceOrderType orderType)
void	setRecyclable(boolean recyclable)
protected void	setStart(long value)
protected void	setValue(long value)
protected boolean	shouldGoOverDistrtibute()
boolean	updateParams(OSequence.CreateParams params)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_START

public static final long DEFAULT_START

See Also:

Constant Field Values

DEFAULT_INCREMENT

public static final int DEFAULT_INCREMENT

See Also:

Constant Field Values

DEFAULT_CACHE

public static final int DEFAULT_CACHE

See Also:

Constant Field Values

DEFAULT_LIMIT_VALUE

public static final Long DEFAULT_LIMIT_VALUE

DEFAULT_RECYCLABLE_VALUE

public static final boolean DEFAULT_RECYCLABLE_VALUE

See Also:

Constant Field Values

DEF_MAX_RETRY

protected static final int DEF_MAX_RETRY

CLASS_NAME

public static final String CLASS_NAME

See Also:

Constant Field Values

tlDocument

protected ThreadLocal<ODocument> tlDocument

DEFAULT_ORDER_TYPE

public static final SequenceOrderType DEFAULT_ORDER_TYPE

replicationProtocolVersion

protected static int replicationProtocolVersion

Constructor Detail

OSequence

protected OSequence()

OSequence

protected OSequence(ODocument iDocument)

OSequence

protected OSequence(ODocument iDocument,
                    OSequence.CreateParams params)

Method Detail

setCrucialValueChanged

protected void setCrucialValueChanged(boolean val)

getCrucialValueChanged

protected boolean getCrucialValueChanged()

save

public void save()

save

public void save(ODatabaseDocument database)

getDocument

public final ODocument getDocument()

initSequence

protected final void initSequence(OSequence.CreateParams params)

shouldGoOverDistrtibute

protected boolean shouldGoOverDistrtibute()

updateParams

public boolean updateParams(OSequence.CreateParams params)
                     throws ODatabaseException

Throws:

ODatabaseException

isOnDistributted

protected boolean isOnDistributted()

onUpdate

public void onUpdate(ODocument iDocument)

getValue

protected static Long getValue(ODocument doc)

getValue

protected long getValue()

setValue

protected void setValue(long value)

getIncrement

protected int getIncrement()

setLimitValue

protected void setLimitValue(Long limitValue)

getLimitValue

protected Long getLimitValue()

setOrderType

protected void setOrderType(SequenceOrderType orderType)

getOrderType

protected SequenceOrderType getOrderType()

setIncrement

protected void setIncrement(int value)

getStart

protected long getStart()

setStart

protected void setStart(long value)

getMaxRetry

public int getMaxRetry()

setMaxRetry

public void setMaxRetry(int maxRetry)

getName

public String getName()

setName

public OSequence setName(String name)

getRecyclable

public boolean getRecyclable()

setRecyclable

public void setRecyclable(boolean recyclable)

getDatabase

protected final ODatabaseDocumentInternal getDatabase()

getSequenceName

public static String getSequenceName(ODocument iDocument)

getSequenceType

public static OSequence.SEQUENCE_TYPE getSequenceType(ODocument document)

initClass

public static void initClass(OClassImpl sequenceClass)

next

public long next()
          throws OSequenceLimitReachedException,
                 ODatabaseException

Throws:

OSequenceLimitReachedException

ODatabaseException

nextWork

public abstract long nextWork()
                       throws OSequenceLimitReachedException

Throws:

OSequenceLimitReachedException

current

public long current()
             throws ODatabaseException

Throws:

ODatabaseException

currentWork

protected abstract long currentWork()

reset

public long reset()
           throws ODatabaseException

Throws:

ODatabaseException

resetWork

public abstract long resetWork()

getSequenceType

public abstract OSequence.SEQUENCE_TYPE getSequenceType()

reloadSequence

protected void reloadSequence()

callRetry

protected <T> T callRetry(boolean reloadSequence,
                          Callable<T> callable,
                          String method)