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
|
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 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.ObjectId |
getIDWithValue(String tablename,
String idfield,
String[] lookupkey,
org.pentaho.di.repository.ObjectId[] key)
|
org.pentaho.di.repository.ObjectId |
getIDWithValue(String tablename,
String idfield,
String lookupfield,
String value)
|
org.pentaho.di.repository.ObjectId |
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)
|
boolean |
getJobEntryAttributeBoolean(org.pentaho.di.repository.ObjectId id_jobentry,
int nr,
String code)
|
boolean |
getJobEntryAttributeBoolean(org.pentaho.di.repository.ObjectId id_jobentry,
int nr,
String code,
boolean def)
|
boolean |
getJobEntryAttributeBoolean(org.pentaho.di.repository.ObjectId id_jobentry,
String code)
|
boolean |
getJobEntryAttributeBoolean(org.pentaho.di.repository.ObjectId id_jobentry,
String code,
boolean def)
|
long |
getJobEntryAttributeInteger(org.pentaho.di.repository.ObjectId id_jobentry,
int nr,
String code)
|
long |
getJobEntryAttributeInteger(org.pentaho.di.repository.ObjectId id_jobentry,
String code)
|
double |
getJobEntryAttributeNumber(org.pentaho.di.repository.ObjectId id_jobentry,
int nr,
String code)
|
double |
getJobEntryAttributeNumber(org.pentaho.di.repository.ObjectId id_jobentry,
String code)
|
String |
getJobEntryAttributeString(org.pentaho.di.repository.ObjectId id_jobentry,
int nr,
String code)
|
String |
getJobEntryAttributeString(org.pentaho.di.repository.ObjectId id_jobentry,
String code)
|
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 sql,
org.pentaho.di.core.row.RowMetaInterface rowMeta,
Object[] rowData)
|
org.pentaho.di.core.RowMetaAndData |
getOneRow(String tablename,
String keyfield,
org.pentaho.di.repository.ObjectId id)
|
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 |
getStepAttributeBoolean(org.pentaho.di.repository.ObjectId id_step,
int nr,
String code,
boolean def)
|
boolean |
getStepAttributeBoolean(org.pentaho.di.repository.ObjectId id_step,
String code)
|
long |
getStepAttributeInteger(org.pentaho.di.repository.ObjectId id_step,
int nr,
String code)
|
long |
getStepAttributeInteger(org.pentaho.di.repository.ObjectId id_step,
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 |
getStepAttributeString(org.pentaho.di.repository.ObjectId id_step,
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)
|
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 |
saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job,
org.pentaho.di.repository.ObjectId id_jobentry,
String code,
boolean value)
|
org.pentaho.di.repository.ObjectId |
saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job,
org.pentaho.di.repository.ObjectId id_jobentry,
String code,
double value)
|
org.pentaho.di.repository.ObjectId |
saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job,
org.pentaho.di.repository.ObjectId id_jobentry,
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)
|
org.pentaho.di.repository.ObjectId |
saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation,
org.pentaho.di.repository.ObjectId id_step,
String code,
boolean value)
|
org.pentaho.di.repository.ObjectId |
saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation,
org.pentaho.di.repository.ObjectId id_step,
String code,
double value)
|
org.pentaho.di.repository.ObjectId |
saveStepAttribute(org.pentaho.di.repository.ObjectId id_transformation,
org.pentaho.di.repository.ObjectId id_step,
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)
|
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
KettleDatabaseRepositoryConnectionDelegate
public KettleDatabaseRepositoryConnectionDelegate(KettleDatabaseRepository repository,
org.pentaho.di.core.database.DatabaseMeta databaseMeta)
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.
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
getStepAttributeBoolean
public boolean getStepAttributeBoolean(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
getStepAttributeInteger
public long getStepAttributeInteger(org.pentaho.di.repository.ObjectId id_step,
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,
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,
String code)
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,
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,
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,
String code,
boolean 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,
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
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
saveJobEntryAttribute
public org.pentaho.di.repository.ObjectId saveJobEntryAttribute(org.pentaho.di.repository.ObjectId id_job,
org.pentaho.di.repository.ObjectId id_jobentry,
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,
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,
String code,
boolean 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,
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)
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
getJobEntryAttributeNumber
public double getJobEntryAttributeNumber(org.pentaho.di.repository.ObjectId id_jobentry,
String code)
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,
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,
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,
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,
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
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.ObjectId getIDWithValue(String tablename,
String idfield,
String lookupfield,
String value)
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.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
getOneRow
public org.pentaho.di.core.RowMetaAndData getOneRow(String tablename,
String keyfield,
org.pentaho.di.repository.ObjectId id)
throws org.pentaho.di.core.exception.KettleException
- 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