Package org.pentaho.di.repository.kdr.delegates

Class KettleDatabaseRepositoryConnectionDelegate

java.lang.Object
org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate
org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryConnectionDelegate
public class KettleDatabaseRepositoryConnectionDelegate extends KettleDatabaseRepositoryBaseDelegate

  • Field Details

    • loggingObject

      public static final org.pentaho.di.core.logging.LoggingObjectInterface loggingObject

    • REQUIRED_MAJOR_VERSION

      public static final int REQUIRED_MAJOR_VERSION
      See Also:

    • REQUIRED_MINOR_VERSION

      public static final int REQUIRED_MINOR_VERSION
      See Also:

    • KEY_POSITIONS

      protected static final int[] KEY_POSITIONS

    • database

      protected org.pentaho.di.core.database.Database database

    • databaseMeta

      protected org.pentaho.di.core.database.DatabaseMeta databaseMeta

    • majorVersion

      protected int majorVersion

    • minorVersion

      protected int minorVersion

    • psStepAttributesLookup

      protected PreparedStatement psStepAttributesLookup

    • psStepAttributesInsert

      protected PreparedStatement psStepAttributesInsert

    • psTransAttributesLookup

      protected PreparedStatement psTransAttributesLookup

    • psTransAttributesInsert

      protected PreparedStatement psTransAttributesInsert

    • psJobAttributesLookup

      protected PreparedStatement psJobAttributesLookup

    • psJobAttributesInsert

      protected PreparedStatement psJobAttributesInsert

    • stepAttributesBuffer

      protected List<Object[]> stepAttributesBuffer

    • stepAttributesRowMeta

      protected org.pentaho.di.core.row.RowMetaInterface stepAttributesRowMeta

    • pstmt_entry_attributes

      protected PreparedStatement pstmt_entry_attributes

    • useBatchProcessing

      protected boolean useBatchProcessing

    • sqlMap

      protected ConcurrentHashMap<String,PreparedStatement> sqlMap

  • Constructor Details

    • KettleDatabaseRepositoryConnectionDelegate

      public KettleDatabaseRepositoryConnectionDelegate(KettleDatabaseRepository repository, org.pentaho.di.core.database.DatabaseMeta databaseMeta)

  • Method Details

    • connect

      public void connect() throws org.pentaho.di.core.exception.KettleException
      Connect to the repository
      Throws:
      org.pentaho.di.core.exception.KettleException

    • connect

      public void connect(boolean no_lookup) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • connect

      public void connect(boolean no_lookup, boolean ignoreVersion) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getRequiredVersion

      public static final String getRequiredVersion()
      Get the required repository version for this version of Kettle.
      Returns:
      the required repository version for this version of Kettle.

    • verifyVersion

      protected void verifyVersion() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • disconnect

      public void disconnect()

    • setAutoCommit

      public void setAutoCommit(boolean autocommit)

    • commit

      public void commit() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • rollback

      public void rollback()

    • getDatabase

      public org.pentaho.di.core.database.Database getDatabase()
      Returns:
      the database

    • setDatabase

      public void setDatabase(org.pentaho.di.core.database.Database database)
      Parameters:
      database - the database to set

    • getDatabaseMeta

      public org.pentaho.di.core.database.DatabaseMeta getDatabaseMeta()
      Returns:
      the databaseMeta

    • setDatabaseMeta

      public void setDatabaseMeta(org.pentaho.di.core.database.DatabaseMeta databaseMeta)
      Parameters:
      databaseMeta - the databaseMeta to set

    • getMajorVersion

      public int getMajorVersion()
      Returns:
      the majorVersion

    • setMajorVersion

      public void setMajorVersion(int majorVersion)
      Parameters:
      majorVersion - the majorVersion to set

    • getMinorVersion

      public int getMinorVersion()
      Returns:
      the minorVersion

    • setMinorVersion

      public void setMinorVersion(int minorVersion)
      Parameters:
      minorVersion - the minorVersion to set

    • getVersion

      public String getVersion()
      Get the repository version.
      Returns:
      The repository version as major version + "." + minor version

    • fillStepAttributesBuffer

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

    • getStepAttributesBuffer

      public List<Object[]> getStepAttributesBuffer()
      Returns:
      Returns the stepAttributesBuffer.

    • setStepAttributesBuffer

      public void setStepAttributesBuffer(List<Object[]> stepAttributesBuffer)
      Parameters:
      stepAttributesBuffer - The stepAttributesBuffer to set.

    • setLookupStepAttribute

      public void setLookupStepAttribute() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • setLookupTransAttribute

      public void setLookupTransAttribute() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • closeTransAttributeLookupPreparedStatement

      public void closeTransAttributeLookupPreparedStatement() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • setLookupJobAttribute

      public void setLookupJobAttribute() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • closeJobAttributeLookupPreparedStatement

      public void closeJobAttributeLookupPreparedStatement() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • closeStepAttributeLookupPreparedStatement

      public void closeStepAttributeLookupPreparedStatement() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • closeStepAttributeInsertPreparedStatement

      public void closeStepAttributeInsertPreparedStatement() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • closeTransAttributeInsertPreparedStatement

      public void closeTransAttributeInsertPreparedStatement() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • closeJobAttributeInsertPreparedStatement

      public void closeJobAttributeInsertPreparedStatement() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getTransAttributeRow

      public org.pentaho.di.core.RowMetaAndData getTransAttributeRow(org.pentaho.di.repository.ObjectId id_transformation, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobAttributeRow

      public org.pentaho.di.core.RowMetaAndData getJobAttributeRow(org.pentaho.di.repository.ObjectId id_job, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getStepAttributeInteger

      public long getStepAttributeInteger(org.pentaho.di.repository.ObjectId id_step, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • findStepAttributeID

      public org.pentaho.di.repository.ObjectId findStepAttributeID(org.pentaho.di.repository.ObjectId id_step, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getStepAttributeString

      public String getStepAttributeString(org.pentaho.di.repository.ObjectId id_step, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getStepAttributeBoolean

      public boolean getStepAttributeBoolean(org.pentaho.di.repository.ObjectId id_step, int nr, String code, boolean def) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveStepAttribute

      public org.pentaho.di.repository.ObjectId saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, long nr, String code, String value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveStepAttribute

      public org.pentaho.di.repository.ObjectId saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, long nr, String code, double value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveStepAttribute

      public org.pentaho.di.repository.ObjectId saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, long nr, String code, boolean value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • countNrStepAttributes

      public int countNrStepAttributes(org.pentaho.di.repository.ObjectId id_step, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getTransAttributeString

      public String getTransAttributeString(org.pentaho.di.repository.ObjectId id_transformation, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getTransAttributeBoolean

      public boolean getTransAttributeBoolean(org.pentaho.di.repository.ObjectId id_transformation, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getTransAttributeNumber

      public double getTransAttributeNumber(org.pentaho.di.repository.ObjectId id_transformation, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getTransAttributeInteger

      public long getTransAttributeInteger(org.pentaho.di.repository.ObjectId id_transformation, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • countNrTransAttributes

      public int countNrTransAttributes(org.pentaho.di.repository.ObjectId id_transformation, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getTransAttributes

      public List<Object[]> getTransAttributes(org.pentaho.di.repository.ObjectId id_transformation, String code, long nr) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getTransAttributesWithPrefix

      public List<Object[]> getTransAttributesWithPrefix(org.pentaho.di.repository.ObjectId id_transformation, String codePrefix) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobAttributeString

      public String getJobAttributeString(org.pentaho.di.repository.ObjectId id_job, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobAttributeBoolean

      public boolean getJobAttributeBoolean(org.pentaho.di.repository.ObjectId id_job, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobAttributeNumber

      public double getJobAttributeNumber(org.pentaho.di.repository.ObjectId id_job, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobAttributeInteger

      public long getJobAttributeInteger(org.pentaho.di.repository.ObjectId id_job, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • countNrJobAttributes

      public int countNrJobAttributes(org.pentaho.di.repository.ObjectId id_job, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobAttributes

      public List<Object[]> getJobAttributes(org.pentaho.di.repository.ObjectId id_job, String code, long nr) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobAttributesWithPrefix

      public List<Object[]> getJobAttributesWithPrefix(org.pentaho.di.repository.ObjectId jobId, String codePrefix) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveJobEntryAttribute

      public org.pentaho.di.repository.ObjectId saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, long nr, String code, String value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveJobEntryAttribute

      public org.pentaho.di.repository.ObjectId saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, long nr, String code, double value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • saveJobEntryAttribute

      public org.pentaho.di.repository.ObjectId saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, long nr, String code, boolean value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • insertJobEntryAttribute

      public org.pentaho.di.repository.ObjectId insertJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, long nr, String code, double value_num, String value_str) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextJobEntryAttributeID

      public org.pentaho.di.repository.LongObjectId getNextJobEntryAttributeID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextID

      public org.pentaho.di.repository.LongObjectId getNextID(String tableName, String fieldName) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • setLookupJobEntryAttribute

      public void setLookupJobEntryAttribute() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • closeLookupJobEntryAttribute

      public void closeLookupJobEntryAttribute() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobEntryAttributeInteger

      public long getJobEntryAttributeInteger(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobEntryAttributeNumber

      public double getJobEntryAttributeNumber(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobEntryAttributeString

      public String getJobEntryAttributeString(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobEntryAttributeBoolean

      public boolean getJobEntryAttributeBoolean(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code, boolean def) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • countNrJobEntryAttributes

      public int countNrJobEntryAttributes(org.pentaho.di.repository.ObjectId id_jobentry, String code) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getJobEntryAttributesWithPrefix

      public List<Object[]> getJobEntryAttributesWithPrefix(org.pentaho.di.repository.ObjectId jobId, org.pentaho.di.repository.ObjectId jobEntryId, String codePrefix) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextTransformationID

      public org.pentaho.di.repository.ObjectId getNextTransformationID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextJobID

      public org.pentaho.di.repository.ObjectId getNextJobID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextNoteID

      public org.pentaho.di.repository.ObjectId getNextNoteID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextLogID

      public org.pentaho.di.repository.ObjectId getNextLogID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextDatabaseID

      public org.pentaho.di.repository.ObjectId getNextDatabaseID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextDatabaseTypeID

      public org.pentaho.di.repository.ObjectId getNextDatabaseTypeID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextDatabaseConnectionTypeID

      public org.pentaho.di.repository.ObjectId getNextDatabaseConnectionTypeID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextLoglevelID

      public org.pentaho.di.repository.ObjectId getNextLoglevelID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextStepTypeID

      public org.pentaho.di.repository.ObjectId getNextStepTypeID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextStepID

      public org.pentaho.di.repository.ObjectId getNextStepID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextJobEntryID

      public org.pentaho.di.repository.ObjectId getNextJobEntryID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextJobEntryTypeID

      public org.pentaho.di.repository.ObjectId getNextJobEntryTypeID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextJobEntryCopyID

      public org.pentaho.di.repository.LongObjectId getNextJobEntryCopyID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextStepAttributeID

      public org.pentaho.di.repository.LongObjectId getNextStepAttributeID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextTransAttributeID

      public org.pentaho.di.repository.LongObjectId getNextTransAttributeID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextJobAttributeID

      public org.pentaho.di.repository.LongObjectId getNextJobAttributeID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextDatabaseAttributeID

      public org.pentaho.di.repository.LongObjectId getNextDatabaseAttributeID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextTransHopID

      public org.pentaho.di.repository.ObjectId getNextTransHopID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextJobHopID

      public org.pentaho.di.repository.ObjectId getNextJobHopID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextDepencencyID

      public org.pentaho.di.repository.ObjectId getNextDepencencyID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextPartitionSchemaID

      public org.pentaho.di.repository.ObjectId getNextPartitionSchemaID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextPartitionID

      public org.pentaho.di.repository.ObjectId getNextPartitionID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextTransformationPartitionSchemaID

      public org.pentaho.di.repository.ObjectId getNextTransformationPartitionSchemaID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextClusterID

      public org.pentaho.di.repository.ObjectId getNextClusterID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextSlaveServerID

      public org.pentaho.di.repository.ObjectId getNextSlaveServerID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextClusterSlaveID

      public org.pentaho.di.repository.ObjectId getNextClusterSlaveID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextTransformationSlaveID

      public org.pentaho.di.repository.ObjectId getNextTransformationSlaveID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextTransformationClusterID

      public org.pentaho.di.repository.ObjectId getNextTransformationClusterID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextConditionID

      public org.pentaho.di.repository.ObjectId getNextConditionID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextValueID

      public org.pentaho.di.repository.ObjectId getNextValueID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getNextUserID

      public org.pentaho.di.repository.ObjectId getNextUserID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • clearNextIDCounters

      public void clearNextIDCounters()

    • getNextDirectoryID

      public org.pentaho.di.repository.ObjectId getNextDirectoryID() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • insertStepAttribute

      public org.pentaho.di.repository.ObjectId insertStepAttribute(org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step, long nr, String code, double value_num, String value_str) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • insertTransAttribute

      public org.pentaho.di.repository.ObjectId insertTransAttribute(org.pentaho.di.repository.ObjectId id_transformation, long nr, String code, long value_num, String value_str) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • insertJobAttribute

      public org.pentaho.di.repository.ObjectId insertJobAttribute(org.pentaho.di.repository.ObjectId id_job, long nr, String code, long value_num, String value_str) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • updateTableRow

      public void updateTableRow(String tablename, String idfield, org.pentaho.di.core.RowMetaAndData values, org.pentaho.di.repository.ObjectId id) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • updateTableRow

      public void updateTableRow(String tablename, String idfield, org.pentaho.di.core.RowMetaAndData values) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getRepositoryObjects

      public List<org.pentaho.di.repository.RepositoryElementMetaInterface> getRepositoryObjects(String tableName, org.pentaho.di.repository.RepositoryObjectType objectType, org.pentaho.di.repository.ObjectId id_directory) throws org.pentaho.di.core.exception.KettleException
      Parameters:
      id_directory -
      Returns:
      A list of RepositoryObjects
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getIDs

      public org.pentaho.di.repository.ObjectId[] getIDs(String sql, org.pentaho.di.repository.ObjectId... objectId) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getStrings

      public String[] getStrings(String sql, org.pentaho.di.repository.ObjectId... objectId) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • convertLongList

      public static final org.pentaho.di.repository.ObjectId[] convertLongList(List<Long> list)

    • lockRepository

      public void lockRepository() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • unlockRepository

      public void unlockRepository() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getStepAttributesRowMeta

      public org.pentaho.di.core.row.RowMetaInterface getStepAttributesRowMeta()
      Returns:
      the stepAttributesRowMeta

    • isUseBatchProcessing

      public boolean isUseBatchProcessing()

    • setStepAttributesRowMeta

      public void setStepAttributesRowMeta(org.pentaho.di.core.row.RowMetaInterface stepAttributesRowMeta)
      Parameters:
      stepAttributesRowMeta - the stepAttributesRowMeta to set

    • getIDWithValue

      public org.pentaho.di.repository.LongObjectId getIDWithValue(String tablename, String idfield, String lookupfield, String value) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getValueToIdMap

      public Map<String,org.pentaho.di.repository.LongObjectId> getValueToIdMap(String tablename, String idfield, String lookupfield) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getIDsWithValues

      public org.pentaho.di.repository.LongObjectId[] getIDsWithValues(String tablename, String idfield, String lookupfield, String[] values) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getIDWithValue

      public org.pentaho.di.repository.ObjectId getIDWithValue(String tablename, String idfield, String lookupfield, String value, String lookupkey, org.pentaho.di.repository.ObjectId key) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getIDWithValue

      public org.pentaho.di.repository.ObjectId getIDWithValue(String tablename, String idfield, String[] lookupkey, org.pentaho.di.repository.ObjectId[] key) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getIDWithValue

      public org.pentaho.di.repository.LongObjectId getIDWithValue(String tablename, String idfield, String lookupfield, String value, String[] lookupkey, org.pentaho.di.repository.ObjectId[] key) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getOneRow

      public org.pentaho.di.core.RowMetaAndData getOneRow(String schemaAndTable, String keyfield, org.pentaho.di.repository.ObjectId id) throws org.pentaho.di.core.exception.KettleException
      This method should be called WITH AN ALREADY QUOTED schema and table
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getOneRow

      public org.pentaho.di.core.RowMetaAndData getOneRow(String sql) throws org.pentaho.di.core.exception.KettleDatabaseException
      Throws:
      org.pentaho.di.core.exception.KettleDatabaseException

    • getOneRow

      public org.pentaho.di.core.RowMetaAndData getOneRow(String sql, org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] rowData) throws org.pentaho.di.core.exception.KettleDatabaseException
      Throws:
      org.pentaho.di.core.exception.KettleDatabaseException

    • getStringWithID

      public String getStringWithID(String tablename, String keyfield, org.pentaho.di.repository.ObjectId id, String fieldname) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getRows

      public List<Object[]> getRows(String sql, int limit) throws org.pentaho.di.core.exception.KettleDatabaseException
      Throws:
      org.pentaho.di.core.exception.KettleDatabaseException

    • getReturnRowMeta

      public org.pentaho.di.core.row.RowMetaInterface getReturnRowMeta() throws org.pentaho.di.core.exception.KettleDatabaseException
      Throws:
      org.pentaho.di.core.exception.KettleDatabaseException

    • insertTableRow

      public void insertTableRow(String tablename, org.pentaho.di.core.RowMetaAndData values) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getDatabaseAttributes

      public Collection<org.pentaho.di.core.RowMetaAndData> getDatabaseAttributes(org.pentaho.di.repository.ObjectId id_database) throws org.pentaho.di.core.exception.KettleDatabaseException, org.pentaho.di.core.exception.KettleValueException
      Throws:
      org.pentaho.di.core.exception.KettleDatabaseException
      org.pentaho.di.core.exception.KettleValueException

    • getParameterMetaData

      public org.pentaho.di.core.RowMetaAndData getParameterMetaData(org.pentaho.di.repository.ObjectId... ids) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • performDelete

      public void performDelete(String sql, org.pentaho.di.repository.ObjectId... ids) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • closeAttributeLookupPreparedStatements

      public void closeAttributeLookupPreparedStatements() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • closeReadTransaction

      public void closeReadTransaction() throws org.pentaho.di.core.exception.KettleDatabaseException
      A MySQL InnoDB hack really... Doesn't like a lock in case there's been a read in another session. It considers it an open transaction.
      Throws:
      org.pentaho.di.core.exception.KettleDatabaseException

    • callRead

      public <V> V callRead(Callable<V> callable) throws org.pentaho.di.core.exception.KettleDatabaseException
      Throws:
      org.pentaho.di.core.exception.KettleDatabaseException