org.pentaho.di.repository.filerep
Class KettleFileRepository

java.lang.Object
  extended by org.pentaho.di.repository.filerep.KettleFileRepository
All Implemented Interfaces:
Repository

public class KettleFileRepository
extends Object
implements Repository


Field Summary
static String FILE_REPOSITORY_VERSION
           
 
Constructor Summary
KettleFileRepository()
           
 
Method Summary
 String calcFilename(ObjectId id)
           
 String calcObjectId(RepositoryDirectoryInterface dir)
           
 String calcObjectId(RepositoryDirectoryInterface directory, String name, String extension)
           
 String calcObjectId(RepositoryElementInterface element)
           
 String calcRelativeElementDirectory(RepositoryDirectoryInterface dir)
           
 void clearSharedObjectCache()
          Clear the shared object cache, if applicable.
 void connect(String username, String password)
          Connect to the repository.
 int countNrJobEntryAttributes(ObjectId id_jobentry, String code)
           
 int countNrStepAttributes(ObjectId id_step, String code)
           
 RepositoryDirectoryInterface createRepositoryDirectory(RepositoryDirectoryInterface parentDirectory, String directoryPath)
          Create a new directory, possibly by creating several sub-directies of / at the same time.
 void deleteClusterSchema(ObjectId id_cluster)
           
 void deleteCondition(ObjectId id_condition)
           
 void deleteDatabaseMeta(String databaseName)
          Remove a database connection from the repository
 void deleteFile(String filename)
           
 void deleteJob(ObjectId id_job)
           
 void deletePartitionSchema(ObjectId id_partition_schema)
           
 void deleteRepositoryDirectory(RepositoryDirectoryInterface dir)
           
 void deleteRootObject(String name, String extension)
           
 void deleteSlave(ObjectId id_slave)
           
 void deleteTransformation(ObjectId id_transformation)
          Delete everything related to a transformation from the repository.
 void delUser(ObjectId id_user)
           
 void disconnect()
          Disconnect from the repository.
 boolean exists(String name, RepositoryDirectoryInterface repositoryDirectory, RepositoryObjectType objectType)
          See if a repository object exists in the repository
 RepositoryDirectoryInterface findDirectory(ObjectId directory)
           
 RepositoryDirectoryInterface findDirectory(String directory)
           
 ObjectId getClusterID(String name)
           
 ObjectId[] getClusterIDs(boolean includeDeleted)
           
 String[] getClusterNames(boolean includeDeleted)
           
 ObjectId[] getClusterSlaveIDs(ObjectId id_cluster_schema)
           
 String[] getClustersUsingSlave(ObjectId id_slave)
           
 String getConnectMessage()
          This is an informational message that a repository can display on connecting within Spoon.
 ObjectId[] getDatabaseAttributeIDs(ObjectId id_database)
           
 ObjectId getDatabaseID(String name)
           
 ObjectId[] getDatabaseIDs(boolean includeDeleted)
           
 String[] getDatabaseNames(boolean includeDeleted)
           
 RepositoryDirectoryInterface getDefaultSaveDirectory(RepositoryElementInterface repositoryElement)
           
 String[] getDirectoryNames(ObjectId id_directory)
          Returns the child directory names of a parent directory
 IRepositoryExporter getExporter()
           
 IRepositoryImporter getImporter()
           
 List<RepositoryElementMetaInterface> getJobAndTransformationObjects(ObjectId id_directory, boolean includeDeleted)
          Gets all job and transformation objects in the given directory.
 boolean getJobEntryAttributeBoolean(ObjectId id_jobentry, int nr, String code)
           
 boolean getJobEntryAttributeBoolean(ObjectId id_jobentry, String code)
           
 boolean getJobEntryAttributeBoolean(ObjectId id_jobentry, String code, boolean def)
           
 long getJobEntryAttributeInteger(ObjectId id_jobentry, int nr, String code)
           
 long getJobEntryAttributeInteger(ObjectId id_jobentry, String code)
           
 String getJobEntryAttributeString(ObjectId id_jobentry, int nr, String code)
           
 String getJobEntryAttributeString(ObjectId id_jobentry, String code)
           
 ObjectId getJobId(String name, RepositoryDirectoryInterface repositoryDirectory)
           
 String[] getJobNames(ObjectId id_directory, boolean includeDeleted)
           
 ObjectId[] getJobNoteIDs(ObjectId id_job)
           
 List<RepositoryElementMetaInterface> getJobObjects(ObjectId id_directory, boolean includeDeleted)
           
 String[] getJobsUsingDatabase(ObjectId id_database)
          Get the repository version.
 LogChannelInterface getLog()
           
 String getName()
           
 int getNrSubDirectories(ObjectId id_directory)
           
 RepositoryObject getObjectInformation(ObjectId objectId, RepositoryObjectType objectType)
          Get more information about a certain object ID in the form of the RepositoryObject
 ObjectId getPartitionSchemaID(String name)
           
 ObjectId[] getPartitionSchemaIDs(boolean includeDeleted)
           
 String[] getPartitionSchemaNames(boolean includeDeleted)
           
 KettleFileRepositoryMeta getRepositoryMeta()
           
 ObjectId getRootDirectoryID()
           
 RepositorySecurityManager getSecurityManager()
           
 RepositorySecurityProvider 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.
 ObjectId getSlaveID(String name)
           
 ObjectId[] getSlaveIDs(boolean includeDeleted)
           
 String[] getSlaveNames(boolean includeDeleted)
           
 List<SlaveServer> getSlaveServers()
           
 boolean getStepAttributeBoolean(ObjectId id_step, int nr, String code)
           
 boolean getStepAttributeBoolean(ObjectId id_step, int nr, String code, boolean def)
           
 boolean getStepAttributeBoolean(ObjectId id_step, String code)
           
 long getStepAttributeInteger(ObjectId id_step, int nr, String code)
           
 long getStepAttributeInteger(ObjectId id_step, String code)
           
 String getStepAttributeString(ObjectId id_step, int nr, String code)
           
 String getStepAttributeString(ObjectId id_step, String code)
           
 ObjectId[] getSubConditionIDs(ObjectId id_condition)
           
 ObjectId[] getSubDirectoryIDs(ObjectId id_directory)
           
 ObjectId[] getTransformationClusterSchemaIDs(ObjectId id_transformation)
           
 ObjectId[] getTransformationConditionIDs(ObjectId id_transformation)
           
 ObjectId[] getTransformationDatabaseIDs(ObjectId id_transformation)
           
 ObjectId getTransformationID(String name, RepositoryDirectoryInterface repositoryDirectory)
           
 String[] getTransformationNames(ObjectId id_directory, boolean includeDeleted)
           
 List<RepositoryElementMetaInterface> getTransformationObjects(ObjectId idDirectory, boolean includeDeleted)
           
 ObjectId[] getTransformationPartitionSchemaIDs(ObjectId id_transformation)
           
 String[] getTransformationsUsingCluster(ObjectId id_cluster)
           
 String[] getTransformationsUsingDatabase(ObjectId id_database)
           
 String[] getTransformationsUsingPartitionSchema(ObjectId id_partition_schema)
           
 String[] getTransformationsUsingSlave(ObjectId id_slave)
           
 ObjectId[] getTransNoteIDs(ObjectId id_transformation)
           
 RepositoryDirectoryInterface getUserHomeDirectory()
           
 ObjectId getUserID(String login)
           
 ObjectId[] getUserIDs()
           
 IUser getUserInfo()
           
 String[] getUserLogins()
           
 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.
 ObjectId insertClusterSlave(ClusterSchema clusterSchema, SlaveServer slaveServer)
           
 void insertJobEntryDatabase(ObjectId id_job, ObjectId id_jobentry, ObjectId id_database)
           
 void insertJobNote(ObjectId id_job, ObjectId id_note)
           
 ObjectId insertLogEntry(String description)
          Insert an entry in the audit trail of the repository.
 void insertStepDatabase(ObjectId id_transformation, ObjectId id_step, ObjectId id_database)
           
 ObjectId insertTransformationCluster(ObjectId id_transformation, ObjectId id_cluster)
           
 ObjectId insertTransformationPartitionSchema(ObjectId id_transformation, ObjectId id_partition_schema)
           
 ObjectId insertTransformationSlave(ObjectId id_transformation, ObjectId id_slave)
           
 void insertTransNote(ObjectId id_transformation, ObjectId id_note)
           
 void insertTransStepCondition(ObjectId id_transformation, ObjectId id_step, ObjectId id_condition)
           
 boolean isConnected()
           
 ClusterSchema loadClusterSchema(ObjectId id_cluster_schema, List<SlaveServer> slaveServers, String versionName)
           
 Condition loadCondition(ObjectId id_condition)
           
 Condition loadConditionFromStepAttribute(ObjectId id_step, String code)
          Load a condition from the repository with the Object ID stored in a step attribute.
 DatabaseMeta loadDatabaseMeta(ObjectId id_database, String versionName)
          Load the Database connection Metadata from the repository
 DatabaseMeta loadDatabaseMetaFromJobEntryAttribute(ObjectId id_jobentry, String nameCode, int nr, String idCode, List<DatabaseMeta> databases)
          This method is introduced to avoid having to go over an integer/string/whatever in the interface and the job entry code.
 DatabaseMeta loadDatabaseMetaFromJobEntryAttribute(ObjectId id_jobentry, String nameCode, String idCode, List<DatabaseMeta> databases)
          This method is introduced to avoid having to go over an integer/string/whatever in the interface and the job entry code.
 DatabaseMeta loadDatabaseMetaFromStepAttribute(ObjectId id_step, String code, List<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(ObjectId idJob, String versionLabel)
          Load a job from the repository by id
 JobMeta loadJob(String jobname, RepositoryDirectoryInterface repdir, ProgressMonitorListener monitor, String versionName)
          Load a job from the repository
 Node loadNodeFromXML(ObjectId id, String tag)
           
 PartitionSchema loadPartitionSchema(ObjectId id_partition_schema, String versionName)
           
 RepositoryDirectoryInterface loadRepositoryDirectoryTree()
           
 RepositoryDirectoryInterface loadRepositoryDirectoryTree(RepositoryDirectoryInterface dir)
           
 SlaveServer loadSlaveServer(ObjectId id_slave_server, String versionName)
           
 TransMeta loadTransformation(ObjectId idTransformation, String versionLabel)
          Load a transformation by id
 TransMeta loadTransformation(String transname, RepositoryDirectoryInterface repdir, ProgressMonitorListener monitor, boolean setInternalVariables, String versionName)
          Load a transformation with a name from a folder in the repository
 UserInfo loadUserInfo(String login)
           
 UserInfo loadUserInfo(String login, String password)
           
 ValueMetaAndData loadValueMetaAndData(ObjectId id_value)
           
 void moveJob(String jobname, ObjectId id_directory_from, ObjectId id_directory_to)
           
 void moveTransformation(String transname, ObjectId id_directory_from, ObjectId id_directory_to)
           
 List<DatabaseMeta> readDatabases()
          Read all the databases defined in the repository
 void readDatabases(HasDatabasesInterface transMeta, boolean overWriteShared)
          Read all the databases from the repository, insert into the has databases object, overwriting optionally
 SharedObjects readJobMetaSharedObjects(JobMeta jobMeta)
           
 SharedObjects readTransSharedObjects(TransMeta transMeta)
           
 ObjectId renameJob(ObjectId id_job, RepositoryDirectoryInterface newDir, String newName)
          Move / rename a job
 ObjectId renameRepositoryDirectory(ObjectId id, RepositoryDirectoryInterface newParentDir, String newName)
          Move / rename a repository directory
 ObjectId renameTransformation(ObjectId id_transformation, RepositoryDirectoryInterface newDir, String newName)
          Move / rename a transformation
 void renameUser(ObjectId id_user, String newname)
           
 void save(RepositoryElementInterface repositoryElement, String versionComment)
           
 void save(RepositoryElementInterface repositoryElement, String versionComment, ProgressMonitorListener monitor)
           
 void save(RepositoryElementInterface repositoryElement, String versionComment, ProgressMonitorListener monitor, boolean overwrite)
          Save an object to the repository optionally overwriting any associated objects.
 void save(RepositoryElementInterface repositoryElement, String versionComment, ProgressMonitorListener monitor, ObjectId parentId, boolean used)
           
 ObjectId saveCondition(Condition condition)
           
 ObjectId saveCondition(Condition condition, ObjectId id_condition_parent)
           
 void saveConditionStepAttribute(ObjectId id_transformation, ObjectId id_step, String code, Condition condition)
          This method saves the object ID of the condition object (if not null) in the step attributes
 void saveDatabaseMetaJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, int nr, String nameCode, String idCode, DatabaseMeta database)
          This method saves the object ID of the database object (if not null) in the job entry attributes
 void saveDatabaseMetaJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, String code, DatabaseMeta database)
           
 void saveDatabaseMetaJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, String nameCode, String idCode, DatabaseMeta database)
          This method saves the object ID of the database object (if not null) in the job entry attributes
 void saveDatabaseMetaStepAttribute(ObjectId id_transformation, ObjectId id_step, String code, DatabaseMeta database)
          This method saves the object ID of the database object (if not null) in the step attributes
 void saveJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, int nr, String code, boolean value)
           
 void saveJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, int nr, String code, long value)
           
 void saveJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, int nr, String code, String value)
           
 void saveJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, String code, boolean value)
           
 void saveJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, String code, long value)
           
 void saveJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, String code, String value)
           
 void saveRepositoryDirectory(RepositoryDirectoryInterface dir)
           
 void saveStepAttribute(ObjectId id_transformation, ObjectId id_step, int nr, String code, boolean value)
           
 void saveStepAttribute(ObjectId id_transformation, ObjectId id_step, int nr, String code, double value)
           
 void saveStepAttribute(ObjectId id_transformation, ObjectId id_step, int nr, String code, long value)
           
 void saveStepAttribute(ObjectId id_transformation, ObjectId id_step, int nr, String code, String value)
           
 void saveStepAttribute(ObjectId id_transformation, ObjectId id_step, String code, boolean value)
           
 void saveStepAttribute(ObjectId id_transformation, ObjectId id_step, String code, double value)
           
 void saveStepAttribute(ObjectId id_transformation, ObjectId id_step, String code, long value)
           
 void saveStepAttribute(ObjectId id_transformation, ObjectId id_step, String code, String value)
           
 void saveUserInfo(UserInfo userInfo)
           
 void setRepositoryMeta(KettleFileRepositoryMeta repositoryMeta)
           
 void undeleteObject(RepositoryElementMetaInterface repositoryObject)
          Removes he deleted flag from a repository element in the repository.
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

