org.pentaho.di.repository.kdr

Class KettleDatabaseRepository

java.lang.Object

org.pentaho.di.repository.AbstractRepository

org.pentaho.di.repository.kdr.KettleDatabaseRepositoryBase

org.pentaho.di.repository.kdr.KettleDatabaseRepository

All Implemented Interfaces:

Repository

public class KettleDatabaseRepository
extends KettleDatabaseRepositoryBase

This class handles interactions with a Kettle repository.

Author:

Matt Created on 31-mrt-2004

Field Summary

Fields

Modifier and Type	Field and Description
KettleDatabaseRepositoryClusterSchemaDelegate	clusterSchemaDelegate
KettleDatabaseRepositoryConditionDelegate	conditionDelegate
KettleDatabaseRepositoryConnectionDelegate	connectionDelegate
KettleDatabaseRepositoryDatabaseDelegate	databaseDelegate
KettleDatabaseRepositoryDirectoryDelegate	directoryDelegate
KettleDatabaseRepositoryJobDelegate	jobDelegate
KettleDatabaseRepositoryJobEntryDelegate	jobEntryDelegate
KettleDatabaseRepositoryMetaStore	metaStore
KettleDatabaseRepositoryMetaStoreDelegate	metaStoreDelegate
KettleDatabaseRepositoryNotePadDelegate	notePadDelegate
KettleDatabaseRepositoryPartitionSchemaDelegate	partitionSchemaDelegate
KettleDatabaseRepositorySlaveServerDelegate	slaveServerDelegate
KettleDatabaseRepositoryStepDelegate	stepDelegate
KettleDatabaseRepositoryTransDelegate	transDelegate
KettleDatabaseRepositoryUserDelegate	userDelegate
KettleDatabaseRepositoryValueDelegate	valueDelegate

Fields inherited from class org.pentaho.di.repository.kdr.KettleDatabaseRepositoryBase

