com.orientechnologies.orient.core.record.impl

Class OVertexDelegate

java.lang.Object

com.orientechnologies.orient.core.record.impl.OVertexDelegate

All Implemented Interfaces:

OIdentifiable, ORecordElement, OElement, ORecord, OVertex, OSerializableStream, Serializable, Comparable<OIdentifiable>, Comparator<OIdentifiable>

public class OVertexDelegate
extends Object
implements OVertex

Author:

Luigi Dell'Aquila

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface com.orientechnologies.orient.core.db.record.ORecordElement

ORecordElement.STATUS

Field Summary

Fields

Modifier and Type	Field and Description
protected ODocument	element

Constructor Summary

Constructors

Constructor and Description
OVertexDelegate(ODocument entry)

Method Summary

Modifier and Type	Method and Description
OEdge	addEdge(OVertex to)
OEdge	addEdge(OVertex to, OClass type)
OEdge	addEdge(OVertex to, String type)
Optional<OEdge>	asEdge() Returns an instance of OEdge representing current element
Optional<OVertex>	asVertex() Returns an instance of OVertex representing current element
protected boolean	checkDeletedInTx()
<RET extends ORecord> RET	clear() All the fields are deleted but the record identity is maintained.
int	compare(OIdentifiable o1, OIdentifiable o2)
int	compareTo(OIdentifiable o)
<RET extends ORecord> RET	copy() Creates a copy of the record.
static Object	createLink(ODocument iFromVertex, OIdentifiable iTo, String iFieldName) (Internal only) Creates a link between a vertices and a Graph Element.
OVertex	delete() Deletes the record from the database.
static void	deleteLinks(OVertex delegate)
boolean	detach() Removes all the dependencies with other records.
protected static void	detachEdge(OVertex vertex, OEdge edge, String fieldPrefix)
protected static void	detachIncomingEdge(OVertex vertex, OEdge edge)
protected static void	detachOutgointEdge(OVertex vertex, OEdge edge)
boolean	equals(Object obj)
<RET extends ORecord> RET	fromJSON(String iJson) Fills the record parsing the content in JSON format.
OSerializableStream	fromStream(byte[] iStream) Unmarshalls the object.
protected OPair<ODirection,String>	getConnection(ODirection iDirection, String iFieldName, String... iClassNames)
static String	getConnectionFieldName(ODirection iDirection, String iClassName, boolean useVertexFieldsForEdgeLabels)
ODatabaseDocument	getDatabase() Returns the database where the record belongs.
protected Set<String>	getEdgeFieldNames(ODirection iDirection, String... iClassNames)
Iterable<OEdge>	getEdges(ODirection direction)
Iterable<OEdge>	getEdges(ODirection direction, OClass... type)
Iterable<OEdge>	getEdges(ODirection direction, String... labels)
ORID	getIdentity() Returns the record identity as <cluster-id>:<cluster-position>
ORecordElement.STATUS	getInternalStatus() Returns the current status of the record.
ORecordElement	getOwner()
<RET> RET	getProperty(String name) Gets a property given its name
Set<String>	getPropertyNames() Returns all the names of defined properties
<T extends ORecord> T	getRecord() Returns the record instance.
Optional<OClass>	getSchemaType() Returns the type of current element, ie the class in the schema (if any)
int	getSize() Returns the size in bytes of the record.
int	getVersion() Returns the current version number of the record.
Iterable<OVertex>	getVertices(ODirection direction)
Iterable<OVertex>	getVertices(ODirection direction, OClass... type)
Iterable<OVertex>	getVertices(ODirection direction, String... type)
int	hashCode()
boolean	isDirty() Checks if the record is dirty, namely if it was changed in memory.
boolean	isEdge() return true if the current element is an edge
boolean	isLocked()
boolean	isVertex() return true if the current element is a vertex
<RET extends ORecord> RET	load() Loads the record content in memory.
void	lock(boolean iExclusive)
OStorage.LOCKING_STRATEGY	lockingStrategy()
ORID	moveTo(String iClassName, String iClusterName)
<RET extends ORecord> RET	reload() Loads the record content in memory.
<RET extends ORecord> RET	reload(String fetchPlan, boolean ignoreCache, boolean force)
<RET> RET	removeProperty(String name) Remove a property
static void	replaceLinks(ODocument iVertex, String iFieldName, OIdentifiable iVertexToRemove, OIdentifiable iNewVertex)
<RET extends ORecord> RET	reset() Resets the record to be reused.
<RET extends ORecord> RET	save() Saves in-memory changes to the database.
<RET extends ORecord> RET	save(boolean forceCreate)
<RET extends ORecord> RET	save(String iCluster) Saves in-memory changes to the database defining a specific cluster where to save it.
<RET extends ORecord> RET	save(String iCluster, boolean forceCreate)
<RET> RET	setDirty() Marks the instance as dirty.
void	setDirtyNoChanged()
void	setInternalStatus(ORecordElement.STATUS iStatus) Changes the current internal status.
void	setProperty(String name, Object value) Sets a property value
void	setProperty(String name, Object value, OType... fieldType) Sets a property value
String	toJSON() Exports the record in JSON format.
String	toJSON(String iFormat) Exports the record in JSON format specifying additional formatting settings.
byte[]	toStream() Marshalls the object.
String	toString()
<RET extends ORecord> RET	unload() Unloads current record.
void	unlock()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Comparator

comparing, comparing, comparingDouble, comparingInt, comparingLong, naturalOrder, nullsFirst, nullsLast, reversed, reverseOrder, thenComparing, thenComparing, thenComparing, thenComparingDouble, thenComparingInt, thenComparingLong

Field Detail

element

protected final ODocument element

Constructor Detail

OVertexDelegate

public OVertexDelegate(ODocument entry)

Method Detail

getEdges

public Iterable<OEdge> getEdges(ODirection direction)

Specified by:

getEdges in interface OVertex

getEdges

public Iterable<OEdge> getEdges(ODirection direction,
                                String... labels)

Specified by:

getEdges in interface OVertex

getEdges

public Iterable<OEdge> getEdges(ODirection direction,
                                OClass... type)

Specified by:

getEdges in interface OVertex

getVertices

public Iterable<OVertex> getVertices(ODirection direction)

Specified by:

getVertices in interface OVertex

getVertices

public Iterable<OVertex> getVertices(ODirection direction,
                                     String... type)

Specified by:

getVertices in interface OVertex

getVertices

public Iterable<OVertex> getVertices(ODirection direction,
                                     OClass... type)

Specified by:

getVertices in interface OVertex

addEdge

public OEdge addEdge(OVertex to)

Specified by:

addEdge in interface OVertex

delete

public OVertex delete()

Description copied from interface: ORecord

Deletes the record from the database. Behavior depends by the current running transaction if any. If no transaction is running then the record is deleted immediately. If an Optimistic transaction is running then the record will be deleted at commit time. The current transaction will continue to see the record as deleted, while others not. If a Pessimistic transaction is running, then an exclusive lock is acquired against the record. Current transaction will continue to see the record as deleted, while others cannot access to it since it's locked.

Specified by:

delete in interface ORecord

Returns:

The Object instance itself giving a "fluent interface". Useful to call multiple methods in chain.

deleteLinks

public static void deleteLinks(OVertex delegate)

detachOutgointEdge

protected static void detachOutgointEdge(OVertex vertex,
                                         OEdge edge)

detachIncomingEdge

protected static void detachIncomingEdge(OVertex vertex,
                                         OEdge edge)

detachEdge

protected static void detachEdge(OVertex vertex,
                                 OEdge edge,
                                 String fieldPrefix)

addEdge

public OEdge addEdge(OVertex to,
                     String type)

Specified by:

addEdge in interface OVertex

addEdge

public OEdge addEdge(OVertex to,
                     OClass type)

Specified by:

addEdge in interface OVertex

getPropertyNames

public Set<String> getPropertyNames()

Description copied from interface: OElement

Returns all the names of defined properties

Specified by:

getPropertyNames in interface OElement

Returns:

all the names of defined properties

getProperty

public <RET> RET getProperty(String name)

Description copied from interface: OElement

Gets a property given its name

Specified by:

getProperty in interface OElement

Parameters:

name - the property name

Returns:

Returns the property value

setProperty

public void setProperty(String name,
                        Object value)

Description copied from interface: OElement

Sets a property value

Specified by:

setProperty in interface OElement

Parameters:

name - the property name

value - the property value

setProperty

public void setProperty(String name,
                        Object value,
                        OType... fieldType)

Description copied from interface: OElement

Sets a property value

Specified by:

setProperty in interface OElement

Parameters:

name - the property name

value - the property value

fieldType - Forced type (not auto-determined)

removeProperty

public <RET> RET removeProperty(String name)

Description copied from interface: OElement

Remove a property

Specified by:

removeProperty in interface OElement

Parameters:

name - the property name

asVertex

public Optional<OVertex> asVertex()

Description copied from interface: OElement

Returns an instance of OVertex representing current element

Specified by:

asVertex in interface OElement

Returns:

An OVertex that represents the current element. An empty optional if the current element is not a vertex

asEdge

public Optional<OEdge> asEdge()

Description copied from interface: OElement

Returns an instance of OEdge representing current element

Specified by:

asEdge in interface OElement

Returns:

An OEdge that represents the current element. An empty optional if the current element is not an edge

isVertex

public boolean isVertex()

Description copied from interface: OElement

return true if the current element is a vertex

Specified by:

isVertex in interface OElement

Returns:

true if the current element is a vertex

isEdge

public boolean isEdge()

Description copied from interface: OElement

return true if the current element is an edge

Specified by:

isEdge in interface OElement

Returns:

true if the current element is an edge

getSchemaType

public Optional<OClass> getSchemaType()

Description copied from interface: OElement

Returns the type of current element, ie the class in the schema (if any)

Specified by:

getSchemaType in interface OElement

Returns:

the type of current element. An empty optional is returned if current element does not have a schema

getRecord

public <T extends ORecord> T getRecord()

Description copied from interface: OIdentifiable

Returns the record instance.

Specified by:

getRecord in interface OIdentifiable

Returns:

ORecord instance

lock

public void lock(boolean iExclusive)

Specified by:

lock in interface OIdentifiable

isLocked

public boolean isLocked()

Specified by:

isLocked in interface OIdentifiable

lockingStrategy

public OStorage.LOCKING_STRATEGY lockingStrategy()

Specified by:

lockingStrategy in interface OIdentifiable

unlock

public void unlock()

Specified by:

unlock in interface OIdentifiable

compareTo

public int compareTo(OIdentifiable o)

Specified by:

compareTo in interface Comparable<OIdentifiable>

compare

public int compare(OIdentifiable o1,
                   OIdentifiable o2)

Specified by:

compare in interface Comparator<OIdentifiable>

getConnection

protected OPair<ODirection,String> getConnection(ODirection iDirection,
                                                 String iFieldName,
                                                 String... iClassNames)

getEdgeFieldNames

protected Set<String> getEdgeFieldNames(ODirection iDirection,
                                        String... iClassNames)

createLink

public static Object createLink(ODocument iFromVertex,
                                OIdentifiable iTo,
                                String iFieldName)

(Internal only) Creates a link between a vertices and a Graph Element.

equals

public boolean equals(Object obj)

Specified by:

equals in interface Comparator<OIdentifiable>

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getInternalStatus

public ORecordElement.STATUS getInternalStatus()

Description copied from interface: ORecordElement

Returns the current status of the record.

Specified by:

getInternalStatus in interface ORecordElement

Returns:

Current status as value between the defined values in the enum ORecordElement.STATUS

setInternalStatus

public void setInternalStatus(ORecordElement.STATUS iStatus)

Description copied from interface: ORecordElement

Changes the current internal status.

Specified by:

setInternalStatus in interface ORecordElement

Parameters:

iStatus - status between the values defined in the enum ORecordElement.STATUS

setDirty

public <RET> RET setDirty()

Description copied from interface: ORecordElement

Marks the instance as dirty. The dirty status could be propagated up if the implementation supports ownership concept.

Specified by:

setDirty in interface ORecordElement

Returns:

The object it self. Useful to call methods in chain.

setDirtyNoChanged

public void setDirtyNoChanged()

Specified by:

setDirtyNoChanged in interface ORecordElement

getOwner

public ORecordElement getOwner()

Specified by:

getOwner in interface ORecordElement

Returns:

Returns record element which contains given one.

toStream

public byte[] toStream()
                throws OSerializationException

Description copied from interface: OSerializableStream

Marshalls the object. Transforms the current object in byte[] form to being stored or transferred over the network.

Specified by:

toStream in interface OSerializableStream

Returns:

The byte array representation of the object

Throws:

OSerializationException - if the marshalling does not succeed

See Also:

OSerializableStream.fromStream(byte[])

fromStream

public OSerializableStream fromStream(byte[] iStream)
                               throws OSerializationException

Description copied from interface: OSerializableStream

Unmarshalls the object. Fills the current object with the values contained in the byte array representation restoring a previous state. Usually byte[] comes from the storage or network.

Specified by:

fromStream in interface OSerializableStream

Parameters:

iStream - byte array representation of the object

Returns:

The Object instance itself giving a "fluent interface". Useful to call multiple methods in chain.

Throws:

OSerializationException - if the unmarshalling does not succeed

detach

public boolean detach()

Description copied from interface: ORecord

Removes all the dependencies with other records. All the relationships remain in form of RecordID. If some links contain dirty records, the detach cannot be complete and this method returns false.

Specified by:

detach in interface ORecord

Returns:

True if the document has been successfully detached, otherwise false.

reset

public <RET extends ORecord> RET reset()

Description copied from interface: ORecord

Resets the record to be reused. The record is fresh like just created. Use this method to recycle records avoiding the creation of them stressing the JVM Garbage Collector.

Specified by:

reset in interface ORecord

Returns:

The Object instance itself giving a "fluent interface". Useful to call multiple methods in chain.

unload

public <RET extends ORecord> RET unload()

Description copied from interface: ORecord

Unloads current record. All information are lost but the record identity. At the next access the record will be auto-reloaded. Useful to free memory or to avoid to keep an old version of it.

Specified by:

unload in interface ORecord

Returns:

The Object instance itself giving a "fluent interface". Useful to call multiple methods in chain.

clear

public <RET extends ORecord> RET clear()

Description copied from interface: ORecord

All the fields are deleted but the record identity is maintained. Use this to remove all the document's fields.

Specified by:

clear in interface ORecord

Returns:

The Object instance itself giving a "fluent interface". Useful to call multiple methods in chain.

copy

public <RET extends ORecord> RET copy()

Description copied from interface: ORecord

Creates a copy of the record. All the record contents are copied.

Specified by:

copy in interface ORecord

Returns:

The Object instance itself giving a "fluent interface". Useful to call multiple methods in chain.

getIdentity

public ORID getIdentity()

Description copied from interface: ORecord

Returns the record identity as <cluster-id>:<cluster-position>

Specified by:

getIdentity in interface OIdentifiable

Specified by:

getIdentity in interface ORecord

Returns:

ORID instance

getVersion

public int getVersion()

Description copied from interface: ORecord

Returns the current version number of the record. When the record is created has version = 0. At every change the storage increment the version number. Version number is used by Optimistic transactions to check if the record is changed in the meanwhile of the transaction.

Specified by:

getVersion in interface ORecord

Returns:

The version number. 0 if it's a brand new record.

See Also:

OTransactionOptimistic

getDatabase

public ODatabaseDocument getDatabase()

Description copied from interface: ORecord

Returns the database where the record belongs.

Specified by:

getDatabase in interface ORecord

Returns:

isDirty

public boolean isDirty()

Description copied from interface: ORecord

Checks if the record is dirty, namely if it was changed in memory.

Specified by:

isDirty in interface ORecord

Returns:

True if dirty, otherwise false

load

public <RET extends ORecord> RET load()
                               throws ORecordNotFoundException

Description copied from interface: ORecord

Loads the record content in memory. If the record is in cache will be returned a new instance, so pay attention to use the returned. If the record is dirty, then it returns to the original content. If the record does not exist a ORecordNotFoundException exception is thrown.

Specified by:

load in interface ORecord

Returns:

The record loaded or itself if the record has been reloaded from the storage. Useful to call methods in chain.

