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