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 and Description
protected Database	database
protected DatabaseMeta	databaseMeta
protected static int[]	KEY_POSITIONS
static 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 RowMetaInterface	stepAttributesRowMeta
protected boolean	useBatchProcessing

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

log, repository

Constructor Summary

Constructors

Constructor and Description
KettleDatabaseRepositoryConnectionDelegate(KettleDatabaseRepository repository, DatabaseMeta databaseMeta)

Method Summary

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

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

databaseMeta

protected 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 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,
                                                  DatabaseMeta databaseMeta)

Method Detail

connect

public void connect()
             throws KettleException

Connect to the repository

Throws:

KettleException

connect

public void connect(boolean no_lookup)
             throws KettleException

Throws:

KettleException

connect

public void connect(boolean no_lookup,
                    boolean ignoreVersion)
             throws KettleException

Throws:

KettleException

getRequiredVersion

public static final String getRequiredVersion()

Get the required repository version for this version of Kettle.

Returns:

the required repository version for this version of Kettle.

verifyVersion

protected void verifyVersion()
                      throws KettleException

Throws:

KettleException

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

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

getTransAttributesWithPrefix

public List<Object[]> getTransAttributesWithPrefix(ObjectId id_transformation,
                                                   String codePrefix)
                                            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

getJobAttributesWithPrefix

public List<Object[]> getJobAttributesWithPrefix(ObjectId jobId,
                                                 String codePrefix)
                                          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,
                                           boolean def)
                                    throws KettleException

Throws:

KettleException

countNrJobEntryAttributes

public int countNrJobEntryAttributes(ObjectId id_jobentry,
                                     String code)
                              throws KettleException

Throws:

KettleException

getJobEntryAttributesWithPrefix

public List<Object[]> getJobEntryAttributesWithPrefix(ObjectId jobId,
                                                      ObjectId jobEntryId,
                                                      String codePrefix)
                                               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 LongObjectId getIDWithValue(String tablename,
                                   String idfield,
                                   String lookupfield,
                                   String value)
                            throws KettleException

Throws:

KettleException

getValueToIdMap

public Map<String,LongObjectId> getValueToIdMap(String tablename,
                                                String idfield,
                                                String lookupfield)
                                         throws KettleException

Throws:

KettleException

getIDsWithValues

public LongObjectId[] getIDsWithValues(String tablename,
                                       String idfield,
                                       String lookupfield,
                                       String[] values)
                                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 LongObjectId getIDWithValue(String tablename,
                                   String idfield,
                                   String lookupfield,
                                   String value,
                                   String[] lookupkey,
                                   ObjectId[] key)
                            throws KettleException

Throws:

KettleException

getOneRow

public RowMetaAndData getOneRow(String schemaAndTable,
                                String keyfield,
                                ObjectId id)
                         throws KettleException

This method should be called WITH AN ALREADY QUOTED schema and table

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

closeAttributeLookupPreparedStatements

public void closeAttributeLookupPreparedStatements()
                                            throws KettleException

Throws:

KettleException

closeReadTransaction

public void closeReadTransaction()
                          throws 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:

KettleDatabaseException

callRead

public <V> V callRead(Callable<V> callable)
               throws KettleDatabaseException

Throws:

KettleDatabaseException