FILE_REPOSITORY_VERSION

public static final String FILE_REPOSITORY_VERSION
See Also:
Constant Field Values
Constructor Detail

KettleFileRepository

public KettleFileRepository()
Method Detail

connect

public void connect(String username,
                    String password)
             throws 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.

Specified by:
connect in interface Repository
Parameters:
username - the username of the user connecting to the repository.
password - the password of the user connecting to the repository.
Throws:
KettleSecurityException - in case the supplied user or password is incorrect.
KettleException - in case there is a general unexpected error OR if we're already connected to the repository.

disconnect

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

Specified by:
disconnect in interface Repository

init

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

Specified by:
init in interface Repository

getLog

public LogChannelInterface getLog()
Specified by:
getLog in interface Repository
Returns:
the logging channel of this repository

isConnected

public boolean isConnected()
Specified by:
isConnected in interface Repository

getSecurityProvider

public RepositorySecurityProvider getSecurityProvider()
Specified by:
getSecurityProvider in interface Repository
Returns:
The security provider for this repository.

getSecurityManager

public RepositorySecurityManager getSecurityManager()
Specified by:
getSecurityManager in interface Repository
Returns:
The security manager for this repository.

calcRelativeElementDirectory

public String calcRelativeElementDirectory(RepositoryDirectoryInterface dir)

calcObjectId

public String calcObjectId(RepositoryDirectoryInterface dir)

calcObjectId

public String calcObjectId(RepositoryDirectoryInterface directory,
                           String name,
                           String extension)

calcObjectId

public String calcObjectId(RepositoryElementInterface element)

calcFilename

public String calcFilename(ObjectId id)

exists

public boolean exists(String name,
                      RepositoryDirectoryInterface repositoryDirectory,
                      RepositoryObjectType objectType)
               throws KettleException
Description copied from interface: Repository
See if a repository object exists in the repository

Specified by:
exists in interface 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:
KettleException - in case something goes wrong.

save

public void save(RepositoryElementInterface repositoryElement,
                 String versionComment)
          throws KettleException
Throws:
KettleException

save

public void save(RepositoryElementInterface repositoryElement,
                 String versionComment,
                 ProgressMonitorListener monitor)
          throws KettleException
Specified by:
save in interface Repository
Throws:
KettleException

save

public void save(RepositoryElementInterface repositoryElement,
                 String versionComment,
                 ProgressMonitorListener monitor,
                 boolean overwrite)
          throws KettleException
Description copied from interface: Repository
Save an object to the repository optionally overwriting any associated objects.

Specified by:
save in interface Repository
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:
KettleException - Error saving the object to the repository

save

public void save(RepositoryElementInterface repositoryElement,
                 String versionComment,
                 ProgressMonitorListener monitor,
                 ObjectId parentId,
                 boolean used)
          throws KettleException
Throws:
KettleException

createRepositoryDirectory

public RepositoryDirectoryInterface createRepositoryDirectory(RepositoryDirectoryInterface parentDirectory,
                                                              String directoryPath)
                                                       throws KettleException
Description copied from interface: Repository
Create a new directory, possibly by creating several sub-directies of / at the same time.

Specified by:
createRepositoryDirectory in interface Repository
Parameters:
parentDirectory - the parent directory
directoryPath - The path to the new Repository Directory, to be created.
Returns:
The created sub-directory
Throws:
KettleException - In case something goes wrong

saveRepositoryDirectory

public void saveRepositoryDirectory(RepositoryDirectoryInterface dir)
                             throws KettleException
Specified by:
saveRepositoryDirectory in interface Repository
Throws:
KettleException

deleteJob

public void deleteJob(ObjectId id_job)
               throws KettleException
Specified by:
deleteJob in interface Repository
Throws:
KettleException

deleteTransformation

public void deleteTransformation(ObjectId id_transformation)
                          throws 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.

Specified by:
deleteTransformation in interface Repository
Parameters:
id_transformation - the transformation id to delete
Throws:
KettleException

deleteClusterSchema

public void deleteClusterSchema(ObjectId id_cluster)
                         throws KettleException
Specified by:
deleteClusterSchema in interface Repository
Throws:
KettleException

deleteCondition

public void deleteCondition(ObjectId id_condition)
                     throws KettleException
Throws:
KettleException

deletePartitionSchema

public void deletePartitionSchema(ObjectId id_partition_schema)
                           throws KettleException
Specified by:
deletePartitionSchema in interface Repository
Throws:
KettleException

deleteRepositoryDirectory

public void deleteRepositoryDirectory(RepositoryDirectoryInterface dir)
                               throws KettleException
Specified by:
deleteRepositoryDirectory in interface Repository
Throws:
KettleException

deleteSlave

public void deleteSlave(ObjectId id_slave)
                 throws KettleException
Specified by:
deleteSlave in interface Repository
Throws:
KettleException

deleteDatabaseMeta

public void deleteDatabaseMeta(String databaseName)
                        throws KettleException
Description copied from interface: Repository
Remove a database connection from the repository

Specified by:
deleteDatabaseMeta in interface Repository
Parameters:
databaseName - The name of the connection to remove
Throws:
KettleException - In case something went wrong: database error, insufficient permissions, depending objects, etc.

deleteRootObject

public void deleteRootObject(String name,
                             String extension)
                      throws KettleException
Throws:
KettleException

deleteFile

public void deleteFile(String filename)
                throws KettleException
Throws:
KettleException

getClusterID

public ObjectId getClusterID(String name)
                      throws KettleException
Specified by:
getClusterID in interface Repository
Throws:
KettleException

getClusterIDs

public ObjectId[] getClusterIDs(boolean includeDeleted)
                         throws KettleException
Specified by:
getClusterIDs in interface Repository
Throws:
KettleException

getClusterNames

public String[] getClusterNames(boolean includeDeleted)
                         throws KettleException
Specified by:
getClusterNames in interface Repository
Throws:
KettleException

getClustersUsingSlave

public String[] getClustersUsingSlave(ObjectId id_slave)
                               throws KettleException
Throws:
KettleException

getTransformationConditionIDs

public ObjectId[] getTransformationConditionIDs(ObjectId id_transformation)
                                         throws KettleException
Throws:
KettleException

getDatabaseAttributeIDs

public ObjectId[] getDatabaseAttributeIDs(ObjectId id_database)
                                   throws KettleException
Throws:
KettleException

getDatabaseID

public ObjectId getDatabaseID(String name)
                       throws KettleException
Specified by:
getDatabaseID in interface Repository
Throws:
KettleException

getTransformationDatabaseIDs

public ObjectId[] getTransformationDatabaseIDs(ObjectId id_transformation)
                                        throws KettleException
Throws:
KettleException

getDatabaseIDs

public ObjectId[] getDatabaseIDs(boolean includeDeleted)
                          throws KettleException
Specified by:
getDatabaseIDs in interface Repository
Throws:
KettleException

getDatabaseNames

public String[] getDatabaseNames(boolean includeDeleted)
                          throws KettleException
Specified by:
getDatabaseNames in interface Repository
Throws:
KettleException

getDirectoryNames

public String[] getDirectoryNames(ObjectId id_directory)
                           throws KettleException
Description copied from interface: Repository
Returns the child directory names of a parent directory

Specified by:
getDirectoryNames in interface Repository
Parameters:
id_directory - parent directory id
Returns:
array of child names
Throws:
KettleException

getJobId

public ObjectId getJobId(String name,
                         RepositoryDirectoryInterface repositoryDirectory)
                  throws KettleException
Specified by:
getJobId in interface Repository
Throws:
KettleException

getJobNames

public String[] getJobNames(ObjectId id_directory,
                            boolean includeDeleted)
                     throws KettleException
Specified by:
getJobNames in interface Repository
Throws:
KettleException

getJobNoteIDs

public ObjectId[] getJobNoteIDs(ObjectId id_job)
                         throws KettleException
Throws:
KettleException

getJobsUsingDatabase

public String[] getJobsUsingDatabase(ObjectId id_database)
                              throws KettleException
Description copied from interface: Repository
Get the repository version.

Specified by:
getJobsUsingDatabase in interface Repository
Returns:
The repository version as a string
Throws:
KettleException

getName

public String getName()
Specified by:
getName in interface Repository
Returns:
The name of the repository

getPartitionSchemaID

public ObjectId getPartitionSchemaID(String name)
                              throws KettleException
Specified by:
getPartitionSchemaID in interface Repository
Throws:
KettleException

getPartitionSchemaIDs

public ObjectId[] getPartitionSchemaIDs(boolean includeDeleted)
                                 throws KettleException
Specified by:
getPartitionSchemaIDs in interface Repository
Throws:
KettleException

getPartitionSchemaNames

public String[] getPartitionSchemaNames(boolean includeDeleted)
                                 throws KettleException
Specified by:
getPartitionSchemaNames in interface Repository
Throws:
KettleException

getRootDirectoryID

public ObjectId getRootDirectoryID()
                            throws KettleException
Throws:
KettleException

getSlaveID

public ObjectId getSlaveID(String name)
                    throws KettleException
Specified by:
getSlaveID in interface Repository
Throws:
KettleException

getSlaveIDs

public ObjectId[] getSlaveIDs(boolean includeDeleted)
                       throws KettleException
Specified by:
getSlaveIDs in interface Repository
Throws:
KettleException

getClusterSlaveIDs

public ObjectId[] getClusterSlaveIDs(ObjectId id_cluster_schema)
                              throws KettleException
Throws:
KettleException

getSlaveNames

public String[] getSlaveNames(boolean includeDeleted)
                       throws KettleException
Specified by:
getSlaveNames in interface Repository
Throws:
KettleException

getSlaveServers

public List<SlaveServer> getSlaveServers()
                                  throws KettleException
Specified by:
getSlaveServers in interface Repository
Returns:
a list of all the slave servers in the repository.
Throws:
KettleException

getStepAttributeBoolean

public boolean getStepAttributeBoolean(ObjectId id_step,
                                       int nr,
                                       String code,
                                       boolean def)
                                throws KettleException
Specified by:
getStepAttributeBoolean in interface Repository
Throws:
KettleException

getStepAttributeBoolean

public boolean getStepAttributeBoolean(ObjectId id_step,
                                       int nr,
                                       String code)
                                throws KettleException