Throws:

ORecordNotFoundException

reload

public <RET extends ORecord> RET reload()
                                 throws ORecordNotFoundException

Description copied from interface: ORecord

Loads the record content in memory. No cache is used. If the record is dirty, then it returns to the original content. If the record does not exist a ORecordNotFoundException exception is thrown.

Specified by:

reload in interface ORecord

Returns:

The Object instance itself giving a "fluent interface". Useful to call multiple methods in chain.

Throws:

ORecordNotFoundException

reload

public <RET extends ORecord> RET reload(String fetchPlan,
                                        boolean ignoreCache,
                                        boolean force)
                                 throws ORecordNotFoundException

Specified by:

reload in interface ORecord

Throws:

ORecordNotFoundException

save

public <RET extends ORecord> RET save()

Description copied from interface: ORecord

Saves in-memory changes to the database. Behavior depends by the current running transaction if any. If no transaction is running then changes apply immediately. If an Optimistic transaction is running then the record will be changed at commit time. The current transaction will continue to see the record as modified, while others not. If a Pessimistic transaction is running, then an exclusive lock is acquired against the record. Current transaction will continue to see the record as modified, while others cannot access to it since it's locked.

Specified by:

save in interface ORecord

Returns:

The Object instance itself giving a "fluent interface". Useful to call multiple methods in chain.

save

public <RET extends ORecord> RET save(String iCluster)

Description copied from interface: ORecord

Saves in-memory changes to the database defining a specific cluster where to save it. Behavior depends by the current running transaction if any. If no transaction is running then changes apply immediately. If an Optimistic transaction is running then the record will be changed at commit time. The current transaction will continue to see the record as modified, while others not. If a Pessimistic transaction is running, then an exclusive lock is acquired against the record. Current transaction will continue to see the record as modified, while others cannot access to it since it's locked.

Specified by:

save in interface ORecord

Returns:

The Object instance itself giving a "fluent interface". Useful to call multiple methods in chain.

save

public <RET extends ORecord> RET save(boolean forceCreate)

Specified by:

save in interface ORecord

save

public <RET extends ORecord> RET save(String iCluster,
                                      boolean forceCreate)

Specified by:

save in interface ORecord

fromJSON

public <RET extends ORecord> RET fromJSON(String iJson)

Description copied from interface: ORecord

Fills the record parsing the content in JSON format.

Specified by:

fromJSON in interface ORecord

Parameters:

iJson - Object content in JSON format

Returns:

The Object instance itself giving a "fluent interface". Useful to call multiple methods in chain.

toJSON

public String toJSON()

Description copied from interface: ORecord

Exports the record in JSON format.

Specified by:

toJSON in interface ORecord

Returns:

Object content in JSON format

toJSON

public String toJSON(String iFormat)

Description copied from interface: ORecord

Exports the record in JSON format specifying additional formatting settings.

Specified by:

toJSON in interface ORecord

Parameters:

iFormat - Format settings separated by comma. Available settings are:

• rid: exports the record's id as property "@rid"
• version: exports the record's version as property "@version"
• class: exports the record's class as property "@class"
• attribSameRow: exports all the record attributes in the same row
• indent:<level>: Indents the output if the <level> specified. Default is 0

Example: "rid,version,class,indent:6" exports record id, version and class properties along with record properties using an indenting level equals of 6.

Returns:

Object content in JSON format

getSize

public int getSize()

Description copied from interface: ORecord

Returns the size in bytes of the record. The size can be computed only for not new records.

Specified by:

getSize in interface ORecord

Returns:

the size in bytes

moveTo

public ORID moveTo(String iClassName,
                   String iClusterName)

Specified by:

moveTo in interface OVertex

checkDeletedInTx

protected boolean checkDeletedInTx()

getConnectionFieldName

public static String getConnectionFieldName(ODirection iDirection,
                                            String iClassName,
                                            boolean useVertexFieldsForEdgeLabels)

replaceLinks

public static void replaceLinks(ODocument iVertex,
                                String iFieldName,
                                OIdentifiable iVertexToRemove,
                                OIdentifiable iNewVertex)

toString

public String toString()

Overrides:

toString in class Object