All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type |
Method and 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 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) |
LongObjectId[] |
getIDsWithValues(String tablename,
String idfield,
String lookupfield,
String[] values) |
ObjectId |
getIDWithValue(String tablename,
String idfield,
String[] lookupkey,
ObjectId[] key) |
LongObjectId |
getIDWithValue(String tablename,
String idfield,
String lookupfield,
String value) |
LongObjectId |
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) |
List<Object[]> |
getJobAttributesWithPrefix(ObjectId jobId,
String codePrefix) |
boolean |
getJobEntryAttributeBoolean(ObjectId id_jobentry,
int nr,
String code,
boolean def) |
long |
getJobEntryAttributeInteger(ObjectId id_jobentry,
int nr,
String code) |
double |
getJobEntryAttributeNumber(ObjectId id_jobentry,
int nr,
String code) |
String |
getJobEntryAttributeString(ObjectId id_jobentry,
int nr,
String code) |
List<Object[]> |
getJobEntryAttributesWithPrefix(ObjectId jobId,
ObjectId jobEntryId,
String codePrefix) |
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 schemaAndTable,
String keyfield,
ObjectId id)
This method should be called WITH AN ALREADY QUOTED schema and table
|
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 def) |
long |
getStepAttributeInteger(ObjectId id_step,
int nr,
String code) |
List<Object[]> |
getStepAttributesBuffer() |
RowMetaInterface |
getStepAttributesRowMeta() |
String |
getStepAttributeString(ObjectId id_step,
int nr,
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) |
List<Object[]> |
getTransAttributesWithPrefix(ObjectId id_transformation,
String codePrefix) |
Map<String,LongObjectId> |
getValueToIdMap(String tablename,
String idfield,
String lookupfield) |
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 |
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) |
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) |
protected void |
verifyVersion() |