org.pentaho.di.repository.kdr.delegates
Class KettleDatabaseRepositoryConnectionDelegate

java.lang.Object
  extended by org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate
      extended by org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryConnectionDelegate

public class KettleDatabaseRepositoryConnectionDelegate
extends KettleDatabaseRepositoryBaseDelegate


Field Summary
static LoggingObjectInterface loggingObject
           
static int REQUIRED_MAJOR_VERSION
           
static int REQUIRED_MINOR_VERSION
           
 
Constructor Summary
KettleDatabaseRepositoryConnectionDelegate(KettleDatabaseRepository repository, DatabaseMeta databaseMeta)
           
 
Method Summary
 void clearNextIDCounters()
           
 void closeJobAttributeInsertPreparedStatement()
           
 void closeJobAttributeLookupPreparedStatement()
           
 void closeLookupJobEntryAttribute()
           
 void closeStepAttributeInsertPreparedStatement()
           
 void closeStepAttributeLookupPreparedStatement()
           
 void closeTransAttributeInsertPreparedStatement()
           
 void closeTransAttributeLookupPreparedStatement()
           
 void commit()
           
 void connect()
          Connect to the repository
 void connect(boolean no_lookup)
           
 void connect(boolean no_lookup, boolean ignoreVersion)
           
static ObjectId[] convertLongList(List<Long> list)
           
 int countNrJobAttributes(ObjectId id_job, String code)
           
 int countNrJobEntryAttributes(ObjectId id_jobentry, String code)
           
 int countNrStepAttributes(ObjectId id_step, String code)
           
 int countNrTransAttributes(ObjectId id_transformation, String code)
           
 void disconnect()
           
 void fillStepAttributesBuffer(ObjectId id_transformation)
           
 ObjectId findStepAttributeID(ObjectId id_step, int nr, String code)
           
 Database getDatabase()
           
 Collection<RowMetaAndData> getDatabaseAttributes(ObjectId id_database)
           
 DatabaseMeta getDatabaseMeta()
           
 ObjectId[] getIDs(String sql, ObjectId... objectId)
           
 ObjectId getIDWithValue(String tablename, String idfield, String[] lookupkey, ObjectId[] key)
           
 ObjectId getIDWithValue(String tablename, String idfield, String lookupfield, String value)
           
 ObjectId getIDWithValue(String tablename, String idfield, String lookupfield, String value, String[] lookupkey, ObjectId[] key)
           
 ObjectId getIDWithValue(String tablename, String idfield, String lookupfield, String value, String lookupkey, ObjectId key)
           
 boolean getJobAttributeBoolean(ObjectId id_job, int nr, String code)
           
 long getJobAttributeInteger(ObjectId id_job, int nr, String code)
           
 double getJobAttributeNumber(ObjectId id_job, int nr, String code)
           
 RowMetaAndData getJobAttributeRow(ObjectId id_job, int nr, String code)
           
 List<Object[]> getJobAttributes(ObjectId id_job, String code, long nr)
           
 String getJobAttributeString(ObjectId id_job, int nr, String code)
           
 boolean getJobEntryAttributeBoolean(ObjectId id_jobentry, int nr, String code)
           
 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, int nr, String code)
           
 long getJobEntryAttributeInteger(ObjectId id_jobentry, String code)
           
 double getJobEntryAttributeNumber(ObjectId id_jobentry, int nr, String code)
           
 double getJobEntryAttributeNumber(ObjectId id_jobentry, String code)
           
 String getJobEntryAttributeString(ObjectId id_jobentry, int nr, String code)
           
 String getJobEntryAttributeString(ObjectId id_jobentry, String code)
           
 int getMajorVersion()
           
 int getMinorVersion()
           
 ObjectId getNextClusterID()
           
 ObjectId getNextClusterSlaveID()
           
 ObjectId getNextConditionID()
           
 LongObjectId getNextDatabaseAttributeID()
           
 ObjectId getNextDatabaseConnectionTypeID()
           
 ObjectId getNextDatabaseID()
           
 ObjectId getNextDatabaseTypeID()
           
 ObjectId getNextDepencencyID()
           
 ObjectId getNextDirectoryID()
           
 LongObjectId getNextID(String tableName, String fieldName)
           
 LongObjectId getNextJobAttributeID()
           
 LongObjectId getNextJobEntryAttributeID()
           
 LongObjectId getNextJobEntryCopyID()
           
 ObjectId getNextJobEntryID()
           
 ObjectId getNextJobEntryTypeID()
           
 ObjectId getNextJobHopID()
           
 ObjectId getNextJobID()
           
 ObjectId getNextLogID()
           
 ObjectId getNextLoglevelID()
           
 ObjectId getNextNoteID()
           
 ObjectId getNextPartitionID()
           
 ObjectId getNextPartitionSchemaID()
           
 ObjectId getNextSlaveServerID()
           
 LongObjectId getNextStepAttributeID()
           
 ObjectId getNextStepID()
           
 ObjectId getNextStepTypeID()
           
 LongObjectId getNextTransAttributeID()
           
 ObjectId getNextTransformationClusterID()
           
 ObjectId getNextTransformationID()
           
 ObjectId getNextTransformationPartitionSchemaID()
           
 ObjectId getNextTransformationSlaveID()
           
 ObjectId getNextTransHopID()
           
 ObjectId getNextUserID()
           
 ObjectId getNextValueID()
           
 RowMetaAndData getOneRow(String sql)
           
 RowMetaAndData getOneRow(String sql, RowMetaInterface rowMeta, Object[] rowData)
           
 RowMetaAndData getOneRow(String tablename, String keyfield, ObjectId id)
           
 RowMetaAndData getParameterMetaData(ObjectId... ids)
           
 List<RepositoryElementMetaInterface> getRepositoryObjects(String tableName, RepositoryObjectType objectType, ObjectId id_directory)
           
