Package org.pentaho.di.repository.filerep

Class KettleFileRepository

java.lang.Object
org.pentaho.di.repository.AbstractRepository
org.pentaho.di.repository.filerep.KettleFileRepository
All Implemented Interfaces:
Repository
public class KettleFileRepository extends AbstractRepository

  • Field Details

    • FILE_REPOSITORY_VERSION

      public static final String FILE_REPOSITORY_VERSION
      See Also:

    • metaStore

      public org.pentaho.metastore.stores.xml.XmlMetaStore metaStore

  • Constructor Details

    • KettleFileRepository

      public KettleFileRepository()

  • Method Details

    • connect

      public void connect(String username, String password) throws org.pentaho.di.core.exception.KettleException
      Description copied from interface: Repository
      Connect to the repository. Make sure you don't connect more than once to the same repository with this repository object.
      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.KettleSecurityException - in case the supplied user or password is incorrect.
      org.pentaho.di.core.exception.KettleException - in case there is a general unexpected error OR if we're already connected to the repository.

    • test

      public boolean test()
      Overrides:
      test in class AbstractRepository

    • disconnect

      public void disconnect()
      Description copied from interface: Repository
      Disconnect from the repository.

    • init

      public void init(RepositoryMeta repositoryMeta)
      Description copied from interface: Repository
      Initialize the repository with the repository metadata and user information.

    • getLog

      public org.pentaho.di.core.logging.LogChannelInterface getLog()
      Returns:
      the logging channel of this repository

    • isConnected

      public boolean isConnected()

    • getSecurityProvider

      public RepositorySecurityProvider getSecurityProvider()
      Returns:
      The security provider for this repository.

    • getSecurityManager

      public RepositorySecurityManager getSecurityManager()
      Returns:
      The security manager for this repository.

    • calcRelativeElementDirectory

      public String calcRelativeElementDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface dir)

    • calcObjectId

      public String calcObjectId(org.pentaho.di.repository.RepositoryDirectoryInterface dir)

    • calcObjectId

      public String calcObjectId(org.pentaho.di.repository.RepositoryDirectoryInterface directory, String name, String extension)

    • calcObjectId

      public String calcObjectId(org.pentaho.di.repository.RepositoryElementInterface element)

    • calcFilename

      public String calcFilename(org.pentaho.di.repository.ObjectId id)

    • 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, 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

    • 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) throws org.pentaho.di.core.exception.KettleException
      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
      Description copied from interface: Repository
      Create a new directory, possibly by creating several sub-directies of / at the same time.
      Parameters:
      parentDirectory - the parent directory
      directoryPath - The partial 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

    • saveRepositoryDirectory

      public void saveRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface dir) throws org.pentaho.di.core.exception.KettleException
      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

    • 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

    • 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

    • 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

    • 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

    • deleteRepositoryDirectory

      public void deleteRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface dir) 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

    • deleteDatabaseMeta

      public void deleteDatabaseMeta(String databaseName) throws org.pentaho.di.core.exception.KettleException
      Description copied from interface: Repository
      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.

    • deleteRootObject

      public void deleteRootObject(String name, String extension) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • deleteFile

      public void deleteFile(String filename) 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

    • getClusterIDs

      public org.pentaho.di.repository.ObjectId[] getClusterIDs(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

    • 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

    • 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

    • 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

    • getDatabaseID

      public org.pentaho.di.repository.ObjectId getDatabaseID(String name) 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

    • getDatabaseIDs

      public org.pentaho.di.repository.ObjectId[] getDatabaseIDs(boolean includeDeleted) 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

    • 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

    • 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

    • 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

    • 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

    • 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

    • getName

      public String getName()
      Returns:
      The name of the repository

    • getPartitionSchemaID

      public org.pentaho.di.repository.ObjectId getPartitionSchemaID(String name) 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

    • getPartitionSchemaNames

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

    • getRootDirectoryID

      public org.pentaho.di.repository.ObjectId getRootDirectoryID() 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

    • 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

    • getSlaveNames

      public String[] getSlaveNames(boolean includeDeleted) throws org.pentaho.di.core.exception.KettleException
      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

    • 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

    • 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

    • 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

    • 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

    • 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

    • 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

    • 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

    • 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

    • 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

    • 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

    • 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

    • 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

    • 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

    • getVersion

      public String getVersion()
      Description copied from interface: Repository
      Get the repository version.
      Returns:
      The repository version as a string

    • 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

    • 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

    • 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

    • 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

    • 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

    • 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

    • 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

    • 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

    • 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

    • 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

    • loadClusterSchema

      public ClusterSchema loadClusterSchema(org.pentaho.di.repository.ObjectId id_cluster_schema, List<SlaveServer> slaveServers, String versionName) throws org.pentaho.di.core.exception.KettleException
      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
      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
      Description copied from interface: Repository
      Load a condition from the repository with the Object ID stored in a step attribute.
      Returns:
      Throws:
      org.pentaho.di.core.exception.KettleException

    • loadNodeFromXML

      public Node loadNodeFromXML(org.pentaho.di.repository.ObjectId id, String tag) 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
      Description copied from interface: Repository
      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.

    • 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
      Description copied from interface: Repository
      This method saves the object ID of the database object (if not null) in the job entry attributes
      Throws:
      org.pentaho.di.core.exception.KettleException

    • loadDatabaseMetaFromStepAttribute

      public org.pentaho.di.core.database.DatabaseMeta loadDatabaseMetaFromStepAttribute(org.pentaho.di.repository.ObjectId id_step, 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

    • 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
      Description copied from interface: Repository
      Load a job from the repository
      Parameters:
      jobname - the name
      repdir - the directory
      monitor - the progress monitor or null
      versionName - the revision to load. Specify null to load the last version.
      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

    • 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 dir) 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

    • getTransformationObjects

      public List<org.pentaho.di.repository.RepositoryElementMetaInterface> getTransformationObjects(org.pentaho.di.repository.ObjectId idDirectory, 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

    • 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

    • 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

    • 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

    • readDatabases

      public void readDatabases(HasDatabasesInterface transMeta, boolean overWriteShared) throws org.pentaho.di.core.exception.KettleException
      Read all the databases from the repository, insert into the has databases object, overwriting optionally
      Parameters:
      TransMeta - The transformation to load into.
      overWriteShared - if an object with the same name exists, overwrite
      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

    • moveJob

      public void moveJob(String jobname, org.pentaho.di.repository.ObjectId id_directory_from, org.pentaho.di.repository.ObjectId id_directory_to) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • moveTransformation

      public void moveTransformation(String transname, org.pentaho.di.repository.ObjectId id_directory_from, org.pentaho.di.repository.ObjectId id_directory_to) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • readDatabases

      public List<org.pentaho.di.core.database.DatabaseMeta> readDatabases() throws org.pentaho.di.core.exception.KettleException
      Description copied from interface: Repository
      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

    • clearSharedObjectCache

      public void clearSharedObjectCache()
      Clear the shared object cache, if applicable.

    • readJobMetaSharedObjects

      public SharedObjects readJobMetaSharedObjects(JobMeta jobMeta) throws org.pentaho.di.core.exception.KettleException
      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

    • renameJob

      public org.pentaho.di.repository.ObjectId renameJob(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.RepositoryDirectoryInterface newDir, 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
      newDir - 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 newDir, 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
      newDir - 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

    • 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

    • 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

    • 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

    • 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
      Description copied from interface: Repository
      This method saves the object ID of the condition object (if not null) in the step attributes
      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, String code, org.pentaho.di.core.database.DatabaseMeta database) throws org.pentaho.di.core.exception.KettleException
      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
      Description copied from interface: Repository
      This method saves the object ID of the database object (if not null) in the step attributes
      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

    • 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

    • delUser

      public void delUser(org.pentaho.di.repository.ObjectId id_user) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getUserID

      public org.pentaho.di.repository.ObjectId getUserID(String login) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getUserIDs

      public org.pentaho.di.repository.ObjectId[] getUserIDs() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getUserInfo

      public IUser getUserInfo()
      Returns:
      the currently logged on user. (also available through the repository security provider)

    • getUserLogins

      public String[] getUserLogins() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • loadUserInfo

      public UserInfo loadUserInfo(String login) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • loadUserInfo

      public UserInfo loadUserInfo(String login, String password) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • renameUser

      public void renameUser(org.pentaho.di.repository.ObjectId id_user, String newname) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveUserInfo

      public void saveUserInfo(UserInfo userInfo) 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

    • 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

    • getRepositoryMeta

      public KettleFileRepositoryMeta getRepositoryMeta()
      Returns:
      the repositoryMeta

    • setRepositoryMeta

      public void setRepositoryMeta(KettleFileRepositoryMeta repositoryMeta)
      Parameters:
      repositoryMeta - the repositoryMeta to set

    • undeleteObject

      public void undeleteObject(org.pentaho.di.repository.RepositoryElementMetaInterface repositoryObject) 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.RepositoryDirectoryInterface 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.RepositoryDirectoryInterface 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

    • getRepositoryMetaStore

      public org.pentaho.metastore.stores.xml.XmlMetaStore getRepositoryMetaStore()
      Returns:
      the Metastore that is implemented in this Repository. Return null if this repository doesn't implement a Metastore. This should only be used when you want a specific repository instance (see RepositoryMetastoreProvider), for all generic metastore usage use MetaStoreConst.getDefaultMetastore()

    • setMetaStore

      public void setMetaStore(org.pentaho.metastore.stores.xml.XmlMetaStore metaStore)