public class DatastoreComponent extends DataStorageDelegate
DefaultDelegate.DefaultAttributeDelegate, DefaultDelegate.DefaultConnectorPointDelegate
oracle.odi.domain.mapping.MapComponentDelegate.AttributeDelegate, oracle.odi.domain.mapping.MapComponentDelegate.MapConnectorPointDelegate
IMapComponent.ComponentCategory
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
BOUND_MODEL_OBJECT
Property key name for the bound datastore property.
|
static java.lang.String |
COMPONENT_TYPE_NAME
The component type name.
|
static java.lang.String |
INTEGRATION_TYPE_APPEND
Integration type property value for type control append.
|
static java.lang.String |
INTEGRATION_TYPE_NONE
Integration type property value for type none.
|
static java.lang.String |
INTEGRATION_TYPE_PROPKEY
Property key name for the integration type property.
|
static java.lang.String |
INTEGRATION_TYPE_SCD
Integration type property value for type slowly changing dimension.
|
static java.lang.String |
INTEGRATION_TYPE_UPDATE
Integration type property value for type incremental update.
|
static java.lang.String |
JOURNALIZED_DATA_FILTER
Property key name for the journalized data filter property.
|
static java.lang.String |
JOURNALIZING_ENABLED
Property key name for the journalizing enabled property.
|
static java.lang.String |
MAX_INTEGRATION_ERROR_PER_PROPERTY
Property key name for the maximum integration errors as a percentage property.
|
static java.lang.String |
MAX_INTEGRATION_ERROR_PROPERTY
Property key name for the maximum integration errors allowed property.
|
static java.lang.String |
NODE_IS_JOURNALIZED
Property key name for the physical node is journalized property.
|
COMPONENT_CONTEXT_PROPKEY, DATASTORE_ORDER_PROPKEY, JAVA_LOGGER, PARTITION_PROPKEY, UPDATE_KEY_PROPKEY
VARIABLE_COMPONENT_TYPE_NAME
Constructor and Description |
---|
DatastoreComponent(MapComponentOwner owner,
IModelObject boundObject)
Creates a new persistent datastore component.
|
DatastoreComponent(MapComponentOwner owner,
IModelObject boundObject,
boolean autoJoinEnabled)
Creates a new persistent datastore component.
|
DatastoreComponent(MapComponentOwner owner,
java.lang.String name)
Creates a new persistent datastore component.
|
Modifier and Type | Method and Description |
---|---|
IMapComponent |
addSourceToDataset(Dataset dset,
IDataStore datastore)
Adds a source to this dataset (ER group)
|
void |
bindTo(IModelObject boundObject,
boolean enableAutoJoin)
Similar to default delegate binding, but provides support for auto detection of join
relationships between bound datastore objects.
|
ILocation |
getComponentCustomLocation(IContext contextAdapter,
MapPhysicalNode node)
Returns the custom location of the component, with special handling for datastores with change data capture enabled.
|
static DatastoreComponent |
getDatastoreComponent(MapPhysicalNode node)
Returns the datastore component associated with the node, if any, else
return null.
|
java.lang.String |
getExecutionContextName(MapPhysicalNode node)
Returns the execution context name for the specified physical datastore node.
|
static IDataStore |
getJournalizedDatastore(MapPhysicalNode node)
Returns the bound datastore object of the datastore component for this particular physical node.
|
java.lang.String |
getJournalizedFilter()
Returns the value of the JOURNALIZED_DATA_FILTER property only when the bound datastore is enabeld with
change data capture.
|
static java.lang.String |
getJournalizedFilter(MapPhysicalNode node)
Returns the value of the JOURNALIZED_DATA_FILTER property of the datastore component of a particular datastore physical node,
only when the bound datastore is enabeld with change data capture.
|
static MapExpression |
getJournalizedFilterExpression(MapPhysicalNode node)
Returns the expression value of the JOURNALIZED_DATA_FILTER property of the datastore component of a particular datastore physical node,
only when the bound datastore is enabled with change data capture.
|
java.lang.String |
getLogicalSchemaName()
Returns the logical schema name for the bound datastore object.
|
java.lang.String |
getLogicalSchemaName(MapPhysicalNode node)
Returns the logical schema name for the physical datastore node.
|
java.lang.Integer |
getMaxIntegrationErrors()
Returns the MAXIMUM_NUMBER_OF_ERRORS_ALLOWED property value.
|
void |
initPhysicalNode(MapPhysicalNode node,
boolean initialCreation)
Initializes the NODE_IS_JOURNALIZED property to the value of the JOURNALIZING_ENABLED property, if the node is initially created.
|
void |
invalidateExpressions()
Invalidates the expressions for this component.
|
boolean |
isBoundObjectDeleted() |
boolean |
isDatastoreJournalized()
Checks whether the bound datastore is enabled with change data capture.
|
static boolean |
isDatastoreNode(MapPhysicalNode node)
Returns true if the node is associated with a datastore component, else return false.
|
boolean |
isJournalized()
Returns the value of the JOURNALIZING_ENABLED property.
|
static boolean |
isJournalizedDatastoreNode(MapPhysicalNode node)
Returns the value of the NODE_IS_JOURNALIZED property of the datastore component of a particular datastore physical node,
only when the bound datastore is enabled with change data capture.
|
boolean |
isMaxIntegrationErrorsAsPercentage()
Returns the value of the INTEGRATION_ERRORS_AS_PERCENTAGE_% property.
|
boolean |
isValidForTechnology(ITechnology techno,
java.util.List issues)
Check whether component is valid for a technology.
|
void |
notifyPropertyChange(java.lang.String key,
java.lang.Object oldValue,
java.lang.Object newValue) |
void |
setJournalizedDataOnly(boolean value)
Sets the value of the JOURNALIZING_ENABLED property only when the bound datastore is enabled with
change data capture.
|
void |
setJournalizedFilter(java.lang.String pFilter)
Sets the value of the JOURNALIZED_DATA_FILTER property.
|
void |
setMaxIntegrationErrors(int maxErrors)
Sets the MAXIMUM_NUMBER_OF_ERRORS_ALLOWED property value.
|
void |
setMaxIntegrationErrorsAsPercentage(boolean maxIntegrationErrorsAsPercentage)
Sets the INTEGRATION_ERRORS_AS_PERCENTAGE_% property value.
|
static void |
setUseJournalizedDataOnly(MapPhysicalNode node,
boolean value)
Sets the value of the NODE_IS_JOURNALIZED property of the datastore component of a particular datastore physical node,
only when the bound datastore is enabled with change data capture.
|
afterPropertyChange, findAttributeForColumn, findComponentsForDatastore, getBoundDataStore, getBoundDatastoreLocation, getBoundDatastoreTechnology, getBoundObjectName, getBoundObjectName, getComponentContext, getDatastoreLocation, getDatastoreOrder, getDatastoreTechnology, getExecutionContexts, getIntegrationType, getIntegrationTypeDomainValues, getIPartition, getPartitionInfo, getPartitions, getResourceName, getUpdateKey, getUpdateKeys, handleMapChangeEvent, hasUpdateKey, isDatastoreOrderHidden, setComponentContext, setComponentContextByCode, setDatastoreOrder, setIntegrationType, setIPartition, setIPartitionId, setKeyIndicators, setUpdateKey, setUpdateKeyByName
customSyncComponent, fixExpressions, getBlockExpressionReferencedAttributes, getExecuteOnHint, getExecuteOnHintString, getNextAvailableInput, getNextAvailableInput, getNextAvailableOutput, isAddInputConnectorPointAllowed, isAddOutputConnectorPointAllowed, isPassive, setExecuteOnHint, setExecuteOnHintByString
afterAddComponent, afterRemoveComponent, allowInputAttribute, connectFrom, createInputConnectorPoint, createInputConnectorPoint, createOutputConnectorPoint, createOutputConnectorPoint, customValidateProposedChildConnection, customValidateProposedChildScoping, equals, getBoundObjectFullName, getBoundShortcutFullName, getComponentType, getInScopeAttributeXMap, getSQLAccessName, getTechnicalDescription, getTypeName, handleChildMapChangeEvent, hashCode, isCompositeComponentType, setComponentType, supportComponentOfType, toString, validateReorderComponent
addComponent, addProperty, afterConnect, bindTo, connectTo, connectTo, connectTo, connectTo, containsComponent, createComponent, createComponent, createComponent, createExpressionAttribute, createExpressionAttribute, createOutputConnectorPoint, createProperty, dump, dump, findAllComponents, findAllSplitPaths, findComponent, findComponentBoundTo, findComponentOfType, findConnector, findConnectorPoint, findInputAttribute, findOutputAttribute, findSubComponentOwner, generateUniqueComponentName, generateUniqueComponentName, generateUniqueConnectorName, generateUniqueName, generateUniqueName, getAdapter, getAlias, getAllComponents, getAllComponentsOfType, getAllExpressions, getAllPathsFrom, getAllPathsFrom, getAllProperties, getAllSubComponentOwners, getAttributeExpressions, getAttributes, getBooleanPropertyValue, getBoundObject, getBoundShortcut, getBoundTechnology, getBusinessName, getCachedIssues, getComponentAttributeMap, getComponentCategory, getComponentCount, getComponentLocation, getComponentOwner, getComponents, getComponentTypeName, getCompositeQualifier, getConnectorPointCount, getConnectorPointCount, getConnectorPoints, getConnectorPoints, getConnectorPointToLeaf, getConnectorTo, getDelegate, getDescription, getDisplayableObjectName, getDisplayableProperties, getDisplayableTypeName, getDomainInterfaceType, getDownstreamConnectedLeafComponents, getDownstreamConnectedPoints, getExpressionPropertyValue, getExpressionReferences, getExpressionValidationCode, getExtraCreatedObjects, getFlowConstraints, getFullName, getGlobalId, getGUID, getInputConnectorPoint, getInputConnectorPoint, getInputConnectorPointCount, getInputConnectorPoints, getInputPoint, getInScopeAttributes, getInScopeAttributeXMap, getInternalId, getIntPropertyValue, getLeafLevelComponents, getLeafLevelTargets, getMapRootContainer, getName, getNumericId, getOutputAttributeExpressions, getOutputAttributes, getOutputConnectorPoint, getOutputConnectorPoint, getOutputConnectorPointCount, getOutputConnectorPoints, getOutputPoint, getOwner, getOwningComponent, getPersistentClassName, getPersistentComponent, getPrefix, getProjectedAttributes, getProjectorOrMultiInputSource, getProperties, getProperty, getPropertyDefinitionOwner, getPropertyValue, getPropertyValueReference, getProposedConnectionIssues, getProposedConnectionIssues, getProposedScopingIssues, getQualifiedName, getRootComponentOwner, getRootContainer, getScopingInputPointForSource, getSecurityContainer, getSources, getStringPropertyValue, getStrongTypeClassName, getSyncState, getTargets, getTopLevelComponentsOfType, getTopLevelSources, getTopLevelTargets, getTopmostComponent, getUpstreamAttributeXMap, getUpstreamComponentOwner, getUpstreamConnectedLeafComponents, getUpstreamConnectedLeafPoints, getUpstreamConnectedPoints, getUpstreamInScopeLeafAttributes, getUpstreamInScopeLeafComponentsFor, getUpstreamInScopeLeafPoints, getUpstreamLeafAttributes, getUpstreamLeafAttributes, getUpstreamLeafConnectorPoints, getUpstreamLeafSources, getUpstreamSources, getUpstreamSplitPaths, hasCustomizedPersistenceMethodFor, invalidateDownstreamExpressions, invokeCustomizedPersistenceMethodFor, invokeMethod, isBound, isComponent, isComponentLevelConnectAllowed, isCompositeComponent, isDecorator, isEndpoint, isHidden, isInScope, isInScope, isMultiInputSelector, isOfType, isProjector, isPropertyDefined, isProposedConnectionValid, isProposedConnectionValid, isProposedScopingValid, isSelector, isSource, isSubComponent, isTarget, isUniqueComponentName, isUniqueComponentName, referencesObject, removeAllConnections, removeAllConnections, removeAllConnectionsAndReroute, removeAllConnectionsAndReroute, removeAllInputConnections, removeComponent, removeComponent, removeInputConnectorPoint, removeInputConnectorPoint, removeInputConnectorPoint, removeOutputConnectorPoint, removeOutputConnectorPoint, removeProperty, reorderInputConnectorPoint, reorderOutputConnectorPoint, rerouteConnections, setAlias, setAttributeExpressionText, setAttributeExpressionText, setBooleanPropertyValue, setBusinessName, setDescription, setIntPropertyValue, setIsHidden, setName, setPropertyValue, syncComponent, validate, validate, validateProperties
public static final java.lang.String COMPONENT_TYPE_NAME
public static final java.lang.String INTEGRATION_TYPE_PROPKEY
public static final java.lang.String MAX_INTEGRATION_ERROR_PROPERTY
public static final java.lang.String MAX_INTEGRATION_ERROR_PER_PROPERTY
public static final java.lang.String JOURNALIZING_ENABLED
public static final java.lang.String JOURNALIZED_DATA_FILTER
public static final java.lang.String BOUND_MODEL_OBJECT
public static final java.lang.String NODE_IS_JOURNALIZED
public static final java.lang.String INTEGRATION_TYPE_NONE
public static final java.lang.String INTEGRATION_TYPE_APPEND
public static final java.lang.String INTEGRATION_TYPE_UPDATE
public static final java.lang.String INTEGRATION_TYPE_SCD
public DatastoreComponent(MapComponent component) throws MappingException
MappingException
public DatastoreComponent(MapComponentType componentType) throws oracle.odi.domain.mapping.exception.MapComponentException
oracle.odi.domain.mapping.exception.MapComponentException
public DatastoreComponent(MapComponentOwner owner, java.lang.String name) throws MappingException, AdapterException
owner
- the component owner that will own the new componentname
- the name for the new componentMappingException
AdapterException
public DatastoreComponent(MapComponentOwner owner, IModelObject boundObject, boolean autoJoinEnabled) throws MappingException, AdapterException
owner
- the component owner that will own the new componentboundObject
- the external object that will be bound to the new datastore componentautoJoinEnabled
- if true, then the framework will check for relationships between
this new datastore and other existing datastore components in the map, and if found,
automatically create join components to join them.MappingException
AdapterException
public DatastoreComponent(MapComponentOwner owner, IModelObject boundObject) throws MappingException, AdapterException
owner
- the component owner that will own the new componentboundObject
- the ODI object that will be bound to the new datastore componentautoJoinEnabled
- if true, then the framework will check for relationships between
this new datastore and other existing datastore components in the map, and if found,
automatically create join components to join them.MappingException
AdapterException
public void bindTo(IModelObject boundObject, boolean enableAutoJoin) throws MappingException, AdapterException
bindTo
in class oracle.odi.domain.mapping.MapComponentDelegator
boundObject
- the ODI object that will be bound to the datastore component.enableAutoJoin
- if true, then the framework will check for relationships between
this new datastore and other existing datastore components in the map, and if found,
automatically create join components to join them.MappingException
AdapterException
oracle.odi.domain.mapping.exception.MapComponentException
PropertyException
oracle.odi.domain.mapping.expression.parser.ExpressionParseException
MapPhysicalException
public boolean isBoundObjectDeleted() throws oracle.odi.domain.mapping.exception.MapComponentException, AdapterException
isBoundObjectDeleted
in class oracle.odi.domain.mapping.MapComponentDelegate
oracle.odi.domain.mapping.exception.MapComponentException
AdapterException
public IMapComponent addSourceToDataset(Dataset dset, IDataStore datastore) throws MappingException, AdapterException
dset
- the dataset to which to add the sourcesource
- the source to add to the datasetMappingException
AdapterException
public void invalidateExpressions()
IMapComponent
invalidateExpressions
in class DefaultDelegate
public java.lang.Integer getMaxIntegrationErrors() throws PropertyException
PropertyException
public void setMaxIntegrationErrors(int maxErrors) throws PropertyException
maxErrors
- the value of the maximum integration errors propertyPropertyException
public boolean isMaxIntegrationErrorsAsPercentage() throws PropertyException
true
if the maximum integration errors property is a percentagePropertyException
public void setMaxIntegrationErrorsAsPercentage(boolean maxIntegrationErrorsAsPercentage) throws PropertyException
maxIntegrationErrorsAsPercentage
- true
if the max integration errors is a percentage, false
otherwisePropertyException
public boolean isDatastoreJournalized() throws oracle.odi.domain.mapping.exception.MapComponentException, AdapterException
true
if bound datastore is enabled with change data capture.oracle.odi.domain.mapping.exception.MapComponentException
AdapterException
public boolean isJournalized() throws MappingException, AdapterException
true
if journalizing is enabled for this datastore component.MappingException
AdapterException
public void setJournalizedDataOnly(boolean value) throws MappingException, AdapterException
value
- true
if journalizing is enabled for this component, else false
MappingException
AdapterException
public void setJournalizedFilter(java.lang.String pFilter) throws oracle.odi.domain.mapping.exception.MapComponentException, MappingException
pFilter
- data filter for journalizingMappingException
oracle.odi.domain.mapping.exception.MapComponentException
public java.lang.String getJournalizedFilter() throws PropertyException, oracle.odi.domain.mapping.exception.MapComponentException, AdapterException
AdapterException
PropertyException
oracle.odi.domain.mapping.exception.MapComponentException
public static java.lang.String getJournalizedFilter(MapPhysicalNode node) throws MappingException, AdapterException
node
- physical node of the datastore componentAdapterException
MappingException
public static MapExpression getJournalizedFilterExpression(MapPhysicalNode node) throws MappingException, AdapterException
node
- physical node of the datastore componentAdapterException
MappingException
public static boolean isJournalizedDatastoreNode(MapPhysicalNode node) throws MappingException, AdapterException
false
.node
- physical node of the datastore componenttrue
if component of the node is journalized, false
otherwiseAdapterException
MappingException
public static void setUseJournalizedDataOnly(MapPhysicalNode node, boolean value) throws MappingException, AdapterException
node
- physical node of the datastore componentvalue
- true
if component node is journalized, false
otherwiseMappingException
AdapterException
public static IDataStore getJournalizedDatastore(MapPhysicalNode node) throws oracle.odi.domain.mapping.exception.MapComponentException, AdapterException
node
- physical node of the datastore componentAdapterException
oracle.odi.domain.mapping.exception.MapComponentException
public static DatastoreComponent getDatastoreComponent(MapPhysicalNode node) throws oracle.odi.domain.mapping.exception.MapComponentException
node
- physical node of the datastore componentoracle.odi.domain.mapping.exception.MapComponentException
public static boolean isDatastoreNode(MapPhysicalNode node) throws oracle.odi.domain.mapping.exception.MapComponentException
node
- physical node of the datastore componenttrue
if node is associated with a datastore componentoracle.odi.domain.mapping.exception.MapComponentException
public void initPhysicalNode(MapPhysicalNode node, boolean initialCreation) throws MappingException
initPhysicalNode
in class oracle.odi.domain.mapping.MapComponentDelegate
node
- physical node of the datastore componentinitialCreation
- true
if node is initially createdMappingException
public ILocation getComponentCustomLocation(IContext contextAdapter, MapPhysicalNode node) throws AdapterException, oracle.odi.domain.mapping.exception.MapComponentException, MapPhysicalException
getComponentCustomLocation
in class oracle.odi.domain.mapping.MapComponentDelegate
contextAdapter
- the context used to retrieve the logical bound object's locationnode
- physical node of the datastore componentoracle.odi.domain.mapping.exception.MapComponentException
AdapterException
MapPhysicalException
public java.lang.String getExecutionContextName(MapPhysicalNode node) throws MappingException, AdapterException
node
- physical node of the datastore componentAdapterException
MappingException
public java.lang.String getLogicalSchemaName() throws MappingException, AdapterException
AdapterException
MappingException
public java.lang.String getLogicalSchemaName(MapPhysicalNode node) throws MappingException, AdapterException
AdapterException
MappingException
public void notifyPropertyChange(java.lang.String key, java.lang.Object oldValue, java.lang.Object newValue)
notifyPropertyChange
in class oracle.odi.domain.mapping.MapComponentDelegate
public boolean isValidForTechnology(ITechnology techno, java.util.List issues) throws MappingException
IMapComponent
isValidForTechnology
in class DefaultDelegate
techno
- The technology to validate againstMappingException