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 Summary

Fields

Modifier and Type	Field	Description
protected org.pentaho.di.core.database.Database	database
protected org.pentaho.di.core.database.DatabaseMeta	databaseMeta
protected static int[]	KEY_POSITIONS
static org.pentaho.di.core.logging.LoggingObjectInterface	loggingObject
protected int	majorVersion
protected int	minorVersion
protected PreparedStatement	psJobAttributesInsert
protected PreparedStatement	psJobAttributesLookup
protected PreparedStatement	psStepAttributesInsert
protected PreparedStatement	psStepAttributesLookup
protected PreparedStatement	pstmt_entry_attributes
protected PreparedStatement	psTransAttributesInsert
protected PreparedStatement	psTransAttributesLookup
static int	REQUIRED_MAJOR_VERSION
static int	REQUIRED_MINOR_VERSION
protected ConcurrentHashMap<String,PreparedStatement>	sqlMap
protected List<Object[]>	stepAttributesBuffer
protected org.pentaho.di.core.row.RowMetaInterface	stepAttributesRowMeta
protected boolean	useBatchProcessing

Fields inherited from class org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate

log, repository

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
<V> V	callRead(Callable<V> callable)
void	clearNextIDCounters()
void	closeAttributeLookupPreparedStatements()
void	closeJobAttributeInsertPreparedStatement()
void	closeJobAttributeLookupPreparedStatement()
void	closeLookupJobEntryAttribute()
void	closeReadTransaction()	A MySQL InnoDB hack really...
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 org.pentaho.di.repository.ObjectId[]	convertLongList(List<Long> list)
int	countNrJobAttributes(org.pentaho.di.repository.ObjectId id_job, String code)
int	countNrJobEntryAttributes(org.pentaho.di.repository.ObjectId id_jobentry, String code)
int	countNrStepAttributes(org.pentaho.di.repository.ObjectId id_step, String code)
int	countNrTransAttributes(org.pentaho.di.repository.ObjectId id_transformation, String code)
void	disconnect()
void	fillStepAttributesBuffer(org.pentaho.di.repository.ObjectId id_transformation)
org.pentaho.di.repository.ObjectId	findStepAttributeID(org.pentaho.di.repository.ObjectId id_step, int nr, String code)
org.pentaho.di.core.database.Database	getDatabase()
Collection<org.pentaho.di.core.RowMetaAndData>	getDatabaseAttributes(org.pentaho.di.repository.ObjectId id_database)
org.pentaho.di.core.database.DatabaseMeta	getDatabaseMeta()
org.pentaho.di.repository.ObjectId[]	getIDs(String sql, org.pentaho.di.repository.ObjectId... objectId)
org.pentaho.di.repository.LongObjectId[]	getIDsWithValues(String tablename, String idfield, String lookupfield, String[] values)
org.pentaho.di.repository.ObjectId	getIDWithValue(String tablename, String idfield, String[] lookupkey, org.pentaho.di.repository.ObjectId[] key)
org.pentaho.di.repository.LongObjectId	getIDWithValue(String tablename, String idfield, String lookupfield, String value)
org.pentaho.di.repository.LongObjectId	getIDWithValue(String tablename, String idfield, String lookupfield, String value, String[] lookupkey, org.pentaho.di.repository.ObjectId[] key)
org.pentaho.di.repository.ObjectId	getIDWithValue(String tablename, String idfield, String lookupfield, String value, String lookupkey, org.pentaho.di.repository.ObjectId key)
boolean	getJobAttributeBoolean(org.pentaho.di.repository.ObjectId id_job, int nr, String code)
long	getJobAttributeInteger(org.pentaho.di.repository.ObjectId id_job, int nr, String code)
double	getJobAttributeNumber(org.pentaho.di.repository.ObjectId id_job, int nr, String code)
org.pentaho.di.core.RowMetaAndData	getJobAttributeRow(org.pentaho.di.repository.ObjectId id_job, int nr, String code)
List<Object[]>	getJobAttributes(org.pentaho.di.repository.ObjectId id_job, String code, long nr)
String	getJobAttributeString(org.pentaho.di.repository.ObjectId id_job, int nr, String code)
List<Object[]>	getJobAttributesWithPrefix(org.pentaho.di.repository.ObjectId jobId, String codePrefix)
boolean	getJobEntryAttributeBoolean(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code, boolean def)
long	getJobEntryAttributeInteger(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code)
double	getJobEntryAttributeNumber(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code)
String	getJobEntryAttributeString(org.pentaho.di.repository.ObjectId id_jobentry, int nr, String code)
List<Object[]>	getJobEntryAttributesWithPrefix(org.pentaho.di.repository.ObjectId jobId, org.pentaho.di.repository.ObjectId jobEntryId, String codePrefix)
int	getMajorVersion()
int	getMinorVersion()
org.pentaho.di.repository.ObjectId	getNextClusterID()
org.pentaho.di.repository.ObjectId	getNextClusterSlaveID()
org.pentaho.di.repository.ObjectId	getNextConditionID()
org.pentaho.di.repository.LongObjectId	getNextDatabaseAttributeID()
org.pentaho.di.repository.ObjectId	getNextDatabaseConnectionTypeID()
org.pentaho.di.repository.ObjectId	getNextDatabaseID()
org.pentaho.di.repository.ObjectId	getNextDatabaseTypeID()
org.pentaho.di.repository.ObjectId	getNextDepencencyID()
org.pentaho.di.repository.ObjectId	getNextDirectoryID()
org.pentaho.di.repository.LongObjectId	getNextID(String tableName, String fieldName)
org.pentaho.di.repository.LongObjectId	getNextJobAttributeID()
org.pentaho.di.repository.LongObjectId	getNextJobEntryAttributeID()
org.pentaho.di.repository.LongObjectId	getNextJobEntryCopyID()
org.pentaho.di.repository.ObjectId	getNextJobEntryID()
org.pentaho.di.repository.ObjectId	getNextJobEntryTypeID()
org.pentaho.di.repository.ObjectId	getNextJobHopID()
org.pentaho.di.repository.ObjectId	getNextJobID()
org.pentaho.di.repository.ObjectId	getNextLogID()
org.pentaho.di.repository.ObjectId	getNextLoglevelID()
org.pentaho.di.repository.ObjectId	getNextNoteID()
org.pentaho.di.repository.ObjectId	getNextPartitionID()
org.pentaho.di.repository.ObjectId	getNextPartitionSchemaID()
org.pentaho.di.repository.ObjectId	getNextSlaveServerID()
org.pentaho.di.repository.LongObjectId	getNextStepAttributeID()
org.pentaho.di.repository.ObjectId	getNextStepID()
org.pentaho.di.repository.ObjectId	getNextStepTypeID()
org.pentaho.di.repository.LongObjectId	getNextTransAttributeID()
org.pentaho.di.repository.ObjectId	getNextTransformationClusterID()
org.pentaho.di.repository.ObjectId	getNextTransformationID()
org.pentaho.di.repository.ObjectId	getNextTransformationPartitionSchemaID()
org.pentaho.di.repository.ObjectId	getNextTransformationSlaveID()
org.pentaho.di.repository.ObjectId	getNextTransHopID()
org.pentaho.di.repository.ObjectId	getNextUserID()
org.pentaho.di.repository.ObjectId	getNextValueID()
org.pentaho.di.core.RowMetaAndData	getOneRow(String sql)
org.pentaho.di.core.RowMetaAndData	getOneRow(String schemaAndTable, String keyfield, org.pentaho.di.repository.ObjectId id)	This method should be called WITH AN ALREADY QUOTED schema and table
org.pentaho.di.core.RowMetaAndData	getOneRow(String sql, org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] rowData)
org.pentaho.di.core.RowMetaAndData	getParameterMetaData(org.pentaho.di.repository.ObjectId... ids)
List<org.pentaho.di.repository.RepositoryElementMetaInterface>	getRepositoryObjects(String tableName, org.pentaho.di.repository.RepositoryObjectType objectType, org.pentaho.di.repository.ObjectId id_directory)
static String	getRequiredVersion()	Get the required repository version for this version of Kettle.
org.pentaho.di.core.row.RowMetaInterface	getReturnRowMeta()
List<Object[]>	getRows(String sql, int limit)
boolean	getStepAttributeBoolean(org.pentaho.di.repository.ObjectId id_step, int nr, String code, boolean def)
long	getStepAttributeInteger(org.pentaho.di.repository.ObjectId id_step, int nr, String code)
List<Object[]>	getStepAttributesBuffer()
org.pentaho.di.core.row.RowMetaInterface	getStepAttributesRowMeta()
String	getStepAttributeString(org.pentaho.di.repository.ObjectId id_step, int nr, String code)
String[]	getStrings(String sql, org.pentaho.di.repository.ObjectId... objectId)
String	getStringWithID(String tablename, String keyfield, org.pentaho.di.repository.ObjectId id, String fieldname)
boolean	getTransAttributeBoolean(org.pentaho.di.repository.ObjectId id_transformation, int nr, String code)
long	getTransAttributeInteger(org.pentaho.di.repository.ObjectId id_transformation, int nr, String code)
double	getTransAttributeNumber(org.pentaho.di.repository.ObjectId id_transformation, int nr, String code)
org.pentaho.di.core.RowMetaAndData	getTransAttributeRow(org.pentaho.di.repository.ObjectId id_transformation, int nr, String code)
List<Object[]>	getTransAttributes(org.pentaho.di.repository.ObjectId id_transformation, String code, long nr)
String	getTransAttributeString(org.pentaho.di.repository.ObjectId id_transformation, int nr, String code)
List<Object[]>	getTransAttributesWithPrefix(org.pentaho.di.repository.ObjectId id_transformation, String codePrefix)
Map<String,org.pentaho.di.repository.LongObjectId>	getValueToIdMap(String tablename, String idfield, String lookupfield)
String	getVersion()	Get the repository version.
org.pentaho.di.repository.ObjectId	insertJobAttribute(org.pentaho.di.repository.ObjectId id_job, long nr, String code, long value_num, String value_str)
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)
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)
void	insertTableRow(String tablename, org.pentaho.di.core.RowMetaAndData values)
org.pentaho.di.repository.ObjectId	insertTransAttribute(org.pentaho.di.repository.ObjectId id_transformation, long nr, String code, long value_num, String value_str)
boolean	isUseBatchProcessing()
void	lockRepository()
void	performDelete(String sql, org.pentaho.di.repository.ObjectId... ids)
void	rollback()
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)
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)
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)
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)
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)
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)
void	setAutoCommit(boolean autocommit)
void	setDatabase(org.pentaho.di.core.database.Database database)
void	setDatabaseMeta(org.pentaho.di.core.database.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(org.pentaho.di.core.row.RowMetaInterface stepAttributesRowMeta)
void	unlockRepository()
void	updateTableRow(String tablename, String idfield, org.pentaho.di.core.RowMetaAndData values)
void	updateTableRow(String tablename, String idfield, org.pentaho.di.core.RowMetaAndData values, org.pentaho.di.repository.ObjectId id)
protected void	verifyVersion()

Methods inherited from class org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate

quote, quoteTable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

loggingObject

public static final org.pentaho.di.core.logging.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

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 Detail

KettleDatabaseRepositoryConnectionDelegate

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

Method Detail

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