org.pentaho.di.repository

Class AbstractRepository

java.lang.Object

org.pentaho.di.repository.AbstractRepository

All Implemented Interfaces:

Repository

Direct Known Subclasses:

KettleDatabaseRepositoryBase, KettleFileRepository

public abstract class AbstractRepository
extends Object
implements Repository

Implementing convenience methods that can be described in terms of other methods in the interface

Constructor Summary

Constructors

Constructor and Description
AbstractRepository()

Method Summary

Modifier and Type	Method and Description
void	create()
boolean	getJobEntryAttributeBoolean(ObjectId id_jobentry, int nr, String code)
abstract boolean	getJobEntryAttributeBoolean(ObjectId id_jobentry, int nr, String code, boolean def)
boolean	getJobEntryAttributeBoolean(ObjectId id_jobentry, String code)
boolean	getJobEntryAttributeBoolean(ObjectId id_jobentry, String code, boolean def)
long	getJobEntryAttributeInteger(ObjectId id_jobentry, String code)
String	getJobEntryAttributeString(ObjectId id_jobentry, String code)
boolean	getStepAttributeBoolean(ObjectId id_step, int nr, String code)
boolean	getStepAttributeBoolean(ObjectId id_step, String code)
long	getStepAttributeInteger(ObjectId id_step, String code)
String	getStepAttributeString(ObjectId id_step, String code)
org.pentaho.platform.api.repository2.unified.IUnifiedRepository	getUnderlyingRepository()
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.
void	save(RepositoryElementInterface repoElement, String versionComment, ProgressMonitorListener monitor)
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	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	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)
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, getMetaStore, getName, getObjectInformation, getPartitionSchemaID, getPartitionSchemaIDs, getPartitionSchemaNames, getRepositoryMeta, getSecurityManager, getSecurityProvider, getService, getServiceInterfaces, getSlaveID, getSlaveIDs, getSlaveNames, getSlaveServers, getStepAttributeBoolean, getStepAttributeInteger, getStepAttributeString, getTransformationID, getTransformationNames, getTransformationObjects, getTransformationsUsingDatabase, 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 Detail

AbstractRepository

public AbstractRepository()

Method Detail

getJobEntryAttributeInteger

public long getJobEntryAttributeInteger(ObjectId id_jobentry,
                                        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

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,
                                           String code,
                                           boolean def)
                                    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 abstract boolean getJobEntryAttributeBoolean(ObjectId id_jobentry,
                                                    int nr,
                                                    String code,
                                                    boolean def)
                                             throws KettleException

Throws:

KettleException

getStepAttributeBoolean

public boolean getStepAttributeBoolean(ObjectId id_step,
                                       String code)
                                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

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,
                                     String code)
                              throws KettleException

Specified by:

getStepAttributeString 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,
                              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,
                              long 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

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,
                                  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,
                                  String value)
                           throws KettleException

Specified by:

saveJobEntryAttribute in interface Repository

Throws:

KettleException

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

save

public void save(RepositoryElementInterface repoElement,
                 String versionComment,
                 ProgressMonitorListener monitor)
          throws KettleException

Specified by:

save in interface Repository

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

test

public boolean test()

create

public void create()

getUnderlyingRepository

public org.pentaho.platform.api.repository2.unified.IUnifiedRepository getUnderlyingRepository()

Specified by:

getUnderlyingRepository in interface Repository

Returns:

repository for connect to server