Specified by:
getStepAttributeBoolean in interface Repository
Throws:
KettleException

getStepAttributeBoolean

public boolean getStepAttributeBoolean(ObjectId id_step,
                                       String code)
                                throws KettleException
Specified by:
getStepAttributeBoolean in interface Repository
Throws:
KettleException

getStepAttributeInteger

public long getStepAttributeInteger(ObjectId id_step,
                                    int nr,
                                    String code)
                             throws KettleException
Specified by:
getStepAttributeInteger in interface Repository
Throws:
KettleException

getStepAttributeInteger

public long getStepAttributeInteger(ObjectId id_step,
                                    String code)
                             throws KettleException
Specified by:
getStepAttributeInteger in interface Repository
Throws:
KettleException

getStepAttributeString

public String getStepAttributeString(ObjectId id_step,
                                     int nr,
                                     String code)
                              throws KettleException
Specified by:
getStepAttributeString in interface Repository
Throws:
KettleException

getStepAttributeString

public String getStepAttributeString(ObjectId id_step,
                                     String code)
                              throws KettleException
Specified by:
getStepAttributeString in interface Repository
Throws:
KettleException

getJobEntryAttributeBoolean

public boolean getJobEntryAttributeBoolean(ObjectId id_jobentry,
                                           String code)
                                    throws KettleException
Specified by:
getJobEntryAttributeBoolean in interface Repository
Throws:
KettleException

getJobEntryAttributeBoolean

public boolean getJobEntryAttributeBoolean(ObjectId id_jobentry,
                                           int nr,
                                           String code)
                                    throws KettleException
Specified by:
getJobEntryAttributeBoolean in interface Repository
Throws:
KettleException

getJobEntryAttributeBoolean

public boolean getJobEntryAttributeBoolean(ObjectId id_jobentry,
                                           String code,
                                           boolean def)
                                    throws KettleException
Specified by:
getJobEntryAttributeBoolean in interface Repository
Throws:
KettleException

getJobEntryAttributeInteger

public long getJobEntryAttributeInteger(ObjectId id_jobentry,
                                        String code)
                                 throws KettleException
Specified by:
getJobEntryAttributeInteger in interface Repository
Throws:
KettleException

getJobEntryAttributeInteger

public long getJobEntryAttributeInteger(ObjectId id_jobentry,
                                        int nr,
                                        String code)
                                 throws KettleException
Specified by:
getJobEntryAttributeInteger in interface Repository
Throws:
KettleException

getJobEntryAttributeString

public String getJobEntryAttributeString(ObjectId id_jobentry,
                                         String code)
                                  throws KettleException
Specified by:
getJobEntryAttributeString in interface Repository
Throws:
KettleException

getJobEntryAttributeString

public String getJobEntryAttributeString(ObjectId id_jobentry,
                                         int nr,
                                         String code)
                                  throws KettleException
Specified by:
getJobEntryAttributeString in interface Repository
Throws:
KettleException

getSubConditionIDs

public ObjectId[] getSubConditionIDs(ObjectId id_condition)
                              throws KettleException
Throws:
KettleException

getSubDirectoryIDs

public ObjectId[] getSubDirectoryIDs(ObjectId id_directory)
                              throws KettleException
Throws:
KettleException

getTransNoteIDs

public ObjectId[] getTransNoteIDs(ObjectId id_transformation)
                           throws KettleException
Throws:
KettleException

getTransformationClusterSchemaIDs

public ObjectId[] getTransformationClusterSchemaIDs(ObjectId id_transformation)
                                             throws KettleException
Throws:
KettleException

getTransformationID

public ObjectId getTransformationID(String name,
                                    RepositoryDirectoryInterface repositoryDirectory)
                             throws KettleException
Specified by:
getTransformationID in interface Repository
Throws:
KettleException

getTransformationNames

public String[] getTransformationNames(ObjectId id_directory,
                                       boolean includeDeleted)
                                throws KettleException
Specified by:
getTransformationNames in interface Repository
Throws:
KettleException

getTransformationPartitionSchemaIDs

public ObjectId[] getTransformationPartitionSchemaIDs(ObjectId id_transformation)
                                               throws KettleException
Throws:
KettleException

getTransformationsUsingCluster

public String[] getTransformationsUsingCluster(ObjectId id_cluster)
                                        throws KettleException
Throws:
KettleException

getTransformationsUsingDatabase

public String[] getTransformationsUsingDatabase(ObjectId id_database)
                                         throws KettleException
Specified by:
getTransformationsUsingDatabase in interface Repository
Throws:
KettleException

getTransformationsUsingPartitionSchema

public String[] getTransformationsUsingPartitionSchema(ObjectId id_partition_schema)
                                                throws KettleException
Throws:
KettleException

getTransformationsUsingSlave

public String[] getTransformationsUsingSlave(ObjectId id_slave)
                                      throws KettleException
Throws:
KettleException

getVersion

public String getVersion()
Description copied from interface: Repository
Get the repository version.

Specified by:
getVersion in interface Repository
Returns:
The repository version as a string

insertClusterSlave

public ObjectId insertClusterSlave(ClusterSchema clusterSchema,
                                   SlaveServer slaveServer)
                            throws KettleException
Throws:
KettleException

insertJobEntryDatabase

public void insertJobEntryDatabase(ObjectId id_job,
                                   ObjectId id_jobentry,
                                   ObjectId id_database)
                            throws KettleException
Specified by:
insertJobEntryDatabase in interface Repository
Throws:
KettleException

insertJobNote

public void insertJobNote(ObjectId id_job,
                          ObjectId id_note)
                   throws KettleException
Throws:
KettleException

insertLogEntry

public ObjectId insertLogEntry(String description)
                        throws 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.

Specified by:
insertLogEntry in interface Repository
Throws:
KettleException

insertStepDatabase

public void insertStepDatabase(ObjectId id_transformation,
                               ObjectId id_step,
                               ObjectId id_database)
                        throws KettleException
Specified by:
insertStepDatabase in interface Repository
Throws:
KettleException

insertTransNote

public void insertTransNote(ObjectId id_transformation,
                            ObjectId id_note)
                     throws KettleException
Throws:
KettleException

insertTransStepCondition

public void insertTransStepCondition(ObjectId id_transformation,
                                     ObjectId id_step,
                                     ObjectId id_condition)
                              throws KettleException
