public class Table extends TableBase implements SchemaObject
Title: Dataspace Framework
Description: Dataspace underlying provider implementation
Copyright: Copyright (c) 2010
Company: StreamScape Technologies
SchemaObject.ConstraintTypes, SchemaObject.Deferable, SchemaObject.Nullability, SchemaObject.ParameterModes, SchemaObject.ReferentialAction, SchemaObject.ViewCheckModes
Modifier and Type | Field and Description |
---|---|
Constraint[] |
checkConstraints |
com.streamscape.ds.parser.expression.Expression[] |
colDefaults |
boolean[] |
colGenerated |
com.streamscape.ds.lib.HashMappedList |
columnList |
com.streamscape.ds.range.RangeVariable[] |
defaultRanges |
com.streamscape.ds.schema.table.DfetchMonitor |
dfetchMonitor |
static Table[] |
emptyArray |
static Collection[] |
emptyCollectionArray |
Constraint[] |
fkConstraints |
Constraint[] |
fkMainConstraints |
int |
identityColumn |
NumberSequence |
identitySequence |
long |
tableSchemaChangeTimestamp |
com.streamscape.ds.trigger.TriggerDef[] |
triggerList |
com.streamscape.ds.trigger.TriggerDef[][] |
triggerLists |
CHANGE_SET_TABLE, colTypes, columnCount, database, fullIndex, FUNCTION_TABLE, INFO_SCHEMA_TABLE, isSessionBased, isTemp, isView, JOURNAL_FILE_QUEUE, LOGGED_TABLE, MEMORY_TABLE, persistenceId, persistenceScope, PERSISTENT_TABLE, RESULT_TABLE, SCOPE_FULL, SCOPE_SESSION, SCOPE_STATEMENT, SCOPE_TRANSACTION, SEMAGRAPH, SNAPSHOT, store, SYSTEM_SUBQUERY, SYSTEM_TABLE, TEMP_TEXT_TABLE, TEXT_TABLE, TRANSIENT_TABLE, TRANSITION_TABLE, VIEW_TABLE
ACTOR, ASPECTS, ASSERTION, CATALOG, CHARSET, COLLATION, COLLECTION, COLUMN, CONNECTION_FACTORY, CONSTRAINT, CURSOR, DOMAIN, 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 |
---|
Table(DataspaceStore database,
NameManager.ObjectName name,
int type) |
Table(Table table,
NameManager.ObjectName name)
trigger transition table
|
Modifier and Type | Method and Description |
---|---|
void |
addColumn(ColumnSchema column)
Performs the table level checks and adds a column to the table at the
DDL level.
|
void |
addColumnNoCheck(ColumnSchema column) |
void |
addConstraint(Constraint c)
Adds a constraint.
|
void |
addFullTextIndex(com.streamscape.ds.persist.fulltext.FullTextIndex index) |
void |
addTrigger(com.streamscape.ds.session.Session session,
com.streamscape.ds.trigger.TriggerDef td,
NameManager.ObjectName otherName,
int triggerOrder)
Adds a trigger.
|
void |
addTriggerSQL(java.util.List list,
DataspaceStore store) |
void |
checkDataReadOnly()
Used by INSERT, DELETE, UPDATE operations
|
void |
clearAllData(com.streamscape.ds.persist.PersistentStore store) |
void |
clearAllData(com.streamscape.ds.session.Session session) |
void |
collectFKReadLocks(int[] columnMap,
com.streamscape.ds.lib.OrderedHashSet set)
columnMap is null for deletes
|
void |
collectFKWriteLocks(int[] columnMap,
com.streamscape.ds.lib.OrderedHashSet set)
columnMap is null for deletes
|
static int |
compareRows(com.streamscape.ds.session.Session session,
java.lang.Object[] a,
java.lang.Object[] b,
int[] cols,
com.streamscape.ds.types.Type[] coltypes)
compares two full table rows based on a set of columns
|
void |
compile(com.streamscape.ds.session.Session session,
SchemaObject parentObject) |
static RowMetaData |
convertColumnListToRowMetaData(com.streamscape.ds.lib.HashMappedList columnList) |
com.streamscape.ds.persist.index.Index |
createIndexForColumns(com.streamscape.ds.session.Session session,
int[] columns)
Used to create an index automatically for system and temp tables.
|
void |
createPrimaryKey()
Shortcut for creating default PK's.
|
void |
createPrimaryKey(NameManager.ObjectName indexName,
int[] columns,
boolean columnsNotNull)
Creates a single or multi-column primary key and index.
|
void |
createPrimaryKeyConstraint(NameManager.ObjectName indexName,
int[] columns,
boolean columnsNotNull) |
void |
dropReplicationSource() |
void |
enforceRowConstraints(com.streamscape.ds.session.Session session,
java.lang.Object[] data)
Enforce max field sizes according to SQL column definition.
|
void |
enforceTypeLimits(com.streamscape.ds.session.Session session,
java.lang.Object[] data) |
int |
findColumn(java.lang.String name)
Returns the index of given column name or -1 if not found.
|
void |
fireTriggers(com.streamscape.ds.session.Session session,
com.streamscape.ds.trigger.Trigger.Type triggerType,
java.lang.Object[] oldData,
java.lang.Object[] newData,
int[] cols)
Fires all row-level triggers of the given set (trigger type)
|
void |
fireTriggers(com.streamscape.ds.session.Session session,
com.streamscape.ds.trigger.Trigger.Type triggerType,
com.streamscape.ds.navigator.RowSetNavigator rowSet) |
void |
fireTriggers(com.streamscape.ds.session.Session session,
com.streamscape.ds.trigger.Trigger.Type triggerType,
com.streamscape.ds.navigator.RowSetNavigatorDataChange rowSet) |
void |
fireWindowTriggers(com.streamscape.ds.session.Session session,
java.lang.Object oldData,
java.lang.Object newData) |
Table |
getBaseTable() |
int[] |
getBaseTableColumnMap() |
int[] |
getBestRowIdentifiers() |
NameManager.ObjectName |
getCatalogName()
Returns the catalog name or null, depending on a database property.
|
long |
getChangeTimestamp() |
com.streamscape.ds.persist.index.Index |
getClusteredIndex() |
ColumnSchema |
getColumn(int i)
Returns the Column object at the given index
|
ColumnSchema |
getColumn(java.lang.String name) |
boolean[] |
getColumnCheckList(int[] columnIndexes) |
int |
getColumnIndex(java.lang.String name)
Returns the index of given column name or throws if not found
|
int[] |
getColumnIndexes(com.streamscape.ds.lib.OrderedHashSet set) |
int[] |
getColumnIndexes(java.lang.String[] list) |
java.lang.String |
getColumnListSQL(int[] col,
int len) |
java.lang.String |
getColumnListWithTypeSQL() |
int[] |
getColumnMap()
Returns direct mapping array.
|
java.util.List |
getColumnNameList(int[] columnIndexes) |
void |
getColumnNames(boolean[] columnCheckList,
com.streamscape.ds.lib.Set set) |
com.streamscape.ds.lib.OrderedHashSet |
getColumnNameSet() |
com.streamscape.ds.lib.OrderedHashSet |
getColumnNameSet(boolean[] columnCheckList) |
com.streamscape.ds.lib.OrderedHashSet |
getColumnNameSet(int[] columnIndexes) |
java.lang.String[] |
getCommentsSQL() |
com.streamscape.ds.lib.OrderedHashSet |
getComponents() |
Constraint |
getConstraint(java.lang.String constraintName)
return the named constriant
|
Constraint[] |
getConstraints()
Returns the list of constraints.
|
com.streamscape.ds.persist.row.Row |
getDeleteRowFromLog(com.streamscape.ds.session.Session session,
java.lang.Object[] data)
For log statements.
|
com.streamscape.ds.lib.OrderedHashSet |
getDependentExternalConstraints() |
Constraint[] |
getFKConstraints()
Returns the list of FK constraints.
|
com.streamscape.ds.persist.index.Index |
getFullIndexForColumns(int[] cols)
Finds an existing index for a full column group
|
java.util.List |
getFullTextIndexes() |
int |
getId()
Used to create row id's
|
int |
getIdentityColumnIndex()
Returns the identity column index.
|
com.streamscape.ds.persist.index.Index |
getIndex(java.lang.String indexName)
Returns the Index object of the given name or null if not found.
|
com.streamscape.ds.persist.index.Index |
getIndexForColumn(com.streamscape.ds.session.Session session,
int col)
Finds an existing index for a column
|
com.streamscape.ds.persist.index.Index |
getIndexForColumns(com.streamscape.ds.session.Session session,
int[] cols)
Finds an existing index for a column group
|
com.streamscape.ds.persist.index.Index |
getIndexForColumns(com.streamscape.ds.session.Session session,
com.streamscape.ds.lib.OrderedIntHashSet set,
boolean ordered)
Finds an existing index for a column set or create one for temporary
tables
|
long[] |
getIndexRootsArray()
Return the list of file pointers to root nodes for this table's
indexes.
|
java.lang.String |
getIndexRootsSQL(long[] roots) |
java.lang.Object[] |
getNewRowData(com.streamscape.ds.session.Session session)
Returns array for a new row with SQL DEFAULT value for each column n
where exists[n] is false.
|
long |
getNextIdentity() |
Constraint |
getNotNullConstraintForColumn(int colIndex) |
NameManager.ObjectName |
getObjectName()
Returns the HsqlName object fo the table
|
int |
getObjectType() |
com.streamscape.ds.rights.Grantee |
getOwner() |
Constraint |
getPrimaryConstraint()
Returns the primary constraint.
|
com.streamscape.ds.parser.expression.QueryExpression |
getQueryExpression() |
com.streamscape.ds.lib.OrderedHashSet |
getReferences() |
com.streamscape.ds.lib.OrderedHashSet |
getReferencesForDependents() |
ReplicationSource |
getReplicationSource() |
RowMetaData |
getRowMetaData() |
com.streamscape.ds.persist.PersistentStore |
getRowStore(com.streamscape.ds.session.Session session)
Path used for INFORMATION_SCHEMA tables
|
NameManager.ObjectName |
getSchemaName()
Returns the schema name.
|
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 |
getSQLForClustered() |
java.lang.String[] |
getSQLForCollection(Collection collection,
com.streamscape.ds.lib.OrderedHashSet resolved,
com.streamscape.ds.lib.OrderedHashSet unresolved) |
java.lang.String |
getSQLForReadOnly() |
java.lang.String[] |
getSQLForTextSource(boolean withHeader) |
com.streamscape.ds.parser.expression.SubQuery |
getSubQuery() |
com.streamscape.ds.trigger.TriggerDef |
getTrigger(java.lang.String name)
Returns a trigger.
|
int |
getTriggerIndex(java.lang.String name) |
com.streamscape.ds.trigger.TriggerDef[] |
getTriggers() |
Constraint |
getUniqueConstraintForColumns(int[] cols)
Returns the UNIQUE or PK constraint with the given column signature.
|
Constraint |
getUniqueConstraintForIndex(com.streamscape.ds.persist.index.Index index)
Returns any unique Constraint using this index
|
int[] |
getUniqueNotNullColumnGroup(boolean[] usedColumns) |
Constraint |
getUniqueOrPKConstraintForIndex(com.streamscape.ds.persist.index.Index index)
Returns any unique Constraint using this index
|
com.streamscape.ds.lib.OrderedHashSet |
getUniquePKConstraintNames() |
int[] |
getUpdatableColumns() |
boolean |
hasForeignKey() |
boolean |
hasGeneratedColumn() |
boolean |
hasIdentityColumn() |
int |
indexTypeForColumn(com.streamscape.ds.session.Session session,
int col) |
com.streamscape.ds.persist.row.Row |
insertData(com.streamscape.ds.session.Session session,
com.streamscape.ds.persist.PersistentStore store,
java.lang.Object[] data)
For system operations outside transaction constrol
|
void |
insertFromScript(com.streamscape.ds.session.Session session,
com.streamscape.ds.persist.PersistentStore store,
java.lang.Object[] data)
Not for general use.
|
void |
insertIntoTable(com.streamscape.ds.session.Session session,
com.streamscape.ds.result.Result result)
Multi-row insert method.
|
void |
insertNoCheckFromLog(com.streamscape.ds.session.Session session,
java.lang.Object[] data) |
void |
insertResult(com.streamscape.ds.session.Session session,
com.streamscape.ds.persist.PersistentStore store,
com.streamscape.ds.result.Result ins)
Used for subquery inserts.
|
com.streamscape.ds.persist.row.Row |
insertSingleRow(com.streamscape.ds.session.Session session,
com.streamscape.ds.persist.PersistentStore store,
java.lang.Object[] data,
int[] changedCols)
Mid level method for inserting single rows.
|
com.streamscape.ds.persist.row.Row |
insertSingleRowForUpdate(com.streamscape.ds.session.Session session,
com.streamscape.ds.persist.PersistentStore store,
java.lang.Object[] data,
int[] changedCols) |
void |
insertSys(com.streamscape.ds.session.Session session,
com.streamscape.ds.persist.PersistentStore store,
java.lang.Object[] data)
Used by the system tables only
|
int |
insertSys(com.streamscape.ds.session.Session session,
com.streamscape.ds.persist.PersistentStore store,
com.streamscape.ds.result.Result ins)
Used for system table inserts.
|
boolean |
isBestRowIdentifiersStrict() |
boolean |
isCached() |
boolean |
isConnected() |
boolean |
isDataReadOnly() |
boolean |
isFileBased()
Text or Cached Tables are normally file based
|
boolean |
isInsertable() |
boolean |
isMemory() |
boolean |
isReadOnly() |
boolean |
isReplicated() |
boolean |
isSchemaBaseTable() |
boolean |
isSnapshot() |
boolean |
isTemp() |
boolean |
isText() |
boolean |
isTriggerDeletable() |
boolean |
isTriggerInsertable() |
boolean |
isTriggerUpdatable() |
boolean |
isUpdatable() |
boolean |
isView() |
boolean |
isWritable() |
void |
releaseTriggers()
Used when dropping all triggers.
|
void |
removeConstraint(int index) |
void |
removeConstraint(java.lang.String name)
remove a named constraint
|
void |
removeFullTextIndex(com.streamscape.ds.persist.fulltext.FullTextIndex index) |
void |
removeTrigger(com.streamscape.ds.trigger.TriggerDef trigger)
Drops a trigger.
|
void |
renameColumn(ColumnSchema column,
NameManager.ObjectName newName) |
com.streamscape.ds.navigator.RowIterator |
rowIteratorClustered(com.streamscape.ds.persist.PersistentStore store) |
com.streamscape.ds.navigator.RowIterator |
rowIteratorClustered(com.streamscape.ds.session.Session session) |
void |
setColumnStructures() |
void |
setColumnTypeVars(int i) |
void |
setDataReadOnly(boolean value) |
void |
setGeneratedColumns(com.streamscape.ds.session.Session session,
java.lang.Object[] data) |
void |
setIdentityColumn(com.streamscape.ds.session.Session session,
java.lang.Object[] data)
If there is an identity or generated column in the table, sets
the value and/or adjusts the identiy value for the table.
|
void |
setIndexRoots(long[] roots)
Sets the index roots of a cached/text table to specified file
pointers.
|
void |
setIndexRoots(com.streamscape.ds.session.Session session,
java.lang.String s)
Sets the index roots.
|
void |
setName(NameManager.ObjectName name) |
void |
setReplicationSource(ReplicationSource replicationSource) |
void |
systemSetIdentityColumn(com.streamscape.ds.session.Session session,
java.lang.Object[] data) |
void |
updateTriggersOrderAndRemoveNulls() |
void |
verifyConstraintsIntegrity() |
createAndAddIndexStructure, createIndex, createIndexStructure, createPrimaryIndex, dropIndex, duplicate, getColumnCount, getColumnTypes, getDataColumnCount, getDataScopeString, getEmptyRowData, getFullIndex, getIndex, getIndexCount, getIndexList, getNewColumnCheckList, getPersistenceId, getPrimaryIndex, getPrimaryKey, getPrimaryKeyTypes, getSampleCount, getSampleCountAsString, getTableType, hasLobColumn, hasPrimaryKey, isDropped, isEmpty, isLogged, isTransactional, onCommitPreserve, releaseRowStore, rowIterator, rowIterator, setBestRowIdentifiers, setDropped, setHasLobColumn, setIndexes, setTransactional
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aggregateObjectStateHolder, getSQLInSchema, recompileObject
public static final Table[] emptyArray
public static final Collection[] emptyCollectionArray
public com.streamscape.ds.lib.HashMappedList columnList
public int identityColumn
public NumberSequence identitySequence
public Constraint[] fkConstraints
public Constraint[] fkMainConstraints
public Constraint[] checkConstraints
public com.streamscape.ds.trigger.TriggerDef[] triggerList
public com.streamscape.ds.trigger.TriggerDef[][] triggerLists
public com.streamscape.ds.parser.expression.Expression[] colDefaults
public boolean[] colGenerated
public com.streamscape.ds.range.RangeVariable[] defaultRanges
public com.streamscape.ds.schema.table.DfetchMonitor dfetchMonitor
public long tableSchemaChangeTimestamp
public Table(DataspaceStore database, NameManager.ObjectName name, int type)
public Table(Table table, NameManager.ObjectName name)
public int getObjectType()
getObjectType
in interface SchemaObject
public void setReplicationSource(ReplicationSource replicationSource)
public final NameManager.ObjectName getObjectName()
getObjectName
in interface SchemaObject
public NameManager.ObjectName getCatalogName()
getCatalogName
in interface SchemaObject
public NameManager.ObjectName getSchemaName()
getSchemaName
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 getReferencesForDependents()
public com.streamscape.ds.lib.OrderedHashSet getComponents()
getComponents
in interface SchemaObject
public void compile(com.streamscape.ds.session.Session session, SchemaObject parentObject)
compile
in interface SchemaObject
public java.lang.String getSQL()
getSQL
in interface SchemaObject
public java.lang.String getSQL(java.lang.String name)
getSQL
in interface SchemaObject
public long getChangeTimestamp()
getChangeTimestamp
in interface SchemaObject
public final void setName(NameManager.ObjectName name)
public java.lang.String[] getSQL(com.streamscape.ds.lib.OrderedHashSet resolved, com.streamscape.ds.lib.OrderedHashSet unresolved)
public java.lang.String[] getSQLForCollection(Collection collection, com.streamscape.ds.lib.OrderedHashSet resolved, com.streamscape.ds.lib.OrderedHashSet unresolved)
public java.lang.String getSQLForReadOnly()
public java.lang.String[] getSQLForTextSource(boolean withHeader)
public java.lang.String getSQLForClustered()
public void addTriggerSQL(java.util.List list, DataspaceStore store)
public java.lang.String getIndexRootsSQL(long[] roots)
public java.lang.String getColumnListSQL(int[] col, int len)
public java.lang.String[] getCommentsSQL()
public java.lang.String getColumnListWithTypeSQL()
public boolean isConnected()
public static int compareRows(com.streamscape.ds.session.Session session, java.lang.Object[] a, java.lang.Object[] b, int[] cols, com.streamscape.ds.types.Type[] coltypes)
a
- a full rowb
- a full rowcols
- array of column indexes to comparecoltypes
- array of column types for the full rowpublic final boolean isSchemaBaseTable()
public final boolean isText()
public final boolean isTemp()
public final boolean isReadOnly()
public final boolean isView()
public boolean isCached()
public boolean isDataReadOnly()
public void checkDataReadOnly()
public void setDataReadOnly(boolean value)
public boolean isFileBased()
public void addConstraint(Constraint c)
public void verifyConstraintsIntegrity()
public Constraint[] getConstraints()
public Constraint[] getFKConstraints()
public Constraint getPrimaryConstraint()
public void collectFKReadLocks(int[] columnMap, com.streamscape.ds.lib.OrderedHashSet set)
public void collectFKWriteLocks(int[] columnMap, com.streamscape.ds.lib.OrderedHashSet set)
public Constraint getNotNullConstraintForColumn(int colIndex)
public Constraint getUniqueConstraintForColumns(int[] cols)
public Constraint getUniqueOrPKConstraintForIndex(com.streamscape.ds.persist.index.Index index)
index
- public void addColumn(ColumnSchema column)
public void addColumnNoCheck(ColumnSchema column)
public boolean hasGeneratedColumn()
public boolean hasIdentityColumn()
public long getNextIdentity()
public com.streamscape.ds.lib.OrderedHashSet getDependentExternalConstraints()
public com.streamscape.ds.lib.OrderedHashSet getUniquePKConstraintNames()
public int getIdentityColumnIndex()
public int getColumnIndex(java.lang.String name)
public int findColumn(java.lang.String name)
public ColumnSchema getColumn(java.lang.String name)
public int[] getBestRowIdentifiers()
public boolean isBestRowIdentifiersStrict()
public com.streamscape.ds.persist.index.Index getClusteredIndex()
public com.streamscape.ds.persist.index.Index getIndexForColumn(com.streamscape.ds.session.Session session, int col)
public int[] getUniqueNotNullColumnGroup(boolean[] usedColumns)
public void createPrimaryKey()
public void createPrimaryKey(NameManager.ObjectName indexName, int[] columns, boolean columnsNotNull)
public void createPrimaryKeyConstraint(NameManager.ObjectName indexName, int[] columns, boolean columnsNotNull)
public void setColumnStructures()
public void setColumnTypeVars(int i)
public int[] getColumnMap()
public boolean[] getColumnCheckList(int[] columnIndexes)
public int[] getColumnIndexes(java.lang.String[] list)
public int[] getColumnIndexes(com.streamscape.ds.lib.OrderedHashSet set)
public ColumnSchema getColumn(int i)
public com.streamscape.ds.lib.OrderedHashSet getColumnNameSet(int[] columnIndexes)
public java.util.List getColumnNameList(int[] columnIndexes)
public com.streamscape.ds.lib.OrderedHashSet getColumnNameSet(boolean[] columnCheckList)
public void getColumnNames(boolean[] columnCheckList, com.streamscape.ds.lib.Set set)
public com.streamscape.ds.lib.OrderedHashSet getColumnNameSet()
public java.lang.Object[] getNewRowData(com.streamscape.ds.session.Session session)
public void addTrigger(com.streamscape.ds.session.Session session, com.streamscape.ds.trigger.TriggerDef td, NameManager.ObjectName otherName, int triggerOrder)
public void updateTriggersOrderAndRemoveNulls()
public com.streamscape.ds.trigger.TriggerDef getTrigger(java.lang.String name)
public int getTriggerIndex(java.lang.String name)
public void removeTrigger(com.streamscape.ds.trigger.TriggerDef trigger)
public void releaseTriggers()
public com.streamscape.ds.persist.index.Index getIndex(java.lang.String indexName)
public Constraint getConstraint(java.lang.String constraintName)
public Constraint getUniqueConstraintForIndex(com.streamscape.ds.persist.index.Index index)
index
- public void removeConstraint(java.lang.String name)
public void removeConstraint(int index)
public void renameColumn(ColumnSchema column, NameManager.ObjectName newName)
public com.streamscape.ds.trigger.TriggerDef[] getTriggers()
public boolean isWritable()
public boolean isInsertable()
public boolean isUpdatable()
public boolean isTriggerInsertable()
public boolean isTriggerUpdatable()
public boolean isTriggerDeletable()
public int[] getUpdatableColumns()
public Table getBaseTable()
public int[] getBaseTableColumnMap()
public com.streamscape.ds.persist.index.Index createIndexForColumns(com.streamscape.ds.session.Session session, int[] columns)
public void fireTriggers(com.streamscape.ds.session.Session session, com.streamscape.ds.trigger.Trigger.Type triggerType, com.streamscape.ds.navigator.RowSetNavigatorDataChange rowSet)
public void fireTriggers(com.streamscape.ds.session.Session session, com.streamscape.ds.trigger.Trigger.Type triggerType, com.streamscape.ds.navigator.RowSetNavigator rowSet)
public void fireTriggers(com.streamscape.ds.session.Session session, com.streamscape.ds.trigger.Trigger.Type triggerType, java.lang.Object[] oldData, java.lang.Object[] newData, int[] cols)
public void fireWindowTriggers(com.streamscape.ds.session.Session session, java.lang.Object oldData, java.lang.Object newData)
public void enforceRowConstraints(com.streamscape.ds.session.Session session, java.lang.Object[] data)
public void enforceTypeLimits(com.streamscape.ds.session.Session session, java.lang.Object[] data)
public int indexTypeForColumn(com.streamscape.ds.session.Session session, int col)
public com.streamscape.ds.persist.index.Index getIndexForColumns(com.streamscape.ds.session.Session session, int[] cols)
public com.streamscape.ds.persist.index.Index getFullIndexForColumns(int[] cols)
public com.streamscape.ds.persist.index.Index getIndexForColumns(com.streamscape.ds.session.Session session, com.streamscape.ds.lib.OrderedIntHashSet set, boolean ordered)
public final long[] getIndexRootsArray()
public void setIndexRoots(long[] roots)
public void setIndexRoots(com.streamscape.ds.session.Session session, java.lang.String s)
public com.streamscape.ds.persist.row.Row insertSingleRow(com.streamscape.ds.session.Session session, com.streamscape.ds.persist.PersistentStore store, java.lang.Object[] data, int[] changedCols)
public com.streamscape.ds.persist.row.Row insertSingleRowForUpdate(com.streamscape.ds.session.Session session, com.streamscape.ds.persist.PersistentStore store, java.lang.Object[] data, int[] changedCols)
public void insertIntoTable(com.streamscape.ds.session.Session session, com.streamscape.ds.result.Result result)
public void insertNoCheckFromLog(com.streamscape.ds.session.Session session, java.lang.Object[] data)
public int insertSys(com.streamscape.ds.session.Session session, com.streamscape.ds.persist.PersistentStore store, com.streamscape.ds.result.Result ins)
public void insertResult(com.streamscape.ds.session.Session session, com.streamscape.ds.persist.PersistentStore store, com.streamscape.ds.result.Result ins)
public void insertFromScript(com.streamscape.ds.session.Session session, com.streamscape.ds.persist.PersistentStore store, java.lang.Object[] data)
public com.streamscape.ds.persist.row.Row insertData(com.streamscape.ds.session.Session session, com.streamscape.ds.persist.PersistentStore store, java.lang.Object[] data)
public void insertSys(com.streamscape.ds.session.Session session, com.streamscape.ds.persist.PersistentStore store, java.lang.Object[] data)
public void setIdentityColumn(com.streamscape.ds.session.Session session, java.lang.Object[] data)
public void setGeneratedColumns(com.streamscape.ds.session.Session session, java.lang.Object[] data)
public void systemSetIdentityColumn(com.streamscape.ds.session.Session session, java.lang.Object[] data)
public com.streamscape.ds.persist.row.Row getDeleteRowFromLog(com.streamscape.ds.session.Session session, java.lang.Object[] data)
public com.streamscape.ds.navigator.RowIterator rowIteratorClustered(com.streamscape.ds.session.Session session)
public com.streamscape.ds.navigator.RowIterator rowIteratorClustered(com.streamscape.ds.persist.PersistentStore store)
public void clearAllData(com.streamscape.ds.session.Session session)
clearAllData
in class TableBase
public void clearAllData(com.streamscape.ds.persist.PersistentStore store)
clearAllData
in class TableBase
public com.streamscape.ds.persist.PersistentStore getRowStore(com.streamscape.ds.session.Session session)
getRowStore
in class TableBase
public com.streamscape.ds.parser.expression.SubQuery getSubQuery()
public com.streamscape.ds.parser.expression.QueryExpression getQueryExpression()
public final boolean hasForeignKey()
public boolean isMemory()
public boolean isSnapshot()
public ReplicationSource getReplicationSource()
public void dropReplicationSource()
public boolean isReplicated()
public RowMetaData getRowMetaData()
public static RowMetaData convertColumnListToRowMetaData(com.streamscape.ds.lib.HashMappedList columnList)
public void addFullTextIndex(com.streamscape.ds.persist.fulltext.FullTextIndex index)
public void removeFullTextIndex(com.streamscape.ds.persist.fulltext.FullTextIndex index)
public java.util.List getFullTextIndexes()
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.