public class KettleDatabaseRepositoryTransDelegate extends KettleDatabaseRepositoryBaseDelegate
Modifier and Type | Field and Description |
---|---|
static String |
TRANS_ATTRIBUTE_PREFIX |
Constructor and Description |
---|
KettleDatabaseRepositoryTransDelegate(KettleDatabaseRepository repository) |
Modifier and Type | Method and Description |
---|---|
int |
countTransParameter(org.pentaho.di.repository.ObjectId id_transformation)
Count the number of parameters of a transaction.
|
boolean |
existsTransMeta(String transname,
org.pentaho.di.repository.RepositoryDirectory directory) |
boolean |
existsTransMeta(String name,
org.pentaho.di.repository.RepositoryDirectoryInterface repositoryDirectory,
org.pentaho.di.repository.RepositoryObjectType objectType) |
org.pentaho.di.repository.ObjectId |
getDependencyID(org.pentaho.di.repository.ObjectId id_transformation,
org.pentaho.di.repository.ObjectId id_database,
String tablename) |
int |
getNrTransDependencies(org.pentaho.di.repository.ObjectId id_transformation) |
int |
getNrTransformations(org.pentaho.di.repository.ObjectId id_directory) |
int |
getNrTransHops(org.pentaho.di.repository.ObjectId id_transformation) |
boolean |
getTransAttributeBoolean(org.pentaho.di.repository.ObjectId id_transformation,
int nr,
String code) |
long |
getTransAttributeInteger(org.pentaho.di.repository.ObjectId id_transformation,
int nr,
String code) |
String |
getTransAttributeString(org.pentaho.di.repository.ObjectId id_transformation,
int nr,
String code) |
org.pentaho.di.core.RowMetaAndData |
getTransDependency(org.pentaho.di.repository.ObjectId id_dependency) |
org.pentaho.di.core.RowMetaAndData |
getTransformation(org.pentaho.di.repository.ObjectId id_transformation) |
org.pentaho.di.repository.ObjectId |
getTransformationID(String name,
org.pentaho.di.repository.ObjectId id_directory) |
String[] |
getTransformationsWithIDList(List<Object[]> list,
org.pentaho.di.core.row.RowMetaInterface rowMeta) |
String[] |
getTransformationsWithIDList(org.pentaho.di.repository.ObjectId[] ids) |
org.pentaho.di.core.RowMetaAndData |
getTransHop(org.pentaho.di.repository.ObjectId id_trans_hop) |
org.pentaho.di.repository.ObjectId |
getTransHopID(org.pentaho.di.repository.ObjectId id_transformation,
org.pentaho.di.repository.ObjectId id_step_from,
org.pentaho.di.repository.ObjectId id_step_to) |
org.pentaho.di.repository.ObjectId[] |
getTransHopIDs(org.pentaho.di.repository.ObjectId id_transformation) |
String |
getTransParameterDefault(org.pentaho.di.repository.ObjectId id_transformation,
int nr)
Get a transformation parameter default.
|
String |
getTransParameterDescription(org.pentaho.di.repository.ObjectId id_transformation,
int nr)
Get a transformation parameter description.
|
String |
getTransParameterKey(org.pentaho.di.repository.ObjectId id_transformation,
int nr)
Get a transformation parameter key.
|
void |
insertTransParameter(org.pentaho.di.repository.ObjectId id_transformation,
long nr,
String key,
String defValue,
String description)
Insert a parameter for a transformation in the repository.
|
TransDependency |
loadTransDependency(org.pentaho.di.repository.ObjectId id_dependency,
List<org.pentaho.di.core.database.DatabaseMeta> databases) |
TransMeta |
loadTransformation(TransMeta transMeta,
String transname,
org.pentaho.di.repository.RepositoryDirectoryInterface repdir,
org.pentaho.di.core.ProgressMonitorListener monitor,
boolean setInternalVariables)
Read a transformation with a certain name from a repository
|
TransHopMeta |
loadTransHopMeta(org.pentaho.di.repository.ObjectId id_trans_hop,
List<StepMeta> steps) |
void |
moveTransformation(String transname,
org.pentaho.di.repository.ObjectId id_directory_from,
org.pentaho.di.repository.ObjectId id_directory_to) |
void |
readClusters(TransMeta transMeta,
boolean overWriteShared)
Read the clusters in the repository and add them to this transformation if they are not yet present.
|
void |
readDatabases(TransMeta transMeta,
boolean overWriteShared)
Read all the databases from the repository, insert into the TransMeta object, overwriting optionally
|
void |
readPartitionSchemas(TransMeta transMeta,
boolean overWriteShared)
Read the partitions in the repository and add them to this transformation if they are not yet present.
|
void |
readSlaves(TransMeta transMeta,
boolean overWriteShared)
Read the slave servers in the repository and add them to this transformation if they are not yet present.
|
SharedObjects |
readTransSharedObjects(TransMeta transMeta) |
void |
renameTransformation(org.pentaho.di.repository.ObjectId id_transformation,
org.pentaho.di.repository.RepositoryDirectoryInterface newParentDir,
String newname) |
void |
saveTransDependency(TransDependency transDependency,
org.pentaho.di.repository.ObjectId id_transformation) |
void |
saveTransformation(TransMeta transMeta,
String versionComment,
org.pentaho.di.core.ProgressMonitorListener monitor,
boolean overwriteAssociated)
Saves the transformation to a repository.
|
void |
saveTransHopMeta(TransHopMeta transHopMeta,
org.pentaho.di.repository.ObjectId id_transformation) |
void |
saveTransParameters(TransMeta transMeta)
Save the parameters of this transformation to the repository.
|
quote, quoteTable
public static final String TRANS_ATTRIBUTE_PREFIX
public KettleDatabaseRepositoryTransDelegate(KettleDatabaseRepository repository)
public org.pentaho.di.core.RowMetaAndData getTransformation(org.pentaho.di.repository.ObjectId id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getTransHop(org.pentaho.di.repository.ObjectId id_trans_hop) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getTransDependency(org.pentaho.di.repository.ObjectId id_dependency) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public boolean existsTransMeta(String name, org.pentaho.di.repository.RepositoryDirectoryInterface repositoryDirectory, org.pentaho.di.repository.RepositoryObjectType objectType) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.repository.ObjectId getTransformationID(String name, org.pentaho.di.repository.ObjectId id_directory) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.repository.ObjectId getTransHopID(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step_from, org.pentaho.di.repository.ObjectId id_step_to) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.repository.ObjectId getDependencyID(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_database, String tablename) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void saveTransformation(TransMeta transMeta, String versionComment, org.pentaho.di.core.ProgressMonitorListener monitor, boolean overwriteAssociated) throws org.pentaho.di.core.exception.KettleException
transMeta
- the transformation metadata to storemonitor
- the way we report progress to the user, can be null if no UI is presentoverwrite
- Overwrite existing object(s)?org.pentaho.di.core.exception.KettleException
- if an error occurs.public void saveTransParameters(TransMeta transMeta) throws org.pentaho.di.core.exception.KettleException
rep
- The repository to save to.org.pentaho.di.core.exception.KettleException
- Upon any error.
TODO: Move this code over to the Repository class for refactoring...public TransMeta loadTransformation(TransMeta transMeta, String transname, org.pentaho.di.repository.RepositoryDirectoryInterface repdir, org.pentaho.di.core.ProgressMonitorListener monitor, boolean setInternalVariables) throws org.pentaho.di.core.exception.KettleException
rep
- The repository to read from.transname
- The name of the transformation.repdir
- the path to the repository directorymonitor
- The progress monitor to display the progress of the file-open operation in a dialogsetInternalVariables
- true if you want to set the internal variables based on this transformation informationorg.pentaho.di.core.exception.KettleException
public int countTransParameter(org.pentaho.di.repository.ObjectId id_transformation) throws org.pentaho.di.core.exception.KettleException
id_transformation
- transformation idorg.pentaho.di.core.exception.KettleException
- Upon any error.public String getTransParameterKey(org.pentaho.di.repository.ObjectId id_transformation, int nr) throws org.pentaho.di.core.exception.KettleException
id_transformation
- transformation idnr
- number of the parameterorg.pentaho.di.core.exception.KettleException
- Upon any error.public String getTransParameterDefault(org.pentaho.di.repository.ObjectId id_transformation, int nr) throws org.pentaho.di.core.exception.KettleException
id_transformation
- transformation idnr
- number of the parameterorg.pentaho.di.core.exception.KettleException
- Upon any error.public String getTransParameterDescription(org.pentaho.di.repository.ObjectId id_transformation, int nr) throws org.pentaho.di.core.exception.KettleException
id_transformation
- transformation idnr
- number of the parameterorg.pentaho.di.core.exception.KettleException
- Upon any error.public void insertTransParameter(org.pentaho.di.repository.ObjectId id_transformation, long nr, String key, String defValue, String description) throws org.pentaho.di.core.exception.KettleException
id_transformation
- transformation idnr
- number of the parameter to insertkey
- key to insertdefValue
- default valuedescription
- description to insertorg.pentaho.di.core.exception.KettleException
- Upon any error.public void readDatabases(TransMeta transMeta, boolean overWriteShared) throws org.pentaho.di.core.exception.KettleException
TransMeta
- The transformation to load into.overWriteShared
- if an object with the same name exists, overwriteorg.pentaho.di.core.exception.KettleException
public void readClusters(TransMeta transMeta, boolean overWriteShared) throws org.pentaho.di.core.exception.KettleException
TransMeta
- The transformation to load into.overWriteShared
- if an object with the same name exists, overwriteorg.pentaho.di.core.exception.KettleException
public void readPartitionSchemas(TransMeta transMeta, boolean overWriteShared) throws org.pentaho.di.core.exception.KettleException
TransMeta
- The transformation to load into.overWriteShared
- if an object with the same name exists, overwriteorg.pentaho.di.core.exception.KettleException
public void readSlaves(TransMeta transMeta, boolean overWriteShared) throws org.pentaho.di.core.exception.KettleException
TransMeta
- The transformation to load into.overWriteShared
- if an object with the same name exists, overwriteorg.pentaho.di.core.exception.KettleException
public TransDependency loadTransDependency(org.pentaho.di.repository.ObjectId id_dependency, List<org.pentaho.di.core.database.DatabaseMeta> databases) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void saveTransDependency(TransDependency transDependency, org.pentaho.di.repository.ObjectId id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void saveTransHopMeta(TransHopMeta transHopMeta, org.pentaho.di.repository.ObjectId id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public TransHopMeta loadTransHopMeta(org.pentaho.di.repository.ObjectId id_trans_hop, List<StepMeta> steps) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrTransformations(org.pentaho.di.repository.ObjectId id_directory) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrTransHops(org.pentaho.di.repository.ObjectId id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrTransDependencies(org.pentaho.di.repository.ObjectId id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String[] getTransformationsWithIDList(List<Object[]> list, org.pentaho.di.core.row.RowMetaInterface rowMeta) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String[] getTransformationsWithIDList(org.pentaho.di.repository.ObjectId[] ids) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public boolean existsTransMeta(String transname, org.pentaho.di.repository.RepositoryDirectory directory) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.repository.ObjectId[] getTransHopIDs(org.pentaho.di.repository.ObjectId id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public boolean getTransAttributeBoolean(org.pentaho.di.repository.ObjectId id_transformation, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String getTransAttributeString(org.pentaho.di.repository.ObjectId id_transformation, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getTransAttributeInteger(org.pentaho.di.repository.ObjectId id_transformation, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public SharedObjects readTransSharedObjects(TransMeta transMeta) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void moveTransformation(String transname, org.pentaho.di.repository.ObjectId id_directory_from, org.pentaho.di.repository.ObjectId id_directory_to) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void renameTransformation(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.RepositoryDirectoryInterface newParentDir, String newname) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException