public class RplScript extends java.lang.Object implements SchemaObject, java.lang.Cloneable, RplSchemaObject
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 |
---|---|
static RplScript[] |
emptyArray |
java.util.List |
eventIds |
static java.lang.String |
INDENT |
boolean |
isRecursive |
int |
maxDynamicResults |
Collection |
returnCollection |
boolean |
returnsCollection |
RoutineSchema |
routineSchema |
com.streamscape.ds.lib.HashMappedList |
scopeVariables |
com.streamscape.ds.parser.statement.Statement |
statement |
Table |
triggerTable |
int |
variableCount |
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 |
---|
RplScript(DataspaceStore store,
NameManager.ObjectName name,
int type) |
RplScript(DataspaceStore store,
NameManager.ObjectName name,
com.streamscape.ds.range.RangeVariable[] ranges) |
RplScript(DataspaceStore store,
NameManager.ObjectName name,
Table table,
com.streamscape.ds.range.RangeVariable[] ranges) |
Modifier and Type | Method and Description |
---|---|
void |
addParameter(ColumnSchema param) |
void |
addTransientVariable(java.lang.String name,
ColumnSchema var) |
DataspaceStateHolder |
aggregateStateHolder()
Aggreagtes object state with all referenced object states.
|
void |
close() |
void |
close(com.streamscape.ds.utils.SourceEventFlowData flowData) |
void |
compile(com.streamscape.ds.session.Session session,
SchemaObject parentObject) |
void |
disable() |
RplScript |
duplicate() |
NameManager.ObjectName |
getCatalogName() |
long |
getChangeTimestamp() |
com.streamscape.ds.lib.OrderedHashSet |
getComponents() |
java.util.List |
getEvents() |
java.util.List |
getEvents(java.lang.String objectName,
EventScope scope) |
java.lang.String |
getExternalName() |
int |
getMaxDynamicResults() |
int |
getNumberOfTransientVariables() |
NameManager.ObjectName |
getObjectName() |
int |
getObjectType() |
com.streamscape.ds.rights.Grantee |
getOwner() |
ColumnSchema |
getParameter(int i) |
int |
getParameterCount() |
int |
getParameterCount(int type) |
int |
getParameterIndex(java.lang.String name) |
com.streamscape.ds.range.RangeVariable[] |
getParameterRangeVariables() |
java.lang.String |
getPrettyPrintSQL() |
com.streamscape.ds.parser.statement.Statement |
getProcedure() |
com.streamscape.ds.lib.OrderedHashSet |
getReferences() |
com.streamscape.ds.types.Type |
getReturnType() |
java.lang.String |
getRpl() |
NameManager.ObjectName |
getSchemaName() |
NameManager.ObjectName |
getSpecificName() |
java.lang.String |
getSQL() |
java.lang.String |
getSQL(java.lang.String name) |
java.lang.String |
getSQLAlter() |
java.lang.String |
getSQLAlter(java.lang.String name) |
java.lang.String |
getSQLBodyDefinition() |
java.lang.String |
getSQLDeclaration() |
java.lang.String |
getSQLDeclaration(java.lang.String name) |
DataspaceStateHolder |
getStateHolder()
Returns state holder that contains state of the object.
|
java.lang.String |
getStateName(com.streamscape.ds.core.DataspaceStoreState state)
Returns state name including enabled/disabled.
|
Table |
getTable() |
NameManager.ObjectName[] |
getTableNamesForRead() |
NameManager.ObjectName[] |
getTableNamesForWrite() |
com.streamscape.ds.types.Type[] |
getTableType() |
java.lang.Object |
getTransientVariable(int index) |
com.streamscape.ds.lib.HashMappedList |
getTransientVariables() |
int |
getVariableCount() |
boolean |
hasTransientVariable(java.lang.String name) |
void |
invalidate(java.lang.String lastError)
Invalidates object state.
|
com.streamscape.ds.result.Result |
invoke(com.streamscape.ds.session.Session session,
java.lang.Object[] data,
java.lang.Object[] aggregateData,
boolean push) |
boolean |
isAggregate() |
boolean |
isDeterministic() |
boolean |
isEventCapable() |
boolean |
isFunction() |
boolean |
isProcedure() |
boolean |
isTableCapable() |
boolean |
isTrigger() |
void |
open(com.streamscape.ds.session.Session session) |
void |
open(com.streamscape.ds.session.Session session,
com.streamscape.ds.utils.SourceEventFlowData flowData) |
void |
resolve(com.streamscape.ds.session.Session session) |
void |
resolveReferences(com.streamscape.ds.session.Session session) |
boolean |
returnsCollection() |
void |
setAggregate(boolean isAggregate) |
void |
setAsAlteredRoutine(RplScript routine) |
void |
setDeterministic(boolean value) |
void |
setMaxDynamicResults(int value) |
void |
setName(NameManager.ObjectName name) |
void |
setNewSavepointLevel(boolean value) |
void |
setProcedure(com.streamscape.ds.parser.statement.Statement statement) |
void |
setReturnCollection(Collection collection) |
void |
setReturnType(com.streamscape.ds.types.Type type) |
void |
setRpl(java.lang.String rpl) |
void |
setSpecificName(NameManager.ObjectName name) |
void |
setTableType(com.streamscape.ds.types.Type[] types) |
void |
setTransientVariable(int index,
java.lang.Object value) |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aggregateObjectStateHolder, getSQLInSchema, recompileObject
public RoutineSchema routineSchema
public Collection returnCollection
public int maxDynamicResults
public boolean isRecursive
public boolean returnsCollection
public com.streamscape.ds.parser.statement.Statement statement
public java.util.List eventIds
public com.streamscape.ds.lib.HashMappedList scopeVariables
public int variableCount
public Table triggerTable
public static final RplScript[] emptyArray
public static final java.lang.String INDENT
public RplScript(DataspaceStore store, NameManager.ObjectName name, int type)
public RplScript(DataspaceStore store, NameManager.ObjectName name, Table table, com.streamscape.ds.range.RangeVariable[] ranges)
public RplScript(DataspaceStore store, NameManager.ObjectName name, com.streamscape.ds.range.RangeVariable[] ranges)
public java.lang.Object getTransientVariable(int index)
public void setTransientVariable(int index, java.lang.Object value)
public int getNumberOfTransientVariables()
public boolean hasTransientVariable(java.lang.String name)
public com.streamscape.ds.lib.HashMappedList getTransientVariables()
public void addTransientVariable(java.lang.String name, ColumnSchema var)
public int getObjectType()
getObjectType
in interface SchemaObject
public NameManager.ObjectName getObjectName()
getObjectName
in interface RplSchemaObject
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 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 java.lang.String getSQLAlter()
public java.lang.String getSQLAlter(java.lang.String name)
public java.lang.String getSQLDeclaration()
public java.lang.String getSQLDeclaration(java.lang.String name)
public java.lang.String getPrettyPrintSQL()
public java.lang.String getSQLBodyDefinition()
public java.lang.String getExternalName()
public long getChangeTimestamp()
getChangeTimestamp
in interface SchemaObject
public void addParameter(ColumnSchema param)
public void setReturnType(com.streamscape.ds.types.Type type)
public com.streamscape.ds.types.Type getReturnType()
public void setTableType(com.streamscape.ds.types.Type[] types)
public com.streamscape.ds.types.Type[] getTableType()
public Table getTable()
public void setProcedure(com.streamscape.ds.parser.statement.Statement statement)
public com.streamscape.ds.parser.statement.Statement getProcedure()
public void setSpecificName(NameManager.ObjectName name)
public int getMaxDynamicResults()
public void setName(NameManager.ObjectName name)
public NameManager.ObjectName getSpecificName()
public void setDeterministic(boolean value)
public boolean isDeterministic()
public void setNewSavepointLevel(boolean value)
public void setMaxDynamicResults(int value)
public void setReturnCollection(Collection collection)
public boolean returnsCollection()
public void setAggregate(boolean isAggregate)
public boolean isAggregate()
public void setRpl(java.lang.String rpl)
public void resolve(com.streamscape.ds.session.Session session)
public void resolveReferences(com.streamscape.ds.session.Session session)
public boolean isTrigger()
public boolean isProcedure()
public boolean isFunction()
public ColumnSchema getParameter(int i)
public int getParameterCount()
public int getParameterCount(int type)
public int getParameterIndex(java.lang.String name)
public com.streamscape.ds.range.RangeVariable[] getParameterRangeVariables()
public int getVariableCount()
public NameManager.ObjectName[] getTableNamesForRead()
public NameManager.ObjectName[] getTableNamesForWrite()
public void setAsAlteredRoutine(RplScript routine)
public com.streamscape.ds.result.Result invoke(com.streamscape.ds.session.Session session, java.lang.Object[] data, java.lang.Object[] aggregateData, boolean push)
public java.util.List getEvents()
public java.util.List getEvents(java.lang.String objectName, EventScope scope)
public void invalidate(java.lang.String lastError)
RplSchemaObject
invalidate
in interface RplSchemaObject
public DataspaceStateHolder getStateHolder()
RplSchemaObject
getStateHolder
in interface RplSchemaObject
public DataspaceStateHolder aggregateStateHolder()
RplSchemaObject
aggregateStateHolder
in interface RplSchemaObject
public java.lang.String getStateName(com.streamscape.ds.core.DataspaceStoreState state)
RplSchemaObject
getStateName
in interface RplSchemaObject
public boolean isEventCapable()
public boolean isTableCapable()
public void open(com.streamscape.ds.session.Session session)
public void open(com.streamscape.ds.session.Session session, com.streamscape.ds.utils.SourceEventFlowData flowData)
public void disable()
disable
in interface RplSchemaObject
public void close()
public void close(com.streamscape.ds.utils.SourceEventFlowData flowData)
public RplScript duplicate()
public java.lang.String getRpl()
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.