public abstract class AbstractCollection extends java.lang.Object implements Collection, DataCollection
Title: Dataspace Framework
Description: Base class for all datspace collections.
Copyright: Copyright (c) 2011
Company: StreamScape Technologies
SchemaObject.ConstraintTypes, SchemaObject.Deferable, SchemaObject.Nullability, SchemaObject.ParameterModes, SchemaObject.ReferentialAction, SchemaObject.ViewCheckModes
ACTOR, ASPECTS, ASSERTION, CATALOG, CHARSET, COLLATION, COLLECTION, COLUMN, CONNECTION_FACTORY, CONSTRAINT, CURSOR, DOMAIN, emptyArray, EVENT_PROTOTYPE, FACETS, FILE_DESCRIPTOR, FULL_TEXT_INDEX, FUNCTION, GRANTEE, INDEX, JOB, LABEL, PARAMETER, PROCEDURE, REFERENCE_LINK, REPLICA, REPLICATION_SOURCE, ROUTINE, SCHEMA, SEMANTIC_TYPE, SEQUENCE, SERVER, SPECIFIC_ROUTINE, SUBQUERY, TABLE, TIMER, TRANSIENT_VAR, TRANSITION, TRIGGER, TYPE, VARIABLE, VIEW, WRAPPER
Modifier and Type | Method and Description |
---|---|
DataspaceStateHolder |
aggregateStateHolder() |
static void |
checkResultIsData(com.streamscape.ds.result.Result result) |
static void |
checkResultNotError(com.streamscape.ds.result.Result result) |
static void |
checkUpdateCountIs(com.streamscape.ds.result.Result result,
int updateCount) |
void |
close() |
void |
compile(com.streamscape.ds.session.Session session,
SchemaObject parentObject) |
void |
compileInternalStatements(com.streamscape.ds.session.Session session) |
java.lang.Long |
count(com.streamscape.ds.session.Session session) |
void |
destroy(com.streamscape.ds.session.Session session) |
void |
dropReplicationSource() |
void |
exposeCollectionState(com.streamscape.ds.navigator.RowSetNavigatorClient navigator,
boolean withValid) |
Table |
getBaseTable() |
NameManager.ObjectName |
getCatalogName() |
long |
getChangeTimestamp() |
com.streamscape.ds.lib.OrderedHashSet |
getCollectionComponents() |
java.lang.String |
getCollectionName()
Returns collection name.
|
java.lang.String |
getCollectionName(com.streamscape.ds.session.Session session) |
com.streamscape.ds.result.Result |
getCollectionProperties(com.streamscape.ds.session.Session session) |
CollectionType |
getCollectionType()
Returns collection Type.
|
CollectionType |
getCollectionType(com.streamscape.ds.session.Session session) |
static java.lang.String |
getCollectionTypeName(CollectionType type) |
static java.lang.String |
getCollectionTypeNameCamelCase(CollectionType type) |
com.streamscape.ds.lib.OrderedHashSet |
getComponents() |
com.streamscape.ds.AbstractDataspace |
getDataspace() |
ImmutableEventDatagram |
getEventForTrigger(com.streamscape.ds.session.Session session,
java.lang.Object[] oldData,
java.lang.Object[] newData,
int when,
int triggerType) |
java.util.List |
getEvents() |
com.streamscape.ds.core.MemoryModel |
getMemoryModel()
Returns collection memory model.
|
com.streamscape.ds.core.MemoryModel |
getMemoryModel(com.streamscape.ds.session.Session session) |
NameManager.ObjectName |
getObjectName() |
int |
getObjectType() |
com.streamscape.ds.rights.Grantee |
getOwner() |
com.streamscape.ds.lib.OrderedHashSet |
getReferences() |
ReplicationSource |
getReplicationSource() |
NameManager.ObjectName |
getSchemaName() |
java.lang.String |
getSQL() |
java.lang.String[] |
getSQL(com.streamscape.ds.lib.OrderedHashSet resolved,
com.streamscape.ds.lib.OrderedHashSet unresolved) |
java.lang.String |
getSQL(java.lang.String name) |
java.lang.String |
getSQL(java.lang.String name,
boolean forReplication) |
java.lang.String |
getSQLForReplication(java.lang.String replicaName) |
DataspaceStateHolder |
getStateHolder() |
java.lang.String |
getTriggerEventId(int whenType,
int operationType) |
java.util.List |
getWindowTriggers() |
boolean |
isReplicated() |
boolean |
isTriggerEventAutogenerated() |
java.util.List |
listTriggers()
Returns list of names of triggers created on collection.
|
java.util.List |
listTriggers(com.streamscape.ds.session.Session session) |
void |
open(com.streamscape.ds.session.Session session) |
void |
resetBaseTable(Table table) |
void |
setReplicationSource(ReplicationSource replicationSource) |
ImmutableEventDatagram |
unwrapEvent(com.streamscape.ds.session.Session session,
java.lang.Object data) |
void |
updateBaseTable(Table table) |
void |
validate(boolean withLobs,
int topN) |
com.streamscape.ds.persist.TableTypesValidator.InvalidTypes |
validateTypes(int topN,
com.streamscape.ds.persist.TableTypesValidator.NormalizeScope normalizeScope) |
java.lang.Object |
wrapEvent(com.streamscape.ds.session.Session session,
ImmutableEventDatagram event) |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aggregateObjectStateHolder, getSQLInSchema, recompileObject
public int getObjectType()
getObjectType
in interface SchemaObject
public com.streamscape.ds.core.MemoryModel getMemoryModel()
DataCollection
getMemoryModel
in interface DataCollection
getMemoryModel
in interface Collection
public com.streamscape.ds.core.MemoryModel getMemoryModel(com.streamscape.ds.session.Session session)
public Table getBaseTable()
getBaseTable
in interface Collection
public void updateBaseTable(Table table)
public DataspaceStateHolder getStateHolder()
public void resetBaseTable(Table table)
resetBaseTable
in interface Collection
public NameManager.ObjectName getObjectName()
getObjectName
in interface SchemaObject
public NameManager.ObjectName getSchemaName()
getSchemaName
in interface SchemaObject
public NameManager.ObjectName getCatalogName()
getCatalogName
in interface SchemaObject
public com.streamscape.ds.rights.Grantee getOwner()
getOwner
in interface SchemaObject
public com.streamscape.ds.lib.OrderedHashSet getReferences()
getReferences
in interface SchemaObject
public com.streamscape.ds.lib.OrderedHashSet getComponents()
getComponents
in interface SchemaObject
public com.streamscape.ds.lib.OrderedHashSet getCollectionComponents()
public void compile(com.streamscape.ds.session.Session session, SchemaObject parentObject)
compile
in interface SchemaObject
public void compileInternalStatements(com.streamscape.ds.session.Session session)
compileInternalStatements
in interface Collection
public java.lang.String getSQL()
getSQL
in interface SchemaObject
public java.lang.String getSQL(java.lang.String name)
getSQL
in interface SchemaObject
public java.lang.String getSQL(java.lang.String name, boolean forReplication)
public java.lang.String getSQLForReplication(java.lang.String replicaName)
getSQLForReplication
in interface Collection
public java.lang.String[] getSQL(com.streamscape.ds.lib.OrderedHashSet resolved, com.streamscape.ds.lib.OrderedHashSet unresolved)
getSQL
in interface Collection
public long getChangeTimestamp()
getChangeTimestamp
in interface SchemaObject
public static java.lang.String getCollectionTypeName(CollectionType type)
public static java.lang.String getCollectionTypeNameCamelCase(CollectionType type)
public com.streamscape.ds.result.Result getCollectionProperties(com.streamscape.ds.session.Session session)
getCollectionProperties
in interface Collection
public void open(com.streamscape.ds.session.Session session)
open
in interface Collection
public void close()
close
in interface Collection
public void destroy(com.streamscape.ds.session.Session session)
destroy
in interface Collection
public java.util.List listTriggers(com.streamscape.ds.session.Session session)
public java.lang.String getCollectionName(com.streamscape.ds.session.Session session)
public java.lang.String getCollectionName()
DataCollection
getCollectionName
in interface DataCollection
public CollectionType getCollectionType(com.streamscape.ds.session.Session session)
public CollectionType getCollectionType()
DataCollection
getCollectionType
in interface DataCollection
getCollectionType
in interface Collection
public java.util.List listTriggers()
DataCollection
listTriggers
in interface DataCollection
public boolean isTriggerEventAutogenerated()
isTriggerEventAutogenerated
in interface Collection
public java.lang.String getTriggerEventId(int whenType, int operationType)
getTriggerEventId
in interface Collection
public ImmutableEventDatagram getEventForTrigger(com.streamscape.ds.session.Session session, java.lang.Object[] oldData, java.lang.Object[] newData, int when, int triggerType)
getEventForTrigger
in interface Collection
public static void checkResultNotError(com.streamscape.ds.result.Result result) throws DataspaceException
DataspaceException
public static void checkUpdateCountIs(com.streamscape.ds.result.Result result, int updateCount) throws DataspaceException
DataspaceException
public static void checkResultIsData(com.streamscape.ds.result.Result result)
public java.lang.Object wrapEvent(com.streamscape.ds.session.Session session, ImmutableEventDatagram event)
wrapEvent
in interface Collection
public ImmutableEventDatagram unwrapEvent(com.streamscape.ds.session.Session session, java.lang.Object data)
unwrapEvent
in interface Collection
public java.util.List getEvents()
getEvents
in interface Collection
public ReplicationSource getReplicationSource()
getReplicationSource
in interface Collection
public void dropReplicationSource()
dropReplicationSource
in interface Collection
public boolean isReplicated()
isReplicated
in interface Collection
public void setReplicationSource(ReplicationSource replicationSource)
setReplicationSource
in interface Collection
public java.lang.Long count(com.streamscape.ds.session.Session session)
count
in interface Collection
public final void validate(boolean withLobs, int topN)
public com.streamscape.ds.persist.TableTypesValidator.InvalidTypes validateTypes(int topN, com.streamscape.ds.persist.TableTypesValidator.NormalizeScope normalizeScope)
public DataspaceStateHolder aggregateStateHolder()
public void exposeCollectionState(com.streamscape.ds.navigator.RowSetNavigatorClient navigator, boolean withValid)
public com.streamscape.ds.AbstractDataspace getDataspace()
public java.util.List getWindowTriggers()
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.