Package com.orientechnologies.orient.core.metadata.schema

Class OSchemaEmbedded

java.lang.Object

com.orientechnologies.orient.core.metadata.schema.OSchemaShared

com.orientechnologies.orient.core.metadata.schema.OSchemaEmbedded

All Implemented Interfaces:

OCloseable

Direct Known Subclasses:

OSchemaDistributed

public class OSchemaEmbedded
extends OSchemaShared

Created by tglman on 13/06/17.

Nested Class Summary

Nested classes/interfaces inherited from class com.orientechnologies.orient.core.metadata.schema.OSchemaShared

OSchemaShared.ClusterIdsAreEmptyException

Field Summary

Fields inherited from class com.orientechnologies.orient.core.metadata.schema.OSchemaShared

classes, clustersToClasses, clustersToViews, CURRENT_VERSION_NUMBER, snapshot, VERSION_NUMBER_V4, VERSION_NUMBER_V5, views

Constructor Summary

Constructors

Constructor	Description
OSchemaEmbedded(OSharedContext sharedContext)

Method Summary

Modifier and Type	Method	Description
protected void	checkClusterIdExists(ODatabaseDocumentInternal database, int clusterId)
protected void	checkClusterOwnedByOther(int clusterId)
protected void	checkClustersAreAbsent(int[] iClusterIds)
protected void	checkClustersExist(int[] clusterIds, ODatabaseDocumentInternal database)
void	checkEmbedded()
OClass	createClass(ODatabaseDocumentInternal database, String className, int[] clusterIds, OClass... superClasses)
OClass	createClass(ODatabaseDocumentInternal database, String className, int clusters, OClass... superClasses)
boolean	createClassIfNotExists(ODatabaseDocumentInternal session, String className)
boolean	createClassIfNotExists(ODatabaseDocumentInternal session, String className, OClass... superclasses)
protected OClassImpl	createClassInstance(String name)
protected OClassImpl	createClassInstance(String className, int[] clusterIds)
protected OClass	createClassInternal(ODatabaseDocumentInternal database, String className, int[] clusterIdsToAdd, List<OClass> superClasses)
protected int[]	createClusters(ODatabaseDocumentInternal database, String className, int minimumClusters)
OView	createView(ODatabaseDocumentInternal database, OViewConfig cfg)
OView	createView(ODatabaseDocumentInternal database, OViewConfig cfg, ViewCreationListener listener)
OView	createView(ODatabaseDocumentInternal database, String viewName, String statement, Map<String,Object> metadata)
protected OViewImpl	createViewInstance(OViewConfig cfg, int[] clusterIds)
protected OViewImpl	createViewInstance(String name)
protected OClass	createViewInternal(ODatabaseDocumentInternal database, OViewConfig cfg, int[] clusterIdsToAdd)
protected OClass	doCreateClass(ODatabaseDocumentInternal database, String className, int[] clusterIds, int retry, OClass... superClasses)
protected void	doDropClass(ODatabaseDocumentInternal database, String className)
protected void	doDropView(ODatabaseDocumentInternal database, String name)
protected void	doRealCreateClass(ODatabaseDocumentInternal database, String className, List<OClass> superClassesList, int[] clusterIds)
protected void	doRealCreateView(ODatabaseDocumentInternal database, OViewConfig config, int[] clusterIds)
void	dropClass(ODatabaseDocumentInternal database, String className)
protected void	dropClassInternal(ODatabaseDocumentInternal database, String className)
void	dropView(ODatabaseDocumentInternal database, String name)
protected void	dropViewInternal(ODatabaseDocumentInternal database, String view)
OClass	getOrCreateClass(ODatabaseDocumentInternal database, String iClassName, OClass... superClasses)
protected boolean	isRunLocal(ODatabaseDocumentInternal database)

Methods inherited from class com.orientechnologies.orient.core.metadata.schema.OSchemaShared

acquireSchemaReadLock, acquireSchemaWriteLock, addBlobCluster, addClusterClassMap, addClusterViewMap, checkClassNameIfValid, checkFieldNameIfValid, close, countClasses, countViews, create, createAbstractClass, createAbstractClass, createAbstractClass, createClass, createClass, createClass, createClass, createClusterIfNeeded, createGlobalProperty, executeThroughDistributedStorage, existsClass, existsView, findOrCreateGlobalProperty, forceSnapshot, fromStream, getBlobClusters, getClass, getClass, getClassByClusterId, getClasses, getClassesRelyOnCluster, getClusterId, getClusterSelectionFactory, getGlobalProperties, getGlobalPropertyById, getIdentity, getOrCreateClass, getOrCreateClass, getVersion, getView, getViewByClusterId, getViews, getViewsRelyOnCluster, load, makeSnapshot, onPostIndexManagement, releaseSchemaReadLock, releaseSchemaWriteLock, releaseSchemaWriteLock, reload, removeBlobCluster, sendCommand, toNetworkStream, toStream

Methods inherited from class java.lang.Object

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

Constructor Details

OSchemaEmbedded

public OSchemaEmbedded(OSharedContext sharedContext)

Method Details

createClass

public OClass createClass(ODatabaseDocumentInternal database,
 String className,
 int[] clusterIds,
 OClass... superClasses)

Specified by:

createClass in class OSchemaShared

createClass

public OClass createClass(ODatabaseDocumentInternal database,
 String className,
 int clusters,
 OClass... superClasses)

Specified by:

createClass in class OSchemaShared

createClassIfNotExists

public boolean createClassIfNotExists(ODatabaseDocumentInternal session,
 String className)

Specified by:

createClassIfNotExists in class OSchemaShared

createClassIfNotExists

public boolean createClassIfNotExists(ODatabaseDocumentInternal session,
 String className,
 OClass... superclasses)

Specified by:

createClassIfNotExists in class OSchemaShared

doRealCreateClass

protected void doRealCreateClass(ODatabaseDocumentInternal database,
 String className,
 List<OClass> superClassesList,
 int[] clusterIds)
                          throws OSchemaShared.ClusterIdsAreEmptyException

Throws:

OSchemaShared.ClusterIdsAreEmptyException

createClassInternal

protected OClass createClassInternal(ODatabaseDocumentInternal database,
 String className,
 int[] clusterIdsToAdd,
 List<OClass> superClasses)
                              throws OSchemaShared.ClusterIdsAreEmptyException

Throws:

OSchemaShared.ClusterIdsAreEmptyException

createView

public OView createView(ODatabaseDocumentInternal database,
 String viewName,
 String statement,
 Map<String,Object> metadata)

Specified by:

createView in class OSchemaShared

createView

public OView createView(ODatabaseDocumentInternal database,
 OViewConfig cfg)

Specified by:

createView in class OSchemaShared

createView

public OView createView(ODatabaseDocumentInternal database,
 OViewConfig cfg,
 ViewCreationListener listener)

Specified by:

createView in class OSchemaShared

doRealCreateView

protected void doRealCreateView(ODatabaseDocumentInternal database,
 OViewConfig config,
 int[] clusterIds)
                         throws OSchemaShared.ClusterIdsAreEmptyException

Throws:

OSchemaShared.ClusterIdsAreEmptyException

createViewInternal

protected OClass createViewInternal(ODatabaseDocumentInternal database,
 OViewConfig cfg,
 int[] clusterIdsToAdd)
                             throws OSchemaShared.ClusterIdsAreEmptyException

Throws:

OSchemaShared.ClusterIdsAreEmptyException

createClassInstance

protected OClassImpl createClassInstance(String className,
 int[] clusterIds)

createViewInstance

protected OViewImpl createViewInstance(OViewConfig cfg,
 int[] clusterIds)

getOrCreateClass

public OClass getOrCreateClass(ODatabaseDocumentInternal database,
 String iClassName,
 OClass... superClasses)

Specified by:

getOrCreateClass in class OSchemaShared

doCreateClass

protected OClass doCreateClass(ODatabaseDocumentInternal database,
 String className,
 int[] clusterIds,
 int retry,
 OClass... superClasses)
                        throws OSchemaShared.ClusterIdsAreEmptyException

Throws:

OSchemaShared.ClusterIdsAreEmptyException

createClusters

protected int[] createClusters(ODatabaseDocumentInternal database,
 String className,
 int minimumClusters)

checkClustersExist

protected void checkClustersExist(int[] clusterIds,
 ODatabaseDocumentInternal database)

checkClusterIdExists

protected void checkClusterIdExists(ODatabaseDocumentInternal database,
 int clusterId)

checkClustersAreAbsent

protected void checkClustersAreAbsent(int[] iClusterIds)

checkClusterOwnedByOther

protected void checkClusterOwnedByOther(int clusterId)

dropClass

public void dropClass(ODatabaseDocumentInternal database,
 String className)

Specified by:

dropClass in class OSchemaShared

doDropClass

protected void doDropClass(ODatabaseDocumentInternal database,
 String className)

dropClassInternal

protected void dropClassInternal(ODatabaseDocumentInternal database,
 String className)

dropView

public void dropView(ODatabaseDocumentInternal database,
 String name)

Specified by:

dropView in class OSchemaShared

doDropView

protected void doDropView(ODatabaseDocumentInternal database,
 String name)

dropViewInternal

protected void dropViewInternal(ODatabaseDocumentInternal database,
 String view)

createClassInstance

protected OClassImpl createClassInstance(String name)

Specified by:

createClassInstance in class OSchemaShared

createViewInstance

protected OViewImpl createViewInstance(String name)

Specified by:

createViewInstance in class OSchemaShared

checkEmbedded

public void checkEmbedded()

Specified by:

checkEmbedded in class OSchemaShared

isRunLocal

protected boolean isRunLocal(ODatabaseDocumentInternal database)