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 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