FIELD_CLUSTER_BASE_PORT, FIELD_CLUSTER_DYNAMIC, FIELD_CLUSTER_ID_CLUSTER, FIELD_CLUSTER_NAME, FIELD_CLUSTER_SLAVE_ID_CLUSTER, FIELD_CLUSTER_SLAVE_ID_CLUSTER_SLAVE, FIELD_CLUSTER_SLAVE_ID_SLAVE, FIELD_CLUSTER_SOCKETS_BUFFER_SIZE, FIELD_CLUSTER_SOCKETS_COMPRESSED, FIELD_CLUSTER_SOCKETS_FLUSH_INTERVAL, FIELD_CONDITION_CONDITION_FUNCTION, FIELD_CONDITION_ID_CONDITION, FIELD_CONDITION_ID_CONDITION_PARENT, FIELD_CONDITION_ID_VALUE_RIGHT, FIELD_CONDITION_LEFT_NAME, FIELD_CONDITION_NEGATED, FIELD_CONDITION_OPERATOR, FIELD_CONDITION_RIGHT_NAME, FIELD_DATABASE_ATTRIBUTE_CODE, FIELD_DATABASE_ATTRIBUTE_ID_DATABASE, FIELD_DATABASE_ATTRIBUTE_ID_DATABASE_ATTRIBUTE, FIELD_DATABASE_ATTRIBUTE_VALUE_STR, FIELD_DATABASE_CONTYPE_CODE, FIELD_DATABASE_CONTYPE_DESCRIPTION, FIELD_DATABASE_CONTYPE_ID_DATABASE_CONTYPE, FIELD_DATABASE_DATA_TBS, FIELD_DATABASE_DATABASE_NAME, FIELD_DATABASE_HOST_NAME, FIELD_DATABASE_ID_DATABASE, FIELD_DATABASE_ID_DATABASE_CONTYPE, FIELD_DATABASE_ID_DATABASE_TYPE, FIELD_DATABASE_INDEX_TBS, FIELD_DATABASE_NAME, FIELD_DATABASE_PASSWORD, FIELD_DATABASE_PORT, FIELD_DATABASE_SERVERNAME, FIELD_DATABASE_TYPE_CODE, FIELD_DATABASE_TYPE_DESCRIPTION, FIELD_DATABASE_TYPE_ID_DATABASE_TYPE, FIELD_DATABASE_USERNAME, FIELD_DEPENDENCY_FIELD_NAME, FIELD_DEPENDENCY_ID_DATABASE, FIELD_DEPENDENCY_ID_DEPENDENCY, FIELD_DEPENDENCY_ID_TRANSFORMATION, FIELD_DEPENDENCY_TABLE_NAME, FIELD_DIRECTORY_DIRECTORY_NAME, FIELD_DIRECTORY_ID_DIRECTORY, FIELD_DIRECTORY_ID_DIRECTORY_PARENT, FIELD_ELEMENT_ATTRIBUTE_ID_ELEMENT, FIELD_ELEMENT_ATTRIBUTE_ID_ELEMENT_ATTRIBUTE, FIELD_ELEMENT_ATTRIBUTE_ID_ELEMENT_ATTRIBUTE_PARENT, FIELD_ELEMENT_ATTRIBUTE_KEY, FIELD_ELEMENT_ATTRIBUTE_VALUE, FIELD_ELEMENT_ID_ELEMENT, FIELD_ELEMENT_ID_ELEMENT_TYPE, FIELD_ELEMENT_NAME, FIELD_ELEMENT_TYPE_DESCRIPTION, FIELD_ELEMENT_TYPE_ID_ELEMENT_TYPE, FIELD_ELEMENT_TYPE_ID_NAMESPACE, FIELD_ELEMENT_TYPE_NAME, FIELD_JOB_ATTRIBUTE_CODE, FIELD_JOB_ATTRIBUTE_ID_JOB, FIELD_JOB_ATTRIBUTE_ID_JOB_ATTRIBUTE, FIELD_JOB_ATTRIBUTE_NR, FIELD_JOB_ATTRIBUTE_VALUE_NUM, FIELD_JOB_ATTRIBUTE_VALUE_STR, FIELD_JOB_CREATED_DATE, FIELD_JOB_CREATED_USER, FIELD_JOB_DESCRIPTION, FIELD_JOB_EXTENDED_DESCRIPTION, FIELD_JOB_HOP_ENABLED, FIELD_JOB_HOP_EVALUATION, FIELD_JOB_HOP_ID_JOB, FIELD_JOB_HOP_ID_JOB_HOP, FIELD_JOB_HOP_ID_JOBENTRY_COPY_FROM, FIELD_JOB_HOP_ID_JOBENTRY_COPY_TO, FIELD_JOB_HOP_UNCONDITIONAL, FIELD_JOB_ID_DATABASE_LOG, FIELD_JOB_ID_DIRECTORY, FIELD_JOB_ID_JOB, FIELD_JOB_JOB_STATUS, FIELD_JOB_JOB_VERSION, FIELD_JOB_LOCK_ID_JOB, FIELD_JOB_LOCK_ID_JOB_LOCK, FIELD_JOB_LOCK_ID_USER, FIELD_JOB_LOCK_LOCK_DATE, FIELD_JOB_LOCK_LOCK_MESSAGE, FIELD_JOB_MODIFIED_DATE, FIELD_JOB_MODIFIED_USER, FIELD_JOB_NAME, FIELD_JOB_NOTE_ID_JOB, FIELD_JOB_NOTE_ID_NOTE, FIELD_JOB_PASS_BATCH_ID, FIELD_JOB_SHARED_FILE, FIELD_JOB_TABLE_NAME_LOG, FIELD_JOB_USE_BATCH_ID, FIELD_JOB_USE_LOGFIELD, FIELD_JOBENTRY_ATTRIBUTE_CODE, FIELD_JOBENTRY_ATTRIBUTE_ID_JOB, FIELD_JOBENTRY_ATTRIBUTE_ID_JOBENTRY, FIELD_JOBENTRY_ATTRIBUTE_ID_JOBENTRY_ATTRIBUTE, FIELD_JOBENTRY_ATTRIBUTE_NR, FIELD_JOBENTRY_ATTRIBUTE_VALUE_NUM, FIELD_JOBENTRY_ATTRIBUTE_VALUE_STR, FIELD_JOBENTRY_COPY_GUI_DRAW, FIELD_JOBENTRY_COPY_GUI_LOCATION_X, FIELD_JOBENTRY_COPY_GUI_LOCATION_Y, FIELD_JOBENTRY_COPY_ID_JOB, FIELD_JOBENTRY_COPY_ID_JOBENTRY, FIELD_JOBENTRY_COPY_ID_JOBENTRY_COPY, FIELD_JOBENTRY_COPY_ID_JOBENTRY_TYPE, FIELD_JOBENTRY_COPY_NR, FIELD_JOBENTRY_COPY_PARALLEL, FIELD_JOBENTRY_DATABASE_ID_DATABASE, FIELD_JOBENTRY_DATABASE_ID_JOB, FIELD_JOBENTRY_DATABASE_ID_JOBENTRY, FIELD_JOBENTRY_DESCRIPTION, FIELD_JOBENTRY_ID_JOB, FIELD_JOBENTRY_ID_JOBENTRY, FIELD_JOBENTRY_ID_JOBENTRY_TYPE, FIELD_JOBENTRY_NAME, FIELD_JOBENTRY_TYPE_CODE, FIELD_JOBENTRY_TYPE_DESCRIPTION, FIELD_JOBENTRY_TYPE_ID_JOBENTRY_TYPE, FIELD_LOG_ADD_DATE, FIELD_LOG_ADD_TIME, FIELD_LOG_FILEEXTENTION, FIELD_LOG_FILENAME, FIELD_LOG_ID_DATABASE_LOG, FIELD_LOG_ID_LOG, FIELD_LOG_ID_LOGLEVEL, FIELD_LOG_LOGTYPE, FIELD_LOG_NAME, FIELD_LOG_TABLE_NAME_LOG, FIELD_LOGLEVEL_CODE, FIELD_LOGLEVEL_DESCRIPTION, FIELD_LOGLEVEL_ID_LOGLEVEL, FIELD_NAMESPACE_ID_NAMESPACE, FIELD_NAMESPACE_NAME, FIELD_NOTE_BACK_GROUND_COLOR_BLUE, FIELD_NOTE_BACK_GROUND_COLOR_GREEN, FIELD_NOTE_BACK_GROUND_COLOR_RED, FIELD_NOTE_BORDER_COLOR_BLUE, FIELD_NOTE_BORDER_COLOR_GREEN, FIELD_NOTE_BORDER_COLOR_RED, FIELD_NOTE_COLOR_BLUE, FIELD_NOTE_COLOR_GREEN, FIELD_NOTE_COLOR_RED, FIELD_NOTE_DRAW_SHADOW, FIELD_NOTE_FONT_BOLD, FIELD_NOTE_FONT_ITALIC, FIELD_NOTE_FONT_NAME, FIELD_NOTE_FONT_SIZE, FIELD_NOTE_GUI_LOCATION_HEIGHT, FIELD_NOTE_GUI_LOCATION_WIDTH, FIELD_NOTE_GUI_LOCATION_X, FIELD_NOTE_GUI_LOCATION_Y, FIELD_NOTE_ID_NOTE, FIELD_NOTE_VALUE_STR, FIELD_PARTITION_ID_PARTITION, FIELD_PARTITION_ID_PARTITION_SCHEMA, FIELD_PARTITION_PARTITION_ID, FIELD_PARTITION_SCHEMA_DYNAMIC_DEFINITION, FIELD_PARTITION_SCHEMA_ID_PARTITION_SCHEMA, FIELD_PARTITION_SCHEMA_NAME, FIELD_PARTITION_SCHEMA_PARTITIONS_PER_SLAVE, FIELD_REPOSITORY_LOG_ID_REPOSITORY_LOG, FIELD_REPOSITORY_LOG_LOG_DATE, FIELD_REPOSITORY_LOG_LOG_USER, FIELD_REPOSITORY_LOG_OPERATION_DESC, FIELD_REPOSITORY_LOG_REP_VERSION, FIELD_SLAVE_HOST_NAME, FIELD_SLAVE_ID_SLAVE, FIELD_SLAVE_MASTER, FIELD_SLAVE_NAME, FIELD_SLAVE_NON_PROXY_HOSTS, FIELD_SLAVE_PASSWORD, FIELD_SLAVE_PORT, FIELD_SLAVE_PROXY_HOST_NAME, FIELD_SLAVE_PROXY_PORT, FIELD_SLAVE_USERNAME, FIELD_SLAVE_WEB_APP_NAME, FIELD_STEP_ATTRIBUTE_CODE, FIELD_STEP_ATTRIBUTE_ID_STEP, FIELD_STEP_ATTRIBUTE_ID_STEP_ATTRIBUTE, FIELD_STEP_ATTRIBUTE_ID_TRANSFORMATION, FIELD_STEP_ATTRIBUTE_NR, FIELD_STEP_ATTRIBUTE_VALUE_NUM, FIELD_STEP_ATTRIBUTE_VALUE_STR, FIELD_STEP_COPIES, FIELD_STEP_COPIES_STRING, FIELD_STEP_DATABASE_ID_DATABASE, FIELD_STEP_DATABASE_ID_STEP, FIELD_STEP_DATABASE_ID_TRANSFORMATION, FIELD_STEP_DESCRIPTION, FIELD_STEP_DISTRIBUTE, FIELD_STEP_GUI_DRAW, FIELD_STEP_GUI_LOCATION_X, FIELD_STEP_GUI_LOCATION_Y, FIELD_STEP_ID_STEP, FIELD_STEP_ID_STEP_TYPE, FIELD_STEP_ID_TRANSFORMATION, FIELD_STEP_NAME, FIELD_STEP_TYPE_CODE, FIELD_STEP_TYPE_DESCRIPTION, FIELD_STEP_TYPE_HELPTEXT, FIELD_STEP_TYPE_ID_STEP_TYPE, FIELD_TRANS_ATTRIBUTE_CODE, FIELD_TRANS_ATTRIBUTE_ID_TRANS_ATTRIBUTE, FIELD_TRANS_ATTRIBUTE_ID_TRANSFORMATION, FIELD_TRANS_ATTRIBUTE_NR, FIELD_TRANS_ATTRIBUTE_VALUE_NUM, FIELD_TRANS_ATTRIBUTE_VALUE_STR, FIELD_TRANS_CLUSTER_ID_CLUSTER, FIELD_TRANS_CLUSTER_ID_TRANS_CLUSTER, FIELD_TRANS_CLUSTER_ID_TRANSFORMATION, FIELD_TRANS_HOP_ENABLED, FIELD_TRANS_HOP_ID_STEP_FROM, FIELD_TRANS_HOP_ID_STEP_TO, FIELD_TRANS_HOP_ID_TRANS_HOP, FIELD_TRANS_HOP_ID_TRANSFORMATION, FIELD_TRANS_LOCK_ID_TRANS_LOCK, FIELD_TRANS_LOCK_ID_TRANSFORMATION, FIELD_TRANS_LOCK_ID_USER, FIELD_TRANS_LOCK_LOCK_DATE, FIELD_TRANS_LOCK_LOCK_MESSAGE, FIELD_TRANS_NOTE_ID_NOTE, FIELD_TRANS_NOTE_ID_TRANSFORMATION, FIELD_TRANS_PARTITION_SCHEMA_ID_PARTITION_SCHEMA, FIELD_TRANS_PARTITION_SCHEMA_ID_TRANS_PARTITION_SCHEMA, FIELD_TRANS_PARTITION_SCHEMA_ID_TRANSFORMATION, FIELD_TRANS_SLAVE_ID_SLAVE, FIELD_TRANS_SLAVE_ID_TRANS_SLAVE, FIELD_TRANS_SLAVE_ID_TRANSFORMATION, FIELD_TRANS_STEP_CONDITION_ID_CONDITION, FIELD_TRANS_STEP_CONDITION_ID_STEP, FIELD_TRANS_STEP_CONDITION_ID_TRANSFORMATION, FIELD_TRANSFORMATION_CREATED_DATE, FIELD_TRANSFORMATION_CREATED_USER, FIELD_TRANSFORMATION_DESCRIPTION, FIELD_TRANSFORMATION_DIFF_MAXDATE, FIELD_TRANSFORMATION_EXTENDED_DESCRIPTION, FIELD_TRANSFORMATION_FIELD_NAME_MAXDATE, FIELD_TRANSFORMATION_ID_DATABASE_LOG, FIELD_TRANSFORMATION_ID_DATABASE_MAXDATE, FIELD_TRANSFORMATION_ID_DIRECTORY, FIELD_TRANSFORMATION_ID_STEP_INPUT, FIELD_TRANSFORMATION_ID_STEP_OUTPUT, FIELD_TRANSFORMATION_ID_STEP_READ, FIELD_TRANSFORMATION_ID_STEP_UPDATE, FIELD_TRANSFORMATION_ID_STEP_WRITE, FIELD_TRANSFORMATION_ID_TRANSFORMATION, FIELD_TRANSFORMATION_MODIFIED_DATE, FIELD_TRANSFORMATION_MODIFIED_USER, FIELD_TRANSFORMATION_NAME, FIELD_TRANSFORMATION_OFFSET_MAXDATE, FIELD_TRANSFORMATION_SIZE_ROWSET, FIELD_TRANSFORMATION_TABLE_NAME_LOG, FIELD_TRANSFORMATION_TABLE_NAME_MAXDATE, FIELD_TRANSFORMATION_TRANS_STATUS, FIELD_TRANSFORMATION_TRANS_VERSION, FIELD_TRANSFORMATION_USE_BATCHID, FIELD_TRANSFORMATION_USE_LOGFIELD, FIELD_USER_DESCRIPTION, FIELD_USER_ENABLED, FIELD_USER_ID_USER, FIELD_USER_LOGIN, FIELD_USER_NAME, FIELD_USER_PASSWORD, FIELD_VALUE_ID_VALUE, FIELD_VALUE_IS_NULL, FIELD_VALUE_NAME, FIELD_VALUE_VALUE_STR, FIELD_VALUE_VALUE_TYPE, FIELD_VERSION_ID_VERSION, FIELD_VERSION_IS_UPGRADE, FIELD_VERSION_MAJOR_VERSION, FIELD_VERSION_MINOR_VERSION, FIELD_VERSION_UPGRADE_DATE, JOB_ATTRIBUTE_LOG_SIZE_LIMIT, JOB_ATTRIBUTE_PARAM_DEFAULT, JOB_ATTRIBUTE_PARAM_DESCRIPTION, JOB_ATTRIBUTE_PARAM_KEY, REP_ORACLE_STRING_LENGTH, REP_STRING_CODE_LENGTH, REP_STRING_LENGTH, repositoryTableNames, TABLE_R_CLUSTER, TABLE_R_CLUSTER_SLAVE, TABLE_R_CONDITION, TABLE_R_DATABASE, TABLE_R_DATABASE_ATTRIBUTE, TABLE_R_DATABASE_CONTYPE, TABLE_R_DATABASE_TYPE, TABLE_R_DEPENDENCY, TABLE_R_DIRECTORY, TABLE_R_ELEMENT, TABLE_R_ELEMENT_ATTRIBUTE, TABLE_R_ELEMENT_TYPE, TABLE_R_JOB, TABLE_R_JOB_ATTRIBUTE, TABLE_R_JOB_HOP, TABLE_R_JOB_LOCK, TABLE_R_JOB_NOTE, TABLE_R_JOBENTRY, TABLE_R_JOBENTRY_ATTRIBUTE, TABLE_R_JOBENTRY_COPY, TABLE_R_JOBENTRY_DATABASE, TABLE_R_JOBENTRY_TYPE, TABLE_R_LOG, TABLE_R_LOGLEVEL, TABLE_R_NAMESPACE, TABLE_R_NOTE, TABLE_R_PARTITION, TABLE_R_PARTITION_SCHEMA, TABLE_R_REPOSITORY_LOG, TABLE_R_SLAVE, TABLE_R_STEP, TABLE_R_STEP_ATTRIBUTE, TABLE_R_STEP_DATABASE, TABLE_R_STEP_TYPE, TABLE_R_TRANS_ATTRIBUTE, TABLE_R_TRANS_CLUSTER, TABLE_R_TRANS_HOP, TABLE_R_TRANS_LOCK, TABLE_R_TRANS_NOTE, TABLE_R_TRANS_PARTITION_SCHEMA, TABLE_R_TRANS_SLAVE, TABLE_R_TRANS_STEP_CONDITION, TABLE_R_TRANSFORMATION, TABLE_R_USER, TABLE_R_VALUE, TABLE_R_VERSION, TRANS_ATTRIBUTE_CAPTURE_STEP_PERFORMANCE, TRANS_ATTRIBUTE_DATA_SERVICE_NAME, TRANS_ATTRIBUTE_FEEDBACK_SHOWN, TRANS_ATTRIBUTE_FEEDBACK_SIZE, TRANS_ATTRIBUTE_ID_STEP_REJECTED, TRANS_ATTRIBUTE_LOG_INTERVAL, TRANS_ATTRIBUTE_LOG_SIZE_LIMIT, TRANS_ATTRIBUTE_PARAM_DEFAULT, TRANS_ATTRIBUTE_PARAM_DESCRIPTION, TRANS_ATTRIBUTE_PARAM_KEY, TRANS_ATTRIBUTE_SHARED_FILE, TRANS_ATTRIBUTE_SLEEP_TIME_EMPTY, TRANS_ATTRIBUTE_SLEEP_TIME_FULL, TRANS_ATTRIBUTE_STEP_PERFORMANCE_CAPTURING_DELAY, TRANS_ATTRIBUTE_STEP_PERFORMANCE_CAPTURING_SIZE_LIMIT, TRANS_ATTRIBUTE_STEP_PERFORMANCE_LOG_TABLE, TRANS_ATTRIBUTE_TRANSFORMATION_TYPE, TRANS_ATTRIBUTE_UNIQUE_CONNECTIONS, TRANS_ATTRIBUTE_USING_THREAD_PRIORITIES

Constructor Summary

Constructors

Constructor and Description
KettleDatabaseRepository()

Method Summary

Methods

Modifier and Type	Method and Description
static String	byteArrayToString(byte[] val) GZips and then base64 encodes an array of bytes to a String
void	clearSharedObjectCache() Clear the shared object cache, if applicable.
void	commit()
void	connect(String username, String password) Connect to the repository.
void	connect(String username, String password, boolean upgrade) Connect to the repository.
int	countNrJobEntryAttributes(org.pentaho.di.repository.ObjectId id_jobentry, String code)
int	countNrStepAttributes(org.pentaho.di.repository.ObjectId id_step, String code)
org.pentaho.di.repository.RepositoryDirectoryInterface	createRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface parentDirectory, String directoryPath) Create a new directory, possibly by creating several sub-directies of / at the same time.
RepositoryMeta	createRepositoryMeta()
void	createRepositorySchema(org.pentaho.di.core.ProgressMonitorListener monitor, boolean upgrade, List<String> statements, boolean dryRun) Create or upgrade repository tables & fields, populate lookup tables, ...
void	delClusterSlaves(org.pentaho.di.repository.ObjectId id_cluster)
void	delDependencies(org.pentaho.di.repository.ObjectId id_transformation)
void	deleteClusterSchema(org.pentaho.di.repository.ObjectId id_cluster)
void	deleteCondition(org.pentaho.di.repository.ObjectId id_condition)
void	deleteDatabaseMeta(String databaseName) Remove a database connection from the repository
void	deleteJob(org.pentaho.di.repository.ObjectId id_job)
void	deletePartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema)
void	deleteRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface dir)
void	deleteSlave(org.pentaho.di.repository.ObjectId id_slave)
void	deleteTransformation(org.pentaho.di.repository.ObjectId id_transformation) Delete everything related to a transformation from the repository.
void	delJob(org.pentaho.di.repository.ObjectId id_job)
void	delJobAttributes(org.pentaho.di.repository.ObjectId id_job)
void	delJobEntries(org.pentaho.di.repository.ObjectId id_job)
void	delJobEntryAttributes(org.pentaho.di.repository.ObjectId id_job)
void	delJobEntryCopies(org.pentaho.di.repository.ObjectId id_job)
void	delJobEntryDatabases(org.pentaho.di.repository.ObjectId id_job) Delete the relationships between the job/job entries and the databases.
void	delJobHops(org.pentaho.di.repository.ObjectId id_job)
void	delJobNotes(org.pentaho.di.repository.ObjectId id_job)
void	delPartitions(org.pentaho.di.repository.ObjectId id_partition_schema)
void	delPartitionSchemas(org.pentaho.di.repository.ObjectId id_transformation)
void	delStepAttributes(org.pentaho.di.repository.ObjectId id_transformation)
void	delStepConditions(org.pentaho.di.repository.ObjectId id_transformation)
void	delStepDatabases(org.pentaho.di.repository.ObjectId id_transformation) Delete the relationships between the transformation/steps and the databases.
void	delSteps(org.pentaho.di.repository.ObjectId id_transformation)
void	delTrans(org.pentaho.di.repository.ObjectId id_transformation)
void	delTransAttributes(org.pentaho.di.repository.ObjectId id_transformation)
void	delTransformationClusters(org.pentaho.di.repository.ObjectId id_transformation)
void	delTransformationSlaves(org.pentaho.di.repository.ObjectId id_transformation)
void	delTransHops(org.pentaho.di.repository.ObjectId id_transformation)
void	delTransNotes(org.pentaho.di.repository.ObjectId id_transformation)
void	delTransStepCondition(org.pentaho.di.repository.ObjectId id_transformation)
void	delValue(org.pentaho.di.repository.ObjectId id_value)
void	disconnect() Disconnect from the repository.
boolean	dropRepositorySchema()
void	execStatement(String sql)
boolean	exists(String name, org.pentaho.di.repository.RepositoryDirectoryInterface repositoryDirectory, org.pentaho.di.repository.RepositoryObjectType objectType) See if a repository object exists in the repository
org.pentaho.di.repository.RepositoryDirectoryInterface	findDirectory(org.pentaho.di.repository.ObjectId directory)
org.pentaho.di.repository.RepositoryDirectoryInterface	findDirectory(String directory)
org.pentaho.di.repository.ObjectId	findStepAttributeID(org.pentaho.di.repository.ObjectId id_step, int nr, String code) This method is only used to check backward compatibility with the 2.x series.
org.pentaho.di.repository.ObjectId	getClusterID(String name)
org.pentaho.di.repository.ObjectId[]	getClusterIDs(boolean includeDeleted)
String[]	getClusterNames(boolean includeDeleted)
org.pentaho.di.repository.ObjectId[]	getClusterSlaveIDs(org.pentaho.di.repository.ObjectId id_cluster_schema)
String[]	getClustersUsingSlave(org.pentaho.di.repository.ObjectId id_slave)
String	getConnectMessage() This is an informational message that a repository can display on connecting within Spoon.
org.pentaho.di.core.database.Database	getDatabase()
org.pentaho.di.repository.ObjectId[]	getDatabaseAttributeIDs(org.pentaho.di.repository.ObjectId id_database)
org.pentaho.di.repository.ObjectId	getDatabaseID(String name)
org.pentaho.di.repository.ObjectId[]	getDatabaseIDs(boolean includeDeleted)
org.pentaho.di.core.database.DatabaseMeta	getDatabaseMeta()
String[]	getDatabaseNames(boolean includeDeleted)
List<org.pentaho.di.core.database.DatabaseMeta>	getDatabases()
org.pentaho.di.repository.RepositoryDirectory	getDefaultSaveDirectory(org.pentaho.di.repository.RepositoryElementInterface repositoryElement)
String[]	getDirectoryNames(org.pentaho.di.repository.ObjectId id_directory) Returns the child directory names of a parent directory
IRepositoryExporter	getExporter()
org.pentaho.di.repository.RepositoryDirectory	getImportBaseDirectory() The directory set during import to signal that job entries like Trans and Job need to point to job entries relative to this directory
IRepositoryImporter	getImporter()
List<org.pentaho.di.repository.RepositoryElementMetaInterface>	getJobAndTransformationObjects(org.pentaho.di.repository.ObjectId id_directory, boolean includeDeleted) Gets all job and transformation objects in the given directory.
boolean	getJobEntryAttributeBoolean(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code, boolean def)
long	getJobEntryAttributeInteger(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code)
String	getJobEntryAttributeString(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code)
org.pentaho.di.repository.ObjectId[]	getJobEntryCopyIDs(org.pentaho.di.repository.ObjectId id_job)
org.pentaho.di.repository.ObjectId[]	getJobEntryCopyIDs(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry)
org.pentaho.di.repository.ObjectId[]	getJobEntryIDs(org.pentaho.di.repository.ObjectId id_job)
org.pentaho.di.repository.ObjectId[]	getJobHopIDs(org.pentaho.di.repository.ObjectId id_job)
org.pentaho.di.repository.ObjectId	getJobId(String name, org.pentaho.di.repository.RepositoryDirectoryInterface repositoryDirectory)
String[]	getJobNames()
String[]	getJobNames(org.pentaho.di.repository.ObjectId id_directory, boolean includeDeleted)
org.pentaho.di.repository.ObjectId[]	getJobNoteIDs(org.pentaho.di.repository.ObjectId id_job)
List<org.pentaho.di.repository.RepositoryElementMetaInterface>	getJobObjects(org.pentaho.di.repository.ObjectId id_directory, boolean includeDeleted)
String[]	getJobsUsingDatabase(org.pentaho.di.repository.ObjectId id_database) Get the repository version.
int	getMajorVersion() Return the major repository version.
KettleDatabaseRepositoryMetaStore	getMetaStore()
int	getMinorVersion() Return the minor repository version.
int	getNrSubDirectories(org.pentaho.di.repository.ObjectId id_directory)
RepositoryObject	getObjectInformation(org.pentaho.di.repository.ObjectId objectId, org.pentaho.di.repository.RepositoryObjectType objectType) Get more information about a certain object ID in the form of the RepositoryObject
org.pentaho.di.repository.ObjectId[]	getPartitionIDs(org.pentaho.di.repository.ObjectId id_partition_schema)
org.pentaho.di.repository.ObjectId	getPartitionSchemaID(String name)
org.pentaho.di.repository.ObjectId[]	getPartitionSchemaIDs(boolean includeDeleted)
String[]	getPartitionSchemaNames(boolean includeDeleted)
org.pentaho.di.repository.ObjectId	getRootDirectoryID()
KettleDatabaseRepositorySecurityProvider	getSecurityManager()
KettleDatabaseRepositorySecurityProvider	getSecurityProvider()
IRepositoryService	getService(Class<? extends IRepositoryService> clazz) Retrieves a given repository service
List<Class<? extends IRepositoryService>>	getServiceInterfaces() Retrieves the current list of of IRepository Services.
org.pentaho.di.repository.ObjectId	getSlaveID(String name)
org.pentaho.di.repository.ObjectId[]	getSlaveIDs(boolean includeDeleted)
String[]	getSlaveNames(boolean includeDeleted)
List<SlaveServer>	getSlaveServers()
boolean	getStepAttributeBoolean(org.pentaho.di.repository.ObjectId id_step, int nr, String code, boolean def)
long	getStepAttributeInteger(org.pentaho.di.repository.ObjectId id_step, int nr, String code)
String	getStepAttributeString(org.pentaho.di.repository.ObjectId id_step, int nr, String code)
org.pentaho.di.repository.ObjectId[]	getStepIDs(org.pentaho.di.repository.ObjectId id_transformation)
org.pentaho.di.repository.ObjectId[]	getSubConditionIDs(org.pentaho.di.repository.ObjectId id_condition)
org.pentaho.di.repository.ObjectId[]	getSubDirectoryIDs(org.pentaho.di.repository.ObjectId id_directory)
org.pentaho.di.repository.ObjectId[]	getTransDependencyIDs(org.pentaho.di.repository.ObjectId id_transformation)
org.pentaho.di.repository.ObjectId[]	getTransformationClusterSchemaIDs(org.pentaho.di.repository.ObjectId id_transformation)
org.pentaho.di.repository.ObjectId[]	getTransformationConditionIDs(org.pentaho.di.repository.ObjectId id_transformation)
org.pentaho.di.repository.ObjectId[]	getTransformationDatabaseIDs(org.pentaho.di.repository.ObjectId id_transformation)
org.pentaho.di.repository.ObjectId	getTransformationID(String name, org.pentaho.di.repository.RepositoryDirectoryInterface repositoryDirectory)
String[]	getTransformationNames(org.pentaho.di.repository.ObjectId id_directory, boolean includeDeleted)
List<org.pentaho.di.repository.RepositoryElementMetaInterface>	getTransformationObjects(org.pentaho.di.repository.ObjectId id_directory, boolean includeDeleted)
org.pentaho.di.repository.ObjectId[]	getTransformationPartitionSchemaIDs(org.pentaho.di.repository.ObjectId id_transformation)
String[]	getTransformationsUsingCluster(org.pentaho.di.repository.ObjectId id_cluster)
String[]	getTransformationsUsingDatabase(org.pentaho.di.repository.ObjectId id_database)
String[]	getTransformationsUsingPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema)
String[]	getTransformationsUsingSlave(org.pentaho.di.repository.ObjectId id_slave)
org.pentaho.di.repository.ObjectId[]	getTransNoteIDs(org.pentaho.di.repository.ObjectId id_transformation)
org.pentaho.di.repository.RepositoryDirectory	getUserHomeDirectory()
IUser	getUserInfo()
String	getVersion() Get the repository version.
boolean	hasService(Class<? extends IRepositoryService> clazz) Checks whether a given repository service is available or not
void	init(RepositoryMeta repositoryMeta) Initialize the repository with the repository metadata and user information.
org.pentaho.di.repository.ObjectId	insertClusterSlave(ClusterSchema clusterSchema, SlaveServer slaveServer)
org.pentaho.di.repository.ObjectId	insertJobEntry(org.pentaho.di.repository.ObjectId id_job, JobEntryBase jobEntryBase)
void	insertJobEntryDatabase(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, org.pentaho.di.repository.ObjectId id_database)
void	insertJobNote(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_note)
org.pentaho.di.repository.ObjectId	insertLogEntry(String description) Insert an entry in the audit trail of the repository.
void	insertStepDatabase(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, org.pentaho.di.repository.ObjectId id_database)
org.pentaho.di.repository.ObjectId	insertTransformationCluster(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_cluster)
org.pentaho.di.repository.ObjectId	insertTransformationPartitionSchema(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_partition_schema)
org.pentaho.di.repository.ObjectId	insertTransformationSlave(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_slave)
void	insertTransNote(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_note)
void	insertTransStepCondition(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, org.pentaho.di.repository.ObjectId id_condition)
boolean	isUseBatchProcessing()
ClusterSchema	loadClusterSchema(org.pentaho.di.repository.ObjectId idClusterSchema, List<SlaveServer> slaveServers, String versionLabel)
org.pentaho.di.core.Condition	loadCondition(org.pentaho.di.repository.ObjectId id_condition) Read a condition from the repository.
org.pentaho.di.core.Condition	loadConditionFromStepAttribute(org.pentaho.di.repository.ObjectId id_step, String code) Load a condition from the repository with the Object ID stored in a step attribute.
org.pentaho.di.core.database.DatabaseMeta	loadDatabaseMeta(org.pentaho.di.repository.ObjectId id_database, String versionName) Load the Database connection Metadata from the repository
org.pentaho.di.core.database.DatabaseMeta	loadDatabaseMetaFromJobEntryAttribute(org.pentaho.di.repository.ObjectId id_jobentry, String nameCode, int nr, String idCode, List<org.pentaho.di.core.database.DatabaseMeta> databases) This method is introduced to avoid having to go over an integer/string/whatever in the interface and the job entry code.
org.pentaho.di.core.database.DatabaseMeta	loadDatabaseMetaFromStepAttribute(org.pentaho.di.repository.ObjectId idStep, String code, List<org.pentaho.di.core.database.DatabaseMeta> databases) This method is introduced to avoid having to go over an integer/string/whatever in the interface and the step code.
JobMeta	loadJob(org.pentaho.di.repository.ObjectId idJob, String versionLabel) Load a job from the repository by id
JobMeta	loadJob(String jobname, org.pentaho.di.repository.RepositoryDirectoryInterface repdir, org.pentaho.di.core.ProgressMonitorListener monitor, String versionName) Load a job in a directory
void	loadJobEntry(JobEntryBase jobEntryBase, org.pentaho.di.repository.ObjectId id_jobentry, List<org.pentaho.di.core.database.DatabaseMeta> databases, List<SlaveServer> slaveServers)
NotePadMeta	loadNotePadMeta(org.pentaho.di.repository.ObjectId id_note)
PartitionSchema	loadPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema, String versionName)
org.pentaho.di.repository.RepositoryDirectoryInterface	loadRepositoryDirectoryTree()
org.pentaho.di.repository.RepositoryDirectoryInterface	loadRepositoryDirectoryTree(org.pentaho.di.repository.RepositoryDirectoryInterface root)
SlaveServer	loadSlaveServer(org.pentaho.di.repository.ObjectId id_slave_server, String versionName)
TransMeta	loadTransformation(org.pentaho.di.repository.ObjectId idTransformation, String versionLabel) Load a transformation by id
TransMeta	loadTransformation(String transname, org.pentaho.di.repository.RepositoryDirectoryInterface repdir, org.pentaho.di.core.ProgressMonitorListener monitor, boolean setInternalVariables, String versionName) Load a transformation with a name from a folder in the repository
org.pentaho.di.core.row.ValueMetaAndData	loadValueMetaAndData(org.pentaho.di.repository.ObjectId id_value)
void	lockRepository()
List<org.pentaho.di.core.database.DatabaseMeta>	readDatabases() Read all the databases defined in the repository
SharedObjects	readJobMetaSharedObjects(JobMeta jobMeta)
SharedObjects	readTransSharedObjects(TransMeta transMeta)
org.pentaho.di.repository.ObjectId	renameJob(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.RepositoryDirectoryInterface dir, String newname) Move / rename a job
org.pentaho.di.repository.ObjectId	renameJob(org.pentaho.di.repository.ObjectId id_job, String versionComment, org.pentaho.di.repository.RepositoryDirectoryInterface dir, String newname) Move / rename a job
org.pentaho.di.repository.ObjectId	renameRepositoryDirectory(org.pentaho.di.repository.ObjectId id, org.pentaho.di.repository.RepositoryDirectoryInterface newParentDir, String newName) Move / rename a repository directory
org.pentaho.di.repository.ObjectId	renameTransformation(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.RepositoryDirectoryInterface newDir, String newName) Move / rename a transformation
org.pentaho.di.repository.ObjectId	renameTransformation(org.pentaho.di.repository.ObjectId id_transformation, String versionComment, org.pentaho.di.repository.RepositoryDirectoryInterface newDir, String newName) Move / rename a transformation
void	rollback()
void	save(org.pentaho.di.repository.RepositoryElementInterface repositoryElement, String versionComment)
void	save(org.pentaho.di.repository.RepositoryElementInterface repositoryElement, String versionComment, Calendar versionDate, org.pentaho.di.core.ProgressMonitorListener monitor, boolean overwrite) Save the object to the repository with version comments as well as version dates.
void	save(org.pentaho.di.repository.RepositoryElementInterface repositoryElement, String versionComment, org.pentaho.di.core.ProgressMonitorListener monitor, boolean overwrite) Save an object to the repository optionally overwriting any associated objects.
void	save(org.pentaho.di.repository.RepositoryElementInterface repositoryElement, String versionComment, org.pentaho.di.core.ProgressMonitorListener monitor, org.pentaho.di.repository.ObjectId parentId, boolean used, boolean overwrite)
org.pentaho.di.repository.ObjectId	saveCondition(org.pentaho.di.core.Condition condition)
org.pentaho.di.repository.ObjectId	saveCondition(org.pentaho.di.core.Condition condition, org.pentaho.di.repository.ObjectId id_condition_parent)
void	saveConditionStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, org.pentaho.di.core.Condition condition) This method saves the object ID of the condition object (if not null) in the step attributes
void	saveDatabaseMetaJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, int nr, String nameCode, String idCode, org.pentaho.di.core.database.DatabaseMeta database) This method saves the object ID of the database object (if not null) in the step attributes
void	saveDatabaseMetaStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, org.pentaho.di.core.database.DatabaseMeta database) This method saves the object ID of the database object (if not null) in the step attributes
void	saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code, boolean value)
void	saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code, long value)
void	saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code, String value)
void	saveNotePadMeta(NotePadMeta note, org.pentaho.di.repository.ObjectId id_transformation)
void	saveRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface dir)
void	saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, int nr, String code, boolean value)
void	saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, int nr, String code, double value)
void	saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, int nr, String code, long value)
void	saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, int nr, String code, String value)
void	setDatabase(org.pentaho.di.core.database.Database database)
void	setImportBaseDirectory(org.pentaho.di.repository.RepositoryDirectory importBaseDirectory) Set this directory during import to signal that job entries like Trans and Job need to point to job entries relative to this directory.
String	toString()
void	undeleteObject(org.pentaho.di.repository.RepositoryElementMetaInterface element) Removes he deleted flag from a repository element in the repository.
void	unlockRepository()
void	updateDatabaseTypes() Update the list in R_DATABASE_TYPE using the plugin registry
void	updateJobEntryTypes() Update the list in R_JOBENTRY_TYPE
void	updateStepTypes() Update the list in R_STEP_TYPE using the StepLoader StepPlugin entries

Methods inherited from class org.pentaho.di.repository.kdr.KettleDatabaseRepositoryBase

getLog, getName, getRepositoryMeta, isConnected, quote, quoteTable, setConnected, setRepositoryMeta

Methods inherited from class org.pentaho.di.repository.AbstractRepository

getJobEntryAttributeBoolean, getJobEntryAttributeBoolean, getJobEntryAttributeBoolean, getJobEntryAttributeInteger, getJobEntryAttributeString, getStepAttributeBoolean, getStepAttributeBoolean, getStepAttributeInteger, getStepAttributeString, loadDatabaseMetaFromJobEntryAttribute, save, saveDatabaseMetaJobEntryAttribute, saveJobEntryAttribute, saveJobEntryAttribute, saveJobEntryAttribute, saveStepAttribute, saveStepAttribute, saveStepAttribute, saveStepAttribute

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

transDelegate

public KettleDatabaseRepositoryTransDelegate transDelegate

jobDelegate

public KettleDatabaseRepositoryJobDelegate jobDelegate

databaseDelegate

public KettleDatabaseRepositoryDatabaseDelegate databaseDelegate

slaveServerDelegate

public KettleDatabaseRepositorySlaveServerDelegate slaveServerDelegate

clusterSchemaDelegate

public KettleDatabaseRepositoryClusterSchemaDelegate clusterSchemaDelegate

