public class DirectoryTableCollection extends TableCollection implements com.streamscape.sef.dii.AccessibleObject, VirtualTable.VirtualTableHelper
Title: Dataspace Framework
Description: Directory table collection implementation.
Copyright: Copyright (c) 2013
Company: StreamScape Technologies
SchemaObject.ConstraintTypes, SchemaObject.Deferable, SchemaObject.Nullability, SchemaObject.ParameterModes, SchemaObject.ReferentialAction, SchemaObject.ViewCheckModes
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DATA_VALUE |
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 |
---|
DirectoryTableCollection(DataspaceStore database,
NameManager.ObjectName name) |
Modifier and Type | Method and Description |
---|---|
void |
checkStatements(com.streamscape.ds.session.Session session) |
void |
compile(com.streamscape.ds.session.Session session,
SchemaObject parentObject) |
void |
deleteFromDirectoryTable(com.streamscape.ds.session.Session session,
com.streamscape.ds.persist.row.Row row) |
void |
destroy(com.streamscape.ds.session.Session session) |
com.streamscape.ds.result.Result |
executeExternalUpdate(com.streamscape.ds.session.Session session,
java.lang.String sql,
java.lang.Object[] data,
int[] jdbcTypes) |
com.streamscape.ds.result.Result |
getCollectionProperties(com.streamscape.ds.session.Session session) |
ClientConnection |
getConnection() |
FileSystem |
getFileSystem(com.streamscape.ds.session.Session session) |
java.lang.String |
getPath() |
com.streamscape.sef.dii.AccessibleObjectProxy |
getProxy() |
com.streamscape.ds.lib.OrderedHashSet |
getReferences() |
FileServerObject |
getServer() |
java.lang.String |
getServerType(com.streamscape.ds.session.Session session) |
java.lang.String |
getSQL() |
boolean |
hasParameter(java.lang.String name) |
void |
insertIntoExternal(com.streamscape.ds.session.Session session,
java.lang.Object[] data,
boolean overwrite) |
void |
insertIntoExternal(com.streamscape.ds.session.Session session,
java.lang.Object[] data,
int[] jdbcTypes) |
static boolean |
isDataColumn(Table table,
int index) |
void |
materialize(com.streamscape.ds.session.Session session) |
void |
setPath(java.lang.String path) |
void |
setRecursive(boolean recursive) |
void |
setServer(FileServerObject fileServer) |
void |
updateDirectoryTable(com.streamscape.ds.session.Session session,
com.streamscape.ds.persist.row.Row row,
java.lang.Object[] changedData,
int[] changedColumns) |
clear, clear, compileColumnNames, compileInternalStatements, containsPrimarykey, delete, delete, deleteAll, drainFromQueue, fromMap, fromQueue, fromRowSet, fromTable, getEvents, getRow, getSQL, getSQLForReplication, hasForeignKey, hasPrimaryKey, insert, insert, insert, insert, insertAll, insertAll, isEmpty, primaryKeySet, rowSet, select, size, toMap, toMapCollection, toQueue, toQueueCollection, toRowSet, toTableCollection, update, update, update, upsert, upsert
aggregateStateHolder, checkResultIsData, checkResultNotError, checkUpdateCountIs, close, count, dropReplicationSource, exposeCollectionState, getBaseTable, getCatalogName, getChangeTimestamp, getCollectionComponents, getCollectionName, getCollectionName, getCollectionType, getCollectionType, getCollectionTypeName, getCollectionTypeNameCamelCase, getComponents, getDataspace, getEventForTrigger, getMemoryModel, getMemoryModel, getObjectName, getObjectType, getOwner, 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 static final java.lang.String DATA_VALUE
public DirectoryTableCollection(DataspaceStore database, NameManager.ObjectName name)
public FileServerObject getServer()
public void setServer(FileServerObject fileServer)
public java.lang.String getPath()
public void setPath(java.lang.String path)
public void setRecursive(boolean recursive)
public java.lang.String getServerType(com.streamscape.ds.session.Session session)
public void compile(com.streamscape.ds.session.Session session, SchemaObject parentObject)
compile
in interface SchemaObject
compile
in class TableCollection
public void destroy(com.streamscape.ds.session.Session session)
destroy
in interface Collection
destroy
in class AbstractCollection
public FileSystem getFileSystem(com.streamscape.ds.session.Session session)
public ClientConnection getConnection()
public com.streamscape.sef.dii.AccessibleObjectProxy getProxy()
getProxy
in interface com.streamscape.sef.dii.AccessibleObject
getProxy
in class TableCollection
public java.lang.String getSQL()
getSQL
in interface SchemaObject
getSQL
in class TableCollection
public void checkStatements(com.streamscape.ds.session.Session session)
public com.streamscape.ds.result.Result getCollectionProperties(com.streamscape.ds.session.Session session)
getCollectionProperties
in interface Collection
getCollectionProperties
in class AbstractCollection
public void materialize(com.streamscape.ds.session.Session session)
materialize
in interface VirtualTable.VirtualTableHelper
public void insertIntoExternal(com.streamscape.ds.session.Session session, java.lang.Object[] data, int[] jdbcTypes)
insertIntoExternal
in interface VirtualTable.VirtualTableHelper
public void insertIntoExternal(com.streamscape.ds.session.Session session, java.lang.Object[] data, boolean overwrite)
public com.streamscape.ds.result.Result executeExternalUpdate(com.streamscape.ds.session.Session session, java.lang.String sql, java.lang.Object[] data, int[] jdbcTypes)
executeExternalUpdate
in interface VirtualTable.VirtualTableHelper
public boolean hasParameter(java.lang.String name)
hasParameter
in interface VirtualTable.VirtualTableHelper
public void updateDirectoryTable(com.streamscape.ds.session.Session session, com.streamscape.ds.persist.row.Row row, java.lang.Object[] changedData, int[] changedColumns)
public void deleteFromDirectoryTable(com.streamscape.ds.session.Session session, com.streamscape.ds.persist.row.Row row)
public com.streamscape.ds.lib.OrderedHashSet getReferences()
getReferences
in interface SchemaObject
getReferences
in class AbstractCollection
public static boolean isDataColumn(Table table, int index)
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.