Throws:
KettleException

insertTransformationCluster

public ObjectId insertTransformationCluster(ObjectId id_transformation,
                                            ObjectId id_cluster)
                                     throws KettleException
Throws:
KettleException

insertTransformationPartitionSchema

public ObjectId insertTransformationPartitionSchema(ObjectId id_transformation,
                                                    ObjectId id_partition_schema)
                                             throws KettleException
Throws:
KettleException

insertTransformationSlave

public ObjectId insertTransformationSlave(ObjectId id_transformation,
                                          ObjectId id_slave)
                                   throws KettleException
Throws:
KettleException

loadClusterSchema

public ClusterSchema loadClusterSchema(ObjectId id_cluster_schema,
                                       List<SlaveServer> slaveServers,
                                       String versionName)
                                throws KettleException
Specified by:
loadClusterSchema in interface Repository
Throws:
KettleException

loadCondition

public Condition loadCondition(ObjectId id_condition)
                        throws KettleException
Throws:
KettleException

loadConditionFromStepAttribute

public Condition loadConditionFromStepAttribute(ObjectId id_step,
                                                String code)
                                         throws KettleException
Description copied from interface: Repository
Load a condition from the repository with the Object ID stored in a step attribute.

Specified by:
loadConditionFromStepAttribute in interface Repository
Returns:
Throws:
KettleException

loadNodeFromXML

public Node loadNodeFromXML(ObjectId id,
                            String tag)
                     throws KettleException
Throws:
KettleException

loadDatabaseMeta

public DatabaseMeta loadDatabaseMeta(ObjectId id_database,
                                     String versionName)
                              throws KettleException
Description copied from interface: Repository
Load the Database connection Metadata from the repository

Specified by:
loadDatabaseMeta in interface 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:
KettleException - in case something goes wrong with database, connection, etc.

loadDatabaseMetaFromJobEntryAttribute

public DatabaseMeta loadDatabaseMetaFromJobEntryAttribute(ObjectId id_jobentry,
                                                          String nameCode,
                                                          String idCode,
                                                          List<DatabaseMeta> databases)
                                                   throws 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.

Specified by:
loadDatabaseMetaFromJobEntryAttribute in interface Repository
Returns:
Throws:
KettleException

loadDatabaseMetaFromJobEntryAttribute

public DatabaseMeta loadDatabaseMetaFromJobEntryAttribute(ObjectId id_jobentry,
                                                          String nameCode,
                                                          int nr,
                                                          String idCode,
                                                          List<DatabaseMeta> databases)
                                                   throws 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.

Specified by:
loadDatabaseMetaFromJobEntryAttribute in interface Repository
Returns:
Throws:
KettleException

saveDatabaseMetaJobEntryAttribute

public void saveDatabaseMetaJobEntryAttribute(ObjectId id_job,
                                              ObjectId id_jobentry,
                                              String nameCode,
                                              String idCode,
                                              DatabaseMeta database)
                                       throws KettleException
Description copied from interface: Repository
This method saves the object ID of the database object (if not null) in the job entry attributes

Specified by:
saveDatabaseMetaJobEntryAttribute in interface Repository
Throws:
KettleException

saveDatabaseMetaJobEntryAttribute

public void saveDatabaseMetaJobEntryAttribute(ObjectId id_job,
                                              ObjectId id_jobentry,
                                              int nr,
                                              String nameCode,
                                              String idCode,
                                              DatabaseMeta database)
                                       throws KettleException
Description copied from interface: Repository
This method saves the object ID of the database object (if not null) in the job entry attributes

Specified by:
saveDatabaseMetaJobEntryAttribute in interface Repository
Throws:
KettleException

loadDatabaseMetaFromStepAttribute

public DatabaseMeta loadDatabaseMetaFromStepAttribute(ObjectId id_step,
                                                      String code,
                                                      List<DatabaseMeta> databases)
                                               throws 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.

Specified by:
loadDatabaseMetaFromStepAttribute in interface Repository
Returns:
Throws:
KettleException

loadJob

public JobMeta loadJob(String jobname,
                       RepositoryDirectoryInterface repdir,
                       ProgressMonitorListener monitor,
                       String versionName)
                throws KettleException
Description copied from interface: Repository
Load a job from the repository

Specified by:
loadJob in interface 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:
KettleException

loadPartitionSchema

public PartitionSchema loadPartitionSchema(ObjectId id_partition_schema,
                                           String versionName)
                                    throws KettleException
Specified by:
loadPartitionSchema in interface Repository
Throws:
KettleException

loadRepositoryDirectoryTree

public RepositoryDirectoryInterface loadRepositoryDirectoryTree()
                                                         throws KettleException
Specified by:
loadRepositoryDirectoryTree in interface Repository
Throws:
KettleException

loadRepositoryDirectoryTree

public RepositoryDirectoryInterface loadRepositoryDirectoryTree(RepositoryDirectoryInterface dir)
                                                         throws KettleException
Throws:
KettleException

findDirectory

public RepositoryDirectoryInterface findDirectory(String directory)
                                           throws KettleException
Specified by:
findDirectory in interface Repository
Throws:
KettleException

findDirectory

public RepositoryDirectoryInterface findDirectory(ObjectId directory)
                                           throws KettleException
Specified by:
findDirectory in interface Repository
Throws:
KettleException

getTransformationObjects

public List<RepositoryElementMetaInterface> getTransformationObjects(ObjectId idDirectory,
                                                                     boolean includeDeleted)
                                                              throws KettleException
Specified by:
getTransformationObjects in interface Repository
Throws:
KettleException

getJobObjects

public List<RepositoryElementMetaInterface> getJobObjects(ObjectId id_directory,
                                                          boolean includeDeleted)
                                                   throws KettleException
Specified by:
getJobObjects in interface Repository
Throws:
KettleException

getNrSubDirectories

public int getNrSubDirectories(ObjectId id_directory)
                        throws KettleException
Throws:
KettleException

loadSlaveServer

public SlaveServer loadSlaveServer(ObjectId id_slave_server,
                                   String versionName)
                            throws KettleException
Specified by:
loadSlaveServer in interface Repository
Throws:
KettleException

loadTransformation

public TransMeta loadTransformation(String transname,
                                    RepositoryDirectoryInterface repdir,
                                    ProgressMonitorListener monitor,
                                    boolean setInternalVariables,
                                    String versionName)
                             throws KettleException
Description copied from interface: Repository
Load a transformation with a name from a folder in the repository

Specified by:
loadTransformation in interface 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:
KettleException

readDatabases

public void readDatabases(HasDatabasesInterface transMeta,
                          boolean overWriteShared)
                   throws 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:
KettleException

loadValueMetaAndData

public ValueMetaAndData loadValueMetaAndData(ObjectId id_value)
                                      throws KettleException
Throws:
KettleException

moveJob

public void moveJob(String jobname,
                    ObjectId id_directory_from,
                    ObjectId id_directory_to)
             throws KettleException
Throws:
KettleException

moveTransformation

public void moveTransformation(String transname,
                               ObjectId id_directory_from,
                               ObjectId id_directory_to)
                        throws KettleException
Throws:
KettleException

readDatabases

public List<DatabaseMeta> readDatabases()
                                 throws KettleException
Description copied from interface: Repository
Read all the databases defined in the repository

Specified by:
readDatabases in interface Repository
Returns:
a list of all the databases defined in the repository
Throws:
KettleException

clearSharedObjectCache

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

Specified by:
clearSharedObjectCache in interface Repository

readJobMetaSharedObjects

public SharedObjects readJobMetaSharedObjects(JobMeta jobMeta)
                                       throws KettleException
Specified by:
readJobMetaSharedObjects in interface Repository
Throws:
KettleException

readTransSharedObjects

public SharedObjects readTransSharedObjects(TransMeta transMeta)
                                     throws KettleException
Specified by:
readTransSharedObjects in interface Repository
Throws:
KettleException

renameJob

public ObjectId renameJob(ObjectId id_job,
                          RepositoryDirectoryInterface newDir,
                          String newName)
                   throws KettleException
Description copied from interface: Repository
Move / rename a job

Specified by:
renameJob in interface Repository
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:
KettleException

renameRepositoryDirectory

public ObjectId renameRepositoryDirectory(ObjectId id,
                                          RepositoryDirectoryInterface newParentDir,
                                          String newName)
                                   throws KettleException
Description copied from interface: Repository
Move / rename a repository directory

Specified by:
renameRepositoryDirectory in interface Repository
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:
KettleException

renameTransformation

public ObjectId renameTransformation(ObjectId id_transformation,
                                     RepositoryDirectoryInterface newDir,
                                     String newName)
                              throws KettleException
Description copied from interface: Repository
Move / rename a transformation

Specified by:
renameTransformation in interface Repository
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:
KettleException

saveCondition

public ObjectId saveCondition(Condition condition)
                       throws KettleException
Throws:
KettleException

saveCondition

public ObjectId saveCondition(Condition condition,
                              ObjectId id_condition_parent)
                       throws KettleException
Throws:
KettleException

saveConditionStepAttribute

public void saveConditionStepAttribute(ObjectId id_transformation,
                                       ObjectId id_step,
                                       String code,
                                       Condition condition)
                                throws KettleException
Description copied from interface: Repository
This method saves the object ID of the condition object (if not null) in the step attributes

Specified by:
saveConditionStepAttribute in interface Repository
Throws:
KettleException

saveDatabaseMetaJobEntryAttribute

public void saveDatabaseMetaJobEntryAttribute(ObjectId id_job,
                                              ObjectId id_jobentry,
                                              String code,
                                              DatabaseMeta database)
                                       throws KettleException
Throws:
KettleException

saveDatabaseMetaStepAttribute

public void saveDatabaseMetaStepAttribute(ObjectId id_transformation,
                                          ObjectId id_step,
                                          String code,
                                          DatabaseMeta database)
                                   throws KettleException
Description copied from interface: Repository
This method saves the object ID of the database object (if not null) in the step attributes

Specified by:
saveDatabaseMetaStepAttribute in interface Repository
Throws:
KettleException

saveJobEntryAttribute

public void saveJobEntryAttribute(ObjectId id_job,
                                  ObjectId id_jobentry,
                                  int nr,
                                  String code,
                                  String value)
                           throws KettleException
Specified by:
saveJobEntryAttribute in interface Repository
Throws:
KettleException

saveJobEntryAttribute

public void saveJobEntryAttribute(ObjectId id_job,
                                  ObjectId id_jobentry,
                                  String code,
                                  String value)
                           throws KettleException
Specified by:
saveJobEntryAttribute in interface Repository
Throws:
KettleException

saveJobEntryAttribute

public void saveJobEntryAttribute(ObjectId id_job,
                                  ObjectId id_jobentry,
                                  int nr,
                                  String code,
                                  boolean value)
                           throws KettleException
Specified by:
saveJobEntryAttribute in interface Repository
Throws:
KettleException

saveJobEntryAttribute

public void saveJobEntryAttribute(ObjectId id_job,
                                  ObjectId id_jobentry,
                                  String code,
                                  boolean value)
                           throws KettleException
Specified by:
saveJobEntryAttribute in interface Repository
Throws:
KettleException

saveJobEntryAttribute

public void saveJobEntryAttribute(ObjectId id_job,
                                  ObjectId id_jobentry,
                                  int nr,
                                  String code,
                                  long value)
                           throws KettleException
Specified by:
saveJobEntryAttribute in interface Repository
Throws:
KettleException

saveJobEntryAttribute

public void saveJobEntryAttribute(ObjectId id_job,
                                  ObjectId id_jobentry,
                                  String code,
                                  long value)
                           throws KettleException
Specified by:
saveJobEntryAttribute in interface Repository
Throws:
KettleException

saveStepAttribute

public void saveStepAttribute(ObjectId id_transformation,
                              ObjectId id_step,
                              int nr,
                              String code,
                              String value)
                       throws KettleException
Specified by:
saveStepAttribute in interface Repository
Throws:
KettleException

saveStepAttribute

public void saveStepAttribute(ObjectId id_transformation,
                              ObjectId id_step,
                              String code,
                              String value)
                       throws KettleException
Specified by:
saveStepAttribute in interface Repository
Throws:
KettleException

saveStepAttribute

public void saveStepAttribute(ObjectId id_transformation,
                              ObjectId id_step,
                              int nr,
                              String code,
                              boolean value)
                       throws KettleException