static String getRequiredVersion()
          Get the required repository version for this version of Kettle.
 RowMetaInterface getReturnRowMeta()
           
 List<Object[]> getRows(String sql, int limit)
           
 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)
           
 List<Object[]> getStepAttributesBuffer()
           
 RowMetaInterface getStepAttributesRowMeta()
           
 String getStepAttributeString(ObjectId id_step, int nr, String code)
           
 String getStepAttributeString(ObjectId id_step, String code)
           
 String[] getStrings(String sql, ObjectId... objectId)
           
 String getStringWithID(String tablename, String keyfield, ObjectId id, String fieldname)
           
 boolean getTransAttributeBoolean(ObjectId id_transformation, int nr, String code)
           
 long getTransAttributeInteger(ObjectId id_transformation, int nr, String code)
           
 double getTransAttributeNumber(ObjectId id_transformation, int nr, String code)
           
 RowMetaAndData getTransAttributeRow(ObjectId id_transformation, int nr, String code)
           
 List<Object[]> getTransAttributes(ObjectId id_transformation, String code, long nr)
           
 String getTransAttributeString(ObjectId id_transformation, int nr, String code)
           
 String getVersion()
          Get the repository version.
 ObjectId insertJobAttribute(ObjectId id_job, long nr, String code, long value_num, String value_str)
           
 ObjectId insertJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, long nr, String code, double value_num, String value_str)
           
 ObjectId insertStepAttribute(ObjectId id_transformation, ObjectId id_step, long nr, String code, double value_num, String value_str)
           
 void insertTableRow(String tablename, RowMetaAndData values)
           
 ObjectId insertTransAttribute(ObjectId id_transformation, long nr, String code, long value_num, String value_str)
           
 boolean isUseBatchProcessing()
           
 void lockRepository()
           
 void performDelete(String sql, ObjectId... ids)
           
 void rollback()
           
 ObjectId saveJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, long nr, String code, boolean value)
           
 ObjectId saveJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, long nr, String code, double value)
           
 ObjectId saveJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, long nr, String code, String value)
           
 ObjectId saveJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, String code, boolean value)
           
 ObjectId saveJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, String code, double value)
           
 ObjectId saveJobEntryAttribute(ObjectId id_job, ObjectId id_jobentry, String code, String value)
           
 ObjectId saveStepAttribute(ObjectId id_transformation, ObjectId id_step, long nr, String code, boolean value)
           
 ObjectId saveStepAttribute(ObjectId id_transformation, ObjectId id_step, long nr, String code, double value)
           
 ObjectId saveStepAttribute(ObjectId id_transformation, ObjectId id_step, long nr, String code, String value)
           
 ObjectId saveStepAttribute(ObjectId id_transformation, ObjectId id_step, String code, boolean value)
           
 ObjectId saveStepAttribute(ObjectId id_transformation, ObjectId id_step, String code, double value)
           
 ObjectId saveStepAttribute(ObjectId id_transformation, ObjectId id_step, String code, String value)
           
 void setAutoCommit(boolean autocommit)
           
 void setDatabase(Database database)
           
 void setDatabaseMeta(DatabaseMeta databaseMeta)
           
 void setLookupJobAttribute()
           
 void setLookupJobEntryAttribute()
           
 void setLookupStepAttribute()
           
 void setLookupTransAttribute()
           
 void setMajorVersion(int majorVersion)
           
 void setMinorVersion(int minorVersion)
           
 void setStepAttributesBuffer(List<Object[]> stepAttributesBuffer)
           
 void setStepAttributesRowMeta(RowMetaInterface stepAttributesRowMeta)
           
 void unlockRepository()
           
 void updateTableRow(String tablename, String idfield, RowMetaAndData values)
           
 void updateTableRow(String tablename, String idfield, RowMetaAndData values, ObjectId id)
           
 
