public class OdiPhysicalSchema extends oracle.odi.domain.support.AbstractOdiEntity implements IPhysicalSchema, IMasterOdiEntity, oracle.odi.domain.impexp.IExportable, IFlexFieldUser, oracle.odi.impexp.smartie.ISmartExportable, oracle.odi.core.audit.support.IAuditableFirstClassObject
OdiPhysicalSchema
is a physical schema defined for a data server
into the physical topology of ODI. An instance of OdiPhysicalSchema
belongs to a single instance of OdiDataServer
and has to be used to
defines ODI related properties of this schema.
OdiPhysicalSchema
is also used to create extract and replicat process
under Jagent for GoldenGate Technology.
When created using one of this class' constructors, an instance of
OdiPhysicalSchema
has default values where some of them are inherited
from the OdiTechnology
that belong to the OdiDataServer
of
this OdiPhysicalSchema
.
Since a default OdiPhysicalSchema
is required to be defined for an
instance of OdiDataServer
, when creating a new OdiPhysicalSchema
for an OdiDataServer
the default state of an OdiPhysicalSchema
will be managed accordingly (if this schema is the first schema for that data
server it will be automatically defined as the default one). Application code
will be able to define the default schema calling the setAsDefault()
method.
By default the name of an OdiPhysicalSchema
is computed according
the data server and technology it belongs using the given pattern:
the name is computed using the follow pattern :
DataServerName.SchemaName.CatalogName
.
However this will apply only if the technology supports catalogs and/or schemas.
If the technology doesn't support schema and catalog then a default value for
the name will be provided but it you will be able to change that name.
OdiDataServer
,
Serialized FormModifier and Type | Class and Description |
---|---|
static class |
OdiPhysicalSchema.OggProcessType |
static class |
OdiPhysicalSchema.OggReportCountFrequencyUnit
Enum encapsulates unit for Oracle Golden Gate physical extract/replicat processes' report count frequency
|
Modifier and Type | Field and Description |
---|---|
static int |
CATALOG_NAME_MAX_LENGTH |
static int |
LOCAL_OBJECT_MASK_MAX_LENGTH |
static int |
LOCAL_SEQUENCE_MASK_MAX_LENGTH |
static int |
NAME_MAX_LENGTH |
static int |
PARTITION_MASK_MAX_LENGTH |
static int |
REMOTE_OBJECT_MASK_MAX_LENGTH |
static int |
REMOTE_SEQUENCE_MASK_MAX_LENGTH |
static int |
SCHEMA_NAME_MAX_LENGTH |
static int |
SUB_PARTITION_MASK_MAX_LENGTH |
static int |
UNIQUE_TAG_CHARACTER_ENCODING_MAX_LENGTH |
static int |
WORK_CATALOG_NAME_MAX_LENGTH |
static int |
WORK_SCHEMA_NAME_MAX_LENGTH |
Constructor and Description |
---|
OdiPhysicalSchema(OdiDataServer pDataServer)
Construct a new
OdiPhysicalSchema and add it to the given
OdiDataServer 's physical schemas. |
Modifier and Type | Method and Description |
---|---|
boolean |
executableLocationEquals(ILocation otherLocation,
IContext context)
Checks if this location can run same code as another location.
|
java.lang.String |
getAdditionalOption()
Method returns additional options set for this Oracle Golden Gate's extract or replicat process.
|
java.lang.String |
getCatalogName()
Returns the catalog name of this schema.
|
IContext |
getContext()
Gets the context object for the location.
|
OdiDataServer |
getDataServer()
Obtains the
OdiDataServer related to this OdiPhysicalSchema . |
OdiDataServer |
getDataServer(IContext context)
Get sa physical data server object for this location.
|
java.lang.String |
getDefinitionFilePath()
Method returns path to definition file to be used by this Oracle Golden Gate's replicat process.
|
java.lang.String |
getDiscardFilePath()
Method returns path to discard file to be used by this Oracle Golden Gate's replicat process.
|
java.lang.String |
getErrorTablePrefix()
Obtains the error table prefix.
|
java.lang.String |
getExecutableLocationName()
Returns the name of the executable location, which is the physical
server that runs processes that can access the data.
|
java.lang.Integer |
getExtractBufferSize()
Method returns size of the buffer to be used by this Oracle Golden Gate's extract process.
|
java.util.Collection |
getFlexFieldsValues()
Obtains flex fields values related to this
IFlexFieldUser . |
java.lang.String |
getIntegrationTablePrefix()
Obtains the integration table prefix.
|
java.io.Serializable |
getInternalId()
Provides a common getter for the persistence layer to obtain an identity,
irrespective of the actual type of identity used.
|
java.lang.String |
getJournalTablePrefix()
Obtains the journal table prefix.
|
java.lang.String |
getJournalTriggerPrefix()
Obtains the journal trigger prefix.
|
java.lang.String |
getJournalViewPrefix()
Obtains the journal view prefix.
|
java.lang.String |
getLoadingTablePrefix()
Obtains the loading table prefix.
|
java.lang.String |
getLocalObjectMask()
Returns the Local Object Mask.
|
java.lang.String |
getLocalSequenceCurrMask()
Obtains the local sequence current value mask.
|
java.lang.String |
getLocalSequenceMask()
Obtains the local sequence mask.
|
java.lang.String |
getLocalTrailFilePath()
Method returns path to local trail file to be used by this Oracle Golden Gate's extract or replicat process.
|
ILogicalSchema |
getLogicalSchema()
Gets a logical schema object for this location.
|
OdiLogicalSchema |
getLogicalSchema(OdiContext pContext)
Obtains the
OdiLogicalSchema associated for a given context. |
java.lang.String |
getName()
Obtains the full read-only name of this
OdiPhysicalSchema that is used
internally by ODI. |
OdiPhysicalSchema.OggProcessType |
getOggProcessType()
Method to be used to check if this instance of
OdiLogicalSchema represents Oracle Golden Gate process. |
java.lang.String |
getPartitionMask()
Obtains the partition mask.
|
IPhysicalSchema |
getPhysicalSchema()
Gets a physical schema object for this location.
|
IPhysicalSchema |
getPhysicalSchema(IContext context)
Get a physical schema object for this location.
|
java.lang.Number |
getPhysicalSchemaId()
Returns the Internal object ID.
|
java.lang.String |
getRemoteObjectMask()
Returns the Remote Object Mask.
|
java.lang.String |
getRemoteSequenceCurrMask()
Obtains the remote sequence current value mask.
|
java.lang.String |
getRemoteSequenceMask()
Obtains the remote sequence mask.
|
java.lang.String |
getRemoteTrailFilePath()
Method returns path to remote trail file to be used by this Oracle Golden Gate's extract process.
|
java.lang.Integer |
getReportCountFrequency()
Method returns report count frequency to be used by this Oracle Golden Gate's extract or replicat process, total operation count id will be reported after the specified interval.
|
OdiPhysicalSchema.OggReportCountFrequencyUnit |
getReportCountFrequencyUnit()
Method returns report count frequency unit to be used by this Oracle Golden Gate's extract or replicat process.
|
java.lang.String |
getSchemaName()
Returns the name of the underlying database schema.
|
IRepositoryEntity |
getSecurityContainer()
Define a generic way to retrieve container for entities.
|
java.lang.String |
getSubPartitionMask()
Obtains the sub partition mask.
|
OdiTechnology |
getTechnology()
Convenient method to obtain the
OdiTechnology that belongs to
this OdiPhysicalSchema . |
java.lang.String |
getTemporaryIndexPrefix()
Obtains the temporary index prefix.
|
java.lang.Integer |
getTrailFileSize()
Method returns size of trail file to be used by this Oracle Golden Gate's extract process.
|
java.lang.String |
getUniqueTagCharacterEncoding()
Returns character encoding string that will be used by the unique tag during codegen.
|
java.lang.String |
getWorkCatalogName()
Returns the work catalog name.
|
java.lang.String |
getWorkSchemaName()
Returns the work schema name.
|
void |
initFlexFields(IOdiFlexFieldFinder pOdiFlexFieldFinder)
Initialize flex fields related to this
IFlexFieldUser . |
boolean |
isDefaultPhysicalSchema()
Tells whether this is the default schema.
|
boolean |
isNameComputed()
Returns
true if schema name has to be computed,
false otherwise. |
boolean |
isPassThru()
Method returns
true if PASSTHRU parameter will be added to the parameter file of pump process. |
boolean |
isReportDetail()
Method returns
true if replicat report will contain collision details and false otherwise. |
boolean |
isReportFetch()
Method returns
true if REPORTFETCH parameter will be added to the parameter file of extract process. |
boolean |
isTargetDuplicatesAllowed()
Method returns true in case it's allowed for the source table to be replicated to more than one target table.
|
boolean |
isUnresolvedLocation() |
boolean |
locationEquals(ILocation otherLocation)
Checks if this location is equals to the given location.
|
void |
resolveLocation(AdapterBase adapter) |
void |
setAdditionalOption(java.lang.String pAdditionalOption)
Method to be used to set additional options for this Oracle Golden Gate's extract or replicat process.
|
void |
setAsDefault()
Deprecated.
|
void |
setCatalogName(java.lang.String pCatalogName)
Sets the catalog name of this schema.
|
void |
setContext(IContext context)
Sets the context for the location.
|
void |
setDefinitionFilePath(java.lang.String pDefinitionFilePath)
Sets path to definition file to be used by this Oracle Golden Gate's replicat process.
|
void |
setDiscardFilePath(java.lang.String pDiscardFilePath)
Sets path to discard file to be used by this Oracle Golden Gate's replicat process.
|
void |
setErrorTablePrefix(java.lang.String pErrorTablePrefix)
Defines the error table prefix.
|
void |
setExtractBufferSize(java.lang.Integer pExtractBufferSize)
Method sets size of the buffer to be used by this Oracle Golden Gate's extract process.
|
void |
setIntegrationTablePrefix(java.lang.String pIntegrationTablePrefix)
Defines the integration table prefix.
|
void |
setJournalTablePrefix(java.lang.String pJournalTablePrefix)
Defines the journal table prefix.
|
void |
setJournalTriggerPrefix(java.lang.String pJournalTriggerPrefix)
Defines the journal trigger prefix.
|
void |
setJournalViewPrefix(java.lang.String pJournalViewPrefix)
Defines the journal view prefix.
|
void |
setLoadingTablePrefix(java.lang.String pLoadingTablePrefix)
Defines the loading table prefix.
|
void |
setLocalObjectMask(java.lang.String pLocalObjectMask)
Sets the local Object Mask.
|
void |
setLocalSequenceCurrMask(java.lang.String pLocalSequenceCurrMask)
Defines the local sequence current value mask.
|
void |
setLocalSequenceMask(java.lang.String pLocalSequenceMask)
Defines the local sequence mask.
|
void |
setLocalTrailFilePath(java.lang.String pLocalTrailFilePath)
Sets path to local trail file to be used by this Oracle Golden Gate's extract or replicat process.
|
void |
setLogicalSchema(ILogicalSchema logSchema)
Sets the logical schema that is associated with this location.
|
void |
setName(java.lang.String pName)
Set the name of this
OdiPhysicalSchema . |
void |
setOggProcessType(OdiPhysicalSchema.OggProcessType pOggProcessType)
Method marks this
OdiLogicalSchema as an Oracle Golden Gate process if pOggProcessType is not null and as a general ODI logical schema otherwise. |
void |
setPartitionMask(java.lang.String pPartitionMask)
Define the partition mask.
|
void |
setPassThru(boolean pPassThru)
Method makes PASSTHRU parameter to be added to the parameter file of pump process.
|
void |
setPhysicalSchema(IPhysicalSchema physSchema)
Sets the physical schema that is associated with this location.
|
void |
setRemoteObjectMask(java.lang.String pRemoteObjectMask)
Sets the Remote Object Mask.
|
void |
setRemoteSequenceCurrMask(java.lang.String pRemoteSequenceCurrMask)
Defines the remote sequence current value mask.
|
void |
setRemoteSequenceMask(java.lang.String pRemoteSequenceMask)
Defines the remote sequence mask.
|
void |
setRemoteTrailFilePath(java.lang.String pRemoteTrailFilePath)
Sets path to remote trail file to be used by this Oracle Golden Gate's extract process.
|
void |
setReportCountFrequency(java.lang.Integer pReportCountFrequency)
Method sets report count frequency to be used by this Oracle Golden Gate's extract or replicat process, total operation count id will be reported after the specified interval.
|
void |
setReportCountFrequencyUnit(OdiPhysicalSchema.OggReportCountFrequencyUnit pReportCountFrequencyUnit)
Method sets report count frequency unit to be used by this Oracle Golden Gate's extract or replicat process.
|
void |
setReportDetail(boolean pReportDetail)
Method used to tell replicat process that report should include collision details if
pReportDetail is true . |
void |
setReportFetch(boolean pReportFetch)
Method makes REPORTFETCH parameter to be added to the parameter file of extract process.
|
void |
setSchemaName(java.lang.String pSchemaName)
Sets the name of the underlying database schema.
|
void |
setSubPartitionMask(java.lang.String pSubPartitionMask)
Define the sub partition mask.
|
void |
setTargetDuplicatesAllowed(boolean pTargetDuplicatesAllowed)
Method used to tell replicat process that it's allowed for the source table to be replicated to more than one target table if
pTargetDuplicatesAllowed is true . |
void |
setTemporaryIndexPrefix(java.lang.String pTemporaryIndexPrefix)
Defines the temporary index prefix.
|
void |
setTrailFileSize(java.lang.Integer pTrailFileSize)
Sets size of trail file to be used by this Oracle Golden Gate's extract process.
|
void |
setUniqueTagCharacterEncoding(java.lang.String pUniqueTagCharacterEncoding)
Sets character encoding string that will be used by the unique tag during codegen, the value set for physical schema will override the value of the corresponding technology.
|
void |
setWorkCatalogName(java.lang.String pWorkCatalogName)
Sets the work catalog name.
|
void |
setWorkSchemaName(java.lang.String pWorkSchemaName)
Sets the work schema name.
|
equals, getFirstDate, getFirstUser, getInternalVersion, getLastDate, getLastUser, hashCode, isInstanceLevelSecurityNeeded, isNew, preCommit, toString
getGlobalId, getNumericId, hasCustomizedPersistenceMethodFor, invokeCustomizedPersistenceMethodFor
getGlobalId, getNumericId
getFirstDate, getFirstUser, getLastDate, getLastUser, isInstanceLevelSecurityNeeded
getGlobalId
public static final int NAME_MAX_LENGTH
public static final int SCHEMA_NAME_MAX_LENGTH
public static final int WORK_SCHEMA_NAME_MAX_LENGTH
public static final int CATALOG_NAME_MAX_LENGTH
public static final int WORK_CATALOG_NAME_MAX_LENGTH
public static final int LOCAL_OBJECT_MASK_MAX_LENGTH
public static final int REMOTE_OBJECT_MASK_MAX_LENGTH
public static final int PARTITION_MASK_MAX_LENGTH
public static final int SUB_PARTITION_MASK_MAX_LENGTH
public static final int LOCAL_SEQUENCE_MASK_MAX_LENGTH
public static final int REMOTE_SEQUENCE_MASK_MAX_LENGTH
public static final int UNIQUE_TAG_CHARACTER_ENCODING_MAX_LENGTH
public OdiPhysicalSchema(OdiDataServer pDataServer)
OdiPhysicalSchema
and add it to the given
OdiDataServer
's physical schemas.
This constructor will initialize the remoteObjectMask and
localObjectMask properties from the ones defined on the related
OdiTechnology
.
This constructor will also defines the name of this OdiPhysicalSchema
with a default name value obtained from the given OdiDataServer
.
pDataServer
- the parent data serverpublic OdiTechnology getTechnology()
OdiTechnology
that belongs to
this OdiPhysicalSchema
.getTechnology
in interface ILocation
public java.io.Serializable getInternalId()
IRepositoryEntity
Typically a subclass will delegate to a public
SomePrimitiveWrapper getId()
method. The necessity for the
getInternalId()
abstract method is solely because the
persistence layer needs a way of obtaining the identity irrespective of
the actual identity implementation choice.
Returning null
from this method will indicate the object has
never been saved. This will likely be relied on by some DAO
implementations.
getInternalId
in interface IRepositoryEntity
public boolean isDefaultPhysicalSchema()
isDefaultPhysicalSchema
in interface IPhysicalSchema
true
if this is the default schema, false
otherwisepublic void setAsDefault()
OdiDataServer.setDefaultPhysicalSchema(OdiPhysicalSchema)
insteadOdiPhysicalSchema
as default schema for its
parent OdiDataServer
.isDefaultPhysicalSchema()
public OdiDataServer getDataServer()
OdiDataServer
related to this OdiPhysicalSchema
.getDataServer
in interface ILocation
getDataServer
in interface IPhysicalSchema
OdiDataServer
public java.lang.String getCatalogName()
getCatalogName
in interface IPhysicalSchema
DomainRuntimeException
- if catalog is not suppported on the underlying technologyOdiTechnology.isCatalogSupported()
,
setCatalogName(String)
public void setCatalogName(java.lang.String pCatalogName)
pCatalogName
- catalog nameDomainRuntimeException
- if catalog is not supported on the underlying technology or if catalog name is longer than 128OdiTechnology.isCatalogSupported()
,
getCatalogName()
public java.lang.String getSchemaName()
getSchemaName
in interface IPhysicalSchema
DomainRuntimeException
- if schema is not supported on the underlying technologyOdiTechnology.isSchemaSupported()
,
setSchemaName(String)
public void setSchemaName(java.lang.String pSchemaName)
OdiPhysicalSchema
's
name accordingly.pSchemaName
- schema nameDomainRuntimeException
- if schema is not supported on the underlying technology or if schema name is longer than 128OdiTechnology.isSchemaSupported()
,
getSchemaName()
public java.lang.String getWorkCatalogName()
getWorkCatalogName
in interface IPhysicalSchema
DomainRuntimeException
- if catalog is not supported on the underlying technologygetCatalogName()
,
setWorkCatalogName(String)
public void setWorkCatalogName(java.lang.String pWorkCatalogName)
pWorkCatalogName
- work catalog nameDomainRuntimeException
- if catalog is not supported on the underlying technology or if catalog's name is longer than 128setCatalogName(String)
,
getWorkCatalogName()
public java.lang.String getWorkSchemaName()
getWorkSchemaName
in interface IPhysicalSchema
DomainRuntimeException
- if schema is not supported on the underlying technologygetSchemaName()
,
setWorkSchemaName(String)
public void setWorkSchemaName(java.lang.String pWorkSchemaName)
pWorkSchemaName
- work schema nameDomainRuntimeException
- if schema is not supported on the underlying technology or if schema's name is longer than 128setSchemaName(String)
,
getWorkSchemaName()
public java.lang.String getName()
OdiPhysicalSchema
that is used
internally by ODI.getName
in interface IFlexFieldUser
getName
in interface IModelObject
getName
in interface IPhysicalSchema
getName
in interface IOdiEntity
getName
in class oracle.odi.domain.support.AbstractOdiEntity
setName(String)
public void setName(java.lang.String pName)
OdiPhysicalSchema
.
This can only be set if the name is not computed. This means the underlying technology doesn't supports catalog or schema or both.
pName
- the nameDomainRuntimeException
- if name is computed or if name is longer than 400getName()
public boolean isNameComputed()
true
if schema name has to be computed,
false
otherwise.isNameComputed
in interface IPhysicalSchema
true
if schema name has to be computed, false
otherwisepublic java.lang.Number getPhysicalSchemaId()
public java.lang.String getErrorTablePrefix()
getErrorTablePrefix
in interface IPhysicalSchema
setErrorTablePrefix(String)
public void setErrorTablePrefix(java.lang.String pErrorTablePrefix)
By default, this property is the same as defined in OdiTechnology
this
OdiPhysicalSchema
belongs to.
pErrorTablePrefix
- error table prefixDomainRuntimeException
- if Error prefix table is null or longer than
getErrorTablePrefix()
,
OdiTechnology.getErrorTablePrefix()
public java.lang.String getTemporaryIndexPrefix()
getTemporaryIndexPrefix
in interface IPhysicalSchema
setTemporaryIndexPrefix(String)
public void setTemporaryIndexPrefix(java.lang.String pTemporaryIndexPrefix)
By default, this property is the same as defined in OdiTechnology
this
OdiPhysicalSchema
belongs to.
pTemporaryIndexPrefix
- temporary index prefixDomainRuntimeException
- if temporary index is lnull or onger than
getTemporaryIndexPrefix()
,
OdiTechnology.getTemporaryIndexPrefix()
public java.lang.String getIntegrationTablePrefix()
getIntegrationTablePrefix
in interface IPhysicalSchema
setIntegrationTablePrefix(String)
public void setIntegrationTablePrefix(java.lang.String pIntegrationTablePrefix)
By default, this property is the same as defined in OdiTechnology
this
OdiPhysicalSchema
belongs to.
pIntegrationTablePrefix
- integration table prefixDomainRuntimeException
- if integration table prefix is lnull or onger than
getIntegrationTablePrefix()
,
OdiTechnology.getIntegrationTablePrefix()
public java.lang.String getJournalTablePrefix()
getJournalTablePrefix
in interface IPhysicalSchema
setJournalTablePrefix(String)
public void setJournalTablePrefix(java.lang.String pJournalTablePrefix)
By default, this property is the same as defined in OdiTechnology
this
OdiPhysicalSchema
belongs to.
pJournalTablePrefix
- journal table prefixDomainRuntimeException
- if Journal table prefix is lnull or onger than
getJournalTablePrefix()
,
#getJournalTablePrefix()#getJournalTablePrefix()
public java.lang.String getJournalTriggerPrefix()
getJournalTriggerPrefix
in interface IPhysicalSchema
setJournalTriggerPrefix(String)
public void setJournalTriggerPrefix(java.lang.String pJournalTriggerPrefix)
By default, this property is the same as defined in OdiTechnology
this
OdiPhysicalSchema
belongs to.
pJournalTriggerPrefix
- journal trigger prefixDomainRuntimeException
- if Journal table prefix is lnull or onger than
getJournalTriggerPrefix()
,
OdiTechnology.getJournalTriggerPrefix()
public java.lang.String getJournalViewPrefix()
getJournalViewPrefix
in interface IPhysicalSchema
setJournalViewPrefix(String)
public void setJournalViewPrefix(java.lang.String pJournalViewPrefix)
By default, this property is the same as defined in OdiTechnology
this
OdiPhysicalSchema
belongs to.
pJournalViewPrefix
- view prefixDomainRuntimeException
- if Journal table prefix is lnull or onger than
getJournalViewPrefix()
,
OdiTechnology.getJournalViewPrefix()
public java.lang.String getLoadingTablePrefix()
getLoadingTablePrefix
in interface IPhysicalSchema
setLoadingTablePrefix(String)
public void setLoadingTablePrefix(java.lang.String pLoadingTablePrefix)
By default, this property is the same as defined in OdiTechnology
this
OdiPhysicalSchema
belongs to.
pLoadingTablePrefix
- table prefixDomainRuntimeException
- if Loading table prefix is lnull or onger than
getLoadingTablePrefix()
,
OdiTechnology.getLoadingTablePrefix()
public java.lang.String getLocalObjectMask()
getLocalObjectMask
in interface IPhysicalSchema
setLocalObjectMask(String)
public void setLocalObjectMask(java.lang.String pLocalObjectMask)
By default, this property is the same as defined in OdiTechnology
this
OdiPhysicalSchema
belongs to.
pLocalObjectMask
- local object maskDomainRuntimeException
- if local object mask is null or longer than
100getLocalObjectMask()
public java.lang.String getRemoteObjectMask()
getRemoteObjectMask
in interface IPhysicalSchema
setRemoteObjectMask(String)
public void setRemoteObjectMask(java.lang.String pRemoteObjectMask)
By default, this property is the same as defined in OdiTechnology
this
OdiPhysicalSchema
belongs to.
pRemoteObjectMask
- remote object maskDomainRuntimeException
- if remote object mask is null or longer than
100getRemoteObjectMask()
public java.lang.String getPartitionMask()
getPartitionMask
in interface IPhysicalSchema
setPartitionMask(String)
public void setPartitionMask(java.lang.String pPartitionMask)
By default, this property is the same as defined in OdiTechnology
this
OdiPhysicalSchema
belongs to.
pPartitionMask
- the partition maskDomainRuntimeException
- if partition mask is null or longer than
250getPartitionMask()
public java.lang.String getSubPartitionMask()
getSubPartitionMask
in interface IPhysicalSchema
setSubPartitionMask(String)
public void setSubPartitionMask(java.lang.String pSubPartitionMask)
By default, this property is the same as defined in OdiTechnology
this
OdiPhysicalSchema
belongs to.
pSubPartitionMask
- the partition maskDomainRuntimeException
- if sub partition mask is null or longer than
250getSubPartitionMask()
public void setLocalSequenceMask(java.lang.String pLocalSequenceMask)
By default, this property is the same as defined in OdiTechnology
this
OdiPhysicalSchema
belongs to.
pLocalSequenceMask
- the sequence maskDomainRuntimeException
- if sequence mask is null or longer than
100getLocalSequenceMask()
public void setLocalSequenceCurrMask(java.lang.String pLocalSequenceCurrMask)
By default, this property is the same as defined in OdiTechnology
this
OdiPhysicalSchema
belongs to.
pLocalSequenceCurrMask
- the sequence current value maskDomainRuntimeException
- if sequence current value mask is null or longer than
100getLocalSequenceCurrMask()
public java.lang.String getLocalSequenceMask()
getLocalSequenceMask
in interface IPhysicalSchema
setLocalSequenceMask(String)
public java.lang.String getLocalSequenceCurrMask()
setLocalSequenceCurrMask(String)
public void setRemoteSequenceMask(java.lang.String pRemoteSequenceMask)
By default, this property is the same as defined in OdiTechnology
this
OdiPhysicalSchema
belongs to.
pRemoteSequenceMask
- the sequence maskDomainRuntimeException
- if sequence mask is null or longer than
100getRemoteSequenceMask()
public java.lang.String getRemoteSequenceMask()
getRemoteSequenceMask
in interface IPhysicalSchema
setRemoteSequenceMask(String)
public void setRemoteSequenceCurrMask(java.lang.String pRemoteSequenceCurrMask)
By default, this property is the same as defined in OdiTechnology
this
OdiPhysicalSchema
belongs to.
pRemoteSequenceCurrMask
- the sequence current value maskDomainRuntimeException
- if sequence mask is null or longer than
100getRemoteSequenceCurrMask()
public java.lang.String getRemoteSequenceCurrMask()
setRemoteSequenceCurrMask(String)
public IRepositoryEntity getSecurityContainer()
IRepositoryEntity
getSecurityContainer
in interface IRepositoryEntity
public java.util.Collection getFlexFieldsValues()
IFlexFieldUser
.
Method initFlexFields(IOdiFlexFieldFinder)
should be
called before calling this method.getFlexFieldsValues
in interface IFlexFieldUser
public void initFlexFields(IOdiFlexFieldFinder pOdiFlexFieldFinder)
IFlexFieldUser
IFlexFieldUser
.initFlexFields
in interface IFlexFieldUser
pOdiFlexFieldFinder
- OdiFlexField
finder to be used to query flex fieldspublic OdiLogicalSchema getLogicalSchema(OdiContext pContext)
OdiLogicalSchema
associated for a given context. Will be null
if there is no OdiLogicalSchema associated to the given OdiContext
.pContext
- the context in which this logical schema is mappedOdiLogicalSchema
object mapped to this OdiPhysicalSchema
in given context.
Will be null
if none is mapped.public OdiDataServer getDataServer(IContext context)
ILocation
getDataServer
in interface ILocation
public ILogicalSchema getLogicalSchema() throws AdapterException
ILocation
getLogicalSchema
in interface ILocation
AdapterException
public IContext getContext()
ILocation
getContext
in interface ILocation
public void setContext(IContext context) throws AdapterException
ILocation
setContext
in interface ILocation
context
- A context object that relates the logical schema to a physical schema.AdapterException
public IPhysicalSchema getPhysicalSchema() throws AdapterException
ILocation
getPhysicalSchema
in interface ILocation
AdapterException
public void setPhysicalSchema(IPhysicalSchema physSchema) throws AdapterException
ILocation
setPhysicalSchema
in interface ILocation
AdapterException
public boolean locationEquals(ILocation otherLocation) throws AdapterException
ILocation
locationEquals
in interface ILocation
AdapterException
public java.lang.String getExecutableLocationName()
ILocation
getExecutableLocationName
in interface ILocation
public boolean executableLocationEquals(ILocation otherLocation, IContext context) throws AdapterException
ILocation
executableLocationEquals
in interface ILocation
otherLocation
- The location to compare to this one.context
- If non-null, a context object to use when finding the data server.AdapterException
public void setLogicalSchema(ILogicalSchema logSchema) throws AdapterException
ILocation
setLogicalSchema
in interface ILocation
logSchema
- the logical schema to be set.AdapterException
public java.lang.String getUniqueTagCharacterEncoding()
public void setUniqueTagCharacterEncoding(java.lang.String pUniqueTagCharacterEncoding)
pUniqueTagCharacterEncoding
- new encoding string.public IPhysicalSchema getPhysicalSchema(IContext context) throws AdapterException
ILocation
getPhysicalSchema
in interface ILocation
AdapterException
public OdiPhysicalSchema.OggProcessType getOggProcessType()
OdiLogicalSchema
represents Oracle Golden Gate process.OggProcessType.EXTRACT
in case of extract process, OggProcessType.REPLICAT
in case of replicat process and null
in case of non OGG processpublic void setOggProcessType(OdiPhysicalSchema.OggProcessType pOggProcessType)
OdiLogicalSchema
as an Oracle Golden Gate process if pOggProcessType
is not null and as a general ODI logical schema otherwise. Default value is null
.pOggProcessType
- OggProcessType.EXTRACT
for extract process, OggProcessType.REPLICAT
for replicat process and null
for general ODI logical schema.public java.lang.String getLocalTrailFilePath()
getOggProcessType()
public void setLocalTrailFilePath(java.lang.String pLocalTrailFilePath)
pLocalTrailFilePath
- path to local trail file to be set#setOggProcessType(String)
public java.lang.String getRemoteTrailFilePath()
getOggProcessType()
public void setRemoteTrailFilePath(java.lang.String pRemoteTrailFilePath)
pRemoteTrailFilePath
- path to remote trail file to be set#setOggProcessType(String)
public java.lang.Integer getTrailFileSize()
getOggProcessType()
public void setTrailFileSize(java.lang.Integer pTrailFileSize)
pTrailFileSize
- new size to be set#setOggProcessType(String)
public boolean isPassThru()
true
if PASSTHRU parameter will be added to the parameter file of pump process. Applicable to OGG extract processes only.getOggProcessType()
public void setPassThru(boolean pPassThru)
pPassThru
- if PASSTHRU parameter should be added to the parameter file of pump processgetOggProcessType()
public boolean isReportFetch()
true
if REPORTFETCH parameter will be added to the parameter file of extract process. Applicable to OGG extract processes only.getOggProcessType()
public void setReportFetch(boolean pReportFetch)
pReportFetch
- if REPORTFETCH parameter should be added to the parameter file of extract processgetOggProcessType()
public java.lang.Integer getExtractBufferSize()
public void setExtractBufferSize(java.lang.Integer pExtractBufferSize)
pExtractBufferSize
- buffer size to be setpublic java.lang.Integer getReportCountFrequency()
public void setReportCountFrequency(java.lang.Integer pReportCountFrequency)
pReportCountFrequency
- frequency to be setpublic OdiPhysicalSchema.OggReportCountFrequencyUnit getReportCountFrequencyUnit()
OdiPhysicalSchema.OggReportCountFrequencyUnit
public void setReportCountFrequencyUnit(OdiPhysicalSchema.OggReportCountFrequencyUnit pReportCountFrequencyUnit)
pReportCountFrequencyUnit
- unit to be usedOdiPhysicalSchema.OggReportCountFrequencyUnit
public java.lang.String getAdditionalOption()
public void setAdditionalOption(java.lang.String pAdditionalOption)
pAdditionalOption
- additional options to setpublic java.lang.String getDefinitionFilePath()
getOggProcessType()
public void setDefinitionFilePath(java.lang.String pDefinitionFilePath)
pDefinitionFilePath
- path to remote trail file to be set#setOggProcessType(String)
public java.lang.String getDiscardFilePath()
getOggProcessType()
public void setDiscardFilePath(java.lang.String pDiscardFilePath)
pDiscardFilePath
- path to remote trail file to be set#setOggProcessType(String)
public boolean isTargetDuplicatesAllowed()
getOggProcessType()
public void setTargetDuplicatesAllowed(boolean pTargetDuplicatesAllowed)
pTargetDuplicatesAllowed
is true
. Applicable to OGG replicat processes only.pTargetDuplicatesAllowed
- source table to multiple tergat table replication is allowed if true
and not allowed if false
getOggProcessType()
public boolean isReportDetail()
true
if replicat report will contain collision details and false
otherwise. Applicable to OGG replicat processes only.getOggProcessType()
public void setReportDetail(boolean pReportDetail)
pReportDetail
is true
. Applicable to OGG replicat processes only.pReportDetail
- include collision details in replicat report if true
and do not otherwisegetOggProcessType()
public boolean isUnresolvedLocation()
isUnresolvedLocation
in interface ILocation
public void resolveLocation(AdapterBase adapter) throws AdapterException
resolveLocation
in interface ILocation
AdapterException