Specified by:
saveStepAttribute in interface Repository
Throws:
KettleException

saveStepAttribute

public void saveStepAttribute(ObjectId id_transformation,
                              ObjectId id_step,
                              String code,
                              boolean value)
                       throws KettleException
Specified by:
saveStepAttribute in interface Repository
Throws:
KettleException

saveStepAttribute

public void saveStepAttribute(ObjectId id_transformation,
                              ObjectId id_step,
                              int nr,
                              String code,
                              long value)
                       throws KettleException
Specified by:
saveStepAttribute in interface Repository
Throws:
KettleException

saveStepAttribute

public void saveStepAttribute(ObjectId id_transformation,
                              ObjectId id_step,
                              String code,
                              long value)
                       throws KettleException
Specified by:
saveStepAttribute in interface Repository
Throws:
KettleException

saveStepAttribute

public void saveStepAttribute(ObjectId id_transformation,
                              ObjectId id_step,
                              int nr,
                              String code,
                              double value)
                       throws KettleException
Specified by:
saveStepAttribute in interface Repository
Throws:
KettleException

saveStepAttribute

public void saveStepAttribute(ObjectId id_transformation,
                              ObjectId id_step,
                              String code,
                              double value)
                       throws KettleException
Specified by:
saveStepAttribute in interface Repository
Throws:
KettleException

delUser

public void delUser(ObjectId id_user)
             throws KettleException
Throws:
KettleException

getUserID

public ObjectId getUserID(String login)
                   throws KettleException
Throws:
KettleException

getUserIDs

public ObjectId[] getUserIDs()
                      throws KettleException
Throws:
KettleException

getUserInfo

public IUser getUserInfo()
Specified by:
getUserInfo in interface Repository
Returns:
the currently logged on user. (also available through the repository security provider)

getUserLogins

public String[] getUserLogins()
                       throws KettleException
Throws:
KettleException

loadUserInfo

public UserInfo loadUserInfo(String login)
                      throws KettleException
Throws:
KettleException

loadUserInfo

public UserInfo loadUserInfo(String login,
                             String password)
                      throws KettleException
Throws:
KettleException

renameUser

public void renameUser(ObjectId id_user,
                       String newname)
                throws KettleException
Throws:
KettleException

saveUserInfo

public void saveUserInfo(UserInfo userInfo)
                  throws KettleException
Throws:
KettleException

countNrJobEntryAttributes

public int countNrJobEntryAttributes(ObjectId id_jobentry,
                                     String code)
                              throws KettleException
Specified by:
countNrJobEntryAttributes in interface Repository
Throws:
KettleException

countNrStepAttributes

public int countNrStepAttributes(ObjectId id_step,
                                 String code)
                          throws KettleException
Specified by:
countNrStepAttributes in interface Repository
Throws:
KettleException

getRepositoryMeta

public KettleFileRepositoryMeta getRepositoryMeta()
Specified by:
getRepositoryMeta in interface Repository
Returns:
the repositoryMeta

setRepositoryMeta

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

undeleteObject

public void undeleteObject(RepositoryElementMetaInterface repositoryObject)
                    throws 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.

Specified by:
undeleteObject in interface Repository
Throws:
KettleException - get throws in case something goes horribly wrong.

getJobAndTransformationObjects

public List<RepositoryElementMetaInterface> getJobAndTransformationObjects(ObjectId id_directory,
                                                                           boolean includeDeleted)
                                                                    throws 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.

Specified by:
getJobAndTransformationObjects in interface Repository
Parameters:
id_directory - directory
includeDeleted - true to return deleted objects
Returns:
list of repository objects
Throws:
KettleException - In case something goes wrong

getService

public IRepositoryService getService(Class<? extends IRepositoryService> clazz)
                              throws KettleException
Description copied from interface: Repository
Retrieves a given repository service

Specified by:
getService in interface Repository
Returns:
repository service
Throws:
KettleException - in case something goes horribly wrong.

getServiceInterfaces

public List<Class<? extends IRepositoryService>> getServiceInterfaces()
                                                               throws KettleException
Description copied from interface: Repository
Retrieves the current list of of IRepository Services.

Specified by:
getServiceInterfaces in interface Repository
Returns:
List of repository services
Throws:
KettleException - in case something goes horribly wrong.

hasService

public boolean hasService(Class<? extends IRepositoryService> clazz)
                   throws KettleException
Description copied from interface: Repository
Checks whether a given repository service is available or not

Specified by:
hasService in interface Repository
Throws:
KettleException - in case something goes horribly wrong.

getDefaultSaveDirectory

public RepositoryDirectoryInterface getDefaultSaveDirectory(RepositoryElementInterface repositoryElement)
                                                     throws KettleException
Specified by:
getDefaultSaveDirectory in interface Repository
Throws:
KettleException

getUserHomeDirectory

public RepositoryDirectoryInterface getUserHomeDirectory()
                                                  throws KettleException
Specified by:
getUserHomeDirectory in interface Repository
Throws:
KettleException

getObjectInformation

public RepositoryObject getObjectInformation(ObjectId objectId,
                                             RepositoryObjectType objectType)
                                      throws KettleException
Description copied from interface: Repository
Get more information about a certain object ID in the form of the RepositoryObject

Specified by:
getObjectInformation in interface Repository
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:
KettleException - In case there was a loading problem.

loadJob

public JobMeta loadJob(ObjectId idJob,
                       String versionLabel)
                throws KettleException
Description copied from interface: Repository
Load a job from the repository by id

Specified by:
loadJob in interface Repository
Parameters:
idJob - the id of the job
versionLabel - version to load. Specify null to load the last version.
Throws:
KettleException

loadTransformation

public TransMeta loadTransformation(ObjectId idTransformation,
                                    String versionLabel)
                             throws KettleException
Description copied from interface: Repository
Load a transformation by id

Specified by:
loadTransformation in interface Repository
Parameters:
idTransformation - the id of the transformation to load
versionLabel - version to load. Specify null to load the last version.
Throws:
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.

Specified by:
getConnectMessage in interface Repository
Returns:
message

getExporter

public IRepositoryExporter getExporter()
Specified by:
getExporter in interface Repository
Returns:
the exporter that will handle exports from this repository

getImporter

public IRepositoryImporter getImporter()
Specified by:
getImporter in interface Repository
Returns:
the importer that will handle imports into this repository