partitionSchemaDelegate

public KettleDatabaseRepositoryPartitionSchemaDelegate partitionSchemaDelegate

directoryDelegate

public KettleDatabaseRepositoryDirectoryDelegate directoryDelegate

connectionDelegate

public KettleDatabaseRepositoryConnectionDelegate connectionDelegate

userDelegate

public KettleDatabaseRepositoryUserDelegate userDelegate

conditionDelegate

public KettleDatabaseRepositoryConditionDelegate conditionDelegate

valueDelegate

public KettleDatabaseRepositoryValueDelegate valueDelegate

notePadDelegate

public KettleDatabaseRepositoryNotePadDelegate notePadDelegate

stepDelegate

public KettleDatabaseRepositoryStepDelegate stepDelegate

jobEntryDelegate

public KettleDatabaseRepositoryJobEntryDelegate jobEntryDelegate

metaStoreDelegate

public KettleDatabaseRepositoryMetaStoreDelegate metaStoreDelegate

metaStore

public KettleDatabaseRepositoryMetaStore metaStore

Constructor Detail

KettleDatabaseRepository

public KettleDatabaseRepository()

Method Detail

init

public void init(RepositoryMeta repositoryMeta)

Initialize the repository with the repository metadata and user information.

createRepositoryMeta

public RepositoryMeta createRepositoryMeta()

Returns:

A new repository meta object

connect

public void connect(String username,
           String password)
             throws org.pentaho.di.core.exception.KettleException

Connect to the repository.

Parameters:

username - the username of the user connecting to the repository.

password - the password of the user connecting to the repository.

Throws:

org.pentaho.di.core.exception.KettleException - in case there is a general unexpected error or if we're already connected

connect

public void connect(String username,
           String password,
           boolean upgrade)
             throws org.pentaho.di.core.exception.KettleException

Connect to the repository.

Throws:

org.pentaho.di.core.exception.KettleException - in case there is a general unexpected error or if we're already connected

commit

public void commit()
            throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

rollback

public void rollback()

getUserInfo

public IUser getUserInfo()

Returns:

the currently logged on user. (also available through the repository security provider)

getMajorVersion

public int getMajorVersion()

Return the major repository version.

Returns:

the major repository version.

getMinorVersion

public int getMinorVersion()

Return the minor repository version.

Returns:

the minor repository version.

getVersion

public String getVersion()

Get the repository version.

Returns:

The repository version as major version + "." + minor version

loadTransformation

public TransMeta loadTransformation(String transname,
                           org.pentaho.di.repository.RepositoryDirectoryInterface repdir,
                           org.pentaho.di.core.ProgressMonitorListener monitor,
                           boolean setInternalVariables,
                           String versionName)
                             throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Load a transformation with a name from a folder in the repository

Parameters:

transname - the name of the transformation to load

monitor - the progress monitor to use (UI feedback)

setInternalVariables - set to true if you want to automatically set the internal variables of the loaded transformation. (true is the default with very few exceptions!)

versionName - the revision to load. Specify null to load the last version.

Throws:

org.pentaho.di.core.exception.KettleException

readTransSharedObjects

public SharedObjects readTransSharedObjects(TransMeta transMeta)
                                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

renameTransformation

public org.pentaho.di.repository.ObjectId renameTransformation(org.pentaho.di.repository.ObjectId id_transformation,
                                                      org.pentaho.di.repository.RepositoryDirectoryInterface newDir,
                                                      String newName)
                                                        throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Move / rename a transformation

Parameters:

id_transformation - The ObjectId of the transformation to move

newDir - The RepositoryDirectoryInterface that will be the new parent of the transformation (May be null if a move is not desired)

newName - The new name of the transformation (May be null if a rename is not desired)

Returns:

The ObjectId of the transformation that was moved

Throws:

org.pentaho.di.core.exception.KettleException

renameTransformation

public org.pentaho.di.repository.ObjectId renameTransformation(org.pentaho.di.repository.ObjectId id_transformation,
                                                      String versionComment,
                                                      org.pentaho.di.repository.RepositoryDirectoryInterface newDir,
                                                      String newName)
                                                        throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Move / rename a transformation

Parameters:

id_transformation - The ObjectId of the transformation to move

versionComment - Version comment for rename

newDir - The RepositoryDirectoryInterface that will be the new parent of the transformation (May be null if a move is not desired)

newName - The new name of the transformation (May be null if a rename is not desired)

Returns:

The ObjectId of the transformation that was moved

Throws:

org.pentaho.di.core.exception.KettleException

loadJob

public JobMeta loadJob(String jobname,
              org.pentaho.di.repository.RepositoryDirectoryInterface repdir,
              org.pentaho.di.core.ProgressMonitorListener monitor,
              String versionName)
                throws org.pentaho.di.core.exception.KettleException

Load a job in a directory

Parameters:

jobname - The name of the job

repdir - The directory in which the job resides.

the - monitor to use as feedback in a UI (or null if not used)

Throws:

org.pentaho.di.core.exception.KettleException

readJobMetaSharedObjects

public SharedObjects readJobMetaSharedObjects(JobMeta jobMeta)
                                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

renameJob

public org.pentaho.di.repository.ObjectId renameJob(org.pentaho.di.repository.ObjectId id_job,
                                           org.pentaho.di.repository.RepositoryDirectoryInterface dir,
                                           String newname)
                                             throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Move / rename a job

Parameters:

id_job - The ObjectId of the job to move

dir - The RepositoryDirectoryInterface that will be the new parent of the job (May be null if a move is not desired)

newname - The new name of the job (May be null if a rename is not desired)

Returns:

The ObjectId of the job that was moved

Throws:

org.pentaho.di.core.exception.KettleException

renameJob

public org.pentaho.di.repository.ObjectId renameJob(org.pentaho.di.repository.ObjectId id_job,
                                           String versionComment,
                                           org.pentaho.di.repository.RepositoryDirectoryInterface dir,
                                           String newname)
                                             throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Move / rename a job

Parameters:

id_job - The ObjectId of the job to move

versionComment - Version comment for rename

dir - The RepositoryDirectoryInterface that will be the new parent of the job (May be null if a move is not desired)

newname - The new name of the job (May be null if a rename is not desired)

Returns:

The ObjectId of the job that was moved

Throws:

org.pentaho.di.core.exception.KettleException

exists

public boolean exists(String name,
             org.pentaho.di.repository.RepositoryDirectoryInterface repositoryDirectory,
             org.pentaho.di.repository.RepositoryObjectType objectType)
               throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

See if a repository object exists in the repository

Parameters:

name - the name of the object

repositoryDirectory - the directory in which it should reside

objectType - the type of repository object

Returns:

true if the job exists

Throws:

org.pentaho.di.core.exception.KettleException - in case something goes wrong.

save

public void save(org.pentaho.di.repository.RepositoryElementInterface repositoryElement,
        String versionComment)
          throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

save

public void save(org.pentaho.di.repository.RepositoryElementInterface repositoryElement,
        String versionComment,
        org.pentaho.di.core.ProgressMonitorListener monitor,
        boolean overwrite)
          throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Save an object to the repository optionally overwriting any associated objects.

Parameters:

repositoryElement - Object to save

versionComment - Version comment for update

monitor - Progress Monitor to report feedback to

overwrite - Overwrite any existing objects involved in saving repositoryElement, e.g. repositoryElement, database connections, slave servers

Throws:

org.pentaho.di.core.exception.KettleException - Error saving the object to the repository

save

public void save(org.pentaho.di.repository.RepositoryElementInterface repositoryElement,
        String versionComment,
        org.pentaho.di.core.ProgressMonitorListener monitor,
        org.pentaho.di.repository.ObjectId parentId,
        boolean used,
        boolean overwrite)
          throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

save

public void save(org.pentaho.di.repository.RepositoryElementInterface repositoryElement,
        String versionComment,
        Calendar versionDate,
        org.pentaho.di.core.ProgressMonitorListener monitor,
        boolean overwrite)
          throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Save the object to the repository with version comments as well as version dates. This form exists largely to support the importing of revisions, preserving their revision date.

Throws:

org.pentaho.di.core.exception.KettleException

loadCondition

public org.pentaho.di.core.Condition loadCondition(org.pentaho.di.repository.ObjectId id_condition)
                                            throws org.pentaho.di.core.exception.KettleException

Read a condition from the repository.

Parameters:

id_condition - The condition id

Throws:

org.pentaho.di.core.exception.KettleException - if something goes wrong.

saveCondition

public org.pentaho.di.repository.ObjectId saveCondition(org.pentaho.di.core.Condition condition)
                                                 throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

saveCondition

public org.pentaho.di.repository.ObjectId saveCondition(org.pentaho.di.core.Condition condition,
                                               org.pentaho.di.repository.ObjectId id_condition_parent)
                                                 throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadDatabaseMeta

public org.pentaho.di.core.database.DatabaseMeta loadDatabaseMeta(org.pentaho.di.repository.ObjectId id_database,
                                                         String versionName)
                                                           throws org.pentaho.di.core.exception.KettleException

