org.pentaho.di.core.database.map

Class DatabaseConnectionMap

java.lang.Object

org.pentaho.di.core.database.map.DatabaseConnectionMap

public class DatabaseConnectionMap
extends Object

This class contains a map between on the one hand the transformation name/thread the partition ID the connection group And on the other hand The database connection The number of times it was opened

Author:

Matt

Method Summary

Methods

Modifier and Type	Method and Description
void	addTransactionListener(String transactionId, DatabaseTransactionListener listener)
static String	createEntryKey(String connectionGroup, String partitionID, Database database)
Database	getDatabase(String connectionGroup, String partitionID, Database database)
static DatabaseConnectionMap	getInstance()
Map<String,Database>	getMap()
String	getNextTransactionId()
List<DatabaseTransactionListener>	getTransactionListeners(String transactionId)
void	removeConnection(String connectionGroup, String partitionID, Database database)
void	removeTransactionListener(String transactionId, DatabaseTransactionListener listener)
void	removeTransactionListeners(String transactionId)
void	storeDatabase(String connectionGroup, String partitionID, Database database)

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static final DatabaseConnectionMap getInstance()

storeDatabase

public void storeDatabase(String connectionGroup,
                 String partitionID,
                 Database database)

removeConnection

public void removeConnection(String connectionGroup,
                    String partitionID,
                    Database database)

getDatabase

public Database getDatabase(String connectionGroup,
                   String partitionID,
                   Database database)

createEntryKey

public static final String createEntryKey(String connectionGroup,
                    String partitionID,
                    Database database)

getMap

public Map<String,Database> getMap()

getNextTransactionId

public String getNextTransactionId()

addTransactionListener

public void addTransactionListener(String transactionId,
                          DatabaseTransactionListener listener)

removeTransactionListener

public void removeTransactionListener(String transactionId,
                             DatabaseTransactionListener listener)

getTransactionListeners

public List<DatabaseTransactionListener> getTransactionListeners(String transactionId)

removeTransactionListeners

public void removeTransactionListeners(String transactionId)