Methods inherited from class org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate
quote, quoteTable
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

loggingObject

public static final LoggingObjectInterface loggingObject

REQUIRED_MAJOR_VERSION

public static final int REQUIRED_MAJOR_VERSION
See Also:
Constant Field Values

REQUIRED_MINOR_VERSION

public static final int REQUIRED_MINOR_VERSION
See Also:
Constant Field Values
Constructor Detail

KettleDatabaseRepositoryConnectionDelegate

public KettleDatabaseRepositoryConnectionDelegate(KettleDatabaseRepository repository,
                                                  DatabaseMeta databaseMeta)
Method Detail

connect

public void connect()
             throws KettleException
Connect to the repository

Throws:
KettleException

connect

public void connect(boolean no_lookup)
             throws KettleException
Throws:
KettleException

connect

public void connect(boolean no_lookup,
                    boolean ignoreVersion)
             throws KettleException
Throws:
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.

disconnect

public void disconnect()

setAutoCommit

public void setAutoCommit(boolean autocommit)

commit

public void commit()
            throws KettleException
Throws:
KettleException

rollback

public void rollback()

getDatabase

public Database getDatabase()
Returns:
the database

setDatabase

public void setDatabase(Database database)
Parameters:
database - the database to set

getDatabaseMeta

public DatabaseMeta getDatabaseMeta()
Returns:
the databaseMeta

setDatabaseMeta

public void setDatabaseMeta(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(ObjectId id_transformation)
                              throws KettleException
Throws:
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 KettleException
Throws:
KettleException

setLookupTransAttribute

public void setLookupTransAttribute()
                             throws KettleException
Throws:
KettleException

closeTransAttributeLookupPreparedStatement

public void closeTransAttributeLookupPreparedStatement()
                                                throws KettleException
Throws:
KettleException

setLookupJobAttribute

public void setLookupJobAttribute()
                           throws KettleException
Throws:
KettleException

closeJobAttributeLookupPreparedStatement

public void closeJobAttributeLookupPreparedStatement()
                                              throws KettleException
Throws:
KettleException

closeStepAttributeLookupPreparedStatement

public void closeStepAttributeLookupPreparedStatement()
                                               throws KettleException
Throws:
KettleException

closeStepAttributeInsertPreparedStatement

public void closeStepAttributeInsertPreparedStatement()
                                               throws KettleException
Throws:
KettleException

closeTransAttributeInsertPreparedStatement

public void closeTransAttributeInsertPreparedStatement()
                                                throws KettleException
Throws:
KettleException

closeJobAttributeInsertPreparedStatement

public void closeJobAttributeInsertPreparedStatement()
                                              throws KettleException
Throws:
KettleException

getTransAttributeRow

public RowMetaAndData getTransAttributeRow(ObjectId id_transformation,
                                           int nr,
                                           String code)
                                    throws KettleException
Throws:
KettleException

getJobAttributeRow

public RowMetaAndData getJobAttributeRow(ObjectId id_job,
                                         int nr,
                                         String code)
                                  throws KettleException
Throws:
KettleException

getStepAttributeInteger

public long getStepAttributeInteger(ObjectId id_step,
                                    int nr,
                                    String code)
                             throws KettleException
Throws:
KettleException

findStepAttributeID

public ObjectId findStepAttributeID(ObjectId id_step,
                                    int nr,
                                    String code)
                             throws KettleException
Throws:
KettleException

getStepAttributeString

public String getStepAttributeString(ObjectId id_step,
                                     int nr,
                                     String code)
                              throws KettleException
Throws:
KettleException

getStepAttributeBoolean

public boolean getStepAttributeBoolean(ObjectId id_step,
                                       int nr,
                                       String code,
                                       boolean def)
                                throws KettleException
Throws:
KettleException

getStepAttributeBoolean

public boolean getStepAttributeBoolean(ObjectId id_step,
                                       int nr,
                                       String code)
                                throws KettleException
Throws:
KettleException

getStepAttributeInteger

public long getStepAttributeInteger(ObjectId id_step,
                                    String code)
                             throws KettleException
Throws:
KettleException

getStepAttributeString

public String getStepAttributeString(ObjectId id_step,
                                     String code)
                              throws KettleException
Throws:
KettleException

getStepAttributeBoolean

public boolean getStepAttributeBoolean(ObjectId id_step,
                                       String code)
                                throws KettleException
Throws:
KettleException

saveStepAttribute

public ObjectId saveStepAttribute(ObjectId id_transformation,
                                  ObjectId id_step,
                                  String code,
                                  String value)
                           throws KettleException
Throws:
KettleException

saveStepAttribute

public ObjectId saveStepAttribute(ObjectId id_transformation,
                                  ObjectId id_step,
                                  String code,
                                  double value)
                           throws KettleException
Throws:
KettleException

saveStepAttribute

public ObjectId saveStepAttribute(ObjectId id_transformation,
                                  ObjectId id_step,
                                  String code,
                                  boolean value)
                           throws KettleException
Throws:
KettleException

saveStepAttribute

public ObjectId saveStepAttribute(ObjectId id_transformation,
                                  ObjectId id_step,
                                  long nr,
                                  String code,
                                  String value)
                           throws KettleException
Throws:
KettleException

saveStepAttribute

public ObjectId saveStepAttribute(ObjectId id_transformation,
                                  ObjectId id_step,
                                  long nr,
                                  String code,
                                  double value)
                           throws KettleException
Throws:
KettleException

saveStepAttribute

public ObjectId saveStepAttribute(ObjectId id_transformation,
                                  ObjectId id_step,
                                  long nr,
                                  String code,
                                  boolean value)
                           throws KettleException
Throws:
KettleException

countNrStepAttributes

public int countNrStepAttributes(ObjectId id_step,
                                 String code)
                          throws KettleException
Throws:
KettleException

getTransAttributeString

public String getTransAttributeString(ObjectId id_transformation,
                                      int nr,
                                      String code)
                               throws KettleException
Throws:
KettleException

getTransAttributeBoolean

public boolean getTransAttributeBoolean(ObjectId id_transformation,
                                        int nr,
                                        String code)
                                 throws KettleException
Throws:
KettleException

getTransAttributeNumber

public double getTransAttributeNumber(ObjectId id_transformation,
                                      int nr,
                                      String code)
                               throws KettleException
Throws:
KettleException

getTransAttributeInteger

public long getTransAttributeInteger(ObjectId id_transformation,
                                     int nr,
                                     String code)
                              throws KettleException
Throws:
KettleException

countNrTransAttributes

public int countNrTransAttributes(ObjectId id_transformation,
                                  String code)
                           throws KettleException
Throws:
KettleException

getTransAttributes

public List<Object[]> getTransAttributes(ObjectId id_transformation,
                                         String code,
                                         long nr)
                                  throws KettleException
Throws:
KettleException

getJobAttributeString

public String getJobAttributeString(ObjectId id_job,
                                    int nr,
                                    String code)
                             throws KettleException
Throws:
KettleException

getJobAttributeBoolean

public boolean getJobAttributeBoolean(ObjectId id_job,
                                      int nr,
                                      String code)
                               throws KettleException
Throws:
KettleException

getJobAttributeNumber

public double getJobAttributeNumber(ObjectId id_job,
                                    int nr,
                                    String code)
                             throws KettleException
Throws:
KettleException

getJobAttributeInteger

public long getJobAttributeInteger(ObjectId id_job,
                                   int nr,
                                   String code)
                            throws KettleException
Throws:
KettleException

countNrJobAttributes

public int countNrJobAttributes(ObjectId id_job,
                                String code)
                         throws KettleException
Throws:
KettleException

getJobAttributes

public List<Object[]> getJobAttributes(ObjectId id_job,
                                       String code,
                                       long nr)
                                throws KettleException
Throws:
KettleException

saveJobEntryAttribute

public ObjectId saveJobEntryAttribute(ObjectId id_job,
                                      ObjectId id_jobentry,
                                      String code,
                                      String value)
                               throws KettleException
Throws:
KettleException

saveJobEntryAttribute

public ObjectId saveJobEntryAttribute(ObjectId id_job,
                                      ObjectId id_jobentry,
                                      String code,
                                      double value)
                               throws KettleException
Throws:
KettleException

saveJobEntryAttribute

public ObjectId saveJobEntryAttribute(ObjectId id_job,
                                      ObjectId id_jobentry,
                                      String code,
                                      boolean value)
                               throws KettleException
Throws:
KettleException

saveJobEntryAttribute

public ObjectId saveJobEntryAttribute(ObjectId id_job,
                                      ObjectId id_jobentry,
                                      long nr,
                                      String code,
                                      String value)
                               throws KettleException
Throws:
KettleException

saveJobEntryAttribute

public ObjectId saveJobEntryAttribute(ObjectId id_job,
                                      ObjectId id_jobentry,
                                      long nr,
                                      String code,
                                      double value)
                               throws KettleException
Throws:
KettleException

saveJobEntryAttribute

public ObjectId saveJobEntryAttribute(ObjectId id_job,
                                      ObjectId id_jobentry,
                                      long nr,
                                      String code,
                                      boolean value)
                               throws KettleException
Throws:
KettleException

insertJobEntryAttribute

public ObjectId insertJobEntryAttribute(ObjectId id_job,
                                        ObjectId id_jobentry,
                                        long nr,
                                        String code,
                                        double value_num,
                                        String value_str)
                                 throws KettleException
Throws:
KettleException

getNextJobEntryAttributeID

public LongObjectId getNextJobEntryAttributeID()
                                        throws KettleException
Throws:
KettleException

getNextID

public LongObjectId getNextID(String tableName,
                              String fieldName)
                       throws KettleException
Throws:
KettleException

setLookupJobEntryAttribute

public void setLookupJobEntryAttribute()
                                throws KettleException
Throws:
KettleException

closeLookupJobEntryAttribute

public void closeLookupJobEntryAttribute()
                                  throws KettleException
Throws:
KettleException

getJobEntryAttributeInteger

public long getJobEntryAttributeInteger(ObjectId id_jobentry,
                                        int nr,
                                        String code)
                                 throws KettleException
Throws:
KettleException

getJobEntryAttributeNumber

public double getJobEntryAttributeNumber(ObjectId id_jobentry,
                                         int nr,
                                         String code)
                                  throws KettleException
Throws:
KettleException

getJobEntryAttributeString

public String getJobEntryAttributeString(ObjectId id_jobentry,
                                         int nr,
                                         String code)
                                  throws KettleException
Throws:
KettleException

getJobEntryAttributeBoolean

public boolean getJobEntryAttributeBoolean(ObjectId id_jobentry,
                                           int nr,
                                           String code)
                                    throws KettleException
Throws:
KettleException

getJobEntryAttributeBoolean

public boolean getJobEntryAttributeBoolean(ObjectId id_jobentry,
                                           int nr,
                                           String code,
                                           boolean def)
                                    throws KettleException
Throws:
KettleException

getJobEntryAttributeNumber

public double getJobEntryAttributeNumber(ObjectId id_jobentry,
                                         String code)
                                  throws KettleException
Throws:
KettleException

getJobEntryAttributeInteger

public long getJobEntryAttributeInteger(ObjectId id_jobentry,
                                        String code)
                                 throws KettleException
Throws:
KettleException

getJobEntryAttributeString

public String getJobEntryAttributeString(ObjectId id_jobentry,
                                         String code)
                                  throws KettleException
Throws:
KettleException

getJobEntryAttributeBoolean

public boolean getJobEntryAttributeBoolean(ObjectId id_jobentry,
                                           String code)
                                    throws KettleException
Throws:
KettleException

getJobEntryAttributeBoolean

public boolean getJobEntryAttributeBoolean(ObjectId id_jobentry,
                                           String code,
                                           boolean def)
                                    throws KettleException
Throws:
KettleException

countNrJobEntryAttributes

public int countNrJobEntryAttributes(ObjectId id_jobentry,
                                     String code)
                              throws KettleException
Throws:
KettleException

getNextTransformationID

public ObjectId getNextTransformationID()
                                 throws KettleException
Throws:
KettleException

getNextJobID

public ObjectId getNextJobID()
                      throws KettleException
Throws:
KettleException

getNextNoteID

public ObjectId getNextNoteID()
                       throws KettleException
Throws:
KettleException

getNextLogID

public ObjectId getNextLogID()
                      throws KettleException
Throws:
KettleException

getNextDatabaseID

public ObjectId getNextDatabaseID()
                           throws KettleException
Throws:
KettleException

getNextDatabaseTypeID

public ObjectId getNextDatabaseTypeID()
                               throws KettleException
Throws:
KettleException

getNextDatabaseConnectionTypeID

public ObjectId getNextDatabaseConnectionTypeID()
                                         throws KettleException
Throws:
KettleException

getNextLoglevelID

public ObjectId getNextLoglevelID()
                           throws KettleException
Throws:
KettleException

getNextStepTypeID

public ObjectId getNextStepTypeID()
                           throws KettleException
Throws:
KettleException

getNextStepID

public ObjectId getNextStepID()
                       throws KettleException
Throws:
KettleException

getNextJobEntryID

public ObjectId getNextJobEntryID()
                           throws KettleException
Throws:
KettleException

getNextJobEntryTypeID

public ObjectId getNextJobEntryTypeID()
                               throws KettleException
Throws:
KettleException

getNextJobEntryCopyID

public LongObjectId getNextJobEntryCopyID()
                                   throws KettleException
Throws:
KettleException

getNextStepAttributeID

public LongObjectId getNextStepAttributeID()
                                    throws KettleException
Throws:
KettleException

getNextTransAttributeID

public LongObjectId getNextTransAttributeID()
                                     throws KettleException
Throws:
KettleException

getNextJobAttributeID

public LongObjectId getNextJobAttributeID()
                                   throws KettleException
Throws:
KettleException

getNextDatabaseAttributeID

public LongObjectId getNextDatabaseAttributeID()
                                        throws KettleException
Throws:
KettleException

getNextTransHopID

public ObjectId getNextTransHopID()
                           throws KettleException
Throws:
KettleException

getNextJobHopID

public ObjectId getNextJobHopID()
                         throws KettleException
Throws:
KettleException

getNextDepencencyID

public ObjectId getNextDepencencyID()
                             throws KettleException
Throws:
KettleException

getNextPartitionSchemaID

public ObjectId getNextPartitionSchemaID()
                                  throws KettleException
Throws:
KettleException

getNextPartitionID

public ObjectId getNextPartitionID()
                            throws KettleException
Throws:
KettleException

getNextTransformationPartitionSchemaID

public ObjectId getNextTransformationPartitionSchemaID()
                                                throws KettleException
Throws:
KettleException

getNextClusterID

public ObjectId getNextClusterID()
                          throws KettleException
Throws:
KettleException

getNextSlaveServerID

public ObjectId getNextSlaveServerID()
                              throws KettleException
Throws:
KettleException

getNextClusterSlaveID

public ObjectId getNextClusterSlaveID()
                               throws KettleException
Throws:
KettleException

getNextTransformationSlaveID

public ObjectId getNextTransformationSlaveID()
                                      throws KettleException
Throws:
KettleException

getNextTransformationClusterID

public ObjectId getNextTransformationClusterID()
                                        throws KettleException
Throws:
KettleException

getNextConditionID

public ObjectId getNextConditionID()
                            throws KettleException
Throws:
KettleException

getNextValueID

public ObjectId getNextValueID()
                        throws KettleException
Throws:
KettleException

getNextUserID

public ObjectId getNextUserID()
                       throws KettleException
Throws:
KettleException

clearNextIDCounters

public void clearNextIDCounters()

getNextDirectoryID

public ObjectId getNextDirectoryID()
                            throws KettleException
Throws:
KettleException

insertStepAttribute

public ObjectId insertStepAttribute(ObjectId id_transformation,
                                    ObjectId id_step,
                                    long nr,
                                    String code,
                                    double value_num,
                                    String value_str)
                             throws KettleException
Throws:
KettleException

insertTransAttribute

public ObjectId insertTransAttribute(ObjectId id_transformation,
                                     long nr,
                                     String code,
                                     long value_num,
                                     String value_str)
                              throws KettleException
Throws:
KettleException

insertJobAttribute

public ObjectId insertJobAttribute(ObjectId id_job,
                                   long nr,
                                   String code,
                                   long value_num,
                                   String value_str)
                            throws KettleException
Throws:
KettleException

updateTableRow

public void updateTableRow(String tablename,
                           String idfield,
                           RowMetaAndData values,
                           ObjectId id)
                    throws KettleException
Throws:
KettleException

updateTableRow

public void updateTableRow(String tablename,
                           String idfield,
                           RowMetaAndData values)
                    throws KettleException
Throws:
KettleException

getRepositoryObjects

public List<RepositoryElementMetaInterface> getRepositoryObjects(String tableName,
                                                                 RepositoryObjectType objectType,
                                                                 ObjectId id_directory)
                                                          throws KettleException
Parameters:
id_directory -
Returns:
A list of RepositoryObjects
Throws:
KettleException

getIDs

public ObjectId[] getIDs(String sql,
                         ObjectId... objectId)
                  throws KettleException
Throws:
KettleException

getStrings

public String[] getStrings(String sql,
                           ObjectId... objectId)
                    throws KettleException
Throws:
KettleException

convertLongList

public static final ObjectId[] convertLongList(List<Long> list)

lockRepository

public void lockRepository()
                    throws KettleException
Throws:
KettleException

unlockRepository

public void unlockRepository()
                      throws KettleException
Throws:
KettleException

getStepAttributesRowMeta

public RowMetaInterface getStepAttributesRowMeta()
Returns:
the stepAttributesRowMeta

isUseBatchProcessing

public boolean isUseBatchProcessing()

setStepAttributesRowMeta

public void setStepAttributesRowMeta(RowMetaInterface stepAttributesRowMeta)
Parameters:
stepAttributesRowMeta - the stepAttributesRowMeta to set

getIDWithValue

public ObjectId getIDWithValue(String tablename,
                               String idfield,
                               String lookupfield,
                               String value)
                        throws KettleException
Throws:
KettleException

getIDWithValue

public ObjectId getIDWithValue(String tablename,
                               String idfield,
                               String lookupfield,
                               String value,
                               String lookupkey,
                               ObjectId key)
                        throws KettleException
Throws:
KettleException

getIDWithValue

public ObjectId getIDWithValue(String tablename,
                               String idfield,
                               String[] lookupkey,
                               ObjectId[] key)
                        throws KettleException
Throws:
KettleException

getIDWithValue

public ObjectId getIDWithValue(String tablename,
                               String idfield,
                               String lookupfield,
                               String value,
                               String[] lookupkey,
                               ObjectId[] key)
                        throws KettleException
Throws:
KettleException

getOneRow

public RowMetaAndData getOneRow(String tablename,
                                String keyfield,
                                ObjectId id)
                         throws KettleException
Throws:
KettleException

getOneRow

public RowMetaAndData getOneRow(String sql)
                         throws KettleDatabaseException
Throws:
KettleDatabaseException

getOneRow

public RowMetaAndData getOneRow(String sql,
                                RowMetaInterface rowMeta,
                                Object[] rowData)
                         throws KettleDatabaseException
Throws:
KettleDatabaseException

getStringWithID

public String getStringWithID(String tablename,
                              String keyfield,
                              ObjectId id,
                              String fieldname)
                       throws KettleException
Throws:
KettleException

getRows

public List<Object[]> getRows(String sql,
                              int limit)
                       throws KettleDatabaseException
Throws:
KettleDatabaseException

getReturnRowMeta

public RowMetaInterface getReturnRowMeta()
                                  throws KettleDatabaseException
Throws:
KettleDatabaseException

insertTableRow

public void insertTableRow(String tablename,
                           RowMetaAndData values)
                    throws KettleException
Throws:
KettleException

getDatabaseAttributes

public Collection<RowMetaAndData> getDatabaseAttributes(ObjectId id_database)
                                                 throws KettleDatabaseException,
                                                        KettleValueException
Throws:
KettleDatabaseException
KettleValueException

getParameterMetaData

public RowMetaAndData getParameterMetaData(ObjectId... ids)
                                    throws KettleException
Throws:
KettleException

performDelete

public void performDelete(String sql,
                          ObjectId... ids)
                   throws KettleException
Throws:
KettleException