Load the Database connection Metadata from the repository

Parameters:

id_database - the id of the database connection to load

versionName - the revision to load. Specify null to load the last version.

Throws:

org.pentaho.di.core.exception.KettleException - in case something goes wrong with database, connection, etc.

deleteDatabaseMeta

public void deleteDatabaseMeta(String databaseName)
                        throws org.pentaho.di.core.exception.KettleException

Remove a database connection from the repository

Parameters:

databaseName - The name of the connection to remove

Throws:

org.pentaho.di.core.exception.KettleException - In case something went wrong: database error, insufficient permissions, depending objects, etc.

loadClusterSchema

public ClusterSchema loadClusterSchema(org.pentaho.di.repository.ObjectId idClusterSchema,
                              List<SlaveServer> slaveServers,
                              String versionLabel)
                                throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadSlaveServer

public SlaveServer loadSlaveServer(org.pentaho.di.repository.ObjectId id_slave_server,
                          String versionName)
                            throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadPartitionSchema

public PartitionSchema loadPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema,
                                  String versionName)
                                    throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadValueMetaAndData

public org.pentaho.di.core.row.ValueMetaAndData loadValueMetaAndData(org.pentaho.di.repository.ObjectId id_value)
                                                              throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadNotePadMeta

public NotePadMeta loadNotePadMeta(org.pentaho.di.repository.ObjectId id_note)
                            throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

saveNotePadMeta

public void saveNotePadMeta(NotePadMeta note,
                   org.pentaho.di.repository.ObjectId id_transformation)
                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadRepositoryDirectoryTree

public org.pentaho.di.repository.RepositoryDirectoryInterface loadRepositoryDirectoryTree()
                                                                                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadRepositoryDirectoryTree

public org.pentaho.di.repository.RepositoryDirectoryInterface loadRepositoryDirectoryTree(org.pentaho.di.repository.RepositoryDirectoryInterface root)
                                                                                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

findDirectory

public org.pentaho.di.repository.RepositoryDirectoryInterface findDirectory(String directory)
                                                                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

findDirectory

public org.pentaho.di.repository.RepositoryDirectoryInterface findDirectory(org.pentaho.di.repository.ObjectId directory)
                                                                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

saveRepositoryDirectory

public void saveRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface dir)
                             throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

deleteRepositoryDirectory

public void deleteRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface dir)
                               throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

renameRepositoryDirectory

public org.pentaho.di.repository.ObjectId renameRepositoryDirectory(org.pentaho.di.repository.ObjectId id,
                                                           org.pentaho.di.repository.RepositoryDirectoryInterface newParentDir,
                                                           String newName)
                                                             throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Move / rename a repository directory

Parameters:

id - The ObjectId of the repository directory to move

newParentDir - The RepositoryDirectoryInterface that will be the new parent of the repository directory (May be null if a move is not desired)

newName - The new name of the repository directory (May be null if a rename is not desired)

Returns:

The ObjectId of the repository directory that was moved

Throws:

org.pentaho.di.core.exception.KettleException

createRepositoryDirectory

public org.pentaho.di.repository.RepositoryDirectoryInterface createRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface parentDirectory,
                                                                               String directoryPath)
                                                                                 throws org.pentaho.di.core.exception.KettleException

Create a new directory, possibly by creating several sub-directies of / at the same time.

Parameters:

parentDirectory - the parent directory

directoryPath - The path to the new Repository Directory, to be created.

Returns:

The created sub-directory

Throws:

org.pentaho.di.core.exception.KettleException - In case something goes wrong

getRootDirectoryID

public org.pentaho.di.repository.ObjectId getRootDirectoryID()
                                                      throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getNrSubDirectories

public int getNrSubDirectories(org.pentaho.di.repository.ObjectId id_directory)
                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getSubDirectoryIDs

public org.pentaho.di.repository.ObjectId[] getSubDirectoryIDs(org.pentaho.di.repository.ObjectId id_directory)
                                                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertLogEntry

public org.pentaho.di.repository.ObjectId insertLogEntry(String description)
                                                  throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Insert an entry in the audit trail of the repository. This is an optional operation and depends on the capabilities of the underlying repository.

Throws:

org.pentaho.di.core.exception.KettleException

insertTransNote

public void insertTransNote(org.pentaho.di.repository.ObjectId id_transformation,
                   org.pentaho.di.repository.ObjectId id_note)
                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertJobNote

public void insertJobNote(org.pentaho.di.repository.ObjectId id_job,
                 org.pentaho.di.repository.ObjectId id_note)
                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertStepDatabase

public void insertStepDatabase(org.pentaho.di.repository.ObjectId id_transformation,
                      org.pentaho.di.repository.ObjectId id_step,
                      org.pentaho.di.repository.ObjectId id_database)
                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertJobEntryDatabase

public void insertJobEntryDatabase(org.pentaho.di.repository.ObjectId id_job,
                          org.pentaho.di.repository.ObjectId id_jobentry,
                          org.pentaho.di.repository.ObjectId id_database)
                            throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertTransformationPartitionSchema

public org.pentaho.di.repository.ObjectId insertTransformationPartitionSchema(org.pentaho.di.repository.ObjectId id_transformation,
                                                                     org.pentaho.di.repository.ObjectId id_partition_schema)
                                                                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertClusterSlave

public org.pentaho.di.repository.ObjectId insertClusterSlave(ClusterSchema clusterSchema,
                                                    SlaveServer slaveServer)
                                                      throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertTransformationCluster

public org.pentaho.di.repository.ObjectId insertTransformationCluster(org.pentaho.di.repository.ObjectId id_transformation,
                                                             org.pentaho.di.repository.ObjectId id_cluster)
                                                               throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertTransformationSlave

public org.pentaho.di.repository.ObjectId insertTransformationSlave(org.pentaho.di.repository.ObjectId id_transformation,
                                                           org.pentaho.di.repository.ObjectId id_slave)
                                                             throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertTransStepCondition

public void insertTransStepCondition(org.pentaho.di.repository.ObjectId id_transformation,
                            org.pentaho.di.repository.ObjectId id_step,
                            org.pentaho.di.repository.ObjectId id_condition)
                              throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationNames

public String[] getTransformationNames(org.pentaho.di.repository.ObjectId id_directory,
                              boolean includeDeleted)
                                throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getJobObjects

public List<org.pentaho.di.repository.RepositoryElementMetaInterface> getJobObjects(org.pentaho.di.repository.ObjectId id_directory,
                                                                           boolean includeDeleted)
                                                                             throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationObjects

public List<org.pentaho.di.repository.RepositoryElementMetaInterface> getTransformationObjects(org.pentaho.di.repository.ObjectId id_directory,
                                                                                      boolean includeDeleted)
                                                                                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getJobNames

public String[] getJobNames(org.pentaho.di.repository.ObjectId id_directory,
                   boolean includeDeleted)
                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getDirectoryNames

public String[] getDirectoryNames(org.pentaho.di.repository.ObjectId id_directory)
                           throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Returns the child directory names of a parent directory

Parameters:

id_directory - parent directory id

Returns:

array of child names

Throws:

org.pentaho.di.core.exception.KettleException

getJobNames

public String[] getJobNames()
                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getSubConditionIDs

public org.pentaho.di.repository.ObjectId[] getSubConditionIDs(org.pentaho.di.repository.ObjectId id_condition)
                                                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransNoteIDs

public org.pentaho.di.repository.ObjectId[] getTransNoteIDs(org.pentaho.di.repository.ObjectId id_transformation)
                                                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationConditionIDs

public org.pentaho.di.repository.ObjectId[] getTransformationConditionIDs(org.pentaho.di.repository.ObjectId id_transformation)
                                                                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationDatabaseIDs

public org.pentaho.di.repository.ObjectId[] getTransformationDatabaseIDs(org.pentaho.di.repository.ObjectId id_transformation)
                                                                  throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getJobNoteIDs

public org.pentaho.di.repository.ObjectId[] getJobNoteIDs(org.pentaho.di.repository.ObjectId id_job)
                                                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getDatabaseIDs

public org.pentaho.di.repository.ObjectId[] getDatabaseIDs(boolean includeDeleted)
                                                    throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getDatabaseAttributeIDs

public org.pentaho.di.repository.ObjectId[] getDatabaseAttributeIDs(org.pentaho.di.repository.ObjectId id_database)
                                                             throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getPartitionSchemaIDs

public org.pentaho.di.repository.ObjectId[] getPartitionSchemaIDs(boolean includeDeleted)
                                                           throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getPartitionIDs

public org.pentaho.di.repository.ObjectId[] getPartitionIDs(org.pentaho.di.repository.ObjectId id_partition_schema)
                                                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationPartitionSchemaIDs

public org.pentaho.di.repository.ObjectId[] getTransformationPartitionSchemaIDs(org.pentaho.di.repository.ObjectId id_transformation)
                                                                         throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationClusterSchemaIDs

public org.pentaho.di.repository.ObjectId[] getTransformationClusterSchemaIDs(org.pentaho.di.repository.ObjectId id_transformation)
                                                                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getClusterIDs

public org.pentaho.di.repository.ObjectId[] getClusterIDs(boolean includeDeleted)
                                                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getSlaveIDs

public org.pentaho.di.repository.ObjectId[] getSlaveIDs(boolean includeDeleted)
                                                 throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getClusterSlaveIDs

public org.pentaho.di.repository.ObjectId[] getClusterSlaveIDs(org.pentaho.di.repository.ObjectId id_cluster_schema)
                                                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getDatabaseNames

public String[] getDatabaseNames(boolean includeDeleted)
                          throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getPartitionSchemaNames

public String[] getPartitionSchemaNames(boolean includeDeleted)
                                 throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getSlaveNames

public String[] getSlaveNames(boolean includeDeleted)
                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getClusterNames

public String[] getClusterNames(boolean includeDeleted)
                         throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getStepIDs

public org.pentaho.di.repository.ObjectId[] getStepIDs(org.pentaho.di.repository.ObjectId id_transformation)
                                                throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationsUsingDatabase

public String[] getTransformationsUsingDatabase(org.pentaho.di.repository.ObjectId id_database)
                                         throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getJobsUsingDatabase

public String[] getJobsUsingDatabase(org.pentaho.di.repository.ObjectId id_database)
                              throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Get the repository version.

Returns:

The repository version as a string

Throws:

org.pentaho.di.core.exception.KettleException

getClustersUsingSlave

public String[] getClustersUsingSlave(org.pentaho.di.repository.ObjectId id_slave)
                               throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationsUsingSlave

public String[] getTransformationsUsingSlave(org.pentaho.di.repository.ObjectId id_slave)
                                      throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationsUsingPartitionSchema

public String[] getTransformationsUsingPartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema)
                                                throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationsUsingCluster

public String[] getTransformationsUsingCluster(org.pentaho.di.repository.ObjectId id_cluster)
                                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getJobHopIDs

public org.pentaho.di.repository.ObjectId[] getJobHopIDs(org.pentaho.di.repository.ObjectId id_job)
                                                  throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransDependencyIDs

public org.pentaho.di.repository.ObjectId[] getTransDependencyIDs(org.pentaho.di.repository.ObjectId id_transformation)
                                                           throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getJobEntryIDs

public org.pentaho.di.repository.ObjectId[] getJobEntryIDs(org.pentaho.di.repository.ObjectId id_job)
                                                    throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getJobEntryCopyIDs

public org.pentaho.di.repository.ObjectId[] getJobEntryCopyIDs(org.pentaho.di.repository.ObjectId id_job)
                                                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getJobEntryCopyIDs

public org.pentaho.di.repository.ObjectId[] getJobEntryCopyIDs(org.pentaho.di.repository.ObjectId id_job,
                                                      org.pentaho.di.repository.ObjectId id_jobentry)
                                                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

byteArrayToString

public static final String byteArrayToString(byte[] val)
                                      throws IOException

GZips and then base64 encodes an array of bytes to a String

Parameters:

val - the array of bytes to convert to a string

Returns:

the base64 encoded string

Throws:

IOException - in the case there is a Base64 or GZip encoding problem

delSteps

public void delSteps(org.pentaho.di.repository.ObjectId id_transformation)
              throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

deleteCondition

public void deleteCondition(org.pentaho.di.repository.ObjectId id_condition)
                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delStepConditions

public void delStepConditions(org.pentaho.di.repository.ObjectId id_transformation)
                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delStepDatabases

public void delStepDatabases(org.pentaho.di.repository.ObjectId id_transformation)
                      throws org.pentaho.di.core.exception.KettleException

Delete the relationships between the transformation/steps and the databases.

Parameters:

id_transformation - the transformation for which we want to delete the databases.

Throws:

org.pentaho.di.core.exception.KettleException - in case something unexpected happens.

delJobEntryDatabases

public void delJobEntryDatabases(org.pentaho.di.repository.ObjectId id_job)
                          throws org.pentaho.di.core.exception.KettleException

Delete the relationships between the job/job entries and the databases.

Parameters:

id_job - the job for which we want to delete the databases.

Throws:

org.pentaho.di.core.exception.KettleDatabaseException - in case something unexpected happens.

org.pentaho.di.core.exception.KettleException

delJobEntries

public void delJobEntries(org.pentaho.di.repository.ObjectId id_job)
                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delJobEntryCopies

public void delJobEntryCopies(org.pentaho.di.repository.ObjectId id_job)
                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delDependencies

public void delDependencies(org.pentaho.di.repository.ObjectId id_transformation)
                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delStepAttributes

public void delStepAttributes(org.pentaho.di.repository.ObjectId id_transformation)
                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delTransAttributes

public void delTransAttributes(org.pentaho.di.repository.ObjectId id_transformation)
                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delJobAttributes

public void delJobAttributes(org.pentaho.di.repository.ObjectId id_job)
                      throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delPartitionSchemas

public void delPartitionSchemas(org.pentaho.di.repository.ObjectId id_transformation)
                         throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delPartitions

public void delPartitions(org.pentaho.di.repository.ObjectId id_partition_schema)
                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delClusterSlaves

public void delClusterSlaves(org.pentaho.di.repository.ObjectId id_cluster)
                      throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delTransformationClusters

public void delTransformationClusters(org.pentaho.di.repository.ObjectId id_transformation)
                               throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delTransformationSlaves

public void delTransformationSlaves(org.pentaho.di.repository.ObjectId id_transformation)
                             throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delJobEntryAttributes

public void delJobEntryAttributes(org.pentaho.di.repository.ObjectId id_job)
                           throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delTransHops

public void delTransHops(org.pentaho.di.repository.ObjectId id_transformation)
                  throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delJobHops

public void delJobHops(org.pentaho.di.repository.ObjectId id_job)
                throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delTransNotes

public void delTransNotes(org.pentaho.di.repository.ObjectId id_transformation)
                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delJobNotes

public void delJobNotes(org.pentaho.di.repository.ObjectId id_job)
                 throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delTrans

public void delTrans(org.pentaho.di.repository.ObjectId id_transformation)
              throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delJob

public void delJob(org.pentaho.di.repository.ObjectId id_job)
            throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delTransStepCondition

public void delTransStepCondition(org.pentaho.di.repository.ObjectId id_transformation)
                           throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

delValue

public void delValue(org.pentaho.di.repository.ObjectId id_value)
              throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

deleteSlave

public void deleteSlave(org.pentaho.di.repository.ObjectId id_slave)
                 throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

deletePartitionSchema

public void deletePartitionSchema(org.pentaho.di.repository.ObjectId id_partition_schema)
                           throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

deleteClusterSchema

public void deleteClusterSchema(org.pentaho.di.repository.ObjectId id_cluster)
                         throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

deleteTransformation

public void deleteTransformation(org.pentaho.di.repository.ObjectId id_transformation)
                          throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Delete everything related to a transformation from the repository. This does not included shared objects : databases, slave servers, cluster and partition schema.

Parameters:

id_transformation - the transformation id to delete

Throws:

org.pentaho.di.core.exception.KettleException

deleteJob

public void deleteJob(org.pentaho.di.repository.ObjectId id_job)
               throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

dropRepositorySchema

public boolean dropRepositorySchema()
                             throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

updateStepTypes

public void updateStepTypes()
                     throws org.pentaho.di.core.exception.KettleException

Update the list in R_STEP_TYPE using the StepLoader StepPlugin entries

Throws:

org.pentaho.di.core.exception.KettleException - if the update didn't go as planned.

updateDatabaseTypes

public void updateDatabaseTypes()
                         throws org.pentaho.di.core.exception.KettleException

Update the list in R_DATABASE_TYPE using the plugin registry

Throws:

org.pentaho.di.core.exception.KettleException - if the update didn't go as planned.

updateJobEntryTypes

public void updateJobEntryTypes()
                         throws org.pentaho.di.core.exception.KettleException

Update the list in R_JOBENTRY_TYPE

Throws:

org.pentaho.di.core.exception.KettleException - if something went wrong during the update.

toString

public String toString()

Overrides:

toString in class Object

clearSharedObjectCache

public void clearSharedObjectCache()

Clear the shared object cache, if applicable.

getDatabase

public org.pentaho.di.core.database.Database getDatabase()

Returns:

Returns the database.

setDatabase

public void setDatabase(org.pentaho.di.core.database.Database database)

Parameters:

database - The database to set.

lockRepository

public void lockRepository()
                    throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

unlockRepository

public void unlockRepository()
                      throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getDatabases

public List<org.pentaho.di.core.database.DatabaseMeta> getDatabases()
                                                             throws org.pentaho.di.core.exception.KettleException

Returns:

a list of all the databases in the repository.

Throws:

org.pentaho.di.core.exception.KettleException

getSlaveServers

public List<SlaveServer> getSlaveServers()
                                  throws org.pentaho.di.core.exception.KettleException

Returns:

a list of all the slave servers in the repository.

Throws:

org.pentaho.di.core.exception.KettleException

getDatabaseMeta

public org.pentaho.di.core.database.DatabaseMeta getDatabaseMeta()

Returns:

the databaseMeta

readDatabases

public List<org.pentaho.di.core.database.DatabaseMeta> readDatabases()
                                                              throws org.pentaho.di.core.exception.KettleException

Read all the databases defined in the repository

Returns:

a list of all the databases defined in the repository

Throws:

org.pentaho.di.core.exception.KettleException

isUseBatchProcessing

public boolean isUseBatchProcessing()

Returns:

the useBatchProcessing

setImportBaseDirectory

public void setImportBaseDirectory(org.pentaho.di.repository.RepositoryDirectory importBaseDirectory)

Set this directory during import to signal that job entries like Trans and Job need to point to job entries relative to this directory.

Parameters:

importBaseDirectory - the base import directory, selected by the user

getImportBaseDirectory

public org.pentaho.di.repository.RepositoryDirectory getImportBaseDirectory()

The directory set during import to signal that job entries like Trans and Job need to point to job entries relative to this directory

Returns:

the base import directory, selected by the user

createRepositorySchema

public void createRepositorySchema(org.pentaho.di.core.ProgressMonitorListener monitor,
                          boolean upgrade,
                          List<String> statements,
                          boolean dryRun)
                            throws org.pentaho.di.core.exception.KettleException

Create or upgrade repository tables & fields, populate lookup tables, ...

Parameters:

monitor - The progress monitor to use, or null if no monitor is present.

upgrade - True if you want to upgrade the repository, false if you want to create it.

statements - the list of statements to populate

dryrun - true if we don't actually execute the statements

Throws:

org.pentaho.di.core.exception.KettleException - in case something goes wrong!

countNrStepAttributes

public int countNrStepAttributes(org.pentaho.di.repository.ObjectId id_step,
                        String code)
                          throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

countNrJobEntryAttributes

public int countNrJobEntryAttributes(org.pentaho.di.repository.ObjectId id_jobentry,
                            String code)
                              throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

disconnect

public void disconnect()

Description copied from interface: Repository

Disconnect from the repository.

getJobEntryAttributeInteger

public long getJobEntryAttributeInteger(org.pentaho.di.repository.ObjectId id_jobentry,
                               int nr,
                               String code)
                                 throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getJobEntryAttributeString

public String getJobEntryAttributeString(org.pentaho.di.repository.ObjectId id_jobentry,
                                int nr,
                                String code)
                                  throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getJobEntryAttributeBoolean

public boolean getJobEntryAttributeBoolean(org.pentaho.di.repository.ObjectId id_jobentry,
                                  int nr,
                                  String code,
                                  boolean def)
                                    throws org.pentaho.di.core.exception.KettleException

Specified by:

getJobEntryAttributeBoolean in class AbstractRepository

Throws:

org.pentaho.di.core.exception.KettleException

saveJobEntryAttribute

public void saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job,
                         org.pentaho.di.repository.ObjectId id_jobentry,
                         int nr,
                         String code,
                         String value)
                           throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

saveJobEntryAttribute

public void saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job,
                         org.pentaho.di.repository.ObjectId id_jobentry,
                         int nr,
                         String code,
                         boolean value)
                           throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

saveJobEntryAttribute

public void saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job,
                         org.pentaho.di.repository.ObjectId id_jobentry,
                         int nr,
                         String code,
                         long value)
                           throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getStepAttributeBoolean

public boolean getStepAttributeBoolean(org.pentaho.di.repository.ObjectId id_step,
                              int nr,
                              String code,
                              boolean def)
                                throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getStepAttributeInteger

public long getStepAttributeInteger(org.pentaho.di.repository.ObjectId id_step,
                           int nr,
                           String code)
                             throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getStepAttributeString

public String getStepAttributeString(org.pentaho.di.repository.ObjectId id_step,
                            int nr,
                            String code)
                              throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

saveStepAttribute

public void saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation,
                     org.pentaho.di.repository.ObjectId id_step,
                     int nr,
                     String code,
                     String value)
                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

saveStepAttribute

public void saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation,
                     org.pentaho.di.repository.ObjectId id_step,
                     int nr,
                     String code,
                     boolean value)
                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

saveStepAttribute

public void saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation,
                     org.pentaho.di.repository.ObjectId id_step,
                     int nr,
                     String code,
                     long value)
                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

saveStepAttribute

public void saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation,
                     org.pentaho.di.repository.ObjectId id_step,
                     int nr,
                     String code,
                     double value)
                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

findStepAttributeID

public org.pentaho.di.repository.ObjectId findStepAttributeID(org.pentaho.di.repository.ObjectId id_step,
                                                     int nr,
                                                     String code)
                                                       throws org.pentaho.di.core.exception.KettleException

This method is only used to check backward compatibility with the 2.x series.

Parameters:

id_step -

nr -

code -

Returns:

Throws:

org.pentaho.di.core.exception.KettleException

execStatement

public void execStatement(String sql)
                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadJobEntry

public void loadJobEntry(JobEntryBase jobEntryBase,
                org.pentaho.di.repository.ObjectId id_jobentry,
                List<org.pentaho.di.core.database.DatabaseMeta> databases,
                List<SlaveServer> slaveServers)
                  throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getClusterID

public org.pentaho.di.repository.ObjectId getClusterID(String name)
                                                throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getDatabaseID

public org.pentaho.di.repository.ObjectId getDatabaseID(String name)
                                                 throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getJobId

public org.pentaho.di.repository.ObjectId getJobId(String name,
                                          org.pentaho.di.repository.RepositoryDirectoryInterface repositoryDirectory)
                                            throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getPartitionSchemaID

public org.pentaho.di.repository.ObjectId getPartitionSchemaID(String name)
                                                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getSlaveID

public org.pentaho.di.repository.ObjectId getSlaveID(String name)
                                              throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getTransformationID

public org.pentaho.di.repository.ObjectId getTransformationID(String name,
                                                     org.pentaho.di.repository.RepositoryDirectoryInterface repositoryDirectory)
                                                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertJobEntry

public org.pentaho.di.repository.ObjectId insertJobEntry(org.pentaho.di.repository.ObjectId id_job,
                                                JobEntryBase jobEntryBase)
                                                  throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadDatabaseMetaFromStepAttribute

public org.pentaho.di.core.database.DatabaseMeta loadDatabaseMetaFromStepAttribute(org.pentaho.di.repository.ObjectId idStep,
                                                                          String code,
                                                                          List<org.pentaho.di.core.database.DatabaseMeta> databases)
                                                                            throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

This method is introduced to avoid having to go over an integer/string/whatever in the interface and the step code.

Returns:

Throws:

org.pentaho.di.core.exception.KettleException

saveDatabaseMetaStepAttribute

public void saveDatabaseMetaStepAttribute(org.pentaho.di.repository.ObjectId id_transformation,
                                 org.pentaho.di.repository.ObjectId id_step,
                                 String code,
                                 org.pentaho.di.core.database.DatabaseMeta database)
                                   throws org.pentaho.di.core.exception.KettleException

This method saves the object ID of the database object (if not null) in the step attributes

Parameters:

id_transformation -

id_step -

string -

database -

Throws:

org.pentaho.di.core.exception.KettleException

loadDatabaseMetaFromJobEntryAttribute

public org.pentaho.di.core.database.DatabaseMeta loadDatabaseMetaFromJobEntryAttribute(org.pentaho.di.repository.ObjectId id_jobentry,
                                                                              String nameCode,
                                                                              int nr,
                                                                              String idCode,
                                                                              List<org.pentaho.di.core.database.DatabaseMeta> databases)
                                                                                throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

This method is introduced to avoid having to go over an integer/string/whatever in the interface and the job entry code.

Returns:

Throws:

org.pentaho.di.core.exception.KettleException

saveDatabaseMetaJobEntryAttribute

public void saveDatabaseMetaJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job,
                                     org.pentaho.di.repository.ObjectId id_jobentry,
                                     int nr,
                                     String nameCode,
                                     String idCode,
                                     org.pentaho.di.core.database.DatabaseMeta database)
                                       throws org.pentaho.di.core.exception.KettleException

This method saves the object ID of the database object (if not null) in the step attributes

Parameters:

id_job -

nr -

id_jobentry -

nameCode -

nameCode -

idCode -

database -

Throws:

org.pentaho.di.core.exception.KettleException

loadConditionFromStepAttribute

public org.pentaho.di.core.Condition loadConditionFromStepAttribute(org.pentaho.di.repository.ObjectId id_step,
                                                           String code)
                                                             throws org.pentaho.di.core.exception.KettleException

Load a condition from the repository with the Object ID stored in a step attribute.

Parameters:

id_step -

code -

Returns:

Throws:

org.pentaho.di.core.exception.KettleException

saveConditionStepAttribute

public void saveConditionStepAttribute(org.pentaho.di.repository.ObjectId id_transformation,
                              org.pentaho.di.repository.ObjectId id_step,
                              String code,
                              org.pentaho.di.core.Condition condition)
                                throws org.pentaho.di.core.exception.KettleException

This method saves the object ID of the condition object (if not null) in the step attributes

Parameters:

id_step -

code -

condition -

Throws:

org.pentaho.di.core.exception.KettleException

getSecurityProvider

public KettleDatabaseRepositorySecurityProvider getSecurityProvider()

Returns:

the securityProvider

getSecurityManager

public KettleDatabaseRepositorySecurityProvider getSecurityManager()

Returns:

The security manager for this repository.

undeleteObject

public void undeleteObject(org.pentaho.di.repository.RepositoryElementMetaInterface element)
                    throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Removes he deleted flag from a repository element in the repository. If it wasn't deleted, it remains untouched.

Throws:

org.pentaho.di.core.exception.KettleException - get throws in case something goes horribly wrong.

getJobAndTransformationObjects

public List<org.pentaho.di.repository.RepositoryElementMetaInterface> getJobAndTransformationObjects(org.pentaho.di.repository.ObjectId id_directory,
                                                                                            boolean includeDeleted)
                                                                                              throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Gets all job and transformation objects in the given directory. (Combines Repository.getJobObjects(ObjectId, boolean) and Repository.getTransformationObjects(ObjectId, boolean) into one operation.

Parameters:

id_directory - directory

includeDeleted - true to return deleted objects

Returns:

list of repository objects

Throws:

org.pentaho.di.core.exception.KettleException - In case something goes wrong

getService

public IRepositoryService getService(Class<? extends IRepositoryService> clazz)
                              throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Retrieves a given repository service

Returns:

repository service

Throws:

org.pentaho.di.core.exception.KettleException - in case something goes horribly wrong.

getServiceInterfaces

public List<Class<? extends IRepositoryService>> getServiceInterfaces()
                                                               throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Retrieves the current list of of IRepository Services.

Returns:

List of repository services

Throws:

org.pentaho.di.core.exception.KettleException - in case something goes horribly wrong.

hasService

public boolean hasService(Class<? extends IRepositoryService> clazz)
                   throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Checks whether a given repository service is available or not

Throws:

org.pentaho.di.core.exception.KettleException - in case something goes horribly wrong.

getDefaultSaveDirectory

public org.pentaho.di.repository.RepositoryDirectory getDefaultSaveDirectory(org.pentaho.di.repository.RepositoryElementInterface repositoryElement)
                                                                      throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getUserHomeDirectory

public org.pentaho.di.repository.RepositoryDirectory getUserHomeDirectory()
                                                                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getObjectInformation

public RepositoryObject getObjectInformation(org.pentaho.di.repository.ObjectId objectId,
                                    org.pentaho.di.repository.RepositoryObjectType objectType)
                                      throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Get more information about a certain object ID in the form of the RepositoryObject

Parameters:

objectId - The ID of the object to get more information about.

objectType - The type of object to investigate.

Returns:

The repository object or null if nothing could be found.

Throws:

org.pentaho.di.core.exception.KettleException - In case there was a loading problem.

loadJob

public JobMeta loadJob(org.pentaho.di.repository.ObjectId idJob,
              String versionLabel)
                throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Load a job from the repository by id

Parameters:

idJob - the id of the job

versionLabel - version to load. Specify null to load the last version.

Throws:

org.pentaho.di.core.exception.KettleException

loadTransformation

public TransMeta loadTransformation(org.pentaho.di.repository.ObjectId idTransformation,
                           String versionLabel)
                             throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Repository

Load a transformation by id

Parameters:

idTransformation - the id of the transformation to load

versionLabel - version to load. Specify null to load the last version.

Throws:

org.pentaho.di.core.exception.KettleException

getConnectMessage

public String getConnectMessage()

Description copied from interface: Repository

This is an informational message that a repository can display on connecting within Spoon. If a null is returned, no message is displayed to the end user.

Returns:

message

getExporter

public IRepositoryExporter getExporter()

Returns:

the exporter that will handle exports from this repository

getImporter

public IRepositoryImporter getImporter()

Returns:

the importer that will handle imports into this repository

getMetaStore

public KettleDatabaseRepositoryMetaStore getMetaStore()

Returns:

the Metastore that is implemented in this Repository. Return null if this repository doesn't implement a Metastore.