Package org.pentaho.di.repository
Class AbstractRepository
java.lang.Object
org.pentaho.di.repository.AbstractRepository
- All Implemented Interfaces:
Repository
- Direct Known Subclasses:
KettleDatabaseRepositoryBase
,KettleFileRepository
Implementing convenience methods that can be described in terms of other methods in the interface
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
create()
boolean
getJobEntryAttributeBoolean
(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code) abstract boolean
getJobEntryAttributeBoolean
(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code, boolean def) boolean
getJobEntryAttributeBoolean
(org.pentaho.di.repository.ObjectId id_jobentry, String code) boolean
getJobEntryAttributeBoolean
(org.pentaho.di.repository.ObjectId id_jobentry, String code, boolean def) long
getJobEntryAttributeInteger
(org.pentaho.di.repository.ObjectId id_jobentry, String code) getJobEntryAttributeString
(org.pentaho.di.repository.ObjectId id_jobentry, String code) boolean
getStepAttributeBoolean
(org.pentaho.di.repository.ObjectId id_step, int nr, String code) boolean
getStepAttributeBoolean
(org.pentaho.di.repository.ObjectId id_step, String code) long
getStepAttributeInteger
(org.pentaho.di.repository.ObjectId id_step, String code) getStepAttributeString
(org.pentaho.di.repository.ObjectId id_step, String code) org.pentaho.platform.api.repository2.unified.IUnifiedRepository
org.pentaho.di.core.database.DatabaseMeta
loadDatabaseMetaFromJobEntryAttribute
(org.pentaho.di.repository.ObjectId id_jobentry, String nameCode, String idCode, List<org.pentaho.di.core.database.DatabaseMeta> databases) This method is introduced to avoid having to go over an integer/string/whatever in the interface and the job entry code.void
save
(org.pentaho.di.repository.RepositoryElementInterface repoElement, String versionComment, org.pentaho.di.core.ProgressMonitorListener monitor) void
saveDatabaseMetaJobEntryAttribute
(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, String nameCode, String idCode, org.pentaho.di.core.database.DatabaseMeta database) This method saves the object ID of the database object (if not null) in the job entry attributesvoid
saveJobEntryAttribute
(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, String code, boolean value) void
saveJobEntryAttribute
(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, String code, long value) void
saveJobEntryAttribute
(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, String code, String value) void
saveStepAttribute
(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, boolean value) void
saveStepAttribute
(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, double value) void
saveStepAttribute
(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, long value) void
saveStepAttribute
(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, String value) boolean
test()
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.pentaho.di.repository.Repository
clearSharedObjectCache, connect, countNrJobEntryAttributes, countNrStepAttributes, createRepositoryDirectory, deleteClusterSchema, deleteDatabaseMeta, deleteJob, deletePartitionSchema, deleteRepositoryDirectory, deleteSlave, deleteTransformation, disconnect, exists, findDirectory, findDirectory, getClusterID, getClusterIDs, getClusterNames, getConnectMessage, getDatabaseID, getDatabaseIDs, getDatabaseNames, getDefaultSaveDirectory, getDirectoryNames, getExporter, getImporter, getJobAndTransformationObjects, getJobEntryAttributeInteger, getJobEntryAttributeString, getJobId, getJobNames, getJobObjects, getJobsUsingDatabase, getLog, getName, getObjectInformation, getPartitionSchemaID, getPartitionSchemaIDs, getPartitionSchemaNames, getRepositoryMeta, getRepositoryMetaStore, getSecurityManager, getSecurityProvider, getService, getServiceInterfaces, getSlaveID, getSlaveIDs, getSlaveNames, getSlaveServers, getStepAttributeBoolean, getStepAttributeInteger, getStepAttributeString, getTransformationID, getTransformationNames, getTransformationObjects, getTransformationsUsingDatabase, getUri, getUserHomeDirectory, getUserInfo, getVersion, hasService, init, insertJobEntryDatabase, insertLogEntry, insertStepDatabase, isConnected, loadClusterSchema, loadConditionFromStepAttribute, loadDatabaseMeta, loadDatabaseMetaFromJobEntryAttribute, loadDatabaseMetaFromStepAttribute, loadJob, loadJob, loadPartitionSchema, loadRepositoryDirectoryTree, loadSlaveServer, loadTransformation, loadTransformation, readDatabases, readJobMetaSharedObjects, readTransSharedObjects, renameJob, renameJob, renameRepositoryDirectory, renameTransformation, renameTransformation, save, save, saveConditionStepAttribute, saveDatabaseMetaJobEntryAttribute, saveDatabaseMetaStepAttribute, saveJobEntryAttribute, saveJobEntryAttribute, saveJobEntryAttribute, saveRepositoryDirectory, saveStepAttribute, saveStepAttribute, saveStepAttribute, saveStepAttribute, undeleteObject
-
Constructor Details
-
AbstractRepository
public AbstractRepository()
-
-
Method Details
-
getJobEntryAttributeInteger
public long getJobEntryAttributeInteger(org.pentaho.di.repository.ObjectId id_jobentry, String code) throws org.pentaho.di.core.exception.KettleException - Specified by:
getJobEntryAttributeInteger
in interfaceRepository
- Throws:
org.pentaho.di.core.exception.KettleException
-
getJobEntryAttributeString
public String getJobEntryAttributeString(org.pentaho.di.repository.ObjectId id_jobentry, String code) throws org.pentaho.di.core.exception.KettleException - Specified by:
getJobEntryAttributeString
in interfaceRepository
- Throws:
org.pentaho.di.core.exception.KettleException
-
getJobEntryAttributeBoolean
public boolean getJobEntryAttributeBoolean(org.pentaho.di.repository.ObjectId id_jobentry, String code) throws org.pentaho.di.core.exception.KettleException - Specified by:
getJobEntryAttributeBoolean
in interfaceRepository
- Throws:
org.pentaho.di.core.exception.KettleException
-
getJobEntryAttributeBoolean
public boolean getJobEntryAttributeBoolean(org.pentaho.di.repository.ObjectId id_jobentry, String code, boolean def) throws org.pentaho.di.core.exception.KettleException - Specified by:
getJobEntryAttributeBoolean
in interfaceRepository
- Throws:
org.pentaho.di.core.exception.KettleException
-
getJobEntryAttributeBoolean
public boolean getJobEntryAttributeBoolean(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code) throws org.pentaho.di.core.exception.KettleException - Specified by:
getJobEntryAttributeBoolean
in interfaceRepository
- Throws:
org.pentaho.di.core.exception.KettleException
-
getJobEntryAttributeBoolean
public abstract boolean getJobEntryAttributeBoolean(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code, boolean def) throws org.pentaho.di.core.exception.KettleException - Throws:
org.pentaho.di.core.exception.KettleException
-
getStepAttributeBoolean
public boolean getStepAttributeBoolean(org.pentaho.di.repository.ObjectId id_step, String code) throws org.pentaho.di.core.exception.KettleException - Specified by:
getStepAttributeBoolean
in interfaceRepository
- Throws:
org.pentaho.di.core.exception.KettleException
-
getStepAttributeBoolean
public boolean getStepAttributeBoolean(org.pentaho.di.repository.ObjectId id_step, int nr, String code) throws org.pentaho.di.core.exception.KettleException - Specified by:
getStepAttributeBoolean
in interfaceRepository
- Throws:
org.pentaho.di.core.exception.KettleException
-
getStepAttributeInteger
public long getStepAttributeInteger(org.pentaho.di.repository.ObjectId id_step, String code) throws org.pentaho.di.core.exception.KettleException - Specified by:
getStepAttributeInteger
in interfaceRepository
- Throws:
org.pentaho.di.core.exception.KettleException
-
getStepAttributeString
public String getStepAttributeString(org.pentaho.di.repository.ObjectId id_step, String code) throws org.pentaho.di.core.exception.KettleException - Specified by:
getStepAttributeString
in interfaceRepository
- Throws:
org.pentaho.di.core.exception.KettleException
-
saveStepAttribute
public void saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, boolean value) throws org.pentaho.di.core.exception.KettleException - Specified by:
saveStepAttribute
in interfaceRepository
- Throws:
org.pentaho.di.core.exception.KettleException
-
saveStepAttribute
public void saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, double value) throws org.pentaho.di.core.exception.KettleException - Specified by:
saveStepAttribute
in interfaceRepository
- Throws:
org.pentaho.di.core.exception.KettleException
-
saveStepAttribute
public void saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, long value) throws org.pentaho.di.core.exception.KettleException - Specified by:
saveStepAttribute
in interfaceRepository
- Throws:
org.pentaho.di.core.exception.KettleException
-
saveStepAttribute
public void saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, String code, String value) throws org.pentaho.di.core.exception.KettleException - Specified by:
saveStepAttribute
in interfaceRepository
- Throws:
org.pentaho.di.core.exception.KettleException
-
saveJobEntryAttribute
public void saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, String code, boolean value) throws org.pentaho.di.core.exception.KettleException - Specified by:
saveJobEntryAttribute
in interfaceRepository
- Throws:
org.pentaho.di.core.exception.KettleException
-
saveJobEntryAttribute
public void saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, String code, long value) throws org.pentaho.di.core.exception.KettleException - Specified by:
saveJobEntryAttribute
in interfaceRepository
- Throws:
org.pentaho.di.core.exception.KettleException
-
saveJobEntryAttribute
public void saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, String code, String value) throws org.pentaho.di.core.exception.KettleException - Specified by:
saveJobEntryAttribute
in interfaceRepository
- Throws:
org.pentaho.di.core.exception.KettleException
-
loadDatabaseMetaFromJobEntryAttribute
public org.pentaho.di.core.database.DatabaseMeta loadDatabaseMetaFromJobEntryAttribute(org.pentaho.di.repository.ObjectId id_jobentry, String nameCode, String idCode, List<org.pentaho.di.core.database.DatabaseMeta> databases) throws org.pentaho.di.core.exception.KettleException Description copied from interface:Repository
This method is introduced to avoid having to go over an integer/string/whatever in the interface and the job entry code.- Specified by:
loadDatabaseMetaFromJobEntryAttribute
in interfaceRepository
- Returns:
- Throws:
org.pentaho.di.core.exception.KettleException
-
save
public void save(org.pentaho.di.repository.RepositoryElementInterface repoElement, String versionComment, org.pentaho.di.core.ProgressMonitorListener monitor) throws org.pentaho.di.core.exception.KettleException - Specified by:
save
in interfaceRepository
- Throws:
org.pentaho.di.core.exception.KettleException
-
saveDatabaseMetaJobEntryAttribute
public void saveDatabaseMetaJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, String nameCode, String idCode, org.pentaho.di.core.database.DatabaseMeta database) throws org.pentaho.di.core.exception.KettleException Description copied from interface:Repository
This method saves the object ID of the database object (if not null) in the job entry attributes- Specified by:
saveDatabaseMetaJobEntryAttribute
in interfaceRepository
- Throws:
org.pentaho.di.core.exception.KettleException
-
test
public boolean test() -
create
public void create() -
getUnderlyingRepository
public org.pentaho.platform.api.repository2.unified.IUnifiedRepository getUnderlyingRepository()- Specified by:
getUnderlyingRepository
in interfaceRepository
- Returns:
- repository for connect to server
-