|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.pentaho.di.repository.filerep.KettleFileRepository
public class KettleFileRepository
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 |
---|
public static final String FILE_REPOSITORY_VERSION
Constructor Detail |
---|
public KettleFileRepository()
Method Detail |
---|
public void connect(String username, String password) throws KettleException
Repository
connect
in interface Repository
username
- the username of the user connecting to the repository.password
- the password of the user connecting to the repository.
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.public void disconnect()
Repository
disconnect
in interface Repository
public void init(RepositoryMeta repositoryMeta)
Repository
init
in interface Repository
public LogChannelInterface getLog()
getLog
in interface Repository
public boolean isConnected()
isConnected
in interface Repository
public RepositorySecurityProvider getSecurityProvider()
getSecurityProvider
in interface Repository
public RepositorySecurityManager getSecurityManager()
getSecurityManager
in interface Repository
public String calcRelativeElementDirectory(RepositoryDirectoryInterface dir)
public String calcObjectId(RepositoryDirectoryInterface dir)
public String calcObjectId(RepositoryDirectoryInterface directory, String name, String extension)
public String calcObjectId(RepositoryElementInterface element)
public String calcFilename(ObjectId id)
public boolean exists(String name, RepositoryDirectoryInterface repositoryDirectory, RepositoryObjectType objectType) throws KettleException
Repository
exists
in interface Repository
name
- the name of the objectrepositoryDirectory
- the directory in which it should resideobjectType
- the type of repository object
KettleException
- in case something goes wrong.public void save(RepositoryElementInterface repositoryElement, String versionComment) throws KettleException
KettleException
public void save(RepositoryElementInterface repositoryElement, String versionComment, ProgressMonitorListener monitor) throws KettleException
save
in interface Repository
KettleException
public void save(RepositoryElementInterface repositoryElement, String versionComment, ProgressMonitorListener monitor, boolean overwrite) throws KettleException
Repository
save
in interface Repository
repositoryElement
- Object to saveversionComment
- Version comment for updatemonitor
- Progress Monitor to report feedback tooverwrite
- Overwrite any existing objects involved in saving repositoryElement
, e.g. repositoryElement, database connections, slave servers
KettleException
- Error saving the object to the repositorypublic void save(RepositoryElementInterface repositoryElement, String versionComment, ProgressMonitorListener monitor, ObjectId parentId, boolean used) throws KettleException
KettleException
public RepositoryDirectoryInterface createRepositoryDirectory(RepositoryDirectoryInterface parentDirectory, String directoryPath) throws KettleException
Repository
createRepositoryDirectory
in interface Repository
parentDirectory
- the parent directorydirectoryPath
- The path to the new Repository Directory, to be created.
KettleException
- In case something goes wrongpublic void saveRepositoryDirectory(RepositoryDirectoryInterface dir) throws KettleException
saveRepositoryDirectory
in interface Repository
KettleException
public void deleteJob(ObjectId id_job) throws KettleException
deleteJob
in interface Repository
KettleException
public void deleteTransformation(ObjectId id_transformation) throws KettleException
Repository
deleteTransformation
in interface Repository
id_transformation
- the transformation id to delete
KettleException
public void deleteClusterSchema(ObjectId id_cluster) throws KettleException
deleteClusterSchema
in interface Repository
KettleException
public void deleteCondition(ObjectId id_condition) throws KettleException
KettleException
public void deletePartitionSchema(ObjectId id_partition_schema) throws KettleException
deletePartitionSchema
in interface Repository
KettleException
public void deleteRepositoryDirectory(RepositoryDirectoryInterface dir) throws KettleException
deleteRepositoryDirectory
in interface Repository
KettleException
public void deleteSlave(ObjectId id_slave) throws KettleException
deleteSlave
in interface Repository
KettleException
public void deleteDatabaseMeta(String databaseName) throws KettleException
Repository
deleteDatabaseMeta
in interface Repository
databaseName
- The name of the connection to remove
KettleException
- In case something went wrong: database error, insufficient permissions, depending objects, etc.public void deleteRootObject(String name, String extension) throws KettleException
KettleException
public void deleteFile(String filename) throws KettleException
KettleException
public ObjectId getClusterID(String name) throws KettleException
getClusterID
in interface Repository
KettleException
public ObjectId[] getClusterIDs(boolean includeDeleted) throws KettleException
getClusterIDs
in interface Repository
KettleException
public String[] getClusterNames(boolean includeDeleted) throws KettleException
getClusterNames
in interface Repository
KettleException
public String[] getClustersUsingSlave(ObjectId id_slave) throws KettleException
KettleException
public ObjectId[] getTransformationConditionIDs(ObjectId id_transformation) throws KettleException
KettleException
public ObjectId[] getDatabaseAttributeIDs(ObjectId id_database) throws KettleException
KettleException
public ObjectId getDatabaseID(String name) throws KettleException
getDatabaseID
in interface Repository
KettleException
public ObjectId[] getTransformationDatabaseIDs(ObjectId id_transformation) throws KettleException
KettleException
public ObjectId[] getDatabaseIDs(boolean includeDeleted) throws KettleException
getDatabaseIDs
in interface Repository
KettleException
public String[] getDatabaseNames(boolean includeDeleted) throws KettleException
getDatabaseNames
in interface Repository
KettleException
public String[] getDirectoryNames(ObjectId id_directory) throws KettleException
Repository
getDirectoryNames
in interface Repository
id_directory
- parent directory id
KettleException
public ObjectId getJobId(String name, RepositoryDirectoryInterface repositoryDirectory) throws KettleException
getJobId
in interface Repository
KettleException
public String[] getJobNames(ObjectId id_directory, boolean includeDeleted) throws KettleException
getJobNames
in interface Repository
KettleException
public ObjectId[] getJobNoteIDs(ObjectId id_job) throws KettleException
KettleException
public String[] getJobsUsingDatabase(ObjectId id_database) throws KettleException
Repository
getJobsUsingDatabase
in interface Repository
KettleException
public String getName()
getName
in interface Repository
public ObjectId getPartitionSchemaID(String name) throws KettleException
getPartitionSchemaID
in interface Repository
KettleException
public ObjectId[] getPartitionSchemaIDs(boolean includeDeleted) throws KettleException
getPartitionSchemaIDs
in interface Repository
KettleException
public String[] getPartitionSchemaNames(boolean includeDeleted) throws KettleException
getPartitionSchemaNames
in interface Repository
KettleException
public ObjectId getRootDirectoryID() throws KettleException
KettleException
public ObjectId getSlaveID(String name) throws KettleException
getSlaveID
in interface Repository
KettleException
public ObjectId[] getSlaveIDs(boolean includeDeleted) throws KettleException
getSlaveIDs
in interface Repository
KettleException
public ObjectId[] getClusterSlaveIDs(ObjectId id_cluster_schema) throws KettleException
KettleException
public String[] getSlaveNames(boolean includeDeleted) throws KettleException
getSlaveNames
in interface Repository
KettleException
public List<SlaveServer> getSlaveServers() throws KettleException
getSlaveServers
in interface Repository
KettleException
public boolean getStepAttributeBoolean(ObjectId id_step, int nr, String code, boolean def) throws KettleException
getStepAttributeBoolean
in interface Repository
KettleException
public boolean getStepAttributeBoolean(ObjectId id_step, int nr, String code) throws KettleException
getStepAttributeBoolean
in interface Repository
KettleException
public boolean getStepAttributeBoolean(ObjectId id_step, String code) throws KettleException
getStepAttributeBoolean
in interface Repository
KettleException
public long getStepAttributeInteger(ObjectId id_step, int nr, String code) throws KettleException
getStepAttributeInteger
in interface Repository
KettleException
public long getStepAttributeInteger(ObjectId id_step, String code) throws KettleException
getStepAttributeInteger
in interface Repository
KettleException
public String getStepAttributeString(ObjectId id_step, int nr, String code) throws KettleException
getStepAttributeString
in interface Repository
KettleException
public String getStepAttributeString(ObjectId id_step, String code) throws KettleException
getStepAttributeString
in interface Repository
KettleException
public boolean getJobEntryAttributeBoolean(ObjectId id_jobentry, String code) throws KettleException
getJobEntryAttributeBoolean
in interface Repository
KettleException
public boolean getJobEntryAttributeBoolean(ObjectId id_jobentry, int nr, String code) throws KettleException
getJobEntryAttributeBoolean
in interface Repository
KettleException
public boolean getJobEntryAttributeBoolean(ObjectId id_jobentry, String code, boolean def) throws KettleException
getJobEntryAttributeBoolean
in interface Repository
KettleException
public long getJobEntryAttributeInteger(ObjectId id_jobentry, String code) throws KettleException
getJobEntryAttributeInteger
in interface Repository
KettleException
public long getJobEntryAttributeInteger(ObjectId id_jobentry, int nr, String code) throws KettleException
getJobEntryAttributeInteger
in interface Repository
KettleException
public String getJobEntryAttributeString(ObjectId id_jobentry, String code) throws KettleException
getJobEntryAttributeString
in interface Repository
KettleException
public String getJobEntryAttributeString(ObjectId id_jobentry, int nr, String code) throws KettleException
getJobEntryAttributeString
in interface Repository
KettleException
public ObjectId[] getSubConditionIDs(ObjectId id_condition) throws KettleException
KettleException
public ObjectId[] getSubDirectoryIDs(ObjectId id_directory) throws KettleException
KettleException
public ObjectId[] getTransNoteIDs(ObjectId id_transformation) throws KettleException
KettleException
public ObjectId[] getTransformationClusterSchemaIDs(ObjectId id_transformation) throws KettleException
KettleException
public ObjectId getTransformationID(String name, RepositoryDirectoryInterface repositoryDirectory) throws KettleException
getTransformationID
in interface Repository
KettleException
public String[] getTransformationNames(ObjectId id_directory, boolean includeDeleted) throws KettleException
getTransformationNames
in interface Repository
KettleException
public ObjectId[] getTransformationPartitionSchemaIDs(ObjectId id_transformation) throws KettleException
KettleException
public String[] getTransformationsUsingCluster(ObjectId id_cluster) throws KettleException
KettleException
public String[] getTransformationsUsingDatabase(ObjectId id_database) throws KettleException
getTransformationsUsingDatabase
in interface Repository
KettleException
public String[] getTransformationsUsingPartitionSchema(ObjectId id_partition_schema) throws KettleException
KettleException
public String[] getTransformationsUsingSlave(ObjectId id_slave) throws KettleException
KettleException
public String getVersion()
Repository
getVersion
in interface Repository
public ObjectId insertClusterSlave(ClusterSchema clusterSchema, SlaveServer slaveServer) throws KettleException
KettleException
public void insertJobEntryDatabase(ObjectId id_job, ObjectId id_jobentry, ObjectId id_database) throws KettleException
insertJobEntryDatabase
in interface Repository
KettleException
public void insertJobNote(ObjectId id_job, ObjectId id_note) throws KettleException
KettleException
public ObjectId insertLogEntry(String description) throws KettleException
Repository
insertLogEntry
in interface Repository
KettleException
public void insertStepDatabase(ObjectId id_transformation, ObjectId id_step, ObjectId id_database) throws KettleException
insertStepDatabase
in interface Repository
KettleException
public void insertTransNote(ObjectId id_transformation, ObjectId id_note) throws KettleException
KettleException
public void insertTransStepCondition(ObjectId id_transformation, ObjectId id_step, ObjectId id_condition) throws KettleException
KettleException
public ObjectId insertTransformationCluster(ObjectId id_transformation, ObjectId id_cluster) throws KettleException
KettleException
public ObjectId insertTransformationPartitionSchema(ObjectId id_transformation, ObjectId id_partition_schema) throws KettleException
KettleException
public ObjectId insertTransformationSlave(ObjectId id_transformation, ObjectId id_slave) throws KettleException
KettleException
public ClusterSchema loadClusterSchema(ObjectId id_cluster_schema, List<SlaveServer> slaveServers, String versionName) throws KettleException
loadClusterSchema
in interface Repository
KettleException
public Condition loadCondition(ObjectId id_condition) throws KettleException
KettleException
public Condition loadConditionFromStepAttribute(ObjectId id_step, String code) throws KettleException
Repository
loadConditionFromStepAttribute
in interface Repository
KettleException
public Node loadNodeFromXML(ObjectId id, String tag) throws KettleException
KettleException
public DatabaseMeta loadDatabaseMeta(ObjectId id_database, String versionName) throws KettleException
Repository
loadDatabaseMeta
in interface Repository
id_database
- the id of the database connection to loadversionName
- the revision to load. Specify null to load the last version.
KettleException
- in case something goes wrong with database, connection, etc.public DatabaseMeta loadDatabaseMetaFromJobEntryAttribute(ObjectId id_jobentry, String nameCode, String idCode, List<DatabaseMeta> databases) throws KettleException
Repository
loadDatabaseMetaFromJobEntryAttribute
in interface Repository
KettleException
public DatabaseMeta loadDatabaseMetaFromJobEntryAttribute(ObjectId id_jobentry, String nameCode, int nr, String idCode, List<DatabaseMeta> databases) throws KettleException
Repository
loadDatabaseMetaFromJobEntryAttribute
in interface Repository
KettleException
public void saveDatabaseMetaJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, String nameCode, String idCode, DatabaseMeta database) throws KettleException
Repository
saveDatabaseMetaJobEntryAttribute
in interface Repository
KettleException
public void saveDatabaseMetaJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, int nr, String nameCode, String idCode, DatabaseMeta database) throws KettleException
Repository
saveDatabaseMetaJobEntryAttribute
in interface Repository
KettleException
public DatabaseMeta loadDatabaseMetaFromStepAttribute(ObjectId id_step, String code, List<DatabaseMeta> databases) throws KettleException
Repository
loadDatabaseMetaFromStepAttribute
in interface Repository
KettleException
public JobMeta loadJob(String jobname, RepositoryDirectoryInterface repdir, ProgressMonitorListener monitor, String versionName) throws KettleException
Repository
loadJob
in interface Repository
jobname
- the namerepdir
- the directorymonitor
- the progress monitor or nullversionName
- the revision to load. Specify null to load the last version.
KettleException
public PartitionSchema loadPartitionSchema(ObjectId id_partition_schema, String versionName) throws KettleException
loadPartitionSchema
in interface Repository
KettleException
public RepositoryDirectoryInterface loadRepositoryDirectoryTree() throws KettleException
loadRepositoryDirectoryTree
in interface Repository
KettleException
public RepositoryDirectoryInterface loadRepositoryDirectoryTree(RepositoryDirectoryInterface dir) throws KettleException
KettleException
public RepositoryDirectoryInterface findDirectory(String directory) throws KettleException
findDirectory
in interface Repository
KettleException
public RepositoryDirectoryInterface findDirectory(ObjectId directory) throws KettleException
findDirectory
in interface Repository
KettleException
public List<RepositoryElementMetaInterface> getTransformationObjects(ObjectId idDirectory, boolean includeDeleted) throws KettleException
getTransformationObjects
in interface Repository
KettleException
public List<RepositoryElementMetaInterface> getJobObjects(ObjectId id_directory, boolean includeDeleted) throws KettleException
getJobObjects
in interface Repository
KettleException
public int getNrSubDirectories(ObjectId id_directory) throws KettleException
KettleException
public SlaveServer loadSlaveServer(ObjectId id_slave_server, String versionName) throws KettleException
loadSlaveServer
in interface Repository
KettleException
public TransMeta loadTransformation(String transname, RepositoryDirectoryInterface repdir, ProgressMonitorListener monitor, boolean setInternalVariables, String versionName) throws KettleException
Repository
loadTransformation
in interface Repository
transname
- the name of the transformation to loadmonitor
- 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.
KettleException
public void readDatabases(HasDatabasesInterface transMeta, boolean overWriteShared) throws KettleException
TransMeta
- The transformation to load into.overWriteShared
- if an object with the same name exists, overwrite
KettleException
public ValueMetaAndData loadValueMetaAndData(ObjectId id_value) throws KettleException
KettleException
public void moveJob(String jobname, ObjectId id_directory_from, ObjectId id_directory_to) throws KettleException
KettleException
public void moveTransformation(String transname, ObjectId id_directory_from, ObjectId id_directory_to) throws KettleException
KettleException
public List<DatabaseMeta> readDatabases() throws KettleException
Repository
readDatabases
in interface Repository
KettleException
public void clearSharedObjectCache()
clearSharedObjectCache
in interface Repository
public SharedObjects readJobMetaSharedObjects(JobMeta jobMeta) throws KettleException
readJobMetaSharedObjects
in interface Repository
KettleException
public SharedObjects readTransSharedObjects(TransMeta transMeta) throws KettleException
readTransSharedObjects
in interface Repository
KettleException
public ObjectId renameJob(ObjectId id_job, RepositoryDirectoryInterface newDir, String newName) throws KettleException
Repository
renameJob
in interface Repository
id_job
- The ObjectId of the job to movenewDir
- 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)
KettleException
public ObjectId renameRepositoryDirectory(ObjectId id, RepositoryDirectoryInterface newParentDir, String newName) throws KettleException
Repository
renameRepositoryDirectory
in interface Repository
id
- The ObjectId of the repository directory to movenewParentDir
- 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)
KettleException
public ObjectId renameTransformation(ObjectId id_transformation, RepositoryDirectoryInterface newDir, String newName) throws KettleException
Repository
renameTransformation
in interface Repository
id_transformation
- The ObjectId of the transformation to movenewDir
- 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)
KettleException
public ObjectId saveCondition(Condition condition) throws KettleException
KettleException
public ObjectId saveCondition(Condition condition, ObjectId id_condition_parent) throws KettleException
KettleException
public void saveConditionStepAttribute(ObjectId id_transformation, ObjectId id_step, String code, Condition condition) throws KettleException
Repository
saveConditionStepAttribute
in interface Repository
KettleException
public void saveDatabaseMetaJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, String code, DatabaseMeta database) throws KettleException
KettleException
public void saveDatabaseMetaStepAttribute(ObjectId id_transformation, ObjectId id_step, String code, DatabaseMeta database) throws KettleException
Repository
saveDatabaseMetaStepAttribute
in interface Repository
KettleException
public void saveJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, int nr, String code, String value) throws KettleException
saveJobEntryAttribute
in interface Repository
KettleException
public void saveJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, String code, String value) throws KettleException
saveJobEntryAttribute
in interface Repository
KettleException
public void saveJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, int nr, String code, boolean value) throws KettleException
saveJobEntryAttribute
in interface Repository
KettleException
public void saveJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, String code, boolean value) throws KettleException
saveJobEntryAttribute
in interface Repository
KettleException
public void saveJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, int nr, String code, long value) throws KettleException
saveJobEntryAttribute
in interface Repository
KettleException
public void saveJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, String code, long value) throws KettleException
saveJobEntryAttribute
in interface Repository
KettleException
public void saveStepAttribute(ObjectId id_transformation, ObjectId id_step, int nr, String code, String value) throws KettleException
saveStepAttribute
in interface Repository
KettleException
public void saveStepAttribute(ObjectId id_transformation, ObjectId id_step, String code, String value) throws KettleException
saveStepAttribute
in interface Repository
KettleException
public void saveStepAttribute(ObjectId id_transformation, ObjectId id_step, int nr, String code, boolean value) throws KettleException
saveStepAttribute
in interface Repository
KettleException
public void saveStepAttribute(ObjectId id_transformation, ObjectId id_step, String code, boolean value) throws KettleException
saveStepAttribute
in interface Repository
KettleException
public void saveStepAttribute(ObjectId id_transformation, ObjectId id_step, int nr, String code, long value) throws KettleException
saveStepAttribute
in interface Repository
KettleException
public void saveStepAttribute(ObjectId id_transformation, ObjectId id_step, String code, long value) throws KettleException
saveStepAttribute
in interface Repository
KettleException
public void saveStepAttribute(ObjectId id_transformation, ObjectId id_step, int nr, String code, double value) throws KettleException
saveStepAttribute
in interface Repository
KettleException
public void saveStepAttribute(ObjectId id_transformation, ObjectId id_step, String code, double value) throws KettleException
saveStepAttribute
in interface Repository
KettleException
public void delUser(ObjectId id_user) throws KettleException
KettleException
public ObjectId getUserID(String login) throws KettleException
KettleException
public ObjectId[] getUserIDs() throws KettleException
KettleException
public IUser getUserInfo()
getUserInfo
in interface Repository
public String[] getUserLogins() throws KettleException
KettleException
public UserInfo loadUserInfo(String login) throws KettleException
KettleException
public UserInfo loadUserInfo(String login, String password) throws KettleException
KettleException
public void renameUser(ObjectId id_user, String newname) throws KettleException
KettleException
public void saveUserInfo(UserInfo userInfo) throws KettleException
KettleException
public int countNrJobEntryAttributes(ObjectId id_jobentry, String code) throws KettleException
countNrJobEntryAttributes
in interface Repository
KettleException
public int countNrStepAttributes(ObjectId id_step, String code) throws KettleException
countNrStepAttributes
in interface Repository
KettleException
public KettleFileRepositoryMeta getRepositoryMeta()
getRepositoryMeta
in interface Repository
public void setRepositoryMeta(KettleFileRepositoryMeta repositoryMeta)
repositoryMeta
- the repositoryMeta to setpublic void undeleteObject(RepositoryElementMetaInterface repositoryObject) throws KettleException
Repository
undeleteObject
in interface Repository
KettleException
- get throws in case something goes horribly wrong.public List<RepositoryElementMetaInterface> getJobAndTransformationObjects(ObjectId id_directory, boolean includeDeleted) throws KettleException
Repository
Repository.getJobObjects(ObjectId, boolean)
and Repository.getTransformationObjects(ObjectId, boolean)
into one
operation.
getJobAndTransformationObjects
in interface Repository
id_directory
- directoryincludeDeleted
- true to return deleted objects
KettleException
- In case something goes wrongpublic IRepositoryService getService(Class<? extends IRepositoryService> clazz) throws KettleException
Repository
getService
in interface Repository
KettleException
- in case something goes horribly wrong.public List<Class<? extends IRepositoryService>> getServiceInterfaces() throws KettleException
Repository
getServiceInterfaces
in interface Repository
KettleException
- in case something goes horribly wrong.public boolean hasService(Class<? extends IRepositoryService> clazz) throws KettleException
Repository
hasService
in interface Repository
KettleException
- in case something goes horribly wrong.public RepositoryDirectoryInterface getDefaultSaveDirectory(RepositoryElementInterface repositoryElement) throws KettleException
getDefaultSaveDirectory
in interface Repository
KettleException
public RepositoryDirectoryInterface getUserHomeDirectory() throws KettleException
getUserHomeDirectory
in interface Repository
KettleException
public RepositoryObject getObjectInformation(ObjectId objectId, RepositoryObjectType objectType) throws KettleException
Repository
getObjectInformation
in interface Repository
objectId
- The ID of the object to get more information about.objectType
- The type of object to investigate.
KettleException
- In case there was a loading problem.public JobMeta loadJob(ObjectId idJob, String versionLabel) throws KettleException
Repository
loadJob
in interface Repository
idJob
- the id of the jobversionLabel
- version to load. Specify null to load the last version.
KettleException
public TransMeta loadTransformation(ObjectId idTransformation, String versionLabel) throws KettleException
Repository
loadTransformation
in interface Repository
idTransformation
- the id of the transformation to loadversionLabel
- version to load. Specify null to load the last version.
KettleException
public String getConnectMessage()
Repository
getConnectMessage
in interface Repository
public IRepositoryExporter getExporter()
getExporter
in interface Repository
public IRepositoryImporter getImporter()
getImporter
in interface Repository
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |