public class TableCollection extends AbstractCollection implements com.streamscape.sef.dii.AccessibleObject
Title: Dataspace Framework
Description: Table Collection
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
Constructor and Description |
---|
TableCollection(DataspaceStore database,
NameManager.ObjectName name,
com.streamscape.ds.core.MemoryModel memoryModel) |
TableCollection(DataspaceStore database,
NameManager.ObjectName name,
com.streamscape.ds.core.MemoryModel memoryModel,
int tableType) |
Modifier and Type | Method and Description |
---|---|
void |
clear(com.streamscape.ds.session.Session session) |
void |
clear(com.streamscape.ds.session.Session session,
java.lang.Boolean force) |
void |
compile(com.streamscape.ds.session.Session session,
SchemaObject parentObject) |
void |
compileColumnNames() |
void |
compileInternalStatements(com.streamscape.ds.session.Session session) |
boolean |
containsPrimarykey(com.streamscape.ds.session.Session session,
java.lang.String key) |
void |
delete(com.streamscape.ds.session.Session session,
int rowId) |
void |
delete(com.streamscape.ds.session.Session session,
java.lang.String selector) |
void |
deleteAll(com.streamscape.ds.session.Session session) |
void |
drainFromQueue(com.streamscape.ds.session.Session session,
java.util.Queue queue) |
void |
fromMap(com.streamscape.ds.session.Session session,
java.util.Map map) |
void |
fromQueue(com.streamscape.ds.session.Session session,
java.util.Queue queue) |
void |
fromRowSet(com.streamscape.ds.session.Session session,
RowSet rowSet) |
void |
fromTable(com.streamscape.ds.session.Session session,
TableCollection table) |
java.util.List |
getEvents() |
com.streamscape.sef.dii.AccessibleObjectProxy |
getProxy() |
Row |
getRow(com.streamscape.ds.session.Session session,
java.lang.String rowId) |
java.lang.String |
getSQL() |
java.lang.String |
getSQL(java.lang.String name,
boolean forReplication) |
java.lang.String |
getSQLForReplication(java.lang.String replicaName) |
boolean |
hasForeignKey(com.streamscape.ds.session.Session session) |
boolean |
hasPrimaryKey(com.streamscape.ds.session.Session session) |
void |
insert(com.streamscape.ds.session.Session session,
java.lang.Object[] rowData) |
void |
insert(com.streamscape.ds.session.Session session,
Row row) |
void |
insert(com.streamscape.ds.session.Session session,
RowArray rowArray) |
void |
insert(com.streamscape.ds.session.Session session,
RowSet rowSet) |
void |
insertAll(com.streamscape.ds.session.Session session,
java.lang.String select) |
void |
insertAll(com.streamscape.ds.session.Session session,
TableCollection table) |
boolean |
isEmpty(com.streamscape.ds.session.Session session) |
java.util.Set |
primaryKeySet(com.streamscape.ds.session.Session session) |
RowSet |
rowSet(com.streamscape.ds.session.Session session) |
RowSet |
select(com.streamscape.ds.session.Session session,
java.lang.String whereClause) |
long |
size(com.streamscape.ds.session.Session session) |
java.util.Map |
toMap(com.streamscape.ds.session.Session session) |
MapCollection |
toMapCollection(com.streamscape.ds.session.Session session) |
java.util.Queue |
toQueue(com.streamscape.ds.session.Session session) |
BlockingQueueCollection |
toQueueCollection(com.streamscape.ds.session.Session session) |
RowSet |
toRowSet(com.streamscape.ds.session.Session session) |
TableCollection |
toTableCollection(com.streamscape.ds.session.Session session) |
void |
update(com.streamscape.ds.session.Session session,
int rowId,
Row row) |
void |
update(com.streamscape.ds.session.Session session,
java.lang.String rowId,
java.lang.Object[] rowData) |
void |
update(com.streamscape.ds.session.Session session,
java.lang.String selector,
Row row) |
void |
upsert(com.streamscape.ds.session.Session session,
java.lang.Object[] rowData) |
void |
upsert(com.streamscape.ds.session.Session session,
Row row) |
aggregateStateHolder, checkResultIsData, checkResultNotError, checkUpdateCountIs, close, count, destroy, dropReplicationSource, exposeCollectionState, getBaseTable, getCatalogName, getChangeTimestamp, getCollectionComponents, getCollectionName, getCollectionName, getCollectionProperties, getCollectionType, getCollectionType, getCollectionTypeName, getCollectionTypeNameCamelCase, getComponents, getDataspace, getEventForTrigger, getMemoryModel, getMemoryModel, getObjectName, getObjectType, getOwner, getReferences, getReplicationSource, getSchemaName, getSQL, getSQL, getStateHolder, getTriggerEventId, getWindowTriggers, isReplicated, isTriggerEventAutogenerated, listTriggers, listTriggers, open, resetBaseTable, setReplicationSource, unwrapEvent, updateBaseTable, validate, validateTypes, wrapEvent
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aggregateObjectStateHolder, getSQLInSchema, recompileObject
public TableCollection(DataspaceStore database, NameManager.ObjectName name, com.streamscape.ds.core.MemoryModel memoryModel, int tableType)
public TableCollection(DataspaceStore database, NameManager.ObjectName name, com.streamscape.ds.core.MemoryModel memoryModel)
public void compile(com.streamscape.ds.session.Session session, SchemaObject parentObject)
compile
in interface SchemaObject
compile
in class AbstractCollection
public void compileColumnNames()
public void compileInternalStatements(com.streamscape.ds.session.Session session)
compileInternalStatements
in interface Collection
compileInternalStatements
in class AbstractCollection
public com.streamscape.sef.dii.AccessibleObjectProxy getProxy()
getProxy
in interface com.streamscape.sef.dii.AccessibleObject
public java.lang.String getSQL()
getSQL
in interface SchemaObject
getSQL
in class AbstractCollection
public java.lang.String getSQL(java.lang.String name, boolean forReplication)
getSQL
in class AbstractCollection
public java.lang.String getSQLForReplication(java.lang.String replicaName)
getSQLForReplication
in interface Collection
getSQLForReplication
in class AbstractCollection
public void clear(com.streamscape.ds.session.Session session)
public void clear(com.streamscape.ds.session.Session session, java.lang.Boolean force)
public void deleteAll(com.streamscape.ds.session.Session session)
public boolean containsPrimarykey(com.streamscape.ds.session.Session session, java.lang.String key)
public void delete(com.streamscape.ds.session.Session session, java.lang.String selector)
public void delete(com.streamscape.ds.session.Session session, int rowId)
public Row getRow(com.streamscape.ds.session.Session session, java.lang.String rowId)
public boolean hasForeignKey(com.streamscape.ds.session.Session session)
public boolean hasPrimaryKey(com.streamscape.ds.session.Session session)
public void insert(com.streamscape.ds.session.Session session, java.lang.Object[] rowData)
public void insert(com.streamscape.ds.session.Session session, Row row)
public void insert(com.streamscape.ds.session.Session session, RowArray rowArray)
public void insert(com.streamscape.ds.session.Session session, RowSet rowSet)
public void insertAll(com.streamscape.ds.session.Session session, TableCollection table)
public void insertAll(com.streamscape.ds.session.Session session, java.lang.String select)
public boolean isEmpty(com.streamscape.ds.session.Session session)
public java.util.Set primaryKeySet(com.streamscape.ds.session.Session session)
public RowSet rowSet(com.streamscape.ds.session.Session session)
public RowSet select(com.streamscape.ds.session.Session session, java.lang.String whereClause)
public long size(com.streamscape.ds.session.Session session)
public void update(com.streamscape.ds.session.Session session, int rowId, Row row)
public void update(com.streamscape.ds.session.Session session, java.lang.String rowId, java.lang.Object[] rowData)
public void update(com.streamscape.ds.session.Session session, java.lang.String selector, Row row)
public void upsert(com.streamscape.ds.session.Session session, Row row)
public void upsert(com.streamscape.ds.session.Session session, java.lang.Object[] rowData)
public java.util.List getEvents()
getEvents
in interface Collection
getEvents
in class AbstractCollection
public RowSet toRowSet(com.streamscape.ds.session.Session session)
public void fromRowSet(com.streamscape.ds.session.Session session, RowSet rowSet)
public java.util.Queue toQueue(com.streamscape.ds.session.Session session)
public void fromQueue(com.streamscape.ds.session.Session session, java.util.Queue queue)
public void drainFromQueue(com.streamscape.ds.session.Session session, java.util.Queue queue)
public java.util.Map toMap(com.streamscape.ds.session.Session session)
public void fromMap(com.streamscape.ds.session.Session session, java.util.Map map)
public TableCollection toTableCollection(com.streamscape.ds.session.Session session)
public void fromTable(com.streamscape.ds.session.Session session, TableCollection table)
public MapCollection toMapCollection(com.streamscape.ds.session.Session session)
public BlockingQueueCollection toQueueCollection(com.streamscape.ds.session.Session session)
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.